Skip to content

Commit 591c97f

Browse files
metacosmmetacosm
committed
chore: update after rebase
1 parent 1eb00e7 commit 591c97f

32 files changed

+118
-65
lines changed

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,9 @@
55

66
import io.fabric8.kubernetes.api.model.HasMetadata;
77
import io.javaoperatorsdk.operator.ReconcilerUtils;
8-
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceEventFilter;
98
import io.javaoperatorsdk.operator.api.reconciler.Constants;
109
import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
10+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceEventFilter;
1111

1212
public interface ControllerConfiguration<R extends HasMetadata> extends
1313
ResourceConfiguration<R, ControllerConfiguration<R>> {

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

+2-2
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@
66
import io.fabric8.kubernetes.api.model.HasMetadata;
77
import io.fabric8.kubernetes.client.CustomResource;
88
import io.javaoperatorsdk.operator.api.reconciler.Constants;
9-
import io.javaoperatorsdk.operator.processing.event.source.ResourceEventFilter;
10-
import io.javaoperatorsdk.operator.processing.event.source.ResourceEventFilters;
9+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceEventFilter;
10+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceEventFilters;
1111

1212
public interface ResourceConfiguration<R extends HasMetadata, T extends ResourceConfiguration<R, T>> {
1313

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/dependent/DependentResourceConfiguration.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44
import io.javaoperatorsdk.operator.api.config.ResourceConfiguration;
55
import io.javaoperatorsdk.operator.processing.event.source.AssociatedSecondaryIdentifier;
66
import io.javaoperatorsdk.operator.processing.event.source.AssociatedSecondaryRetriever;
7-
import io.javaoperatorsdk.operator.processing.event.source.Mappers;
87
import io.javaoperatorsdk.operator.processing.event.source.PrimaryResourcesRetriever;
8+
import io.javaoperatorsdk.operator.processing.event.source.informer.Mappers;
99

1010
import static io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResourceConfiguration.CREATABLE_DEFAULT;
1111
import static io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResourceConfiguration.OWNED_DEFAULT;

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/dependent/DependentResource.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44
import io.javaoperatorsdk.operator.api.config.dependent.DefaultDependentResourceConfiguration;
55
import io.javaoperatorsdk.operator.api.config.dependent.DependentResourceConfiguration;
66
import io.javaoperatorsdk.operator.processing.event.ResourceID;
7-
import io.javaoperatorsdk.operator.processing.event.source.ResourceCache;
87
import io.javaoperatorsdk.operator.processing.event.source.ResourceEventSource;
8+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
99

1010
public class DependentResource<R extends HasMetadata, P extends HasMetadata>
1111
implements Builder<R, P>, Updater<R, P> {

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/dependent/DependentResourceConfiguration.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,8 @@
77
import io.javaoperatorsdk.operator.processing.event.source.AssociatedSecondaryIdentifier;
88
import io.javaoperatorsdk.operator.processing.event.source.EventSourceRegistry;
99
import io.javaoperatorsdk.operator.processing.event.source.PrimaryResourcesRetriever;
10-
import io.javaoperatorsdk.operator.processing.event.source.ResourceCache;
11-
import io.javaoperatorsdk.operator.processing.event.source.ResourceEventFilter;
10+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
11+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceEventFilter;
1212

1313
import static io.javaoperatorsdk.operator.api.reconciler.Constants.EMPTY_STRING;
1414

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/dependent/Fetcher.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import io.fabric8.kubernetes.api.model.HasMetadata;
44
import io.javaoperatorsdk.operator.processing.event.ResourceID;
5-
import io.javaoperatorsdk.operator.processing.event.source.ResourceCache;
5+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
66

77
@FunctionalInterface
88
public interface Fetcher<R extends HasMetadata> {

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/Controller.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
import io.javaoperatorsdk.operator.processing.event.source.DependentResourceEventSource;
3434
import io.javaoperatorsdk.operator.processing.event.source.EventSourceRegistry;
3535
import io.javaoperatorsdk.operator.processing.event.source.EventSourceWrapper;
36-
import io.javaoperatorsdk.operator.processing.event.source.ResourceEventFilter;
36+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceEventFilter;
3737

3838
public class Controller<R extends HasMetadata> implements Reconciler<R>,
3939
LifecycleAware, EventSourceInitializer<R> {

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@
1616
import io.javaoperatorsdk.operator.processing.LifecycleAware;
1717
import io.javaoperatorsdk.operator.processing.event.source.EventSource;
1818
import io.javaoperatorsdk.operator.processing.event.source.EventSourceRegistry;
19-
import io.javaoperatorsdk.operator.processing.event.source.ResourceEventSource;
2019
import io.javaoperatorsdk.operator.processing.event.source.ResourceEventAware;
20+
import io.javaoperatorsdk.operator.processing.event.source.ResourceEventSource;
2121
import io.javaoperatorsdk.operator.processing.event.source.controller.ControllerResourceEventSource;
2222
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceAction;
2323
import io.javaoperatorsdk.operator.processing.event.source.timer.TimerEventSource;

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

+5-1
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,10 @@
1717
import io.javaoperatorsdk.operator.api.config.ResourceConfiguration;
1818
import io.javaoperatorsdk.operator.processing.LifecycleAware;
1919
import io.javaoperatorsdk.operator.processing.event.ResourceID;
20+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceAction;
21+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
22+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceEvent;
23+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceEventFilter;
2024

2125
import static io.javaoperatorsdk.operator.processing.KubernetesResourceUtils.getName;
2226
import static io.javaoperatorsdk.operator.processing.KubernetesResourceUtils.getUID;
@@ -61,7 +65,7 @@ protected abstract V wrapEventSource(
6165
FilterWatchListDeletable<T, KubernetesResourceList<T>> filteredBySelectorClient,
6266
Cloner cloner);
6367

64-
void eventReceived(ResourceAction action, T resource, T oldResource) {
68+
protected void eventReceived(ResourceAction action, T resource, T oldResource) {
6569
log.debug("Event received for resource: {}", getName(resource));
6670
if (filter.acceptChange(configuration, oldResource, resource)) {
6771
getEventHandler().handleEvent(new ResourceEvent(action, ResourceID.fromResource(resource)));

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

+2-1
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,9 @@
77

88
import io.fabric8.kubernetes.api.model.HasMetadata;
99
import io.javaoperatorsdk.operator.processing.event.ResourceID;
10+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
1011

11-
import static io.javaoperatorsdk.operator.processing.event.source.ControllerResourceEventSource.ANY_NAMESPACE_MAP_KEY;
12+
import static io.javaoperatorsdk.operator.processing.event.source.controller.ControllerResourceEventSource.ANY_NAMESPACE_MAP_KEY;
1213

1314
public class AggregateResourceCache<T extends HasMetadata, V extends EventSourceWrapper<T>>
1415
implements ResourceCache<T> {

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

+7-4
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
import org.slf4j.Logger;
88
import org.slf4j.LoggerFactory;
99

10+
import io.fabric8.kubernetes.api.model.HasMetadata;
1011
import io.javaoperatorsdk.operator.OperatorException;
1112
import io.javaoperatorsdk.operator.processing.event.Event;
1213
import io.javaoperatorsdk.operator.processing.event.ResourceID;
@@ -23,13 +24,15 @@
2324
*
2425
* @param <T> represents the type of resources (usually external non-kubernetes ones) being handled.
2526
*/
26-
public abstract class CachingEventSource<T> extends LifecycleAwareEventSource {
27+
public abstract class CachingEventSource<T, P extends HasMetadata>
28+
extends LifecycleAwareEventSource<P> {
2729

2830
private static final Logger log = LoggerFactory.getLogger(CachingEventSource.class);
2931

3032
protected Cache<ResourceID, T> cache;
3133

32-
public CachingEventSource(Cache<ResourceID, T> cache) {
34+
public CachingEventSource(Cache<ResourceID, T> cache, Class<P> resourceClass) {
35+
super(resourceClass);
3336
this.cache = cache;
3437
}
3538

@@ -41,7 +44,7 @@ protected void handleDelete(ResourceID relatedResourceID) {
4144
cache.remove(relatedResourceID);
4245
// we only propagate event if the resource was previously in cache
4346
if (cachedValue != null) {
44-
eventHandler.handleEvent(new Event(relatedResourceID));
47+
getEventHandler().handleEvent(new Event(relatedResourceID));
4548
}
4649
}
4750

@@ -52,7 +55,7 @@ protected void handleEvent(T value, ResourceID relatedResourceID) {
5255
var cachedValue = cache.get(relatedResourceID);
5356
if (cachedValue == null || !cachedValue.equals(value)) {
5457
cache.put(relatedResourceID, value);
55-
eventHandler.handleEvent(new Event(relatedResourceID));
58+
getEventHandler().handleEvent(new Event(relatedResourceID));
5659
}
5760
}
5861

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

+2
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,8 @@
1111
import io.javaoperatorsdk.operator.api.config.ResourceConfiguration;
1212
import io.javaoperatorsdk.operator.api.config.dependent.DependentResourceConfiguration;
1313
import io.javaoperatorsdk.operator.processing.event.ResourceID;
14+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
15+
import io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource;
1416

1517
public class DependentResourceEventSource<T extends HasMetadata, P extends HasMetadata>
1618
extends InformerEventSource<T, P>

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44

55
import io.fabric8.kubernetes.api.model.HasMetadata;
66
import io.javaoperatorsdk.operator.OperatorException;
7-
import io.javaoperatorsdk.operator.processing.event.source.controller.ControllerResourceEventSource;
87
import io.javaoperatorsdk.operator.processing.event.EventHandler;
8+
import io.javaoperatorsdk.operator.processing.event.source.controller.ControllerResourceEventSource;
99

1010
public interface EventSourceRegistry<T extends HasMetadata> {
1111

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

+1
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
import io.fabric8.kubernetes.api.model.HasMetadata;
44
import io.javaoperatorsdk.operator.processing.LifecycleAware;
5+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
56

67
public interface EventSourceWrapper<T extends HasMetadata>
78
extends LifecycleAware, ResourceCache<T> {

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

+1
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99
import io.fabric8.kubernetes.client.informers.cache.Cache;
1010
import io.javaoperatorsdk.operator.api.config.Cloner;
1111
import io.javaoperatorsdk.operator.processing.event.ResourceID;
12+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
1213

1314
public class InformerResourceCache<T extends HasMetadata> implements ResourceCache<T> {
1415

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

+7-1
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,17 @@
11
package io.javaoperatorsdk.operator.processing.event.source;
22

3+
import io.fabric8.kubernetes.api.model.HasMetadata;
34
import io.javaoperatorsdk.operator.OperatorException;
45

5-
public abstract class LifecycleAwareEventSource extends AbstractEventSource {
6+
public abstract class LifecycleAwareEventSource<P extends HasMetadata>
7+
extends AbstractEventSource<P> {
68

79
private volatile boolean running = false;
810

11+
protected LifecycleAwareEventSource(Class<P> resourceClass) {
12+
super(resourceClass);
13+
}
14+
915
public boolean isRunning() {
1016
return running;
1117
}

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

+1
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
import io.fabric8.kubernetes.api.model.HasMetadata;
44
import io.javaoperatorsdk.operator.api.config.ResourceConfiguration;
5+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
56

67
public interface ResourceEventSource<T extends HasMetadata, P extends HasMetadata>
78
extends EventSource<P> {

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

+2-1
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,8 @@
1010
import io.javaoperatorsdk.operator.processing.Controller;
1111
import io.javaoperatorsdk.operator.processing.MDCUtils;
1212
import io.javaoperatorsdk.operator.processing.event.ResourceID;
13-
import io.javaoperatorsdk.operator.processing.event.source.AbstractEventSource;
13+
import io.javaoperatorsdk.operator.processing.event.source.AbstractResourceEventSource;
14+
import io.javaoperatorsdk.operator.processing.event.source.EventSourceRegistry;
1415

1516
/**
1617
* This is a special case since is not bound to a single custom resource

‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/InformerEventSourceWrapper.java renamed to ‎operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/controller/InformerEventSourceWrapper.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package io.javaoperatorsdk.operator.processing.event.source;
1+
package io.javaoperatorsdk.operator.processing.event.source.controller;
22

33
import java.util.Optional;
44
import java.util.function.Predicate;
@@ -10,6 +10,8 @@
1010
import io.javaoperatorsdk.operator.OperatorException;
1111
import io.javaoperatorsdk.operator.api.config.Cloner;
1212
import io.javaoperatorsdk.operator.processing.event.ResourceID;
13+
import io.javaoperatorsdk.operator.processing.event.source.EventSourceWrapper;
14+
import io.javaoperatorsdk.operator.processing.event.source.InformerResourceCache;
1315

1416
class InformerEventSourceWrapper<T extends HasMetadata> implements EventSourceWrapper<T> {
1517

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

+4-3
Original file line numberDiff line numberDiff line change
@@ -2,13 +2,14 @@
22

33
import javax.cache.Cache;
44

5+
import io.fabric8.kubernetes.api.model.HasMetadata;
56
import io.javaoperatorsdk.operator.processing.event.ResourceID;
67
import io.javaoperatorsdk.operator.processing.event.source.CachingEventSource;
78

8-
public class CachingInboundEventSource<T> extends CachingEventSource<T> {
9+
public class CachingInboundEventSource<T, P extends HasMetadata> extends CachingEventSource<T, P> {
910

10-
public CachingInboundEventSource(Cache<ResourceID, T> cache) {
11-
super(cache);
11+
public CachingInboundEventSource(Cache<ResourceID, T> cache, Class<P> resourceClass) {
12+
super(cache, resourceClass);
1213
}
1314

1415
public void handleResourceEvent(T resource, ResourceID relatedResourceID) {

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

+7-2
Original file line numberDiff line numberDiff line change
@@ -3,17 +3,22 @@
33
import org.slf4j.Logger;
44
import org.slf4j.LoggerFactory;
55

6+
import io.fabric8.kubernetes.api.model.HasMetadata;
67
import io.javaoperatorsdk.operator.processing.event.Event;
78
import io.javaoperatorsdk.operator.processing.event.ResourceID;
89
import io.javaoperatorsdk.operator.processing.event.source.LifecycleAwareEventSource;
910

10-
public class SimpleInboundEventSource extends LifecycleAwareEventSource {
11+
public class SimpleInboundEventSource<P extends HasMetadata> extends LifecycleAwareEventSource<P> {
1112

1213
private static final Logger log = LoggerFactory.getLogger(SimpleInboundEventSource.class);
1314

15+
protected SimpleInboundEventSource(Class<P> resourceClass) {
16+
super(resourceClass);
17+
}
18+
1419
public void propagateEvent(ResourceID resourceID) {
1520
if (isRunning()) {
16-
eventHandler.handleEvent(new Event(resourceID));
21+
getEventHandler().handleEvent(new Event(resourceID));
1722
} else {
1823
log.debug("Event source not started yet, not propagating event for: {}", resourceID);
1924
}

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

+4
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,10 @@
1313
import io.javaoperatorsdk.operator.processing.event.Event;
1414
import io.javaoperatorsdk.operator.processing.event.ResourceID;
1515
import io.javaoperatorsdk.operator.processing.event.source.AbstractEventSource;
16+
import io.javaoperatorsdk.operator.processing.event.source.AssociatedSecondaryRetriever;
17+
import io.javaoperatorsdk.operator.processing.event.source.InformerResourceCache;
18+
import io.javaoperatorsdk.operator.processing.event.source.PrimaryResourcesRetriever;
19+
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceCache;
1620

1721
public class InformerEventSource<T extends HasMetadata, P extends HasMetadata>
1822
extends AbstractEventSource<P> {

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

+2
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,8 @@
55

66
import io.fabric8.kubernetes.api.model.HasMetadata;
77
import io.javaoperatorsdk.operator.processing.event.ResourceID;
8+
import io.javaoperatorsdk.operator.processing.event.source.AssociatedSecondaryIdentifier;
9+
import io.javaoperatorsdk.operator.processing.event.source.PrimaryResourcesRetriever;
810

911
public class Mappers {
1012

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

+6-5
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
* @param <R> related custom resource
3232
*/
3333
public class PerResourcePollingEventSource<T, R extends HasMetadata>
34-
extends CachingEventSource<T>
34+
extends CachingEventSource<T, R>
3535
implements ResourceEventAware<R> {
3636

3737
private static final Logger log = LoggerFactory.getLogger(PerResourcePollingEventSource.class);
@@ -44,14 +44,15 @@ public class PerResourcePollingEventSource<T, R extends HasMetadata>
4444
private final long period;
4545

4646
public PerResourcePollingEventSource(ResourceSupplier<T, R> resourceSupplier,
47-
ResourceCache<R> resourceCache, long period, Cache<ResourceID, T> cache) {
48-
this(resourceSupplier, resourceCache, period, cache, null);
47+
ResourceCache<R> resourceCache, long period, Cache<ResourceID, T> cache,
48+
Class<R> resourceClass) {
49+
this(resourceSupplier, resourceCache, period, cache, null, resourceClass);
4950
}
5051

5152
public PerResourcePollingEventSource(ResourceSupplier<T, R> resourceSupplier,
5253
ResourceCache<R> resourceCache, long period, Cache<ResourceID, T> cache,
53-
Predicate<R> registerPredicate) {
54-
super(cache);
54+
Predicate<R> registerPredicate, Class<R> resourceClass) {
55+
super(cache, resourceClass);
5556
this.resourceSupplier = resourceSupplier;
5657
this.resourceCache = resourceCache;
5758
this.period = period;

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

+4-3
Original file line numberDiff line numberDiff line change
@@ -9,11 +9,12 @@
99
import org.slf4j.Logger;
1010
import org.slf4j.LoggerFactory;
1111

12+
import io.fabric8.kubernetes.api.model.HasMetadata;
1213
import io.javaoperatorsdk.operator.OperatorException;
1314
import io.javaoperatorsdk.operator.processing.event.ResourceID;
1415
import io.javaoperatorsdk.operator.processing.event.source.CachingEventSource;
1516

16-
public class PollingEventSource<T> extends CachingEventSource<T> {
17+
public class PollingEventSource<T, P extends HasMetadata> extends CachingEventSource<T, P> {
1718

1819
private static final Logger log = LoggerFactory.getLogger(PollingEventSource.class);
1920

@@ -22,8 +23,8 @@ public class PollingEventSource<T> extends CachingEventSource<T> {
2223
private final long period;
2324

2425
public PollingEventSource(Supplier<Map<ResourceID, T>> supplier,
25-
long period, Cache<ResourceID, T> cache) {
26-
super(cache);
26+
long period, Cache<ResourceID, T> cache, Class<P> resourceClass) {
27+
super(cache, resourceClass);
2728
this.supplierToPoll = supplier;
2829
this.period = period;
2930
}

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212
import org.slf4j.LoggerFactory;
1313

1414
import io.fabric8.kubernetes.api.model.HasMetadata;
15-
import io.javaoperatorsdk.operator.processing.event.source.controller.ControllerResourceCache;
15+
import io.javaoperatorsdk.operator.processing.event.source.AggregateResourceCache;
1616
import io.javaoperatorsdk.operator.processing.event.source.controller.ControllerResourceEventSource;
1717
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceAction;
1818
import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceEvent;

0 commit comments

Comments
 (0)