| 20 | ) |
| 21 | |
| 22 | type asyncTraceSharder struct { |
| 23 | next pipeline.AsyncRoundTripper[combiner.PipelineResponse] |
| 24 | cfg *TraceByIDConfig |
| 25 | logger log.Logger |
| 26 | blockBoundaries [][]byte |
| 27 | jobsPerQuery *prometheus.HistogramVec |
| 28 | } |
| 29 | |
| 30 | func newAsyncTraceIDSharder(cfg *TraceByIDConfig, jobsPerQuery *prometheus.HistogramVec, logger log.Logger) pipeline.AsyncMiddleware[combiner.PipelineResponse] { |
| 31 | return pipeline.AsyncMiddlewareFunc[combiner.PipelineResponse](func(next pipeline.AsyncRoundTripper[combiner.PipelineResponse]) pipeline.AsyncRoundTripper[combiner.PipelineResponse] { |
nothing calls this directly
no outgoing calls
no test coverage detected