func()

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
}