Merge pull request #11 from Mikaelemmmm/master

add es optional  username、password

Author: kevwan

stash/config/config.go

@@ -21,6 +21,8 @@ type (
 		TimeZone      string `json:",optional"`
 		MaxChunkBytes int    `json:",default=15728640"` // default 15M
 		Compress      bool   `json:",default=false"`
+		Username	  string `json:",optional"`
+		Password	  string `json:",optional"`
 	}
 
 	Filter struct {

stash/es/writer.go

@@ -27,6 +27,7 @@ func NewWriter(c config.ElasticSearchConf) (*Writer, error) {
 		elastic.SetSniff(false),
 		elastic.SetURL(c.Hosts...),
 		elastic.SetGzip(c.Compress),
+		elastic.SetBasicAuth(c.Username,c.Password),
 	)
 	if err != nil {
 		return nil, err

stash/stash.go

@@ -53,6 +53,7 @@ func main() {
 		client, err := elastic.NewClient(
 			elastic.SetSniff(false),
 			elastic.SetURL(processor.Output.ElasticSearch.Hosts...),
+			elastic.SetBasicAuth(processor.Output.ElasticSearch.Username,processor.Output.ElasticSearch.Password),
 		)
 		logx.Must(err)