Fix total structure change for Elasticsearch 6.x

medcl · May 15, 2020 · 1316c96 · 1316c96
1 parent 861db96
commit 1316c96
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/v6.go b/v6.go
@@ -93,7 +93,7 @@ func (s *ESAPIV6) NewScroll(indexNames string, scrollTime string, docBufferCount
 		return nil, err
 	}
 
-	scroll = &ScrollV7{}
+	scroll = &Scroll{}
 	err = DecodeJson(body, scroll)
 	if err != nil {
 		log.Error(err)
@@ -124,7 +124,7 @@ func (s *ESAPIV6) NextScroll(scrollTime string, scrollId string) (interface{}, e
 	}
 
 	// decode elasticsearch scroll response
-	scroll := &ScrollV7{}
+	scroll := &Scroll{}
 	err := DecodeJson(body, &scroll)
 	if err != nil {
 		log.Error(body)