Skip to content

Commit eafd8d8

Browse files
committed
fix: expose ResourceCache instead of InformerEventSource
1 parent 8f51cb3 commit eafd8d8

File tree

5 files changed

+11
-13
lines changed

5 files changed

+11
-13
lines changed

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,12 @@
11
package io.javaoperatorsdk.operator.api.config;
22

3+
import java.util.Collections;
4+
import java.util.List;
5+
36
import io.fabric8.kubernetes.api.model.HasMetadata;
47
import io.javaoperatorsdk.operator.ReconcilerUtils;
58
import io.javaoperatorsdk.operator.api.reconciler.DependentResource;
69
import io.javaoperatorsdk.operator.processing.event.source.ResourceEventFilter;
7-
import java.util.Collections;
8-
import java.util.List;
910

1011
public interface ControllerConfiguration<R extends HasMetadata> extends
1112
ResourceConfiguration<R, ControllerConfiguration<R>> {

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,16 @@
11
package io.javaoperatorsdk.operator.api.config;
22

3-
import static io.javaoperatorsdk.operator.api.reconciler.DependentResourceConfiguration.CREATABLE_DEFAULT;
4-
import static io.javaoperatorsdk.operator.api.reconciler.DependentResourceConfiguration.OWNED_DEFAULT;
5-
import static io.javaoperatorsdk.operator.api.reconciler.DependentResourceConfiguration.UPDATABLE_DEFAULT;
6-
73
import java.util.Set;
84
import java.util.function.Function;
95

106
import io.fabric8.kubernetes.api.model.HasMetadata;
117
import io.javaoperatorsdk.operator.processing.event.ResourceID;
128
import io.javaoperatorsdk.operator.processing.event.source.Mappers;
139

10+
import static io.javaoperatorsdk.operator.api.reconciler.DependentResourceConfiguration.CREATABLE_DEFAULT;
11+
import static io.javaoperatorsdk.operator.api.reconciler.DependentResourceConfiguration.OWNED_DEFAULT;
12+
import static io.javaoperatorsdk.operator.api.reconciler.DependentResourceConfiguration.UPDATABLE_DEFAULT;
13+
1414
public interface DependentResourceConfiguration<R extends HasMetadata>
1515
extends ResourceConfiguration<R, DependentResourceConfiguration<R>> {
1616

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

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

3-
import java.lang.reflect.ParameterizedType;
43
import java.util.Collections;
54
import java.util.Set;
65

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

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

33
import io.fabric8.kubernetes.api.model.HasMetadata;
44
import io.javaoperatorsdk.operator.api.config.DependentResourceConfiguration;
5-
import io.javaoperatorsdk.operator.processing.event.source.InformerEventSource;
5+
import io.javaoperatorsdk.operator.processing.event.ResourceID;
6+
import io.javaoperatorsdk.operator.processing.event.source.ResourceCache;
67

78
public interface DependentResource<R extends HasMetadata> {
89
default R build() {
910
throw new UnsupportedOperationException(
1011
"Should be implemented only if DependentResource is configured as creatable");
1112
}
1213

13-
InformerEventSource<R> source();
14+
ResourceCache<R> getCache();
1415

1516
default R fetchFor(HasMetadata owner) {
16-
return source().getAssociated(owner);
17+
return getCache().get(ResourceID.fromResource(owner)).orElse(null);
1718
}
1819

1920
DependentResourceConfiguration<R> getConfiguration();

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

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,5 @@
11
package io.javaoperatorsdk.operator.api.reconciler;
22

3-
import java.util.Collections;
4-
import java.util.List;
5-
63
import io.fabric8.kubernetes.api.model.HasMetadata;
74

85
public interface Reconciler<R extends HasMetadata> {

0 commit comments

Comments
 (0)