Skip to content

Commit 567383f

Browse files
committed
feat: automatically derive the the dependent resource type if not specified
Signed-off-by: xstefank <xstefank122@gmail.com>
1 parent 4225645 commit 567383f

14 files changed

Lines changed: 24 additions & 33 deletions

File tree

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/AbstractEventSourceHolderDependentResource.java

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package io.javaoperatorsdk.operator.processing.dependent;
22

3+
import java.lang.reflect.ParameterizedType;
34
import java.util.Optional;
45

56
import io.fabric8.kubernetes.api.model.HasMetadata;
@@ -23,13 +24,25 @@ public abstract class AbstractEventSourceHolderDependentResource<
2324
private boolean isCacheFillerEventSource;
2425
protected String eventSourceNameToUse;
2526

27+
@SuppressWarnings("unchecked")
28+
protected AbstractEventSourceHolderDependentResource() {
29+
this(null, null);
30+
}
31+
2632
protected AbstractEventSourceHolderDependentResource(Class<R> resourceType) {
2733
this(resourceType, null);
2834
}
2935

36+
@SuppressWarnings("unchecked")
3037
protected AbstractEventSourceHolderDependentResource(Class<R> resourceType, String name) {
3138
super(name);
32-
this.resourceType = resourceType;
39+
if (resourceType == null) {
40+
this.resourceType =
41+
(Class<R>)
42+
((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0];
43+
} else {
44+
this.resourceType = resourceType;
45+
}
3346
}
3447

3548
/**

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/AbstractExternalDependentResource.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,8 @@ public abstract class AbstractExternalDependentResource<
2121

2222
private InformerEventSource<?, P> externalStateEventSource;
2323

24+
protected AbstractExternalDependentResource() {}
25+
2426
@SuppressWarnings("unchecked")
2527
protected AbstractExternalDependentResource(Class<R> resourceType) {
2628
super(resourceType);

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/external/AbstractPollingDependentResource.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,8 @@ public abstract class AbstractPollingDependentResource<R, P extends HasMetadata>
1616
public static final Duration DEFAULT_POLLING_PERIOD = Duration.ofMillis(5000);
1717
private Duration pollingPeriod;
1818

19+
protected AbstractPollingDependentResource() {}
20+
1921
protected AbstractPollingDependentResource(Class<R> resourceType) {
2022
this(resourceType, DEFAULT_POLLING_PERIOD);
2123
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/external/PerResourcePollingDependentResource.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,8 @@ public abstract class PerResourcePollingDependentResource<R, P extends HasMetada
1414
extends AbstractPollingDependentResource<R, P>
1515
implements PerResourcePollingEventSource.ResourceFetcher<R, P> {
1616

17+
public PerResourcePollingDependentResource() {}
18+
1719
public PerResourcePollingDependentResource(Class<R> resourceType) {
1820
super(resourceType);
1921
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/kubernetes/CRUDKubernetesDependentResource.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,8 @@ public abstract class CRUDKubernetesDependentResource<R extends HasMetadata, P e
1818
extends KubernetesDependentResource<R, P>
1919
implements Creator<R, P>, Updater<R, P>, GarbageCollected<P> {
2020

21+
public CRUDKubernetesDependentResource() {}
22+
2123
public CRUDKubernetesDependentResource(Class<R> resourceType) {
2224
super(resourceType);
2325
}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/kubernetes/KubernetesDependentResource.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,8 @@ public abstract class KubernetesDependentResource<R extends HasMetadata, P exten
4141
private KubernetesDependentResourceConfig<R> kubernetesDependentResourceConfig;
4242
private volatile Boolean useSSA;
4343

44+
public KubernetesDependentResource() {}
45+
4446
public KubernetesDependentResource(Class<R> resourceType) {
4547
this(resourceType, null);
4648
}

sample-operators/mysql-schema/src/main/java/io/javaoperatorsdk/operator/sample/dependent/SchemaDependentResource.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -54,10 +54,6 @@ public class SchemaDependentResource
5454

5555
private MySQLDbConfig dbConfig;
5656

57-
public SchemaDependentResource() {
58-
super(Schema.class);
59-
}
60-
6157
@Override
6258
public Optional<ResourcePollerConfig> configuration() {
6359
return Optional.of(new ResourcePollerConfig(getPollingPeriod(), dbConfig));

sample-operators/mysql-schema/src/main/java/io/javaoperatorsdk/operator/sample/dependent/SecretDependentResource.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,10 +27,6 @@ public class SecretDependentResource extends KubernetesDependentResource<Secret,
2727
public static final String MYSQL_SECRET_USERNAME = "mysql.secret.user.name";
2828
public static final String MYSQL_SECRET_PASSWORD = "mysql.secret.user.password";
2929

30-
public SecretDependentResource() {
31-
super(Secret.class);
32-
}
33-
3430
private static String encode(String value) {
3531
return Base64.getEncoder().encodeToString(value.getBytes());
3632
}

sample-operators/tomcat-operator/src/main/java/io/javaoperatorsdk/operator/sample/DeploymentDependentResource.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,6 @@
1414
public class DeploymentDependentResource
1515
extends CRUDKubernetesDependentResource<Deployment, Tomcat> {
1616

17-
public DeploymentDependentResource() {
18-
super(Deployment.class);
19-
}
20-
2117
private static String tomcatImage(Tomcat tomcat) {
2218
return "tomcat:" + tomcat.getSpec().getVersion();
2319
}

sample-operators/tomcat-operator/src/main/java/io/javaoperatorsdk/operator/sample/ServiceDependentResource.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -13,10 +13,6 @@
1313
informer = @Informer(labelSelector = "app.kubernetes.io/managed-by=tomcat-operator"))
1414
public class ServiceDependentResource extends CRUDKubernetesDependentResource<Service, Tomcat> {
1515

16-
public ServiceDependentResource() {
17-
super(Service.class);
18-
}
19-
2016
@Override
2117
protected Service desired(Tomcat tomcat, Context<Tomcat> context) {
2218
final ObjectMeta tomcatMetadata = tomcat.getMetadata();

0 commit comments

Comments
 (0)