fix: remove unnecessary field

cam-inc · Jan 31, 2024 · ba1bd95 · ba1bd95
1 parent 03b3b29
commit ba1bd95
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/interfaces/opensearch/export.go b/interfaces/opensearch/export.go
@@ -47,7 +47,6 @@ type (
 
 	openSearchBulkIndexerImpl struct {
 		osClient *opensearchapi.Client
-		queue    chan *bulkIndexerItem
 		idBufs   map[string][]*bytes.Buffer // The key is the object_id of the mongo doc.
 		config   bulkIndexerConfig
 	}
@@ -230,7 +229,6 @@ func (o *OpenSearchImpl) NewBulkIndexer(ctx context.Context, client *opensearcha
 
 	bi := openSearchBulkIndexerImpl{
 		osClient: client,
-		queue:    make(chan *bulkIndexerItem),
 		idBufs:   make(map[string][]*bytes.Buffer),
 		config:   biCfg,
 	}