Skip to content

Commit f5906cf

Browse files
committed
handling informer for GenericKubernetesDependentResource
Signed-off-by: Attila Mészáros <csviri@gmail.com>
1 parent 0d198cc commit f5906cf

File tree

2 files changed

+7
-13
lines changed

2 files changed

+7
-13
lines changed

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

Lines changed: 2 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -3,9 +3,7 @@
33
import io.fabric8.kubernetes.api.model.GenericKubernetesResource;
44
import io.fabric8.kubernetes.api.model.HasMetadata;
55
import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
6-
import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
76
import io.javaoperatorsdk.operator.processing.GroupVersionKind;
8-
import io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource;
97

108
public class GenericKubernetesDependentResource<P extends HasMetadata>
119
extends KubernetesDependentResource<GenericKubernetesResource, P> {
@@ -17,16 +15,8 @@ public GenericKubernetesDependentResource(GroupVersionKind groupVersionKind) {
1715
this.groupVersionKind = groupVersionKind;
1816
}
1917

20-
// todo super functionality filters etc
21-
@Override
22-
protected InformerEventSource<GenericKubernetesResource, P> createEventSource(
23-
EventSourceContext<P> context) {
24-
var es = new InformerEventSource<>(
25-
InformerConfiguration.<GenericKubernetesResource>from(groupVersionKind, context)
26-
.build(),
27-
context);
28-
29-
return es;
18+
protected InformerConfiguration.InformerConfigurationBuilder<GenericKubernetesResource> informerConfigurationBuilder() {
19+
return InformerConfiguration.from(groupVersionKind);
3020
}
3121

3222
public GroupVersionKind getGroupVersionKind() {

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

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ private void configureWith(String labelSelector, Set<String> namespaces,
6767
namespaces = context.getControllerConfiguration().getNamespaces();
6868
}
6969

70-
var ic = InformerConfiguration.from(resourceType())
70+
var ic = informerConfigurationBuilder()
7171
.withLabelSelector(labelSelector)
7272
.withSecondaryToPrimaryMapper(getSecondaryToPrimaryMapper())
7373
.withNamespaces(namespaces, inheritNamespacesOnChange)
@@ -76,6 +76,10 @@ private void configureWith(String labelSelector, Set<String> namespaces,
7676
configureWith(new InformerEventSource<>(ic, context));
7777
}
7878

79+
protected InformerConfiguration.InformerConfigurationBuilder<R> informerConfigurationBuilder() {
80+
return InformerConfiguration.from(resourceType());
81+
}
82+
7983
@SuppressWarnings("unchecked")
8084
private SecondaryToPrimaryMapper<R> getSecondaryToPrimaryMapper() {
8185
if (this instanceof SecondaryToPrimaryMapper) {

0 commit comments

Comments
 (0)