in bulk_indexer_pool.go [216:226]
func (p *BulkIndexerPool) count(id string) int64 { if id == "" { return -1 } p.mu.RLock() defer p.mu.RUnlock() if entry, exists := p.entries[id]; exists { return entry.leased.Load() } return -1 }