10 // Import all Kubernetes client auth plugins (e.g. Azure, GCP, OIDC, etc.)
11 _ "k8s.io/client-go/plugin/pkg/client/auth"
13 "demo/vnfs/DAaaS/collectd-operator/pkg/apis"
14 "demo/vnfs/DAaaS/collectd-operator/pkg/controller"
16 "github.com/operator-framework/operator-sdk/pkg/k8sutil"
17 "github.com/operator-framework/operator-sdk/pkg/leader"
18 "github.com/operator-framework/operator-sdk/pkg/log/zap"
19 "github.com/operator-framework/operator-sdk/pkg/metrics"
20 "github.com/operator-framework/operator-sdk/pkg/restmapper"
21 sdkVersion "github.com/operator-framework/operator-sdk/version"
22 "github.com/spf13/pflag"
23 "sigs.k8s.io/controller-runtime/pkg/client/config"
24 "sigs.k8s.io/controller-runtime/pkg/manager"
25 logf "sigs.k8s.io/controller-runtime/pkg/runtime/log"
26 "sigs.k8s.io/controller-runtime/pkg/runtime/signals"
29 // Change below variables to serve metrics on different host or port.
31 metricsHost = "0.0.0.0"
32 metricsPort int32 = 8383
34 var log = logf.Log.WithName("cmd")
37 log.Info(fmt.Sprintf("Go Version: %s", runtime.Version()))
38 log.Info(fmt.Sprintf("Go OS/Arch: %s/%s", runtime.GOOS, runtime.GOARCH))
39 log.Info(fmt.Sprintf("Version of operator-sdk: %v", sdkVersion.Version))
43 // Add the zap logger flag set to the CLI. The flag set must
44 // be added before calling pflag.Parse().
45 pflag.CommandLine.AddFlagSet(zap.FlagSet())
47 // Add flags registered by imported packages (e.g. glog and
48 // controller-runtime)
49 pflag.CommandLine.AddGoFlagSet(flag.CommandLine)
53 // Use a zap logr.Logger implementation. If none of the zap
54 // flags are configured (or if the zap flag set is not being
55 // used), this defaults to a production zap logger.
57 // The logger instantiated here can be changed to any logger
58 // implementing the logr.Logger interface. This logger will
59 // be propagated through the whole operator, generating
60 // uniform and structured logs.
61 logf.SetLogger(zap.Logger())
65 namespace, err := k8sutil.GetWatchNamespace()
67 log.Error(err, "Failed to get watch namespace")
71 // Get a config to talk to the apiserver
72 cfg, err := config.GetConfig()
80 // Become the leader before proceeding
81 err = leader.Become(ctx, "collectd-operator-lock")
87 // Create a new Cmd to provide shared dependencies and start components
88 mgr, err := manager.New(cfg, manager.Options{
90 MapperProvider: restmapper.NewDynamicRESTMapper,
91 MetricsBindAddress: fmt.Sprintf("%s:%d", metricsHost, metricsPort),
98 log.Info("Registering Components.")
100 // Setup Scheme for all resources
101 if err := apis.AddToScheme(mgr.GetScheme()); err != nil {
106 // Setup all Controllers
107 if err := controller.AddToManager(mgr); err != nil {
112 // Create Service object to expose the metrics port.
113 _, err = metrics.ExposeMetricsPort(ctx, metricsPort)
115 log.Info(err.Error())
118 log.Info("Starting the Cmd.")
121 if err := mgr.Start(signals.SetupSignalHandler()); err != nil {
122 log.Error(err, "Manager exited non-zero")