Skip to content

Commit 0926c9c

Browse files
authored
Merge pull request kubernetes#89131 from cwdsuzhou/March/expose_scheduler_metric
Expose scheduler metric to make it possible for plugins to use it
2 parents 7061ddd + bbaa76c commit 0926c9c

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

pkg/scheduler/metrics/metrics.go

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -261,16 +261,22 @@ var registerMetrics sync.Once
261261
func Register() {
262262
// Register the metrics.
263263
registerMetrics.Do(func() {
264-
for _, metric := range metricsList {
265-
legacyregistry.MustRegister(metric)
266-
}
264+
RegisterMetrics(metricsList...)
267265
volumeschedulingmetrics.RegisterVolumeSchedulingMetrics()
268266
PodScheduleSuccesses = scheduleAttempts.With(metrics.Labels{"result": "scheduled"})
269267
PodScheduleFailures = scheduleAttempts.With(metrics.Labels{"result": "unschedulable"})
270268
PodScheduleErrors = scheduleAttempts.With(metrics.Labels{"result": "error"})
271269
})
272270
}
273271

272+
// RegisterMetrics registers a list of metrics.
273+
// This function is exported because it is intended to be used by out-of-tree plugins to register their custom metrics.
274+
func RegisterMetrics(extraMetrics ...metrics.Registerable) {
275+
for _, metric := range extraMetrics {
276+
legacyregistry.MustRegister(metric)
277+
}
278+
}
279+
274280
// GetGather returns the gatherer. It used by test case outside current package.
275281
func GetGather() metrics.Gatherer {
276282
return legacyregistry.DefaultGatherer

0 commit comments

Comments
 (0)