Skip to content

Commit 0bc95d5

Browse files
committed
improve: remove owner refernce check (#2838)
this was added to fabric8 client meanwhile Signed-off-by: Attila Mészáros <[email protected]>
1 parent 22e4af8 commit 0bc95d5

File tree

3 files changed

+0
-73
lines changed

3 files changed

+0
-73
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/ReconcilerUtils.java

Lines changed: 0 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -6,14 +6,11 @@
66
import java.lang.reflect.Method;
77
import java.util.Arrays;
88
import java.util.Locale;
9-
import java.util.Objects;
109
import java.util.function.Predicate;
1110
import java.util.regex.Pattern;
1211

1312
import io.fabric8.kubernetes.api.builder.Builder;
14-
import io.fabric8.kubernetes.api.model.GenericKubernetesResource;
1513
import io.fabric8.kubernetes.api.model.HasMetadata;
16-
import io.fabric8.kubernetes.api.model.Namespaced;
1714
import io.fabric8.kubernetes.client.CustomResource;
1815
import io.fabric8.kubernetes.client.KubernetesClientException;
1916
import io.fabric8.kubernetes.client.utils.Serialization;
@@ -75,36 +72,6 @@ public static String getNameFor(Class<? extends Reconciler> reconcilerClass) {
7572
return getDefaultNameFor(reconcilerClass);
7673
}
7774

78-
public static void checkIfCanAddOwnerReference(HasMetadata owner, HasMetadata resource) {
79-
if (owner instanceof GenericKubernetesResource
80-
|| resource instanceof GenericKubernetesResource) {
81-
return;
82-
}
83-
if (owner instanceof Namespaced) {
84-
if (!(resource instanceof Namespaced)) {
85-
throw new OperatorException(
86-
"Cannot add owner reference from a cluster scoped to a namespace scoped resource."
87-
+ resourcesIdentifierDescription(owner, resource));
88-
} else if (!Objects.equals(
89-
owner.getMetadata().getNamespace(), resource.getMetadata().getNamespace())) {
90-
throw new OperatorException(
91-
"Cannot add owner reference between two resource in different namespaces."
92-
+ resourcesIdentifierDescription(owner, resource));
93-
}
94-
}
95-
}
96-
97-
private static String resourcesIdentifierDescription(HasMetadata owner, HasMetadata resource) {
98-
return " Owner name: "
99-
+ owner.getMetadata().getName()
100-
+ " Kind: "
101-
+ owner.getKind()
102-
+ ", Resource name: "
103-
+ resource.getMetadata().getName()
104-
+ " Kind: "
105-
+ resource.getKind();
106-
}
107-
10875
public static String getNameFor(Reconciler reconciler) {
10976
return getNameFor(reconciler.getClass());
11077
}

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import io.fabric8.kubernetes.api.model.HasMetadata;
1212
import io.fabric8.kubernetes.api.model.Namespaced;
1313
import io.fabric8.kubernetes.client.dsl.Resource;
14-
import io.javaoperatorsdk.operator.ReconcilerUtils;
1514
import io.javaoperatorsdk.operator.api.config.dependent.Configured;
1615
import io.javaoperatorsdk.operator.api.config.informer.InformerEventSourceConfiguration;
1716
import io.javaoperatorsdk.operator.api.reconciler.Context;
@@ -208,7 +207,6 @@ protected Resource<R> prepare(Context<P> context, R desired, P primary, String a
208207

209208
protected void addReferenceHandlingMetadata(R desired, P primary) {
210209
if (addOwnerReference()) {
211-
ReconcilerUtils.checkIfCanAddOwnerReference(primary, desired);
212210
desired.addOwnerReference(primary);
213211
} else if (useNonOwnerRefBasedSecondaryToPrimaryMapping()) {
214212
addSecondaryToPrimaryMapperAnnotations(desired, primary);

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/ReconcilerUtilsTest.java

Lines changed: 0 additions & 38 deletions
Original file line numberDiff line numberDiff line change
@@ -178,44 +178,6 @@ void handleKubernetesExceptionShouldThrowMissingCRDExceptionWhenAppropriate() {
178178
HasMetadata.getFullResourceName(Tomcat.class)));
179179
}
180180

181-
@Test
182-
void checksIfOwnerReferenceCanBeAdded() {
183-
assertThrows(
184-
OperatorException.class,
185-
() ->
186-
ReconcilerUtils.checkIfCanAddOwnerReference(
187-
namespacedResource(), namespacedResourceFromOtherNamespace()));
188-
189-
assertThrows(
190-
OperatorException.class,
191-
() ->
192-
ReconcilerUtils.checkIfCanAddOwnerReference(
193-
namespacedResource(), clusterScopedResource()));
194-
195-
assertDoesNotThrow(
196-
() -> {
197-
ReconcilerUtils.checkIfCanAddOwnerReference(
198-
clusterScopedResource(), clusterScopedResource());
199-
ReconcilerUtils.checkIfCanAddOwnerReference(namespacedResource(), namespacedResource());
200-
});
201-
}
202-
203-
private ClusterRole clusterScopedResource() {
204-
return new ClusterRoleBuilder().withMetadata(new ObjectMetaBuilder().build()).build();
205-
}
206-
207-
private ConfigMap namespacedResource() {
208-
return new ConfigMapBuilder()
209-
.withMetadata(new ObjectMetaBuilder().withNamespace("testns1").build())
210-
.build();
211-
}
212-
213-
private ConfigMap namespacedResourceFromOtherNamespace() {
214-
return new ConfigMapBuilder()
215-
.withMetadata(new ObjectMetaBuilder().withNamespace("testns2").build())
216-
.build();
217-
}
218-
219181
@Group("tomcatoperator.io")
220182
@Version("v1")
221183
@ShortNames("tc")

0 commit comments

Comments
 (0)