(tenant string)
| 134 | } |
| 135 | |
| 136 | func (p *writer) instanceForTenant(tenant string) (*tenantStore, error) { |
| 137 | p.mtx.Lock() |
| 138 | defer p.mtx.Unlock() |
| 139 | |
| 140 | if i, ok := p.m[tenant]; ok { |
| 141 | return i, nil |
| 142 | } |
| 143 | |
| 144 | i, err := newTenantStore(tenant, p.partition, p.startOffset, p.startTime, p.cycleDuration, p.slackDuration, p.blockCfg, p.logger, p.wal, p.enc, p.overrides) |
| 145 | if err != nil { |
| 146 | return nil, err |
| 147 | } |
| 148 | |
| 149 | p.m[tenant] = i |
| 150 | |
| 151 | return i, nil |
| 152 | } |
| 153 | |
| 154 | func idsToString(ids [][]byte) string { |
| 155 | b := strings.Builder{} |
no test coverage detected