Method init

esutil/bulk_indexer.go:532–545

init initializes the bulk indexer.

()

// init initializes the bulk indexer.
func (bi *bulkIndexer) init() {
	for i := 1; i <= bi.config.NumWorkers; i++ {
		bi.wg.Add(1)
		w := worker{
			id:     i,
			ch:     make(chan BulkIndexerItem, bi.config.QueueSizeMultiplier),
			bi:     bi,
			buf:    bytes.NewBuffer(make([]byte, 0, bi.config.FlushBytes)),
			ticker: time.NewTicker(bi.nextFlushInterval()),
		}
		w.run()
		bi.workers = append(bi.workers, &w)
	}
}

// nextFlushInterval returns FlushInterval plus a random jitter in
// [0, FlushJitter) when FlushJitter > 0. Callers are independent worker