(ctx context.Context)
| 266 | } |
| 267 | |
| 268 | func (q *BlocksStoreQueryable) starting(ctx context.Context) error { |
| 269 | q.subservicesWatcher.WatchManager(q.subservices) |
| 270 | |
| 271 | if err := services.StartManagerAndAwaitHealthy(ctx, q.subservices); err != nil { |
| 272 | return errors.Wrap(err, "unable to start blocks storage queryable subservices") |
| 273 | } |
| 274 | |
| 275 | return nil |
| 276 | } |
| 277 | |
| 278 | func (q *BlocksStoreQueryable) running(ctx context.Context) error { |
| 279 | for { |
nothing calls this directly
no test coverage detected