fix: id mapper

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/external/AbstractPollingDependentResource.java

@@ -28,7 +28,7 @@ public long getPollingPeriod() {
 
   // for now dependent resources support event sources only with one owned resource.
   @Override
-  public String apply(R r) {
-    return IDMapper.singleResourceIDMapper().apply(r);
+  public String getID(R r) {
+    return IDMapper.singleResourceIDMapper().getID(r);
   }
 }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/ExternalResourceCachingEventSource.java

@@ -52,11 +52,11 @@ protected synchronized void handleDelete(ResourceID primaryID) {
   }
 
   protected synchronized void handleDeletes(ResourceID primaryID, Set<R> resource) {
-    handleDelete(primaryID, resource.stream().map(idMapper).collect(Collectors.toSet()));
+    handleDelete(primaryID, resource.stream().map(idMapper::getID).collect(Collectors.toSet()));
   }
 
   protected synchronized void handleDelete(ResourceID primaryID, R resource) {
-    handleDelete(primaryID, Set.of(idMapper.apply(resource)));
+    handleDelete(primaryID, Set.of(idMapper.getID(resource)));
   }
 
   protected synchronized void handleDelete(ResourceID primaryID, Set<String> resourceID) {
@@ -98,7 +98,7 @@ protected synchronized void handleResources(ResourceID primaryID, Set<R> newReso
       return;
     }
     var cachedResources = cache.get(primaryID);
-    var newResourcesMap = newResources.stream().collect(Collectors.toMap(idMapper, r -> r));
+    var newResourcesMap = newResources.stream().collect(Collectors.toMap(idMapper::getID, r -> r));
     cache.put(primaryID, newResourcesMap);
     if (propagateEvent && !newResourcesMap.equals(cachedResources)) {
       getEventHandler().handleEvent(new Event(primaryID));
@@ -108,7 +108,7 @@ protected synchronized void handleResources(ResourceID primaryID, Set<R> newReso
   @Override
   public synchronized void handleRecentResourceCreate(ResourceID primaryID, R resource) {
     var actualValues = cache.get(primaryID);
-    var resourceId = idMapper.apply(resource);
+    var resourceId = idMapper.getID(resource);
     if (actualValues == null) {
       actualValues = new HashMap<>();
       cache.put(primaryID, actualValues);
@@ -123,7 +123,7 @@ public synchronized void handleRecentResourceUpdate(
       ResourceID primaryID, R resource, R previousVersionOfResource) {
     var actualValues = cache.get(primaryID);
     if (actualValues != null) {
-      var resourceId = idMapper.apply(resource);
+      var resourceId = idMapper.getID(resource);
       R actualResource = actualValues.get(resourceId);
       if (actualResource.equals(previousVersionOfResource)) {
         actualValues.put(resourceId, resource);

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/IDMapper.java

@@ -1,8 +1,8 @@
 package io.javaoperatorsdk.operator.processing.event.source;
 
-import java.util.function.Function;
+public interface IDMapper<R> {
 
-public interface IDMapper<R> extends Function<R, String> {
+  String getID(R var1);
 
   /**
    * Used If a polling event source handles only single secondary resource. See also docs for: