File tree 3 files changed +1
-25
lines changed
operator-framework-core/src
main/java/io/javaoperatorsdk/operator
test/java/io/javaoperatorsdk/operator
operator-framework-junit5/src/main/java/io/javaoperatorsdk/operator/junit
3 files changed +1
-25
lines changed Original file line number Diff line number Diff line change 1
1
package io .javaoperatorsdk .operator ;
2
2
3
- import java .util .ArrayList ;
4
3
import java .util .HashMap ;
5
- import java .util .List ;
6
4
import java .util .Map ;
7
5
import java .util .function .Consumer ;
8
6
@@ -75,10 +73,6 @@ public KubernetesClient getKubernetesClient() {
75
73
return kubernetesClient ;
76
74
}
77
75
78
- public List <Controller > getControllers () {
79
- return new ArrayList <>(controllers .controllers .values ());
80
- }
81
-
82
76
/**
83
77
* Finishes the operator startup process. This is mostly used in injection-aware applications
84
78
* where there is no obvious entrypoint to the application which can trigger the injection process
Original file line number Diff line number Diff line change 10
10
import io .fabric8 .kubernetes .client .KubernetesClient ;
11
11
import io .javaoperatorsdk .operator .api .config .AbstractConfigurationService ;
12
12
import io .javaoperatorsdk .operator .api .config .ConfigurationServiceProvider ;
13
- import io .javaoperatorsdk .operator .api .config .MockControllerConfiguration ;
14
13
import io .javaoperatorsdk .operator .api .reconciler .Context ;
15
14
import io .javaoperatorsdk .operator .api .reconciler .Reconciler ;
16
15
import io .javaoperatorsdk .operator .api .reconciler .UpdateControl ;
17
16
18
- import static org .assertj .core .api .AssertionsForClassTypes .assertThat ;
19
-
20
17
@ SuppressWarnings ("rawtypes" )
21
18
class OperatorTest {
22
19
@@ -30,20 +27,6 @@ static void setUpConfigurationServiceProvider() {
30
27
ConfigurationServiceProvider .reset ();
31
28
}
32
29
33
- @ Test
34
- @ DisplayName ("should register `Reconciler` to Controller" )
35
- public void shouldRegisterReconcilerToController () {
36
- // given
37
- final var configuration = MockControllerConfiguration .forResource (ConfigMap .class );
38
-
39
- // when
40
- operator .register (fooReconciler , configuration );
41
-
42
- // then
43
- assertThat (operator .getControllers ().size ()).isEqualTo (1 );
44
- assertThat (operator .getControllers ().get (0 ).getReconciler ()).isEqualTo (fooReconciler );
45
- }
46
-
47
30
@ Test
48
31
@ DisplayName ("should throw `OperationException` when Configuration is null" )
49
32
public void shouldThrowOperatorExceptionWhenConfigurationIsNull () {
Original file line number Diff line number Diff line change 18
18
import io .javaoperatorsdk .operator .api .config .ConfigurationService ;
19
19
import io .javaoperatorsdk .operator .api .config .ControllerConfigurationOverrider ;
20
20
import io .javaoperatorsdk .operator .api .reconciler .Reconciler ;
21
- import io .javaoperatorsdk .operator .processing .Controller ;
22
21
import io .javaoperatorsdk .operator .processing .retry .Retry ;
23
22
24
23
import static io .javaoperatorsdk .operator .api .config .ControllerConfigurationOverrider .override ;
@@ -65,7 +64,7 @@ public static Builder builder() {
65
64
}
66
65
67
66
private Stream <Reconciler > reconcilers () {
68
- return operator . getControllers (). stream ().map (Controller :: getReconciler );
67
+ return reconcilers . stream ().map (reconcilerSpec -> reconcilerSpec . reconciler );
69
68
}
70
69
71
70
public List <Reconciler > getReconcilers () {
You can’t perform that action at this time.
0 commit comments