22
22
@ SuppressWarnings ("rawtypes" )
23
23
public class Operator implements AutoCloseable {
24
24
private static final Logger log = LoggerFactory .getLogger (Operator .class );
25
- private final KubernetesClient k8sClient ;
25
+ private final KubernetesClient kubernetesClient ;
26
26
private final ConfigurationService configurationService ;
27
27
private final ControllerManager controllers = new ControllerManager ();
28
28
29
- public Operator (KubernetesClient k8sClient , ConfigurationService configurationService ) {
30
- this .k8sClient = k8sClient ;
29
+ public Operator (KubernetesClient kubernetesClient , ConfigurationService configurationService ) {
30
+ this .kubernetesClient = kubernetesClient ;
31
31
this .configurationService = configurationService ;
32
32
}
33
33
@@ -37,7 +37,7 @@ public void installShutdownHook() {
37
37
}
38
38
39
39
public KubernetesClient getKubernetesClient () {
40
- return k8sClient ;
40
+ return kubernetesClient ;
41
41
}
42
42
43
43
public ConfigurationService getConfigurationService () {
@@ -65,7 +65,7 @@ public void start() {
65
65
66
66
log .info ("Client version: {}" , Version .clientVersion ());
67
67
try {
68
- final var k8sVersion = k8sClient .getVersion ();
68
+ final var k8sVersion = kubernetesClient .getVersion ();
69
69
if (k8sVersion != null ) {
70
70
log .info ("Server version: {}.{}" , k8sVersion .getMajor (), k8sVersion .getMinor ());
71
71
}
@@ -93,7 +93,7 @@ public void close() {
93
93
controllers .close ();
94
94
95
95
ExecutorServiceManager .close ();
96
- k8sClient .close ();
96
+ kubernetesClient .close ();
97
97
}
98
98
99
99
/**
@@ -138,7 +138,7 @@ public <R extends CustomResource> void register(
138
138
configuration = existing ;
139
139
}
140
140
final var configuredController =
141
- new ConfiguredController (controller , configuration , k8sClient );
141
+ new ConfiguredController (controller , configuration , kubernetesClient );
142
142
controllers .add (configuredController );
143
143
144
144
final var watchedNS =
0 commit comments