添加ES客户端协程池,修改错误

5f738b70 · 谢宇轩 · daa6d25a · 5f738b70
Commit 5f738b70 authored Dec 27, 2021 by 谢宇轩 😅
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

matedata.go entity/matedata.go +1 -1

No files found.
--- a/entity/matedata.go
+++ b/entity/matedata.go
@@ -43,7 +43,7 @@ func CloseMessageChan() {

 func MatedateSender(ctx context.Context, esClient *elastic.Client) {

-	wp := &WorkPool{
+	wp := &ESWorkPool{
 		WorkerFunc: func(matedatas []*Matedata) bool {
 			bulkRequest := esClient.Bulk()
 			for _, m := range matedatas {