Browse Source

feat:es初始化调整

fuwencai 1 year ago
parent
commit
0d8b109a5e
1 changed files with 7 additions and 1 deletions
  1. 7 1
      jyBXCore/rpc/init/db.go

+ 7 - 1
jyBXCore/rpc/init/db.go

@@ -94,6 +94,12 @@ func EsInit(es *entity.EsStruct) {
 func NoLoginEsInit(es *entity.EsStruct) {
 	if es.Addr != "" {
 		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()
 	}
 }