func NewBulkIndexerPool()

in bulk_indexer_pool.go [57:68]

• 12 lines of code
• 1 McCabe index (conditional complexity)

func NewBulkIndexerPool(guaranteed, max, total int, c BulkIndexerConfig) *BulkIndexerPool {
	p := BulkIndexerPool{
		indexers: make(chan *BulkIndexer, total),
		entries:  make(map[string]idEntry),
		min:      int64(guaranteed),
		max:      int64(max),
		total:    int64(total),
		config:   c,
	}
	p.cond = sync.NewCond(&p.mu)
	return &p
}