Merge pull request #21 from arthur-jx/master

update es optional docType='', support es 8.X
kevwan · Sep 17, 2022 · 15d7aaa · 15d7aaa
2 parents 010fdeb + 2c5899e
commit 15d7aaa
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/stash/es/writer.go b/stash/es/writer.go
@@ -52,7 +52,11 @@ func (w *Writer) execute(vals []interface{}) {
 	var bulk = w.client.Bulk()
 	for _, val := range vals {
 		pair := val.(valueWithIndex)
-		req := elastic.NewBulkIndexRequest().Index(pair.index).Type(w.docType).Doc(pair.val)
+		req := elastic.NewBulkIndexRequest().Index(pair.index)
+		if len(w.docType) > 0 {
+		    req = req.Type(w.docType)
+		}
+		req = req.Doc(pair.val)
 		bulk.Add(req)
 	}
 	resp, err := bulk.Do(context.Background())