Struct bulkIndexer

esutil/bulk_indexer.go:293–303

}

type bulkIndexer struct {
	wg      sync.WaitGroup
	workers []*worker
	stats   *bulkIndexerStats

	config      BulkIndexerConfig
	ownedClient *elasticsearch.BaseClient // non-nil when NewBulkIndexer auto-created the client; closed by Close
	addCounter  atomic.Uint64             // round-robin dispatch counter for Add()
	flushMu     sync.Mutex                // serialises Flush() and Close()
	closed      atomic.Bool               // set by Close()
}

type bulkIndexerStats struct {
	numAdded     uint64