|
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