From 2048b7b8fd45bc46efd53a29ef0c6bb91e0f31c5 Mon Sep 17 00:00:00 2001 From: Ed Bartosh Date: Thu, 10 Oct 2024 00:32:05 +0300 Subject: [PATCH] kubelet: add DRAGRPCOperationsDuration metric --- pkg/kubelet/metrics/metrics.go | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) diff --git a/pkg/kubelet/metrics/metrics.go b/pkg/kubelet/metrics/metrics.go index 97f79dd052c..be0a4cbfa53 100644 --- a/pkg/kubelet/metrics/metrics.go +++ b/pkg/kubelet/metrics/metrics.go @@ -134,7 +134,8 @@ const ( ContainerAlignedComputeResourcesBoundaryLabelKey = "boundary" // Metric keys for DRA operations - DRAOperationsDurationKey = "operations_duration_seconds" + DRAOperationsDurationKey = "operations_duration_seconds" + DRAGRPCOperationsDurationKey = "grpc_operations_duration_seconds" // Values used in metric labels Container = "container" @@ -954,6 +955,18 @@ var ( }, []string{"operation_name", "is_error"}, ) + + // DRAGRPCOperationsDuration tracks the duration of the DRA GRPC operations. + DRAGRPCOperationsDuration = metrics.NewHistogramVec( + &metrics.HistogramOpts{ + Subsystem: DRASubsystem, + Name: DRAGRPCOperationsDurationKey, + Help: "Duration in seconds of the DRA gRPC operations", + Buckets: metrics.DefBuckets, + StabilityLevel: metrics.ALPHA, + }, + []string{"driver_name", "method_name", "grpc_status_code"}, + ) ) var registerMetrics sync.Once @@ -1049,6 +1062,7 @@ func Register(collectors ...metrics.StableCollector) { if utilfeature.DefaultFeatureGate.Enabled(features.DynamicResourceAllocation) { legacyregistry.MustRegister(DRAOperationsDuration) + legacyregistry.MustRegister(DRAGRPCOperationsDuration) } }) }