Skip to content

Commit fb139e5

Browse files
metacosmmetacosm
committed
refactor: InformerConfiguration to InformerEventSourceConfiguration
Signed-off-by: Chris Laprun <claprun@redhat.com>
1 parent a4da0ca commit fb139e5

File tree

34 files changed

+129
-107
lines changed

34 files changed

+129
-107
lines changed

‎caffeine-bounded-cache-support/src/test/java/io/javaoperatorsdk/operator/processing/event/source/cache/sample/AbstractTestReconciler.java

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
import io.fabric8.kubernetes.client.CustomResource;
1515
import io.fabric8.kubernetes.client.KubernetesClient;
1616
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
17-
import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
17+
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
1818
import io.javaoperatorsdk.operator.api.reconciler.*;
1919
import io.javaoperatorsdk.operator.processing.event.source.EventSource;
2020
import io.javaoperatorsdk.operator.processing.event.source.cache.BoundedItemStore;
@@ -77,12 +77,14 @@ public List<EventSource<?, P>> prepareEventSources(
7777
boundedItemStore(new KubernetesClientBuilder().build(),
7878
ConfigMap.class, Duration.ofMinutes(1), 1); // setting max size for testing purposes
7979

80-
var es = new InformerEventSource<>(InformerConfiguration.from(ConfigMap.class, primaryClass())
81-
.withInformerConfiguration(c -> c.withItemStore(boundedItemStore))
82-
.withSecondaryToPrimaryMapper(
83-
Mappers.fromOwnerReferences(context.getPrimaryResourceClass(),
84-
this instanceof BoundedCacheClusterScopeTestReconciler))
85-
.build(), context);
80+
var es = new InformerEventSource<>(
81+
InformerEventSourceConfiguration.from(ConfigMap.class, primaryClass())
82+
.withInformerConfiguration(c -> c.withItemStore(boundedItemStore))
83+
.withSecondaryToPrimaryMapper(
84+
Mappers.fromOwnerReferences(context.getPrimaryResourceClass(),
85+
this instanceof BoundedCacheClusterScopeTestReconciler))
86+
.build(),
87+
context);
8688

8789
return List.of(es);
8890
}

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/informer/InformerConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
import io.javaoperatorsdk.operator.processing.event.source.filter.OnDeleteFilter;
1414
import io.javaoperatorsdk.operator.processing.event.source.filter.OnUpdateFilter;
1515

16-
import static io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration.DEFAULT_FOLLOW_CONTROLLER_NAMESPACES_ON_CHANGE;
16+
import static io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration.DEFAULT_FOLLOW_CONTROLLER_NAMESPACES_ON_CHANGE;
1717
import static io.javaoperatorsdk.operator.api.reconciler.Constants.NO_LONG_VALUE_SET;
1818
import static io.javaoperatorsdk.operator.api.reconciler.Constants.NO_VALUE_SET;
1919

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/informer/InformerConfigHolder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ public InformerConfigHolder<R> buildForController() {
116116
// if the informer config uses the default "same as controller" value, reset the namespaces to
117117
// the default set for controllers
118118
if (namespaces == null || namespaces.isEmpty()
119-
|| InformerConfiguration.inheritsNamespacesFromController(namespaces)) {
119+
|| InformerEventSourceConfiguration.inheritsNamespacesFromController(namespaces)) {
120120
namespaces = Constants.DEFAULT_NAMESPACES_SET;
121121
}
122122
return InformerConfigHolder.this;
@@ -128,7 +128,7 @@ public InformerConfigHolder<R> buildForInformerEventSource() {
128128
}
129129
if (followControllerNamespacesOnChange == null) {
130130
followControllerNamespacesOnChange =
131-
InformerConfiguration.DEFAULT_FOLLOW_CONTROLLER_NAMESPACES_ON_CHANGE;
131+
InformerEventSourceConfiguration.DEFAULT_FOLLOW_CONTROLLER_NAMESPACES_ON_CHANGE;
132132
}
133133
return InformerConfigHolder.this;
134134
}

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/informer/InformerConfiguration.java renamed to ‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/informer/InformerEventSourceConfiguration.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919

2020
import static io.javaoperatorsdk.operator.api.reconciler.Constants.SAME_AS_CONTROLLER_NAMESPACES_SET;
2121

22-
public interface InformerConfiguration<R extends HasMetadata>
22+
public interface InformerEventSourceConfiguration<R extends HasMetadata>
2323
extends ResourceConfiguration<R> {
2424

2525
boolean DEFAULT_FOLLOW_CONTROLLER_NAMESPACES_ON_CHANGE = true;
@@ -78,16 +78,16 @@ default String name() {
7878
@Override
7979
default Class<R> getResourceClass() {
8080
return (Class<R>) Utils.getFirstTypeArgumentFromSuperClassOrInterface(getClass(),
81-
InformerConfiguration.class);
81+
InformerEventSourceConfiguration.class);
8282
}
8383

84-
class DefaultInformerConfiguration<R extends HasMetadata> extends
85-
DefaultResourceConfiguration<R> implements InformerConfiguration<R> {
84+
class DefaultInformerEventSourceConfiguration<R extends HasMetadata> extends
85+
DefaultResourceConfiguration<R> implements InformerEventSourceConfiguration<R> {
8686
private final PrimaryToSecondaryMapper<?> primaryToSecondaryMapper;
8787
private final SecondaryToPrimaryMapper<R> secondaryToPrimaryMapper;
8888
private final GroupVersionKind groupVersionKind;
8989

90-
protected DefaultInformerConfiguration(
90+
protected DefaultInformerEventSourceConfiguration(
9191
Class<R> resourceClass,
9292
GroupVersionKind groupVersionKind,
9393
PrimaryToSecondaryMapper<?> primaryToSecondaryMapper,
@@ -121,7 +121,7 @@ public Optional<GroupVersionKind> getGroupVersionKind() {
121121
}
122122

123123
public boolean inheritsNamespacesFromController() {
124-
return InformerConfiguration.inheritsNamespacesFromController(getNamespaces());
124+
return InformerEventSourceConfiguration.inheritsNamespacesFromController(getNamespaces());
125125
}
126126

127127
@Override
@@ -216,14 +216,14 @@ public void updateFrom(InformerConfigHolder<R> informerConfig) {
216216
}
217217
}
218218

219-
public InformerConfiguration<R> build() {
219+
public InformerEventSourceConfiguration<R> build() {
220220
if (groupVersionKind != null
221221
&& !GenericKubernetesResource.class.isAssignableFrom(resourceClass)) {
222222
throw new IllegalStateException(
223223
"If GroupVersionKind is set the resource type must be GenericKubernetesDependentResource");
224224
}
225225

226-
return new DefaultInformerConfiguration<>(resourceClass,
226+
return new DefaultInformerEventSourceConfiguration<>(resourceClass,
227227
groupVersionKind,
228228
primaryToSecondaryMapper,
229229
Objects.requireNonNullElse(secondaryToPrimaryMapper,

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

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import io.fabric8.kubernetes.api.model.GenericKubernetesResource;
44
import io.fabric8.kubernetes.api.model.HasMetadata;
5-
import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
5+
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
66
import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
77
import io.javaoperatorsdk.operator.processing.GroupVersionKind;
88

@@ -16,9 +16,10 @@ public GenericKubernetesDependentResource(GroupVersionKind groupVersionKind) {
1616
this.groupVersionKind = groupVersionKind;
1717
}
1818

19-
protected InformerConfiguration.InformerConfigurationBuilder<GenericKubernetesResource> informerConfigurationBuilder(
19+
protected InformerEventSourceConfiguration.InformerConfigurationBuilder<GenericKubernetesResource> informerConfigurationBuilder(
2020
EventSourceContext<P> context) {
21-
return InformerConfiguration.from(groupVersionKind, context.getPrimaryResourceClass());
21+
return InformerEventSourceConfiguration.from(groupVersionKind,
22+
context.getPrimaryResourceClass());
2223
}
2324

2425
@SuppressWarnings("unused")

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
import io.fabric8.kubernetes.client.dsl.Resource;
1414
import io.javaoperatorsdk.operator.ReconcilerUtils;
1515
import io.javaoperatorsdk.operator.api.config.dependent.Configured;
16-
import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
16+
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
1717
import io.javaoperatorsdk.operator.api.reconciler.Context;
1818
import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
1919
import io.javaoperatorsdk.operator.api.reconciler.Ignore;
@@ -188,7 +188,7 @@ protected void addReferenceHandlingMetadata(R desired, P primary) {
188188

189189
@Override
190190
protected InformerEventSource<R, P> createEventSource(EventSourceContext<P> context) {
191-
final InformerConfiguration.InformerConfigurationBuilder<R> configBuilder =
191+
final InformerEventSourceConfiguration.InformerConfigurationBuilder<R> configBuilder =
192192
informerConfigurationBuilder(context)
193193
.withSecondaryToPrimaryMapper(getSecondaryToPrimaryMapper(context).orElseThrow())
194194
.withName(name());
@@ -207,9 +207,9 @@ protected InformerEventSource<R, P> createEventSource(EventSourceContext<P> cont
207207
/**
208208
* To handle {@link io.fabric8.kubernetes.api.model.GenericKubernetesResource} based dependents.
209209
*/
210-
protected InformerConfiguration.InformerConfigurationBuilder<R> informerConfigurationBuilder(
210+
protected InformerEventSourceConfiguration.InformerConfigurationBuilder<R> informerConfigurationBuilder(
211211
EventSourceContext<P> context) {
212-
return InformerConfiguration.from(resourceType(), context.getPrimaryResourceClass());
212+
return InformerEventSourceConfiguration.from(resourceType(), context.getPrimaryResourceClass());
213213
}
214214

215215
private boolean useNonOwnerRefBasedSecondaryToPrimaryMapping() {

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/PrimaryToSecondaryMapper.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import java.util.Set;
44

55
import io.fabric8.kubernetes.api.model.HasMetadata;
6+
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
67
import io.javaoperatorsdk.operator.processing.event.ResourceID;
78

89
/**
@@ -12,13 +13,12 @@
1213
* primary resources *without* a standard way (e.g. owner reference or annotations) to materialize
1314
* that relations. When owner references are present, a {@code PrimaryToSecondaryMapper} instance
1415
* should not be needed. In other words, associating such a mapper with your
15-
* {@link io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration} is usually needed
16-
* when your secondary resources are referenced in some way by your primary resource but that this
17-
* link does not exist in the secondary resource information. The mapper implementation instructs
18-
* the SDK on how to find all the secondary resources associated with a given primary resource so
19-
* that this primary resource can properly be reconciled when changes impact the associated
20-
* secondary resources, even though these don't contain any information allowing to make such an
21-
* inference.
16+
* {@link InformerEventSourceConfiguration} is usually needed when your secondary resources are
17+
* referenced in some way by your primary resource but that this link does not exist in the
18+
* secondary resource information. The mapper implementation instructs the SDK on how to find all
19+
* the secondary resources associated with a given primary resource so that this primary resource
20+
* can properly be reconciled when changes impact the associated secondary resources, even though
21+
* these don't contain any information allowing to make such an inference.
2222
* </p>
2323
* <p>
2424
* This helps particularly in cases where several secondary resources, listed in some way in the

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerEventSource.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
import io.fabric8.kubernetes.client.KubernetesClient;
1111
import io.fabric8.kubernetes.client.dsl.MixedOperation;
1212
import io.fabric8.kubernetes.client.informers.ResourceEventHandler;
13-
import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
13+
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
1414
import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
1515
import io.javaoperatorsdk.operator.processing.event.Event;
1616
import io.javaoperatorsdk.operator.processing.event.EventHandler;
@@ -64,7 +64,7 @@
6464
* @param <P> type of the primary resource
6565
*/
6666
public class InformerEventSource<R extends HasMetadata, P extends HasMetadata>
67-
extends ManagedInformerEventSource<R, P, InformerConfiguration<R>>
67+
extends ManagedInformerEventSource<R, P, InformerEventSourceConfiguration<R>>
6868
implements ResourceEventHandler<R> {
6969

7070
public static String PREVIOUS_ANNOTATION_KEY = "javaoperatorsdk.io/previous";
@@ -77,18 +77,18 @@ public class InformerEventSource<R extends HasMetadata, P extends HasMetadata>
7777
private final String id = UUID.randomUUID().toString();
7878

7979
public InformerEventSource(
80-
InformerConfiguration<R> configuration, EventSourceContext<P> context) {
80+
InformerEventSourceConfiguration<R> configuration, EventSourceContext<P> context) {
8181
this(configuration, context.getClient(),
8282
context.getControllerConfiguration().getConfigurationService()
8383
.parseResourceVersionsForEventFilteringAndCaching());
8484
}
8585

86-
InformerEventSource(InformerConfiguration<R> configuration, KubernetesClient client) {
86+
InformerEventSource(InformerEventSourceConfiguration<R> configuration, KubernetesClient client) {
8787
this(configuration, client, false);
8888
}
8989

9090
@SuppressWarnings({"unchecked", "rawtypes"})
91-
private InformerEventSource(InformerConfiguration<R> configuration,
91+
private InformerEventSource(InformerEventSourceConfiguration<R> configuration,
9292
KubernetesClient client,
9393
boolean parseResourceVersions) {
9494
super(configuration.name(),

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/TemporaryResourceCache.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
import org.slf4j.LoggerFactory;
1010

1111
import io.fabric8.kubernetes.api.model.HasMetadata;
12-
import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
12+
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
1313
import io.javaoperatorsdk.operator.processing.dependent.kubernetes.KubernetesDependentResource;
1414
import io.javaoperatorsdk.operator.processing.event.ResourceID;
1515

@@ -161,9 +161,9 @@ public synchronized boolean isKnownResourceVersion(T resource) {
161161
}
162162

163163
/**
164-
* @return true if {@link InformerConfiguration#parseResourceVersions()} is enabled and the
165-
* resourceVersion of newResource is numerically greater than cachedResource, otherwise
166-
* false
164+
* @return true if {@link InformerEventSourceConfiguration#parseResourceVersions()} is enabled and
165+
* the resourceVersion of newResource is numerically greater than cachedResource,
166+
* otherwise false
167167
*/
168168
private boolean isLaterResourceVersion(ResourceID resourceId, T newResource, T cachedResource) {
169169
try {

‎operator-framework-core/src/test/java/io/javaoperatorsdk/operator/api/config/ControllerConfigurationOverriderTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
import io.javaoperatorsdk.operator.processing.dependent.kubernetes.KubernetesDependentResourceConfigBuilder;
3131
import io.javaoperatorsdk.operator.processing.dependent.workflow.Condition;
3232

33-
import static io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration.inheritsNamespacesFromController;
33+
import static io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration.inheritsNamespacesFromController;
3434
import static org.junit.jupiter.api.Assertions.*;
3535

3636
class ControllerConfigurationOverriderTest {

‎operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/EventSourceManagerTest.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
import io.javaoperatorsdk.operator.OperatorException;
1111
import io.javaoperatorsdk.operator.api.config.BaseConfigurationService;
1212
import io.javaoperatorsdk.operator.api.config.MockControllerConfiguration;
13-
import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
13+
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
1414
import io.javaoperatorsdk.operator.api.reconciler.Reconciler;
1515
import io.javaoperatorsdk.operator.processing.Controller;
1616
import io.javaoperatorsdk.operator.processing.event.source.AbstractEventSource;
@@ -168,7 +168,8 @@ void changesNamespacesOnControllerAndInformerEventSources() {
168168
when(controllerResourceEventSourceMock.allowsNamespaceChanges()).thenCallRealMethod();
169169
var manager = new EventSourceManager(controller, eventSources);
170170

171-
InformerConfiguration informerConfigurationMock = mock(InformerConfiguration.class);
171+
InformerEventSourceConfiguration informerConfigurationMock =
172+
mock(InformerEventSourceConfiguration.class);
172173
when(informerConfigurationMock.followControllerNamespaceChanges()).thenReturn(true);
173174
InformerEventSource informerEventSource = mock(InformerEventSource.class);
174175
when(informerEventSource.name()).thenReturn("ies");

‎operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerEventSourceTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
import io.javaoperatorsdk.operator.api.config.ConfigurationService;
1717
import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
1818
import io.javaoperatorsdk.operator.api.config.InformerStoppedHandler;
19-
import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
19+
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
2020
import io.javaoperatorsdk.operator.processing.event.EventHandler;
2121
import io.javaoperatorsdk.operator.processing.event.ResourceID;
2222
import io.javaoperatorsdk.operator.processing.event.source.SecondaryToPrimaryMapper;
@@ -44,8 +44,8 @@ class InformerEventSourceTest {
4444
private final TemporaryResourceCache<Deployment> temporaryResourceCacheMock =
4545
mock(TemporaryResourceCache.class);
4646
private final EventHandler eventHandlerMock = mock(EventHandler.class);
47-
private final InformerConfiguration<Deployment> informerConfiguration =
48-
mock(InformerConfiguration.class);
47+
private final InformerEventSourceConfiguration<Deployment> informerConfiguration =
48+
mock(InformerEventSourceConfiguration.class);
4949

5050
@BeforeEach
5151
void setup() {

‎operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/changenamespace/ChangeNamespaceTestReconciler.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
import io.fabric8.kubernetes.api.model.ConfigMap;
88
import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
9-
import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
9+
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
1010
import io.javaoperatorsdk.operator.api.reconciler.*;
1111
import io.javaoperatorsdk.operator.processing.event.ResourceID;
1212
import io.javaoperatorsdk.operator.processing.event.source.EventSource;
@@ -25,7 +25,8 @@ public List<EventSource<?, ChangeNamespaceTestCustomResource>> prepareEventSourc
2525

2626
InformerEventSource<ConfigMap, ChangeNamespaceTestCustomResource> configMapES =
2727
new InformerEventSource<>(
28-
InformerConfiguration.from(ConfigMap.class, ChangeNamespaceTestCustomResource.class)
28+
InformerEventSourceConfiguration
29+
.from(ConfigMap.class, ChangeNamespaceTestCustomResource.class)
2930
.build(),
3031
context);
3132

‎operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/clusterscopedresource/ClusterScopedCustomResourceReconciler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import io.fabric8.kubernetes.api.model.ConfigMap;
77
import io.fabric8.kubernetes.api.model.ConfigMapBuilder;
88
import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
9-
import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
9+
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
1010
import io.javaoperatorsdk.operator.api.reconciler.Context;
1111
import io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration;
1212
import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
@@ -60,7 +60,7 @@ private ConfigMap desired(ClusterScopedCustomResource resource) {
6060
public List<EventSource<?, ClusterScopedCustomResource>> prepareEventSources(
6161
EventSourceContext<ClusterScopedCustomResource> context) {
6262
var ies = new InformerEventSource<>(
63-
InformerConfiguration.from(ConfigMap.class, ClusterScopedCustomResource.class)
63+
InformerEventSourceConfiguration.from(ConfigMap.class, ClusterScopedCustomResource.class)
6464
.withSecondaryToPrimaryMapper(
6565
Mappers.fromOwnerReferences(context.getPrimaryResourceClass(), true))
6666
.withInformerConfiguration(

‎operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/createupdateeventfilter/CreateUpdateEventFilterTestReconciler.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77

88
import io.fabric8.kubernetes.api.model.ConfigMap;
99
import io.fabric8.kubernetes.api.model.ObjectMeta;
10-
import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
10+
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
1111
import io.javaoperatorsdk.operator.api.reconciler.Context;
1212
import io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration;
1313
import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
@@ -69,8 +69,9 @@ private ConfigMap createConfigMap(CreateUpdateEventFilterTestCustomResource reso
6969
@Override
7070
public List<EventSource<?, CreateUpdateEventFilterTestCustomResource>> prepareEventSources(
7171
EventSourceContext<CreateUpdateEventFilterTestCustomResource> context) {
72-
InformerConfiguration<ConfigMap> informerConfiguration =
73-
InformerConfiguration.from(ConfigMap.class, CreateUpdateEventFilterTestCustomResource.class)
72+
InformerEventSourceConfiguration<ConfigMap> informerConfiguration =
73+
InformerEventSourceConfiguration
74+
.from(ConfigMap.class, CreateUpdateEventFilterTestCustomResource.class)
7475
.withInformerConfiguration(c -> c
7576
.withLabelSelector("integrationtest = " + this.getClass().getSimpleName()))
7677
.build();

0 commit comments

Comments
 (0)