|
1 | 1 | package io.javaoperatorsdk.operator.processing.dependent.kubernetes; |
2 | 2 |
|
| 3 | +import java.util.HashMap; |
| 4 | +import java.util.Optional; |
| 5 | +import java.util.Set; |
| 6 | + |
| 7 | +import org.slf4j.Logger; |
| 8 | +import org.slf4j.LoggerFactory; |
| 9 | + |
3 | 10 | import io.fabric8.kubernetes.api.model.HasMetadata; |
4 | 11 | import io.fabric8.kubernetes.api.model.Namespaced; |
5 | 12 | import io.fabric8.kubernetes.client.KubernetesClient; |
|
21 | 28 | import io.javaoperatorsdk.operator.processing.event.source.SecondaryToPrimaryMapper; |
22 | 29 | import io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource; |
23 | 30 | import io.javaoperatorsdk.operator.processing.event.source.informer.Mappers; |
24 | | -import org.slf4j.Logger; |
25 | | -import org.slf4j.LoggerFactory; |
26 | | - |
27 | | -import java.util.HashMap; |
28 | | -import java.util.Optional; |
29 | | -import java.util.Set; |
30 | 31 |
|
31 | 32 | @Ignore |
32 | 33 | @Configured(by = KubernetesDependent.class, with = KubernetesDependentResourceConfig.class, |
@@ -163,11 +164,13 @@ protected Resource<R> prepare(R desired, P primary, String actionName) { |
163 | 164 | actionName, |
164 | 165 | desired.getClass(), |
165 | 166 | ResourceID.fromResource(desired)); |
| 167 | + |
166 | 168 | if (addOwnerReference()) { |
167 | 169 | desired.addOwnerReference(primary); |
168 | 170 | } else if (useDefaultAnnotationsToIdentifyPrimary()) { |
169 | 171 | addDefaultSecondaryToPrimaryMapperAnnotations(desired, primary); |
170 | 172 | } |
| 173 | + |
171 | 174 | if (desired instanceof Namespaced) { |
172 | 175 | return client.resource(desired).inNamespace(desired.getMetadata().getNamespace()); |
173 | 176 | } else { |
|
0 commit comments