karmada/cmd/controller-manager/controller-manager.go

40 lines
1.5 KiB
Go

package main
import (
"os"
// Note that Kubernetes registers workqueue metrics to default prometheus Registry. And the registry will be
// initialized by the package 'k8s.io/apiserver/pkg/server'.
// See https://github.com/kubernetes/kubernetes/blob/f61ed439882e34d9dad28b602afdc852feb2337a/staging/src/k8s.io/component-base/metrics/prometheus/workqueue/metrics.go#L25
// But the controller-runtime registers workqueue metrics to its own Registry instead of default prometheus Registry.
// See https://github.com/kubernetes-sigs/controller-runtime/blob/4d10a0615b11507451ecb58bfd59f0f6ef313a29/pkg/metrics/workqueue.go#L24-L26
// However, global workqueue metrics factory will be only initialized once.
// See https://github.com/kubernetes/kubernetes/blob/f61ed439882e34d9dad28b602afdc852feb2337a/staging/src/k8s.io/client-go/util/workqueue/metrics.go#L257-L261
// So this package should be initialized before 'k8s.io/apiserver/pkg/server', thus the internal registry of
// controller-runtime could be set first.
_ "sigs.k8s.io/controller-runtime/pkg/metrics"
apiserver "k8s.io/apiserver/pkg/server"
"k8s.io/component-base/logs"
"github.com/karmada-io/karmada/cmd/controller-manager/app"
)
func main() {
if err := runControllerManagerCmd(); err != nil {
os.Exit(1)
}
}
func runControllerManagerCmd() error {
logs.InitLogs()
defer logs.FlushLogs()
ctx := apiserver.SetupSignalContext()
if err := app.NewControllerManagerCommand(ctx).Execute(); err != nil {
return err
}
return nil
}