2222@ SuppressWarnings ("rawtypes" )
2323public class Operator implements AutoCloseable {
2424 private static final Logger log = LoggerFactory .getLogger (Operator .class );
25- private final KubernetesClient k8sClient ;
25+ private final KubernetesClient kubernetesClient ;
2626 private final ConfigurationService configurationService ;
2727 private final ControllerManager controllers = new ControllerManager ();
2828
29- public Operator (KubernetesClient k8sClient , ConfigurationService configurationService ) {
30- this .k8sClient = k8sClient ;
29+ public Operator (KubernetesClient kubernetesClient , ConfigurationService configurationService ) {
30+ this .kubernetesClient = kubernetesClient ;
3131 this .configurationService = configurationService ;
3232 }
3333
@@ -37,7 +37,7 @@ public void installShutdownHook() {
3737 }
3838
3939 public KubernetesClient getKubernetesClient () {
40- return k8sClient ;
40+ return kubernetesClient ;
4141 }
4242
4343 public ConfigurationService getConfigurationService () {
@@ -65,7 +65,7 @@ public void start() {
6565
6666 log .info ("Client version: {}" , Version .clientVersion ());
6767 try {
68- final var k8sVersion = k8sClient .getVersion ();
68+ final var k8sVersion = kubernetesClient .getVersion ();
6969 if (k8sVersion != null ) {
7070 log .info ("Server version: {}.{}" , k8sVersion .getMajor (), k8sVersion .getMinor ());
7171 }
@@ -93,7 +93,7 @@ public void close() {
9393 controllers .close ();
9494
9595 ExecutorServiceManager .close ();
96- k8sClient .close ();
96+ kubernetesClient .close ();
9797 }
9898
9999 /**
@@ -138,7 +138,7 @@ public <R extends CustomResource> void register(
138138 configuration = existing ;
139139 }
140140 final var configuredController =
141- new ConfiguredController (controller , configuration , k8sClient );
141+ new ConfiguredController (controller , configuration , kubernetesClient );
142142 controllers .add (configuredController );
143143
144144 final var watchedNS =
0 commit comments