MergeTokensByZone is like MergeTokens but does it for each input zone.
(zones map[string][][]uint32)
| 703 | |
| 704 | // MergeTokensByZone is like MergeTokens but does it for each input zone. |
| 705 | func MergeTokensByZone(zones map[string][][]uint32) map[string][]uint32 { |
| 706 | out := make(map[string][]uint32, len(zones)) |
| 707 | for zone, tokens := range zones { |
| 708 | out[zone] = MergeTokens(tokens) |
| 709 | } |
| 710 | return out |
| 711 | } |
| 712 | |
| 713 | func (d *Desc) SplitByID() map[string]any { |
| 714 | out := make(map[string]any, len(d.Ingesters)) |