1
- package io .javaoperatorsdk .operator .baseapi .propagateallevent .onlyreconcile ;
1
+ package io .javaoperatorsdk .operator .baseapi .triggerallevent .onlyreconcile ;
2
2
3
3
import java .time .Duration ;
4
4
9
9
import io .javaoperatorsdk .operator .junit .LocallyRunOperatorExtension ;
10
10
import io .javaoperatorsdk .operator .processing .retry .GenericRetry ;
11
11
12
- import static io .javaoperatorsdk .operator .baseapi .propagateallevent .onlyreconcile .PropagateEventReconciler .ADDITIONAL_FINALIZER ;
13
- import static io .javaoperatorsdk .operator .baseapi .propagateallevent .onlyreconcile .PropagateEventReconciler .FINALIZER ;
14
- import static io .javaoperatorsdk .operator .baseapi .propagateallevent .onlyreconcile .PropagateEventReconciler .NO_MORE_EXCEPTION_ANNOTATION_KEY ;
12
+ import static io .javaoperatorsdk .operator .baseapi .triggerallevent .onlyreconcile .TriggerReconcilerOnAllEventReconciler .ADDITIONAL_FINALIZER ;
13
+ import static io .javaoperatorsdk .operator .baseapi .triggerallevent .onlyreconcile .TriggerReconcilerOnAllEventReconciler .FINALIZER ;
14
+ import static io .javaoperatorsdk .operator .baseapi .triggerallevent .onlyreconcile .TriggerReconcilerOnAllEventReconciler .NO_MORE_EXCEPTION_ANNOTATION_KEY ;
15
15
import static org .assertj .core .api .Assertions .assertThat ;
16
16
import static org .awaitility .Awaitility .await ;
17
17
18
- public class PropagateAllEventIT {
18
+ public class TriggerReconcilerOnAllEventIT {
19
19
20
20
public static final String TEST = "test1" ;
21
21
public static final int MAX_RETRY_ATTEMPTS = 2 ;
@@ -24,7 +24,7 @@ public class PropagateAllEventIT {
24
24
LocallyRunOperatorExtension extension =
25
25
LocallyRunOperatorExtension .builder ()
26
26
.withReconciler (
27
- new PropagateEventReconciler (),
27
+ new TriggerReconcilerOnAllEventReconciler (),
28
28
o ->
29
29
o .withRetry (
30
30
new GenericRetry ()
@@ -35,7 +35,7 @@ public class PropagateAllEventIT {
35
35
36
36
@ Test
37
37
void eventsPresent () {
38
- var reconciler = extension .getReconcilerOfType (PropagateEventReconciler .class );
38
+ var reconciler = extension .getReconcilerOfType (TriggerReconcilerOnAllEventReconciler .class );
39
39
extension .serverSideApply (testResource ());
40
40
await ()
41
41
.untilAsserted (
@@ -58,7 +58,7 @@ void eventsPresent() {
58
58
59
59
@ Test
60
60
void deleteEventPresentWithoutFinalizer () {
61
- var reconciler = extension .getReconcilerOfType (PropagateEventReconciler .class );
61
+ var reconciler = extension .getReconcilerOfType (TriggerReconcilerOnAllEventReconciler .class );
62
62
reconciler .setUseFinalizer (false );
63
63
extension .serverSideApply (testResource ());
64
64
@@ -77,7 +77,7 @@ void deleteEventPresentWithoutFinalizer() {
77
77
78
78
@ Test
79
79
void retriesExceptionOnDeleteEvent () {
80
- var reconciler = extension .getReconcilerOfType (PropagateEventReconciler .class );
80
+ var reconciler = extension .getReconcilerOfType (TriggerReconcilerOnAllEventReconciler .class );
81
81
reconciler .setUseFinalizer (false );
82
82
reconciler .setThrowExceptionOnFirstDeleteEvent (true );
83
83
@@ -98,7 +98,7 @@ void retriesExceptionOnDeleteEvent() {
98
98
99
99
@ Test
100
100
void additionalFinalizer () {
101
- var reconciler = extension .getReconcilerOfType (PropagateEventReconciler .class );
101
+ var reconciler = extension .getReconcilerOfType (TriggerReconcilerOnAllEventReconciler .class );
102
102
reconciler .setUseFinalizer (true );
103
103
var res = testResource ();
104
104
res .addFinalizer (ADDITIONAL_FINALIZER );
@@ -132,7 +132,7 @@ void additionalFinalizer() {
132
132
@ Test
133
133
void additionalEventDuringRetryOnDeleteEvent () {
134
134
135
- var reconciler = extension .getReconcilerOfType (PropagateEventReconciler .class );
135
+ var reconciler = extension .getReconcilerOfType (TriggerReconcilerOnAllEventReconciler .class );
136
136
reconciler .setThrowExceptionIfNoAnnotation (true );
137
137
reconciler .setWaitAfterFirstRetry (true );
138
138
var res = testResource ();
@@ -189,7 +189,7 @@ void additionalEventDuringRetryOnDeleteEvent() {
189
189
@ Test
190
190
void additionalEventAfterExhaustedRetry () {
191
191
192
- var reconciler = extension .getReconcilerOfType (PropagateEventReconciler .class );
192
+ var reconciler = extension .getReconcilerOfType (TriggerReconcilerOnAllEventReconciler .class );
193
193
reconciler .setThrowExceptionIfNoAnnotation (true );
194
194
var res = testResource ();
195
195
res .addFinalizer (ADDITIONAL_FINALIZER );
@@ -223,18 +223,18 @@ private void removeAdditionalFinalizerWaitForResourceDeletion() {
223
223
}
224
224
225
225
private void addNoMoreExceptionAnnotation () {
226
- PropagateAllEventCustomResource res ;
226
+ TriggerReconcilerOnAllEventCustomResource res ;
227
227
res = getResource ();
228
228
res .getMetadata ().getAnnotations ().put (NO_MORE_EXCEPTION_ANNOTATION_KEY , "true" );
229
229
extension .update (res );
230
230
}
231
231
232
- PropagateAllEventCustomResource getResource () {
233
- return extension .get (PropagateAllEventCustomResource .class , TEST );
232
+ TriggerReconcilerOnAllEventCustomResource getResource () {
233
+ return extension .get (TriggerReconcilerOnAllEventCustomResource .class , TEST );
234
234
}
235
235
236
- PropagateAllEventCustomResource testResource () {
237
- var res = new PropagateAllEventCustomResource ();
236
+ TriggerReconcilerOnAllEventCustomResource testResource () {
237
+ var res = new TriggerReconcilerOnAllEventCustomResource ();
238
238
res .setMetadata (new ObjectMetaBuilder ().withName (TEST ).build ());
239
239
return res ;
240
240
}
0 commit comments