Merge pull request #6 from hellobike/feature/optimize

revert simple client
hellobike · Dec 29, 2018 · 109a988 · 109a988
2 parents b1d3907 + e474ac8
commit 109a988
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/handler/output/es.go b/handler/output/es.go
@@ -41,7 +41,7 @@ func newESOutput(sub *conf.Subscribe) Output {
  panic("es conf is nil")
  }
 
- client, err := elastic.NewSimpleClient(elastic.SetURL(strings.Split(sub.ESConf.Addrs, ",")...), elastic.SetBasicAuth(sub.ESConf.User, sub.ESConf.Password))
+ client, err := elastic.NewClient(elastic.SetURL(strings.Split(sub.ESConf.Addrs, ",")...), elastic.SetBasicAuth(sub.ESConf.User, sub.ESConf.Password))
  if err != nil {
  panic(err)
  }