(cfg ring.Config, name, key string)
| 158 | } |
| 159 | |
| 160 | func (t *App) initReadRing(cfg ring.Config, name, key string) (*ring.Ring, error) { |
| 161 | ring, err := tempo_ring.New(cfg, name, key, prometheus.DefaultRegisterer) |
| 162 | if err != nil { |
| 163 | return nil, fmt.Errorf("failed to create ring %s: %w", name, err) |
| 164 | } |
| 165 | |
| 166 | t.Server.HTTPRouter().Handle("/"+name+"/ring", ring) |
| 167 | t.readRings[name] = ring |
| 168 | |
| 169 | return ring, nil |
| 170 | } |
| 171 | |
| 172 | func (t *App) initPartitionRing() (services.Service, error) { |
| 173 | var ( |
no test coverage detected