@@ -18,7 +18,11 @@ package main
1818
1919import (
2020 "flag"
21+ "fmt"
22+ intController "github.com/splunk/splunk-operator/internal/controller"
23+ "github.com/splunk/splunk-operator/internal/controller/debug"
2124 "os"
25+ "sigs.k8s.io/controller-runtime/pkg/metrics/filters"
2226 "time"
2327
2428 // Import all Kubernetes client auth plugins (e.g. Azure, GCP, OIDC, etc.)
@@ -36,12 +40,10 @@ import (
3640 "sigs.k8s.io/controller-runtime/pkg/healthz"
3741 "sigs.k8s.io/controller-runtime/pkg/log/zap"
3842 "sigs.k8s.io/controller-runtime/pkg/manager"
43+ metricsserver "sigs.k8s.io/controller-runtime/pkg/metrics/server"
3944
4045 enterpriseApiV3 "github.com/splunk/splunk-operator/api/v3"
4146 enterpriseApi "github.com/splunk/splunk-operator/api/v4"
42- "github.com/splunk/splunk-operator/controllers"
43- debug "github.com/splunk/splunk-operator/controllers/debug"
44- "github.com/splunk/splunk-operator/pkg/config"
4547 //+kubebuilder:scaffold:imports
4648 //extapi "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
4749)
@@ -106,73 +108,76 @@ func main() {
106108 // Logging setup
107109 ctrl .SetLogger (zap .New (zap .UseFlagOptions (& opts )))
108110
109- options := ctrl.Options {
111+ mgr , err := ctrl .NewManager (ctrl .GetConfigOrDie (), ctrl.Options {
112+ Metrics : metricsserver.Options {
113+ BindAddress : metricsAddr ,
114+ FilterProvider : filters .WithAuthenticationAndAuthorization ,
115+ },
110116 Scheme : scheme ,
111- MetricsBindAddress : metricsAddr ,
112- Port : 9443 ,
113117 HealthProbeBindAddress : probeAddr ,
114118 LeaderElection : enableLeaderElection ,
115119 LeaderElectionID : "270bec8c.splunk.com" ,
116120 LeaseDuration : & leaseDuration ,
117121 RenewDeadline : & renewDeadline ,
118- }
122+ })
119123
120- mgr , err := ctrl .NewManager (ctrl .GetConfigOrDie (), config .ManagerOptionsWithNamespaces (setupLog , options ))
121124 if err != nil {
122125 setupLog .Error (err , "unable to start manager" )
123126 os .Exit (1 )
124127 }
125128
126- if err = (& controllers. ClusterMasterReconciler {
129+ if err = (& intController. ClusterManagerReconciler {
127130 Client : mgr .GetClient (),
128131 Scheme : mgr .GetScheme (),
129132 }).SetupWithManager (mgr ); err != nil {
130- setupLog .Error (err , "unable to create controller" , "controller" , "ClusterMaster" )
133+ fmt .Printf (" error - %v" , err )
134+ setupLog .Error (err , "unable to create controller" , "controller" , "ClusterManager " )
131135 os .Exit (1 )
132136 }
133- if err = (& controllers.ClusterManagerReconciler {
137+ fmt .Printf ("%v" , err )
138+ if err = (& intController.ClusterMasterReconciler {
134139 Client : mgr .GetClient (),
135140 Scheme : mgr .GetScheme (),
136141 }).SetupWithManager (mgr ); err != nil {
137- setupLog .Error (err , "unable to create controller" , "controller" , "ClusterManager " )
142+ setupLog .Error (err , "unable to create controller" , "controller" , "ClusterMaster " )
138143 os .Exit (1 )
139144 }
140- if err = (& controllers .IndexerClusterReconciler {
145+ if err = (& intController .IndexerClusterReconciler {
141146 Client : mgr .GetClient (),
142147 Scheme : mgr .GetScheme (),
143148 }).SetupWithManager (mgr ); err != nil {
144149 setupLog .Error (err , "unable to create controller" , "controller" , "IndexerCluster" )
145150 os .Exit (1 )
146151 }
147- if err = (& controllers .LicenseMasterReconciler {
152+ if err = (& intController .LicenseMasterReconciler {
148153 Client : mgr .GetClient (),
149154 Scheme : mgr .GetScheme (),
150155 }).SetupWithManager (mgr ); err != nil {
151156 setupLog .Error (err , "unable to create controller" , "controller" , "LicenseMaster" )
152157 os .Exit (1 )
153158 }
154- if err = (& controllers .LicenseManagerReconciler {
159+ if err = (& intController .LicenseManagerReconciler {
155160 Client : mgr .GetClient (),
156161 Scheme : mgr .GetScheme (),
157162 }).SetupWithManager (mgr ); err != nil {
158163 setupLog .Error (err , "unable to create controller" , "controller" , "LicenseManager" )
159164 os .Exit (1 )
160165 }
161- if err = (& controllers .MonitoringConsoleReconciler {
166+ if err = (& intController .MonitoringConsoleReconciler {
162167 Client : mgr .GetClient (),
163168 Scheme : mgr .GetScheme (),
164169 }).SetupWithManager (mgr ); err != nil {
165170 setupLog .Error (err , "unable to create controller" , "controller" , "MonitoringConsole" )
166171 os .Exit (1 )
167172 }
168- if err = (& controllers .SearchHeadClusterReconciler {
173+ if err = (& intController .SearchHeadClusterReconciler {
169174 Client : mgr .GetClient (),
170175 Scheme : mgr .GetScheme (),
171176 }).SetupWithManager (mgr ); err != nil {
172177 setupLog .Error (err , "unable to create controller" , "controller" , "SearchHeadCluster" )
173178 os .Exit (1 )
174179 }
175- if err = (& controllers .StandaloneReconciler {
180+ if err = (& intController .StandaloneReconciler {
176181 Client : mgr .GetClient (),
177182 Scheme : mgr .GetScheme (),
178183 }).SetupWithManager (mgr ); err != nil {
@@ -205,7 +210,7 @@ func main() {
205210// Note that these endpoints meant to be sensitive and shouldn't be exposed publicly.
206211func customSetupEndpoints (pprofActive bool , mgr manager.Manager ) error {
207212 if pprofActive {
208- if err := debug .RegisterEndpoint (mgr .AddMetricsExtraHandler , nil ); err != nil {
213+ if err := debug .RegisterEndpoint (mgr .AddMetricsServerExtraHandler , nil ); err != nil {
209214 setupLog .Error (err , "Unable to register pprof endpoint" )
210215 return err
211216 }
0 commit comments