@@ -27,8 +27,7 @@ import (
27
27
"strings"
28
28
"sync"
29
29
30
- grpc_middleware "github.com/grpc-ecosystem/go-grpc-middleware"
31
- grpc_prometheus "github.com/grpc-ecosystem/go-grpc-prometheus"
30
+ grpc_prometheus "github.com/grpc-ecosystem/go-grpc-middleware/providers/prometheus"
32
31
33
32
"github.com/fsnotify/fsnotify"
34
33
"github.com/golang/glog"
@@ -212,16 +211,23 @@ func startRpcServer(resourceManager *resource.ResourceManager) {
212
211
glog .Fatalf ("Failed to start RPC server: %v" , err )
213
212
}
214
213
215
- grpc_prometheus .EnableHandlingTimeHistogram (
216
- grpc_prometheus .WithHistogramBuckets ([]float64 {
217
- 0.01 , 0.03 , 0.1 , 0.3 , 1 , 3 , 10 , 15 , 30 , 60 , 120 , 300 , //10 ms -> 5 min
218
- }),
214
+ metrics := grpc_prometheus .NewServerMetrics (
215
+ grpc_prometheus .WithServerHandlingTimeHistogram (
216
+ grpc_prometheus .WithHistogramBuckets ([]float64 {
217
+ 0.01 , 0.03 , 0.1 , 0.3 , 1 , 3 , 10 , 15 , 30 , 60 , 120 , 300 ,
218
+ }),
219
+ ),
219
220
)
220
- m := grpc_middleware .WithUnaryServerChain (
221
- apiServerInterceptor ,
222
- grpc_prometheus .UnaryServerInterceptor ,
221
+
222
+ s := grpc .NewServer (
223
+ grpc .ChainUnaryInterceptor (
224
+ apiServerInterceptor ,
225
+ metrics .UnaryServerInterceptor (),
226
+ ),
227
+ grpc .MaxRecvMsgSize (math .MaxInt32 ),
223
228
)
224
- s := grpc .NewServer (m , grpc .MaxRecvMsgSize (math .MaxInt32 ))
229
+
230
+ metrics .InitializeMetrics (s )
225
231
226
232
sharedExperimentServer := server .NewExperimentServer (resourceManager , & server.ExperimentServerOptions {CollectMetrics : * collectMetricsFlag })
227
233
sharedPipelineServer := server .NewPipelineServer (
0 commit comments