github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 18:00:08 +00:00
Code Issues Projects Releases Wiki Activity

removed dependency on external prometheus

Browse Source
This commit is contained in:
JD Nurme 2021-12-09 00:37:08 +00:00
parent a520d5e74b
commit bdedfb7653
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
staging/src/k8s.io/component-base/metrics/prometheus/controllers/metrics.go
View File

@ -17,7 +17,8 @@ limitations under the License.
package controllers package controllers
import ( import (
"github.com/prometheus/client_golang/prometheus" k8smetrics "k8s.io/component-base/metrics"
"k8s.io/component-base/metrics/legacyregistry"
) )
var ( var (
@ -27,19 +28,19 @@ var (
// ControllerMetrics includes all the metrics of the proxy server. // ControllerMetrics includes all the metrics of the proxy server.
type ControllerMetrics struct { type ControllerMetrics struct {
controllerInstanceCount *prometheus.GaugeVec controllerInstanceCount *k8smetrics.GaugeVec
} }
// newControllerMetrics create a new ControllerMetrics, configured with default metric names. // newControllerMetrics create a new ControllerMetrics, configured with default metric names.
func newControllerMetrics() *ControllerMetrics { func newControllerMetrics() *ControllerMetrics {
controllerInstanceCount := prometheus.NewGaugeVec( controllerInstanceCount := k8smetrics.NewGaugeVec(
prometheus.GaugeOpts{ &k8smetrics.GaugeOpts{
Name: "managed_controller_instance_count", Name: "managed_controller_instance_count",
Help: "Instances of individual controllers currently running", Help: "Instances of individual controllers currently running",
}, },
[]string{"controller_name", "controller_manager"}, []string{"controller_name", "controller_manager"},
) )
prometheus.MustRegister(controllerInstanceCount) legacyregistry.MustRegister(controllerInstanceCount)
return &ControllerMetrics{ return &ControllerMetrics{
controllerInstanceCount: controllerInstanceCount, controllerInstanceCount: controllerInstanceCount,
} }
@ -47,10 +48,10 @@ func newControllerMetrics() *ControllerMetrics {
// ControllerStarted sets the controllerInstanceCount to 1. // ControllerStarted sets the controllerInstanceCount to 1.
func (a *ControllerMetrics) ControllerStarted(controllerName string, controllerManager string) { func (a *ControllerMetrics) ControllerStarted(controllerName string, controllerManager string) {
a.controllerInstanceCount.With(prometheus.Labels{"controller_name": controllerName, "controller_manager": controllerManager}).Set(float64(1)) a.controllerInstanceCount.With(k8smetrics.Labels{"controller_name": controllerName, "controller_manager": controllerManager}).Set(float64(1))
} }
// ControllerStopped sets the controllerInstanceCount to 0. // ControllerStopped sets the controllerInstanceCount to 0.
func (a *ControllerMetrics) ControllerStopped(controllerName string, controllerManager string) { func (a *ControllerMetrics) ControllerStopped(controllerName string, controllerManager string) {
a.controllerInstanceCount.With(prometheus.Labels{"controller_name": controllerName, "controller_manager": controllerManager}).Set(float64(0)) a.controllerInstanceCount.With(k8smetrics.Labels{"controller_name": controllerName, "controller_manager": controllerManager}).Set(float64(0))
} }