Skip to content

Commit f47d4ed

Browse files
committed
improve: dependent resource matcher API and handling (#1881)
1 parent 95c2a9c commit f47d4ed

File tree

2 files changed

+4
-8
lines changed

2 files changed

+4
-8
lines changed

Diff for: operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/Updater.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,9 @@
22

33
import io.fabric8.kubernetes.api.model.HasMetadata;
44
import io.javaoperatorsdk.operator.api.reconciler.Context;
5-
import io.javaoperatorsdk.operator.processing.dependent.Matcher.Result;
65

7-
public interface Updater<R, P extends HasMetadata> {
6+
public interface Updater<R, P extends HasMetadata> extends Matcher<R, P> {
7+
88
R update(R actual, R desired, P primary, Context<P> context);
99

10-
Result<R> match(R actualResource, P primary, Context<P> context);
1110
}

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

+2-5
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import io.javaoperatorsdk.operator.api.reconciler.dependent.managed.DependentResourceConfigurator;
2323
import io.javaoperatorsdk.operator.api.reconciler.dependent.managed.KubernetesClientAware;
2424
import io.javaoperatorsdk.operator.processing.dependent.AbstractEventSourceHolderDependentResource;
25-
import io.javaoperatorsdk.operator.processing.dependent.Matcher;
2625
import io.javaoperatorsdk.operator.processing.dependent.Matcher.Result;
2726
import io.javaoperatorsdk.operator.processing.dependent.kubernetes.processors.GenericResourceUpdatePreProcessor;
2827
import io.javaoperatorsdk.operator.processing.event.ResourceID;
@@ -41,16 +40,13 @@ public abstract class KubernetesDependentResource<R extends HasMetadata, P exten
4140
private static final Logger log = LoggerFactory.getLogger(KubernetesDependentResource.class);
4241

4342
protected KubernetesClient client;
44-
private final Matcher<R, P> matcher;
4543
private final ResourceUpdatePreProcessor<R> processor;
4644
private final boolean garbageCollected = this instanceof GarbageCollected;
4745
private KubernetesDependentResourceConfig<R> kubernetesDependentResourceConfig;
4846

4947
@SuppressWarnings("unchecked")
5048
public KubernetesDependentResource(Class<R> resourceType) {
5149
super(resourceType);
52-
matcher = this instanceof Matcher ? (Matcher<R, P>) this
53-
: GenericKubernetesResourceMatcher.matcherFor(resourceType, this);
5450

5551
processor = this instanceof ResourceUpdatePreProcessor
5652
? (ResourceUpdatePreProcessor<R>) this
@@ -141,7 +137,8 @@ public R update(R actual, R target, P primary, Context<P> context) {
141137
}
142138

143139
public Result<R> match(R actualResource, P primary, Context<P> context) {
144-
return matcher.match(actualResource, primary, context);
140+
return GenericKubernetesResourceMatcher
141+
.match(this, actualResource, primary, context, false);
145142
}
146143

147144
@SuppressWarnings("unused")

0 commit comments

Comments
 (0)