()
| 679 | } |
| 680 | |
| 681 | func (t *App) initBackendWorker() (services.Service, error) { |
| 682 | if IsSingleBinary(t.cfg.Target) && t.cfg.BackendWorker.BackendSchedulerAddr == "" { |
| 683 | t.cfg.BackendWorker.BackendSchedulerAddr = fmt.Sprintf("127.0.0.1:%d", t.cfg.Server.GRPCListenPort) |
| 684 | level.Warn(log.Logger).Log("msg", "Scheduler address is empty in single binary mode. Attempting automatic worker configuration.", "address", t.cfg.BackendWorker.BackendSchedulerAddr) |
| 685 | } |
| 686 | |
| 687 | worker, err := backendworker.New(t.cfg.BackendWorker, t.cfg.BackenSchedulerClient, t.store, t.Overrides, prometheus.DefaultRegisterer) |
| 688 | if err != nil { |
| 689 | return nil, fmt.Errorf("failed to create backend scheduler: %w", err) |
| 690 | } |
| 691 | t.backendWorker = worker |
| 692 | |
| 693 | if t.backendWorker.Ring != nil { |
| 694 | t.Server.HTTPRouter().Handle("/backend-worker/ring", t.backendWorker.Ring) |
| 695 | } |
| 696 | |
| 697 | return worker, nil |
| 698 | } |
| 699 | |
| 700 | func (t *App) initLiveStore() (services.Service, error) { |
| 701 | // In single-binary mode traces are pushed in-process from distributor, |
nothing calls this directly
no test coverage detected