in main.go [59:235]
func main() {
var (
metricsAddr string
probeAddr string
enableLeaderElection bool
)
flag.StringVar(&metricsAddr, "metrics-bind-address", ":8080", "The address the metric endpoint binds to.")
flag.StringVar(&probeAddr, "health-probe-bind-address", ":8081", "The address the probe endpoint binds to.")
flag.BoolVar(&enableLeaderElection, "leader-elect", true,
"Enable leader election for controller manager. "+
"Enabling this will ensure there is only one active controller manager.")
opts := zap.Options{
Development: true,
}
opts.BindFlags(flag.CommandLine)
flag.Parse()
ctrl.SetLogger(zap.New(zap.UseFlagOptions(&opts)))
v := buildInfo.Get()
setupLog.Info("Starting the Keycloak Operator",
"version", v.Version,
"git-commit", v.GitCommit,
"git-tag", v.GitTag,
"build-date", v.BuildDate,
"go-version", v.Go,
"go-client", v.KubectlVersion,
"platform", v.Platform,
)
utilruntime.Must(clientgoscheme.AddToScheme(scheme))
utilruntime.Must(keycloakApi.AddToScheme(scheme))
utilruntime.Must(keycloakApi1alpha1.AddToScheme(scheme))
utilruntime.Must(corev1.AddToScheme(scheme))
ns, err := util.GetWatchNamespace()
if err != nil {
setupLog.Error(err, "unable to get watch namespace")
os.Exit(1)
}
cfg := ctrl.GetConfigOrDie()
mgr, err := ctrl.NewManager(cfg, ctrl.Options{
Scheme: scheme,
MetricsBindAddress: metricsAddr,
HealthProbeBindAddress: probeAddr,
Port: managerPort,
LeaderElection: enableLeaderElection,
LeaderElectionID: keycloakOperatorLock,
MapperProvider: func(c *rest.Config) (meta.RESTMapper, error) {
return apiutil.NewDynamicRESTMapper(cfg)
},
Namespace: ns,
})
if err != nil {
setupLog.Error(err, "unable to start manager")
os.Exit(1)
}
successReconcileTimeoutValue, err := getSuccessReconcileTimeout()
if err != nil {
setupLog.Error(err, "unable to parse reconcile timeout")
os.Exit(1)
}
operatorNamespace, err := getOperatorNamespace()
if err != nil {
setupLog.Error(err, "unable to get operator namespace")
os.Exit(1)
}
h := helper.MakeHelper(mgr.GetClient(), mgr.GetScheme(), operatorNamespace)
keycloakCtrl := keycloak.NewReconcileKeycloak(mgr.GetClient(), mgr.GetScheme(), h)
if err = keycloakCtrl.SetupWithManager(mgr, successReconcileTimeoutValue); err != nil {
setupLog.Error(err, "unable to create keycloak controller")
os.Exit(1)
}
keycloakClientCtrl := keycloakclient.NewReconcileKeycloakClient(mgr.GetClient(), h)
if err = keycloakClientCtrl.SetupWithManager(mgr, successReconcileTimeoutValue); err != nil {
setupLog.Error(err, "unable to create keycloak-client controller")
os.Exit(1)
}
keycloakRealmCtrl := keycloakrealm.NewReconcileKeycloakRealm(mgr.GetClient(), mgr.GetScheme(), h)
if err = keycloakRealmCtrl.SetupWithManager(mgr, successReconcileTimeoutValue); err != nil {
setupLog.Error(err, "unable to create keycloak-realm controller")
os.Exit(1)
}
krgCtrl := keycloakrealmgroup.NewReconcileKeycloakRealmGroup(mgr.GetClient(), h)
if err = krgCtrl.SetupWithManager(mgr, successReconcileTimeoutValue); err != nil {
setupLog.Error(err, "unable to create keycloak-realm-group controller")
os.Exit(1)
}
krrCtrl := keycloakrealmrole.NewReconcileKeycloakRealmRole(mgr.GetClient(), h)
if err = krrCtrl.SetupWithManager(mgr, successReconcileTimeoutValue); err != nil {
setupLog.Error(err, "unable to create keycloak-realm-role controller")
os.Exit(1)
}
krrbCtrl := keycloakrealmrolebatch.NewReconcileKeycloakRealmRoleBatch(mgr.GetClient(), h)
if err = krrbCtrl.SetupWithManager(mgr, successReconcileTimeoutValue); err != nil {
setupLog.Error(err, "unable to create keycloak-realm-role-batch controller")
os.Exit(1)
}
kafCtrl := keycloakauthflow.NewReconcile(mgr.GetClient(), h)
if err = kafCtrl.SetupWithManager(mgr); err != nil {
setupLog.Error(err, "unable to create keycloak-auth-flow controller")
os.Exit(1)
}
kruCtrl := keycloakrealmuser.NewReconcile(mgr.GetClient(), h)
if err = kruCtrl.SetupWithManager(mgr); err != nil {
setupLog.Error(err, "unable to create keycloak-realm-user controller")
os.Exit(1)
}
if err = keycloakclientscope.NewReconcile(mgr.GetClient(), h).
SetupWithManager(mgr); err != nil {
setupLog.Error(err, "unable to create keycloak-client-scope controller")
os.Exit(1)
}
if err = keycloakrealmcomponent.NewReconcile(mgr.GetClient(), mgr.GetScheme(), h, secretref.NewSecretRef(mgr.GetClient())).
SetupWithManager(mgr, successReconcileTimeoutValue); err != nil {
setupLog.Error(err, "unable to create keycloak-realm-component controller")
os.Exit(1)
}
if err = keycloakrealmidentityprovider.NewReconcile(mgr.GetClient(), h, secretref.NewSecretRef(mgr.GetClient())).
SetupWithManager(mgr, successReconcileTimeoutValue); err != nil {
setupLog.Error(err, "unable to create keycloak-realm-identity-provider controller")
os.Exit(1)
}
if ns == "" {
if err = clusterkeycloak.NewReconcile(mgr.GetClient(), mgr.GetScheme(), h, operatorNamespace).
SetupWithManager(mgr); err != nil {
setupLog.Error(err, "unable to create clusterkeycloak controller")
os.Exit(1)
}
if err = clusterkeycloakrealm.NewClusterKeycloakRealmReconciler(mgr.GetClient(), mgr.GetScheme(), h, operatorNamespace).
SetupWithManager(mgr); err != nil {
setupLog.Error(err, "unable to create controller", "controller", "ClusterKeycloakRealm")
os.Exit(1)
}
}
//+kubebuilder:scaffold:builder
if err := mgr.AddHealthzCheck("healthz", healthz.Ping); err != nil {
setupLog.Error(err, "unable to set up health check")
os.Exit(1)
}
if err := mgr.AddReadyzCheck("readyz", healthz.Ping); err != nil {
setupLog.Error(err, "unable to set up ready check")
os.Exit(1)
}
setupLog.Info("starting manager")
if err := mgr.Start(ctrl.SetupSignalHandler()); err != nil {
setupLog.Error(err, "problem running manager")
os.Exit(1)
}
}