Function InstrumentReusableStream

pkg/util/grpcclient/instrumentation.go:29–42

(requestDuration *prometheus.HistogramVec)

}

func InstrumentReusableStream(requestDuration *prometheus.HistogramVec) ([]grpc.UnaryClientInterceptor, []grpc.StreamClientInterceptor) {
	return []grpc.UnaryClientInterceptor{
			grpcutil.HTTPHeaderPropagationClientInterceptor,
			otgrpc.OpenTracingClientInterceptor(opentracing.GlobalTracer()),
			middleware.ClientUserHeaderInterceptor,
			cortexmiddleware.PrometheusGRPCUnaryInstrumentation(requestDuration),
		}, []grpc.StreamClientInterceptor{
			grpcutil.HTTPHeaderPropagationStreamClientInterceptor,
			unwrapErrorStreamClientInterceptor(),
			otgrpc.OpenTracingStreamClientInterceptor(opentracing.GlobalTracer()),
			middleware.StreamClientUserHeaderInterceptor,
			cortexmiddleware.PrometheusGRPCReusableStreamInstrumentation(requestDuration),
		}
}