Skip to content

Commit 8ccee4d

Browse files
committed
revert instance reference
1 parent 080fbee commit 8ccee4d

File tree

8 files changed

+25
-16
lines changed

8 files changed

+25
-16
lines changed

operator-framework/src/main/java/io/javaoperatorsdk/operator/config/runtime/DefaultConfigurationService.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -9,9 +9,12 @@
99

1010
public class DefaultConfigurationService implements ConfigurationService {
1111

12+
private static final ConfigurationService instance = new DefaultConfigurationService();
1213
private final Map<String, ControllerConfiguration> configurations = new ConcurrentHashMap<>();
1314

14-
public static final ConfigurationService INSTANCE = new DefaultConfigurationService();
15+
public static ConfigurationService instance() {
16+
return instance;
17+
}
1518

1619
@Override
1720
public <R extends CustomResource> ControllerConfiguration<R> getConfigurationFor(

operator-framework/src/test/java/io/javaoperatorsdk/operator/IntegrationTestSupport.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public void initialize(
5454
CustomResourceDefinitionContext crdContext = CustomResourceDefinitionContext.fromCrd(crd);
5555
this.controller = controller;
5656

57-
final var configurationService = DefaultConfigurationService.INSTANCE;
57+
final var configurationService = DefaultConfigurationService.instance();
5858

5959
final var config = configurationService.getConfigurationFor(controller);
6060
Class doneableClass = config.getDoneableClass();

operator-framework/src/test/java/io/javaoperatorsdk/operator/config/runtime/DefaultConfigurationServiceTest.java

+5-3
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,8 @@ public class DefaultConfigurationServiceTest {
2222
@Test
2323
public void returnsValuesFromControllerAnnotationFinalizer() {
2424
final var controller = new TestCustomResourceController();
25-
final var configuration = DefaultConfigurationService.INSTANCE.getConfigurationFor(controller);
25+
final var configuration =
26+
DefaultConfigurationService.instance().getConfigurationFor(controller);
2627
assertEquals(TestCustomResourceController.CRD_NAME, configuration.getCRDName());
2728
assertEquals(
2829
ControllerUtils.getDefaultFinalizerName(configuration.getCRDName()),
@@ -35,7 +36,8 @@ public void returnsValuesFromControllerAnnotationFinalizer() {
3536
@Test
3637
public void returnCustomerFinalizerNameIfSet() {
3738
final var controller = new TestCustomFinalizerController();
38-
final var configuration = DefaultConfigurationService.INSTANCE.getConfigurationFor(controller);
39+
final var configuration =
40+
DefaultConfigurationService.instance().getConfigurationFor(controller);
3941
assertEquals(CUSTOM_FINALIZER_NAME, configuration.getFinalizer());
4042
}
4143

@@ -44,7 +46,7 @@ public void supportsInnerClassCustomResources() {
4446
final var controller = new TestCustomFinalizerController();
4547
assertDoesNotThrow(
4648
() -> {
47-
DefaultConfigurationService.INSTANCE.getConfigurationFor(controller).getDoneableClass();
49+
DefaultConfigurationService.instance().getConfigurationFor(controller).getDoneableClass();
4850
});
4951
}
5052

samples/mysql-schema/src/main/java/io/javaoperatorsdk/operator/sample/MySQLSchemaOperator.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ public static void main(String[] args) throws IOException {
2323

2424
Config config = new ConfigBuilder().withNamespace(null).build();
2525
KubernetesClient client = new DefaultKubernetesClient(config);
26-
Operator operator = new Operator(client, DefaultConfigurationService.INSTANCE);
26+
Operator operator = new Operator(client, DefaultConfigurationService.instance());
2727
operator.registerControllerForAllNamespaces(new SchemaController(client));
2828

2929
new FtBasic(new TkFork(new FkRegex("/health", "ALL GOOD!")), 8080).start(Exit.NEVER);
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,19 @@
11
package io.javaoperatorsdk.operator.sample;
22

3-
import io.fabric8.kubernetes.client.DefaultKubernetesClient;
4-
import io.fabric8.kubernetes.client.KubernetesClient;
5-
import io.javaoperatorsdk.operator.Operator;
6-
import io.javaoperatorsdk.operator.config.runtime.DefaultConfigurationService;
3+
import java.util.concurrent.atomic.LongAccumulator;
74

85
public class PureJavaApplicationRunner {
96

107
public static void main(String[] args) {
11-
KubernetesClient client = new DefaultKubernetesClient();
12-
Operator operator = new Operator(client, DefaultConfigurationService.INSTANCE);
13-
operator.registerController(new CustomServiceController(client));
8+
// KubernetesClient client = new DefaultKubernetesClient();
9+
// Operator operator = new Operator(client, DefaultConfigurationService.INSTANCE);
10+
// operator.registerController(new CustomServiceController(client));
11+
12+
final var acc = new LongAccumulator(Long::min, Integer.MAX_VALUE);
13+
acc.accumulate(10);
14+
acc.accumulate(20);
15+
acc.accumulate(90);
16+
17+
System.out.println(acc.get());
1418
}
1519
}

samples/spring-boot-plain/src/main/java/io/javaoperatorsdk/operator/sample/Config.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ public CustomServiceController customServiceController(KubernetesClient client)
2525
// Register all controller beans
2626
@Bean
2727
public Operator operator(KubernetesClient client, List<ResourceController> controllers) {
28-
Operator operator = new Operator(client, DefaultConfigurationService.INSTANCE);
28+
Operator operator = new Operator(client, DefaultConfigurationService.instance());
2929
controllers.forEach(c -> operator.registerControllerForAllNamespaces(c));
3030
return operator;
3131
}

samples/tomcat/src/main/java/io/javaoperatorsdk/operator/sample/TomcatOperator.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ public static void main(String[] args) throws IOException {
2222

2323
Config config = new ConfigBuilder().withNamespace(null).build();
2424
KubernetesClient client = new DefaultKubernetesClient(config);
25-
Operator operator = new Operator(client, DefaultConfigurationService.INSTANCE);
25+
Operator operator = new Operator(client, DefaultConfigurationService.instance());
2626

2727
TomcatController tomcatController = new TomcatController(client);
2828
operator.registerControllerForAllNamespaces(tomcatController);

samples/webserver/src/main/java/io/javaoperatorsdk/operator/sample/WebServerOperator.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ public static void main(String[] args) throws IOException {
2323

2424
Config config = new ConfigBuilder().withNamespace(null).build();
2525
KubernetesClient client = new DefaultKubernetesClient(config);
26-
Operator operator = new Operator(client, DefaultConfigurationService.INSTANCE);
26+
Operator operator = new Operator(client, DefaultConfigurationService.instance());
2727
operator.registerControllerForAllNamespaces(new WebServerController(client));
2828

2929
new FtBasic(new TkFork(new FkRegex("/health", "ALL GOOD!")), 8080).start(Exit.NEVER);

0 commit comments

Comments
 (0)