@@ -10,6 +10,7 @@ import (
10
10
"github.com/go-kit/log/level"
11
11
"github.com/grafana/dskit/backoff"
12
12
"github.com/grafana/dskit/grpcclient"
13
+ dsmiddleware "github.com/grafana/dskit/middleware"
13
14
"github.com/grafana/dskit/services"
14
15
otgrpc "github.com/opentracing-contrib/go-grpc"
15
16
"github.com/opentracing/opentracing-go"
@@ -27,7 +28,6 @@ import (
27
28
"github.com/cortexproject/cortex/pkg/scheduler/schedulerpb"
28
29
"github.com/cortexproject/cortex/pkg/util/httpgrpcutil"
29
30
util_log "github.com/cortexproject/cortex/pkg/util/log"
30
- cortex_middleware "github.com/cortexproject/cortex/pkg/util/middleware"
31
31
)
32
32
33
33
func newSchedulerProcessor (cfg Config , handler RequestHandler , log log.Logger , reg prometheus.Registerer ) (* schedulerProcessor , []services.Service ) {
@@ -198,7 +198,7 @@ func (sp *schedulerProcessor) createFrontendClient(addr string) (client.PoolClie
198
198
opts , err := sp .grpcConfig .DialOption ([]grpc.UnaryClientInterceptor {
199
199
otgrpc .OpenTracingClientInterceptor (opentracing .GlobalTracer ()),
200
200
middleware .ClientUserHeaderInterceptor ,
201
- cortex_middleware .PrometheusGRPCUnaryInstrumentation (sp .frontendClientRequestDuration ),
201
+ dsmiddleware .PrometheusGRPCUnaryInstrumentation (sp .frontendClientRequestDuration ),
202
202
}, nil )
203
203
204
204
if err != nil {
0 commit comments