Skip to content

Commit fec65d8

Browse files
committed
naming fix
1 parent 90ba3a6 commit fec65d8

File tree

6 files changed

+11
-11
lines changed

6 files changed

+11
-11
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,6 @@ public long getPollingPeriod() {
2929
// for now dependent resources support event sources only with one owned resource.
3030
@Override
3131
public String keyFor(R r) {
32-
return CacheKeyMapper.singleResourceIDMapper().keyFor(r);
32+
return CacheKeyMapper.singleResourceCacheKeyMapper().keyFor(r);
3333
}
3434
}

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

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -10,23 +10,23 @@ public abstract class PollingDependentResource<R, P extends HasMetadata>
1010
extends AbstractPollingDependentResource<R, P>
1111
implements PollingEventSource.GenericResourceFetcher<R> {
1212

13-
private final CacheKeyMapper<R> idProvider;
13+
private final CacheKeyMapper<R> cacheKeyMapper;
1414

15-
public PollingDependentResource(Class<R> resourceType, CacheKeyMapper<R> idProvider) {
15+
public PollingDependentResource(Class<R> resourceType, CacheKeyMapper<R> cacheKeyMapper) {
1616
super(resourceType);
17-
this.idProvider = idProvider;
17+
this.cacheKeyMapper = cacheKeyMapper;
1818
}
1919

2020
public PollingDependentResource(Class<R> resourceType, long pollingPeriod,
21-
CacheKeyMapper<R> idProvider) {
21+
CacheKeyMapper<R> cacheKeyMapper) {
2222
super(resourceType, pollingPeriod);
23-
this.idProvider = idProvider;
23+
this.cacheKeyMapper = cacheKeyMapper;
2424
}
2525

2626
@Override
2727
protected ExternalResourceCachingEventSource<R, P> createEventSource(
2828
EventSourceContext<P> context) {
29-
return new PollingEventSource<>(this, getPollingPeriod(), resourceType(), idProvider);
29+
return new PollingEventSource<>(this, getPollingPeriod(), resourceType(), cacheKeyMapper);
3030
}
3131

3232
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ public interface CacheKeyMapper<R> {
1111
* @return static id mapper, all resources are mapped for same id.
1212
* @param <T> secondary resource type
1313
*/
14-
static <T> CacheKeyMapper<T> singleResourceIDMapper() {
14+
static <T> CacheKeyMapper<T> singleResourceCacheKeyMapper() {
1515
return r -> "id";
1616
}
1717

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ public class PerResourcePollingEventSource<R, P extends HasMetadata>
4444
public PerResourcePollingEventSource(ResourceFetcher<R, P> resourceFetcher,
4545
Cache<P> resourceCache, long period, Class<R> resourceClass) {
4646
this(resourceFetcher, resourceCache, period, null, resourceClass,
47-
CacheKeyMapper.singleResourceIDMapper());
47+
CacheKeyMapper.singleResourceCacheKeyMapper());
4848
}
4949

5050
public PerResourcePollingEventSource(ResourceFetcher<R, P> resourceFetcher,

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ public PollingEventSource(
5353
GenericResourceFetcher<R> supplier,
5454
long period,
5555
Class<R> resourceClass) {
56-
super(resourceClass, CacheKeyMapper.singleResourceIDMapper());
56+
super(resourceClass, CacheKeyMapper.singleResourceCacheKeyMapper());
5757
this.genericResourceFetcher = supplier;
5858
this.period = period;
5959
}

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/source/polling/PerResourcePollingEventSourceTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ void pollsTheResourceAfterAwareOfIt() throws InterruptedException {
5757
void registeringTaskOnAPredicate() throws InterruptedException {
5858
setUpSource(new PerResourcePollingEventSource<>(supplier, resourceCache, PERIOD,
5959
testCustomResource -> testCustomResource.getMetadata().getGeneration() > 1,
60-
SampleExternalResource.class, CacheKeyMapper.singleResourceIDMapper()));
60+
SampleExternalResource.class, CacheKeyMapper.singleResourceCacheKeyMapper()));
6161
source.onResourceCreated(testCustomResource);
6262
Thread.sleep(2 * PERIOD);
6363

0 commit comments

Comments
 (0)