@@ -26,15 +26,15 @@ public class ConfiguredController<R extends CustomResource<?, ?>> implements Res
26
26
Closeable {
27
27
private final ResourceController <R > controller ;
28
28
private final ControllerConfiguration <R > configuration ;
29
- private final KubernetesClient k8sClient ;
29
+ private final KubernetesClient kubernetesClient ;
30
30
private EventSourceManager eventSourceManager ;
31
31
32
32
public ConfiguredController (ResourceController <R > controller ,
33
33
ControllerConfiguration <R > configuration ,
34
- KubernetesClient k8sClient ) {
34
+ KubernetesClient kubernetesClient ) {
35
35
this .controller = controller ;
36
36
this .configuration = configuration ;
37
- this .k8sClient = k8sClient ;
37
+ this .kubernetesClient = kubernetesClient ;
38
38
}
39
39
40
40
@ Override
@@ -140,11 +140,11 @@ public ControllerConfiguration<R> getConfiguration() {
140
140
}
141
141
142
142
public KubernetesClient getClient () {
143
- return k8sClient ;
143
+ return kubernetesClient ;
144
144
}
145
145
146
146
public MixedOperation <R , KubernetesResourceList <R >, Resource <R >> getCRClient () {
147
- return k8sClient .resources (configuration .getCustomResourceClass ());
147
+ return kubernetesClient .resources (configuration .getCustomResourceClass ());
148
148
}
149
149
150
150
/**
@@ -164,7 +164,8 @@ public void start() throws OperatorException {
164
164
// check that the custom resource is known by the cluster if configured that way
165
165
final CustomResourceDefinition crd ; // todo: check proper CRD spec version based on config
166
166
if (configuration .getConfigurationService ().checkCRDAndValidateLocalModel ()) {
167
- crd = k8sClient .apiextensions ().v1 ().customResourceDefinitions ().withName (crdName ).get ();
167
+ crd =
168
+ kubernetesClient .apiextensions ().v1 ().customResourceDefinitions ().withName (crdName ).get ();
168
169
if (crd == null ) {
169
170
throwMissingCRDException (crdName , specVersion , controllerName );
170
171
}
0 commit comments