Skip to content

Commit de5b95f

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

File tree

3 files changed

+0
-75
lines changed

3 files changed

+0
-75
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;
@@ -73,36 +70,6 @@ public static String getNameFor(Class<? extends Reconciler> reconcilerClass) {
7370
return getDefaultNameFor(reconcilerClass);
7471
}
7572

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

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;
@@ -206,7 +205,6 @@ protected Resource<R> prepare(Context<P> context, R desired, P primary, String a
206205

207206
protected void addReferenceHandlingMetadata(R desired, P primary) {
208207
if (addOwnerReference()) {
209-
ReconcilerUtils.checkIfCanAddOwnerReference(primary, desired);
210208
desired.addOwnerReference(primary);
211209
} else if (useNonOwnerRefBasedSecondaryToPrimaryMapping()) {
212210
addSecondaryToPrimaryMapperAnnotations(desired, primary);

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

Lines changed: 0 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,6 @@
88
import io.fabric8.kubernetes.api.model.apps.Deployment;
99
import io.fabric8.kubernetes.api.model.apps.DeploymentBuilder;
1010
import io.fabric8.kubernetes.api.model.apps.DeploymentSpec;
11-
import io.fabric8.kubernetes.api.model.rbac.ClusterRole;
12-
import io.fabric8.kubernetes.api.model.rbac.ClusterRoleBuilder;
1311
import io.fabric8.kubernetes.client.CustomResource;
1412
import io.fabric8.kubernetes.client.KubernetesClientException;
1513
import io.fabric8.kubernetes.client.http.HttpRequest;
@@ -154,44 +152,6 @@ void handleKubernetesExceptionShouldThrowMissingCRDExceptionWhenAppropriate() {
154152
HasMetadata.getFullResourceName(Tomcat.class)));
155153
}
156154

157-
@Test
158-
void checksIfOwnerReferenceCanBeAdded() {
159-
assertThrows(
160-
OperatorException.class,
161-
() ->
162-
ReconcilerUtils.checkIfCanAddOwnerReference(
163-
namespacedResource(), namespacedResourceFromOtherNamespace()));
164-
165-
assertThrows(
166-
OperatorException.class,
167-
() ->
168-
ReconcilerUtils.checkIfCanAddOwnerReference(
169-
namespacedResource(), clusterScopedResource()));
170-
171-
assertDoesNotThrow(
172-
() -> {
173-
ReconcilerUtils.checkIfCanAddOwnerReference(
174-
clusterScopedResource(), clusterScopedResource());
175-
ReconcilerUtils.checkIfCanAddOwnerReference(namespacedResource(), namespacedResource());
176-
});
177-
}
178-
179-
private ClusterRole clusterScopedResource() {
180-
return new ClusterRoleBuilder().withMetadata(new ObjectMetaBuilder().build()).build();
181-
}
182-
183-
private ConfigMap namespacedResource() {
184-
return new ConfigMapBuilder()
185-
.withMetadata(new ObjectMetaBuilder().withNamespace("testns1").build())
186-
.build();
187-
}
188-
189-
private ConfigMap namespacedResourceFromOtherNamespace() {
190-
return new ConfigMapBuilder()
191-
.withMetadata(new ObjectMetaBuilder().withNamespace("testns2").build())
192-
.build();
193-
}
194-
195155
@Group("tomcatoperator.io")
196156
@Version("v1")
197157
@ShortNames("tc")

0 commit comments

Comments
 (0)