(ctx context.Context)
| 932 | } |
| 933 | |
| 934 | func (i *Ingester) startingV2ForFlusher(ctx context.Context) error { |
| 935 | if err := i.openExistingTSDB(ctx); err != nil { |
| 936 | // Try to rollback and close opened TSDBs before halting the ingester. |
| 937 | i.closeAllTSDB() |
| 938 | |
| 939 | return errors.Wrap(err, "opening existing TSDBs") |
| 940 | } |
| 941 | |
| 942 | // Don't start any sub-services (lifecycler, compaction, shipper) at all. |
| 943 | return nil |
| 944 | } |
| 945 | |
| 946 | func (i *Ingester) starting(ctx context.Context) error { |
| 947 | // Important: we want to keep lifecycler running until we ask it to stop, so we need to give it independent context |
nothing calls this directly
no test coverage detected