| 89 | } |
| 90 | |
| 91 | type querierWorker struct { |
| 92 | *services.BasicService |
| 93 | |
| 94 | cfg Config |
| 95 | log log.Logger |
| 96 | |
| 97 | processor processor |
| 98 | |
| 99 | subservices *services.Manager |
| 100 | |
| 101 | mu sync.Mutex |
| 102 | // Set to nil when stop is called... no more managers are created afterwards. |
| 103 | managers map[string]*processorManager |
| 104 | } |
| 105 | |
| 106 | func NewQuerierWorker(cfg Config, handler RequestHandler, log log.Logger, reg prometheus.Registerer) (services.Service, error) { |
| 107 | if cfg.QuerierID == "" { |
nothing calls this directly
no outgoing calls
no test coverage detected