@@ -22,7 +22,7 @@ import (
22
22
"time"
23
23
24
24
"k8s.io/apimachinery/pkg/runtime"
25
- "k8s.io/client-go/kubernetes/scheme"
25
+ clientgoscheme "k8s.io/client-go/kubernetes/scheme"
26
26
_ "k8s.io/client-go/plugin/pkg/client/auth/gcp"
27
27
"k8s.io/klog"
28
28
"k8s.io/klog/klogr"
@@ -35,14 +35,14 @@ import (
35
35
)
36
36
37
37
var (
38
- myscheme = runtime .NewScheme ()
38
+ scheme = runtime .NewScheme ()
39
39
setupLog = ctrl .Log .WithName ("setup" )
40
40
)
41
41
42
42
func init () {
43
- _ = scheme .AddToScheme (myscheme )
44
- _ = bootstrapv1 .AddToScheme (myscheme )
45
- _ = clusterv1 .AddToScheme (myscheme )
43
+ _ = clientgoscheme .AddToScheme (scheme )
44
+ _ = bootstrapv1 .AddToScheme (scheme )
45
+ _ = clusterv1 .AddToScheme (scheme )
46
46
// +kubebuilder:scaffold:scheme
47
47
}
48
48
@@ -54,17 +54,34 @@ func main() {
54
54
enableLeaderElection bool
55
55
syncPeriod time.Duration
56
56
)
57
- flag .StringVar (& metricsAddr , "metrics-addr" , ":8080" , "The address the metric endpoint binds to." )
58
- flag .BoolVar (& enableLeaderElection , "enable-leader-election" , false ,
59
- "Enable leader election for controller manager. Enabling this will ensure there is only one active controller manager." )
60
- flag .DurationVar (& syncPeriod , "sync-period" , 10 * time .Minute ,
61
- "The minimum interval at which watched resources are reconciled (e.g. 10m)" )
57
+
58
+ flag .StringVar (
59
+ & metricsAddr ,
60
+ "metrics-addr" ,
61
+ ":8080" ,
62
+ "The address the metric endpoint binds to." ,
63
+ )
64
+
65
+ flag .BoolVar (
66
+ & enableLeaderElection ,
67
+ "enable-leader-election" ,
68
+ false ,
69
+ "Enable leader election for controller manager. Enabling this will ensure there is only one active controller manager." ,
70
+ )
71
+
72
+ flag .DurationVar (
73
+ & syncPeriod ,
74
+ "sync-period" ,
75
+ 10 * time .Minute ,
76
+ "The minimum interval at which watched resources are reconciled (e.g. 10m)" ,
77
+ )
78
+
62
79
flag .Parse ()
63
80
64
81
ctrl .SetLogger (klogr .New ())
65
82
66
83
mgr , err := ctrl .NewManager (ctrl .GetConfigOrDie (), ctrl.Options {
67
- Scheme : myscheme ,
84
+ Scheme : scheme ,
68
85
MetricsBindAddress : metricsAddr ,
69
86
LeaderElection : enableLeaderElection ,
70
87
SyncPeriod : & syncPeriod ,
@@ -77,10 +94,10 @@ func main() {
77
94
if err := (& controllers.KubeadmConfigReconciler {
78
95
Client : mgr .GetClient (),
79
96
SecretsClientFactory : controllers.ClusterSecretsClientFactory {},
80
- Log : ctrl .Log .WithName ("reconciler " ),
97
+ Log : ctrl .Log .WithName ("KubeadmConfigReconciler " ),
81
98
KubeadmInitLock : locking .NewControlPlaneInitMutex (ctrl .Log .WithName ("init-locker" ), mgr .GetClient ()),
82
99
}).SetupWithManager (mgr ); err != nil {
83
- setupLog .Error (err , "unable to create controller" , "controller" , "reconciler " )
100
+ setupLog .Error (err , "unable to create controller" , "controller" , "KubeadmConfigReconciler " )
84
101
os .Exit (1 )
85
102
}
86
103
// +kubebuilder:scaffold:builder
0 commit comments