File tree Expand file tree Collapse 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 Expand file tree Collapse file tree 3 files changed +1
-25
lines changed Original file line number Diff line number Diff line change 11package io .javaoperatorsdk .operator ;
22
3- import java .util .ArrayList ;
43import java .util .HashMap ;
5- import java .util .List ;
64import java .util .Map ;
75import java .util .function .Consumer ;
86
@@ -75,10 +73,6 @@ public KubernetesClient getKubernetesClient() {
7573 return kubernetesClient ;
7674 }
7775
78- public List <Controller > getControllers () {
79- return new ArrayList <>(controllers .controllers .values ());
80- }
81-
8276 /**
8377 * Finishes the operator startup process. This is mostly used in injection-aware applications
8478 * 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 1010import io .fabric8 .kubernetes .client .KubernetesClient ;
1111import io .javaoperatorsdk .operator .api .config .AbstractConfigurationService ;
1212import io .javaoperatorsdk .operator .api .config .ConfigurationServiceProvider ;
13- import io .javaoperatorsdk .operator .api .config .MockControllerConfiguration ;
1413import io .javaoperatorsdk .operator .api .reconciler .Context ;
1514import io .javaoperatorsdk .operator .api .reconciler .Reconciler ;
1615import io .javaoperatorsdk .operator .api .reconciler .UpdateControl ;
1716
18- import static org .assertj .core .api .AssertionsForClassTypes .assertThat ;
19-
2017@ SuppressWarnings ("rawtypes" )
2118class OperatorTest {
2219
@@ -30,20 +27,6 @@ static void setUpConfigurationServiceProvider() {
3027 ConfigurationServiceProvider .reset ();
3128 }
3229
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-
4730 @ Test
4831 @ DisplayName ("should throw `OperationException` when Configuration is null" )
4932 public void shouldThrowOperatorExceptionWhenConfigurationIsNull () {
Original file line number Diff line number Diff line change 1818import io .javaoperatorsdk .operator .api .config .ConfigurationService ;
1919import io .javaoperatorsdk .operator .api .config .ControllerConfigurationOverrider ;
2020import io .javaoperatorsdk .operator .api .reconciler .Reconciler ;
21- import io .javaoperatorsdk .operator .processing .Controller ;
2221import io .javaoperatorsdk .operator .processing .retry .Retry ;
2322
2423import static io .javaoperatorsdk .operator .api .config .ControllerConfigurationOverrider .override ;
@@ -65,7 +64,7 @@ public static Builder builder() {
6564 }
6665
6766 private Stream <Reconciler > reconcilers () {
68- return operator . getControllers (). stream ().map (Controller :: getReconciler );
67+ return reconcilers . stream ().map (reconcilerSpec -> reconcilerSpec . reconciler );
6968 }
7069
7170 public List <Reconciler > getReconcilers () {
You can’t perform that action at this time.
0 commit comments