Merge pull request kubernetes#84522 from liu-cong/plugin

Add scheduler plugin execution duration metric.

Author: k8s-ci-robot

pkg/scheduler/framework/v1alpha1/BUILD

@@ -6,6 +6,7 @@ go_library(
         "cycle_state.go",
         "framework.go",
         "interface.go",
+        "metrics_recorder.go",
         "registry.go",
         "waiting_pods_map.go",
     ],
@@ -25,6 +26,7 @@ go_library(
         "//staging/src/k8s.io/client-go/informers:go_default_library",
         "//staging/src/k8s.io/client-go/kubernetes:go_default_library",
         "//staging/src/k8s.io/client-go/util/workqueue:go_default_library",
+        "//staging/src/k8s.io/component-base/metrics:go_default_library",
         "//vendor/k8s.io/klog:go_default_library",
         "//vendor/sigs.k8s.io/yaml:go_default_library",
     ],

pkg/scheduler/framework/v1alpha1/cycle_state.go

@@ -44,6 +44,8 @@ type StateKey string
 type CycleState struct {
 	mx      sync.RWMutex
 	storage map[StateKey]StateData
+	// if recordFrameworkMetrics is true, framework metrics will be recorded for this cycle.
+	recordFrameworkMetrics bool
 }
 
 // NewCycleState initializes a new CycleState and returns its pointer.
@@ -53,6 +55,22 @@ func NewCycleState() *CycleState {
 	}
 }
 
+// ShouldRecordFrameworkMetrics returns whether framework metrics should be recorded.
+func (c *CycleState) ShouldRecordFrameworkMetrics() bool {
+	if c == nil {
+		return false
+	}
+	return c.recordFrameworkMetrics
+}
+
+// SetRecordFrameworkMetrics sets recordFrameworkMetrics to the given value.
+func (c *CycleState) SetRecordFrameworkMetrics(flag bool) {
+	if c == nil {
+		return
+	}
+	c.recordFrameworkMetrics = flag
+}
+
 // Clone creates a copy of CycleState and returns its pointer. Clone returns
 // nil if the context being cloned is nil.
 func (c *CycleState) Clone() *CycleState {