Browse Source

feat:新增es工具类

wangchuanjin 2 years ago
parent
commit
d883031cd3
1 changed files with 2 additions and 2 deletions
  1. 2 2
      es/es.go

+ 2 - 2
es/es.go

@@ -133,12 +133,12 @@ func NewEs(version, address string, size int, userName, password string) Es {
 	if version == "v1" {
 		es = &EsV1{
 			Address: address,
-			Size:    5,
+			Size:    size,
 		}
 	} else {
 		es = &EsV7{
 			Address:  address,
-			Size:     5,
+			Size:     size,
 			UserName: userName,
 			Password: password,
 		}