1
1
package io .javaoperatorsdk .operator .processing ;
2
2
3
- import java .util .ArrayList ;
4
- import java .util .HashMap ;
5
- import java .util .List ;
6
- import java .util .Map ;
7
- import java .util .Optional ;
8
- import java .util .Set ;
3
+ import java .util .*;
9
4
10
5
import org .slf4j .Logger ;
11
6
import org .slf4j .LoggerFactory ;
25
20
import io .javaoperatorsdk .operator .api .config .ControllerConfiguration ;
26
21
import io .javaoperatorsdk .operator .api .monitoring .Metrics ;
27
22
import io .javaoperatorsdk .operator .api .monitoring .Metrics .ControllerExecution ;
28
- import io .javaoperatorsdk .operator .api .reconciler .Cleaner ;
29
- import io .javaoperatorsdk .operator .api .reconciler .Constants ;
30
- import io .javaoperatorsdk .operator .api .reconciler .Context ;
31
- import io .javaoperatorsdk .operator .api .reconciler .ContextInitializer ;
32
- import io .javaoperatorsdk .operator .api .reconciler .DeleteControl ;
33
- import io .javaoperatorsdk .operator .api .reconciler .EventSourceContext ;
34
- import io .javaoperatorsdk .operator .api .reconciler .EventSourceInitializer ;
35
- import io .javaoperatorsdk .operator .api .reconciler .Ignore ;
36
- import io .javaoperatorsdk .operator .api .reconciler .Reconciler ;
37
- import io .javaoperatorsdk .operator .api .reconciler .UpdateControl ;
23
+ import io .javaoperatorsdk .operator .api .reconciler .*;
38
24
import io .javaoperatorsdk .operator .api .reconciler .dependent .EventSourceNotFoundException ;
39
25
import io .javaoperatorsdk .operator .api .reconciler .dependent .EventSourceProvider ;
40
26
import io .javaoperatorsdk .operator .api .reconciler .dependent .EventSourceReferencer ;
@@ -56,6 +42,13 @@ public class Controller<P extends HasMetadata>
56
42
RegisteredController <P > {
57
43
58
44
private static final Logger log = LoggerFactory .getLogger (Controller .class );
45
+ private static final String CLEANUP = "cleanup" ;
46
+ private static final String DELETE = "delete" ;
47
+ private static final String FINALIZER_NOT_REMOVED = "finalizerNotRemoved" ;
48
+ private static final String RECONCILE = "reconcile" ;
49
+ private static final String RESOURCE = "resource" ;
50
+ private static final String STATUS = "status" ;
51
+ private static final String BOTH = "both" ;
59
52
60
53
private final Reconciler <P > reconciler ;
61
54
private final ControllerConfiguration <P > configuration ;
@@ -103,7 +96,7 @@ public UpdateControl<P> reconcile(P resource, Context<P> context) throws Excepti
103
96
new ControllerExecution <>() {
104
97
@ Override
105
98
public String name () {
106
- return "reconcile" ;
99
+ return RECONCILE ;
107
100
}
108
101
109
102
@ Override
@@ -113,12 +106,12 @@ public String controllerName() {
113
106
114
107
@ Override
115
108
public String successTypeName (UpdateControl <P > result ) {
116
- String successType = "resource" ;
109
+ String successType = RESOURCE ;
117
110
if (result .isUpdateStatus ()) {
118
- successType = "status" ;
111
+ successType = STATUS ;
119
112
}
120
113
if (result .isUpdateResourceAndStatus ()) {
121
- successType = "both" ;
114
+ successType = BOTH ;
122
115
}
123
116
return successType ;
124
117
}
@@ -154,7 +147,7 @@ public DeleteControl cleanup(P resource, Context<P> context) {
154
147
new ControllerExecution <>() {
155
148
@ Override
156
149
public String name () {
157
- return "cleanup" ;
150
+ return CLEANUP ;
158
151
}
159
152
160
153
@ Override
@@ -164,7 +157,7 @@ public String controllerName() {
164
157
165
158
@ Override
166
159
public String successTypeName (DeleteControl deleteControl ) {
167
- return deleteControl .isRemoveFinalizer () ? "delete" : "finalizerNotRemoved" ;
160
+ return deleteControl .isRemoveFinalizer () ? DELETE : FINALIZER_NOT_REMOVED ;
168
161
}
169
162
170
163
@ Override
0 commit comments