tenantIndexBuilder returns true if this poller owns this tenant
(tenant string)
| 507 | |
| 508 | // tenantIndexBuilder returns true if this poller owns this tenant |
| 509 | func (p *Poller) tenantIndexBuilder(tenant string) bool { |
| 510 | for i := 0; i < p.cfg.TenantIndexBuilders; i++ { |
| 511 | job := jobPrefix + strconv.Itoa(i) + "-" + tenant |
| 512 | if p.sharder.Owns(job) { |
| 513 | return true |
| 514 | } |
| 515 | } |
| 516 | |
| 517 | return false |
| 518 | } |
| 519 | |
| 520 | func (p *Poller) tenantIndexPollError(idx *backend.TenantIndex, err error) error { |
| 521 | if err != nil { |
no test coverage detected