|
1 | 1 | package io.javaoperatorsdk.operator.processing.dependent.kubernetes; |
2 | 2 |
|
3 | | -import io.fabric8.kubernetes.api.model.ConfigMap; |
4 | 3 | import io.fabric8.kubernetes.api.model.HasMetadata; |
5 | | -import io.fabric8.kubernetes.api.model.Secret; |
6 | | -import io.javaoperatorsdk.operator.ReconcilerUtils; |
7 | 4 | import io.javaoperatorsdk.operator.api.reconciler.Context; |
8 | 5 |
|
9 | 6 | public abstract class GenericResourceUpdatePreProcessor<R extends HasMetadata> implements |
10 | 7 | ResourceUpdatePreProcessor<R> { |
11 | 8 |
|
12 | 9 | private GenericResourceUpdatePreProcessor() {} |
13 | 10 |
|
14 | | - @SuppressWarnings("unchecked") |
15 | | - public static <R extends HasMetadata> ResourceUpdatePreProcessor<R> processorFor( |
16 | | - Class<R> resourceType) { |
17 | | - if (Secret.class.isAssignableFrom(resourceType)) { |
18 | | - return (ResourceUpdatePreProcessor<R>) new GenericResourceUpdatePreProcessor<Secret>() { |
19 | | - @Override |
20 | | - protected void updateClonedActual(Secret actual, Secret desired) { |
21 | | - actual.setData(desired.getData()); |
22 | | - actual.setStringData(desired.getStringData()); |
23 | | - } |
24 | | - }; |
25 | | - } else if (ConfigMap.class.isAssignableFrom(resourceType)) { |
26 | | - return (ResourceUpdatePreProcessor<R>) new GenericResourceUpdatePreProcessor<ConfigMap>() { |
27 | | - |
28 | | - @Override |
29 | | - protected void updateClonedActual(ConfigMap actual, ConfigMap desired) { |
30 | | - actual.setData(desired.getData()); |
31 | | - actual.setBinaryData((desired.getBinaryData())); |
32 | | - } |
33 | | - }; |
34 | | - } else { |
35 | | - return new GenericResourceUpdatePreProcessor<>() { |
36 | | - @Override |
37 | | - protected void updateClonedActual(R actual, R desired) { |
38 | | - var desiredSpec = ReconcilerUtils.getSpec(desired); |
39 | | - ReconcilerUtils.setSpec(actual, desiredSpec); |
40 | | - } |
41 | | - }; |
42 | | - } |
43 | | - } |
44 | | - |
45 | 11 | public R replaceSpecOnActual(R actual, R desired, Context<?> context) { |
46 | 12 | var clonedActual = context.getControllerConfiguration().getConfigurationService() |
47 | 13 | .getResourceCloner() |
|
0 commit comments