1
1
package io .javaoperatorsdk .operator ;
2
2
3
+ import java .time .Duration ;
4
+
3
5
import org .junit .jupiter .api .Test ;
4
6
import org .junit .jupiter .api .extension .RegisterExtension ;
5
7
8
+ import io .fabric8 .kubernetes .api .model .ConfigMap ;
6
9
import io .fabric8 .kubernetes .api .model .ObjectMetaBuilder ;
7
10
import io .javaoperatorsdk .operator .junit .OperatorExtension ;
11
+ import io .javaoperatorsdk .operator .processing .event .source .informer .Mappers ;
8
12
import io .javaoperatorsdk .operator .sample .dependentannotationsecondarymapper .DependentAnnotationSecondaryMapperReconciler ;
9
13
import io .javaoperatorsdk .operator .sample .dependentannotationsecondarymapper .DependentAnnotationSecondaryMapperResource ;
10
14
@@ -27,9 +31,23 @@ void mapsSecondaryByAnnotation() {
27
31
var reconciler =
28
32
operator .getReconcilerOfType (DependentAnnotationSecondaryMapperReconciler .class );
29
33
30
- await ().untilAsserted (() -> {
34
+ await ().pollDelay ( Duration . ofMillis ( 150 )). untilAsserted (() -> {
31
35
assertThat (reconciler .getNumberOfExecutions ()).isEqualTo (1 );
32
36
});
37
+ var configMap = operator .get (ConfigMap .class , TEST_RESOURCE_NAME );
38
+
39
+ var annotations = configMap .getMetadata ().getAnnotations ();
40
+ assertThat (annotations .get (Mappers .DEFAULT_ANNOTATION_FOR_NAME )).isEqualTo (TEST_RESOURCE_NAME );
41
+ assertThat (annotations .get (Mappers .DEFAULT_ANNOTATION_FOR_NAMESPACE ))
42
+ .isEqualTo (operator .getNamespace ());
43
+ assertThat (configMap .getMetadata ().getOwnerReferences ()).isEmpty ();
44
+
45
+ configMap .getData ().put ("additional_data" , "data" );
46
+ operator .replace (ConfigMap .class , configMap );
47
+
48
+ await ().pollDelay (Duration .ofMillis (150 )).untilAsserted (() -> {
49
+ assertThat (reconciler .getNumberOfExecutions ()).isEqualTo (2 );
50
+ });
33
51
}
34
52
35
53
0 commit comments