Skip to content

Commit e8360c6

Browse files
committed
use full class name of the controller as name instead of simple name
1 parent 8d79068 commit e8360c6

File tree

9 files changed

+12
-17
lines changed

9 files changed

+12
-17
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/ResourceController.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ default String getName() {
5151
}
5252
}
5353

54-
// otherwise, use the lower-cased class name
55-
return clazz.getSimpleName().toLowerCase(Locale.ROOT);
54+
// otherwise, use the lower-cased full class name
55+
return clazz.getCanonicalName().toLowerCase(Locale.ROOT);
5656
}
5757
}

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

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,12 +9,9 @@
99

1010
public class DefaultConfigurationService implements ConfigurationService {
1111

12-
private static final ConfigurationService instance = new DefaultConfigurationService();
1312
private final Map<String, ControllerConfiguration> configurations = new ConcurrentHashMap<>();
1413

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

1916
@Override
2017
public <R extends CustomResource> ControllerConfiguration<R> getConfigurationFor(

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

Lines changed: 1 addition & 1 deletion
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

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,7 @@ public class DefaultConfigurationServiceTest {
2222
@Test
2323
public void returnsValuesFromControllerAnnotationFinalizer() {
2424
final var controller = new TestCustomResourceController();
25-
final var configuration =
26-
DefaultConfigurationService.instance().getConfigurationFor(controller);
25+
final var configuration = DefaultConfigurationService.INSTANCE.getConfigurationFor(controller);
2726
assertEquals(TestCustomResourceController.CRD_NAME, configuration.getCRDName());
2827
assertEquals(
2928
ControllerUtils.getDefaultFinalizerName(configuration.getCRDName()),
@@ -36,8 +35,7 @@ public void returnsValuesFromControllerAnnotationFinalizer() {
3635
@Test
3736
public void returnCustomerFinalizerNameIfSet() {
3837
final var controller = new TestCustomFinalizerController();
39-
final var configuration =
40-
DefaultConfigurationService.instance().getConfigurationFor(controller);
38+
final var configuration = DefaultConfigurationService.INSTANCE.getConfigurationFor(controller);
4139
assertEquals(CUSTOM_FINALIZER_NAME, configuration.getFinalizer());
4240
}
4341

@@ -46,7 +44,7 @@ public void supportsInnerClassCustomResources() {
4644
final var controller = new TestCustomFinalizerController();
4745
assertDoesNotThrow(
4846
() -> {
49-
DefaultConfigurationService.instance().getConfigurationFor(controller).getDoneableClass();
47+
DefaultConfigurationService.INSTANCE.getConfigurationFor(controller).getDoneableClass();
5048
});
5149
}
5250

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

Lines changed: 1 addition & 1 deletion
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);

samples/pure-java/src/main/java/io/javaoperatorsdk/operator/sample/PureJavaApplicationRunner.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ public class PureJavaApplicationRunner {
99

1010
public static void main(String[] args) {
1111
KubernetesClient client = new DefaultKubernetesClient();
12-
Operator operator = new Operator(client, DefaultConfigurationService.instance());
12+
Operator operator = new Operator(client, DefaultConfigurationService.INSTANCE);
1313
operator.registerController(new CustomServiceController(client));
1414
}
1515
}

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

Lines changed: 1 addition & 1 deletion
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

Lines changed: 1 addition & 1 deletion
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

Lines changed: 1 addition & 1 deletion
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)