Wire up feature_gate.go with metrics via AddMetrics method

wire up feature_gate.go with metrics via AddMetrics method

Change-Id: I9b4f6b04c0f4eb9bcb198b16284393d21c774ad8

wire in metrics to kubernetes components

Change-Id: I6d4ef8b26f149f62b03f32d1658f04f3056fe4dc

rename metric since we're using the value to determine if enabled is true or false

Change-Id: I13a6b6df90a5ffb4b9c5b34fa187562413bea029

Update staging/src/k8s.io/component-base/featuregate/feature_gate.go

Co-authored-by: Jordan Liggitt <jordan@liggitt.net>
This commit is contained in:
Han Kang
2022-09-23 09:24:42 -07:00
parent ce4fd5c31d
commit e95179ffb6
12 changed files with 431 additions and 15 deletions

View File

@@ -127,7 +127,8 @@ cluster's shared state through which all other components interact.`,
if errs := completedOptions.Validate(); len(errs) != 0 {
return utilerrors.NewAggregate(errs)
}
// add feature enablement metrics
utilfeature.DefaultMutableFeatureGate.AddMetrics()
return Run(completedOptions, genericapiserver.SetupSignalHandler())
},
Args: func(cmd *cobra.Command, args []string) error {

View File

@@ -134,7 +134,8 @@ controller, and serviceaccounts controller.`,
if err != nil {
return err
}
// add feature enablement metrics
utilfeature.DefaultMutableFeatureGate.AddMetrics()
return Run(c.Complete(), wait.NeverStop)
},
Args: func(cmd *cobra.Command, args []string) error {

View File

@@ -484,7 +484,8 @@ with the apiserver API to configure the proxy.`,
if err := opts.Validate(); err != nil {
return fmt.Errorf("failed validate: %w", err)
}
// add feature enablement metrics
utilfeature.DefaultMutableFeatureGate.AddMetrics()
if err := opts.Run(); err != nil {
klog.ErrorS(err, "Error running ProxyServer")
return err

View File

@@ -138,7 +138,8 @@ func runCommand(cmd *cobra.Command, opts *options.Options, registryOptions ...Op
if err != nil {
return err
}
// add feature enablement metrics
utilfeature.DefaultMutableFeatureGate.AddMetrics()
return Run(ctx, cc, sched)
}

View File

@@ -269,6 +269,7 @@ HTTP server: The kubelet can also listen for HTTP and respond to a simple API
// set up signal context for kubelet shutdown
ctx := genericapiserver.SetupSignalContext()
utilfeature.DefaultMutableFeatureGate.AddMetrics()
// run the kubelet
return Run(ctx, kubeletServer, kubeletDeps, utilfeature.DefaultFeatureGate)
},