27
27
public class Operator implements LifecycleAware {
28
28
private static final Logger log = LoggerFactory .getLogger (Operator .class );
29
29
private final KubernetesClient kubernetesClient ;
30
- private final ConfigurationService configurationService ;
31
30
private final ControllerManager controllers = new ControllerManager ();
32
31
33
32
public Operator () {
@@ -64,7 +63,6 @@ public Operator(KubernetesClient client, Consumer<ConfigurationServiceOverrider>
64
63
*/
65
64
public Operator (KubernetesClient kubernetesClient , ConfigurationService configurationService ) {
66
65
this .kubernetesClient = kubernetesClient ;
67
- this .configurationService = configurationService ;
68
66
ConfigurationServiceProvider .set (configurationService );
69
67
}
70
68
@@ -89,7 +87,7 @@ public List<Controller> getControllers() {
89
87
public void start () {
90
88
controllers .shouldStart ();
91
89
92
- final var version = configurationService .getVersion ();
90
+ final var version = ConfigurationServiceProvider . instance () .getVersion ();
93
91
log .info (
94
92
"Operator SDK {} (commit: {}) built on {} starting..." ,
95
93
version .getSdkVersion (),
@@ -105,6 +103,7 @@ public void start() {
105
103
106
104
@ Override
107
105
public void stop () throws OperatorException {
106
+ final var configurationService = ConfigurationServiceProvider .instance ();
108
107
log .info (
109
108
"Operator SDK {} is shutting down..." , configurationService .getVersion ().getSdkVersion ());
110
109
@@ -126,7 +125,8 @@ public void stop() throws OperatorException {
126
125
*/
127
126
public <R extends HasMetadata > void register (Reconciler <R > reconciler )
128
127
throws OperatorException {
129
- final var controllerConfiguration = configurationService .getConfigurationFor (reconciler );
128
+ final var controllerConfiguration =
129
+ ConfigurationServiceProvider .instance ().getConfigurationFor (reconciler );
130
130
register (reconciler , controllerConfiguration );
131
131
}
132
132
@@ -151,7 +151,8 @@ public <R extends HasMetadata> void register(Reconciler<R> reconciler,
151
151
"Cannot register reconciler with name " + reconciler .getClass ().getCanonicalName () +
152
152
" reconciler named " + ReconcilerUtils .getNameFor (reconciler )
153
153
+ " because its configuration cannot be found.\n " +
154
- " Known reconcilers are: " + configurationService .getKnownReconcilerNames ());
154
+ " Known reconcilers are: "
155
+ + ConfigurationServiceProvider .instance ().getKnownReconcilerNames ());
155
156
}
156
157
157
158
final var controller = new Controller <>(reconciler , configuration , kubernetesClient );
@@ -177,7 +178,8 @@ public <R extends HasMetadata> void register(Reconciler<R> reconciler,
177
178
*/
178
179
public <R extends HasMetadata > void register (Reconciler <R > reconciler ,
179
180
Consumer <ControllerConfigurationOverrider <R >> configOverrider ) {
180
- final var controllerConfiguration = configurationService .getConfigurationFor (reconciler );
181
+ final var controllerConfiguration =
182
+ ConfigurationServiceProvider .instance ().getConfigurationFor (reconciler );
181
183
var configToOverride = ControllerConfigurationOverrider .override (controllerConfiguration );
182
184
configOverrider .accept (configToOverride );
183
185
register (reconciler , configToOverride .build ());
0 commit comments