File tree Expand file tree Collapse file tree 5 files changed +18
-8
lines changed
operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent
operator-framework/src/test/java/io/javaoperatorsdk/operator
dependent/multiplemanagedexternaldependenttype
sample-operators/mysql-schema/src/main/java/io/javaoperatorsdk/operator/sample/schema Expand file tree Collapse file tree 5 files changed +18
-8
lines changed Original file line number Diff line number Diff line change @@ -119,7 +119,11 @@ protected Optional<R> selectTargetSecondaryResource(
119119 if (desired instanceof ExternalDependentIDProvider <?> desiredWithId ) {
120120 targetResources =
121121 secondaryResources .stream ()
122- .filter (r -> ((ExternalDependentIDProvider <?>) r ).id ().equals (desiredWithId .id ()))
122+ .filter (
123+ r ->
124+ ((ExternalDependentIDProvider <?>) r )
125+ .externalResourceId ()
126+ .equals (desiredWithId .externalResourceId ()))
123127 .toList ();
124128 } else {
125129 throw new IllegalStateException (
Original file line number Diff line number Diff line change 99 */
1010public interface ExternalDependentIDProvider <T > {
1111
12- T id ();
12+ T externalResourceId ();
1313}
Original file line number Diff line number Diff line change 1414class MultipleManagedExternalDependentSameTypeIT {
1515
1616 @ RegisterExtension
17- LocallyRunOperatorExtension operator =
17+ LocallyRunOperatorExtension extension =
1818 LocallyRunOperatorExtension .builder ()
1919 .withReconciler (new MultipleManagedExternalDependentResourceReconciler ())
2020 .build ();
@@ -27,15 +27,15 @@ class MultipleManagedExternalDependentSameTypeIT {
2727
2828 @ Test
2929 void handlesExternalCrudOperations () {
30- operator .create (testResource ());
30+ extension .create (testResource ());
3131 assertResourceCreatedWithData (DEFAULT_SPEC_VALUE );
3232
3333 var updatedResource = testResource ();
3434 updatedResource .getSpec ().setValue (UPDATED_SPEC_VALUE );
35- operator .replace (updatedResource );
35+ extension .replace (updatedResource );
3636 assertResourceCreatedWithData (UPDATED_SPEC_VALUE );
3737
38- operator .delete (testResource ());
38+ extension .delete (testResource ());
3939 assertExternalResourceDeleted ();
4040 }
4141
Original file line number Diff line number Diff line change 33import java .util .Objects ;
44
55import io .fabric8 .kubernetes .api .model .HasMetadata ;
6+ import io .javaoperatorsdk .operator .processing .dependent .ExternalDependentIDProvider ;
67import io .javaoperatorsdk .operator .processing .event .ResourceID ;
78
8- public class ExternalResource {
9+ public class ExternalResource implements ExternalDependentIDProvider < String > {
910
1011 public static final String EXTERNAL_RESOURCE_NAME_DELIMITER = "#" ;
1112
@@ -65,4 +66,9 @@ public static String toExternalResourceId(HasMetadata primary) {
6566 + EXTERNAL_RESOURCE_NAME_DELIMITER
6667 + primary .getMetadata ().getNamespace ();
6768 }
69+
70+ @ Override
71+ public String externalResourceId () {
72+ return id ;
73+ }
6874}
Original file line number Diff line number Diff line change @@ -42,7 +42,7 @@ public String toString() {
4242 }
4343
4444 @ Override
45- public String id () {
45+ public String externalResourceId () {
4646 return name ;
4747 }
4848}
You can’t perform that action at this time.
0 commit comments