Skip to content

Commit b39cafe

Browse files
committed
changed sample
Signed-off-by: Attila Mészáros <[email protected]>
1 parent 9c7b6ad commit b39cafe

File tree

2 files changed

+5
-10
lines changed

2 files changed

+5
-10
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/ResourceIDProvider.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
* Provides the identifier for an object that represents resource. This ID is used to select target
2020
* external resource for a dependent resource from the resources returned by `{@link
2121
* io.javaoperatorsdk.operator.api.reconciler.Context#getSecondaryResources(Class)}`. But also for
22-
* {@link ResourceIDMapper} for event sources in external resources
22+
* {@link ResourceIDMapper} for event sources in external resources.
2323
*
2424
* @param <T>
2525
*/

operator-framework/src/test/java/io/javaoperatorsdk/operator/dependent/bulkdependent/external/ExternalBulkDependentResource.java

Lines changed: 4 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -95,10 +95,10 @@ public Map<String, ExternalResource> desiredResources(
9595
Map<String, ExternalResource> res = new HashMap<>();
9696
for (int i = 0; i < number; i++) {
9797
var key = Integer.toString(i);
98-
res.put(
99-
key,
98+
var resource =
10099
new ExternalResource(
101-
toExternalResourceId(primary, key), primary.getSpec().getAdditionalData()));
100+
toExternalResourceId(primary, key), primary.getSpec().getAdditionalData());
101+
res.put(getResourceIDMapper().idFor(resource), resource);
102102
}
103103
return res;
104104
}
@@ -116,12 +116,7 @@ public Map<String, ExternalResource> getSecondaryResources(
116116
+ EXTERNAL_RESOURCE_NAME_DELIMITER
117117
+ primary.getMetadata().getNamespace()
118118
+ EXTERNAL_RESOURCE_NAME_DELIMITER))
119-
.collect(
120-
Collectors.toMap(
121-
r ->
122-
r.getId()
123-
.substring(r.getId().lastIndexOf(EXTERNAL_RESOURCE_NAME_DELIMITER) + 1),
124-
r -> r));
119+
.collect(Collectors.toMap(r -> getResourceIDMapper().idFor(r), r -> r));
125120
}
126121

127122
@Override

0 commit comments

Comments
 (0)