| 41 | var ringOp = ring.NewOp([]ring.InstanceState{ring.ACTIVE}, nil) |
| 42 | |
| 43 | type BackendWorker struct { |
| 44 | services.Service |
| 45 | |
| 46 | cfg Config |
| 47 | store storage.Store |
| 48 | overrides overrides.Interface |
| 49 | backendScheduler tempopb.BackendSchedulerClient |
| 50 | |
| 51 | workerID string |
| 52 | |
| 53 | // Ring used for sharding tenant index writing. |
| 54 | ringLifecycler *ring.BasicLifecycler |
| 55 | Ring *ring.Ring |
| 56 | |
| 57 | subservices *services.Manager |
| 58 | subservicesWatcher *services.FailureWatcher |
| 59 | } |
| 60 | |
| 61 | // var tracer = otel.Tracer("modules/backendworker") |
| 62 |
nothing calls this directly
no outgoing calls
no test coverage detected