update es optional docType='', support es 8.X

kevwan · Aug 4, 2022 · 2c5899e · 2c5899e
1 parent 1d3e2d3
commit 2c5899e
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())