(handler http.Handler)
| 116 | } |
| 117 | |
| 118 | func (q *Querier) CreateAndRegisterWorker(handler http.Handler) error { |
| 119 | q.cfg.Worker.MaxConcurrentRequests = q.cfg.MaxConcurrentQueries |
| 120 | worker, err := worker.NewQuerierWorker( |
| 121 | q.cfg.Worker, |
| 122 | httpgrpc_server.NewServer(handler), |
| 123 | log.Logger, |
| 124 | nil, |
| 125 | ) |
| 126 | if err != nil { |
| 127 | return fmt.Errorf("failed to create frontend worker: %w", err) |
| 128 | } |
| 129 | |
| 130 | subservices := []services.Service{worker, q.liveStorePool} |
| 131 | err = q.RegisterSubservices(subservices...) |
| 132 | if err != nil { |
| 133 | return fmt.Errorf("failed to register live-store pool sub-service: %w", err) |
| 134 | } |
| 135 | |
| 136 | return nil |
| 137 | } |
| 138 | |
| 139 | func (q *Querier) RegisterSubservices(s ...services.Service) error { |
| 140 | var err error |
no test coverage detected