|
@@ -94,6 +94,12 @@ func EsInit(es *entity.EsStruct) {
|
|
func NoLoginEsInit(es *entity.EsStruct) {
|
|
func NoLoginEsInit(es *entity.EsStruct) {
|
|
if es.Addr != "" {
|
|
if es.Addr != "" {
|
|
log.Println("--初始化 nologin elasticsearch--")
|
|
log.Println("--初始化 nologin elasticsearch--")
|
|
- NoLoginEs = NewEs(es.Version, es.Addr, es.Size, es.UserName, es.Password)
|
|
|
|
|
|
+ NoLoginEs = &EsV7{
|
|
|
|
+ Address: es.Addr,
|
|
|
|
+ Size: es.Size,
|
|
|
|
+ UserName: es.UserName,
|
|
|
|
+ Password: es.Password,
|
|
|
|
+ }
|
|
|
|
+ NoLoginEs.Init()
|
|
}
|
|
}
|
|
}
|
|
}
|