()
| 520 | } |
| 521 | |
| 522 | func (t *Cortex) initFlusher() (serv services.Service, err error) { |
| 523 | t.tsdbIngesterConfig() |
| 524 | |
| 525 | t.Flusher, err = flusher.New( |
| 526 | t.Cfg.Flusher, |
| 527 | t.Cfg.Ingester, |
| 528 | t.OverridesConfig, |
| 529 | prometheus.DefaultRegisterer, |
| 530 | util_log.Logger, |
| 531 | ) |
| 532 | if err != nil { |
| 533 | return |
| 534 | } |
| 535 | |
| 536 | return t.Flusher, nil |
| 537 | } |
| 538 | |
| 539 | // initQueryFrontendTripperware instantiates the tripperware used by the query frontend |
| 540 | // to optimize Prometheus query requests. |
nothing calls this directly
no test coverage detected