更新es配置

src/config.json

@@ -58,7 +58,9 @@
         "addr": "http://192.168.3.206:9800",
         "pool": 15,
         "index": "bidding",
-        "type": "bidding"
+        "type": "bidding",
+        "username": "",
+        "password": ""
     },
     "luadisablelib": {
         "baselib": {

src/main.go

@@ -41,8 +41,10 @@ func init() {
 	spider.EsIndex = qu.ObjToString(Config.Es["index"])
 	spider.EsType = qu.ObjToString(Config.Es["type"])
 	spider.Es = &es.Elastic{
-		S_esurl: qu.ObjToString(Config.Es["addr"]),
-		I_size:  qu.IntAll(Config.Es["pool"]),
+		S_esurl:  qu.ObjToString(Config.Es["addr"]),
+		I_size:   qu.IntAll(Config.Es["pool"]),
+		Username: qu.ObjToString(Config.Es["username"]),
+		Password: qu.ObjToString(Config.Es["password"]),
 	}
 	spider.Es.InitElasticSize()
 	//启动消息服务