Skip to content

Commit c5c44d7

Browse files
committed
fix: rename getAssiciatedResource to getResource
1 parent 69e3f0c commit c5c44d7

File tree

16 files changed

+21
-21
lines changed

16 files changed

+21
-21
lines changed

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/DefaultContext.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ public Optional<RetryInfo> getRetryInfo() {
3232
public <T> Optional<T> getSecondaryResource(Class<T> expectedType, String eventSourceName) {
3333
return controller.getEventSourceManager()
3434
.getResourceEventSourceFor(expectedType, eventSourceName)
35-
.flatMap(es -> es.getAssociatedResource(primaryResource));
35+
.flatMap(es -> es.getResource(primaryResource));
3636
}
3737

3838
@Override

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,5 +22,5 @@ public interface ResourceOwner<R, P extends HasMetadata> {
2222
* @return an {@link Optional} containing the secondary resource or {@link Optional#empty()} if it
2323
* doesn't exist
2424
*/
25-
Optional<R> getAssociatedResource(P primary);
25+
Optional<R> getResource(P primary);
2626
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ public AbstractDependentResource() {
2828

2929
@Override
3030
public ReconcileResult<R> reconcile(P primary, Context<P> context) {
31-
var maybeActual = getAssociatedResource(primary);
31+
var maybeActual = getResource(primary);
3232
if (creatable || updatable) {
3333
if (maybeActual.isEmpty()) {
3434
if (creatable) {

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ protected AbstractCachingDependentResource(Class<R> resourceType) {
1616
}
1717

1818
public Optional<R> fetchResource(P primaryResource) {
19-
return eventSource().getAssociatedResource(primaryResource);
19+
return eventSource().getResource(primaryResource);
2020
}
2121

2222
@Override
@@ -25,7 +25,7 @@ public Class<R> resourceType() {
2525
}
2626

2727
@Override
28-
public Optional<R> getAssociatedResource(P primaryResource) {
29-
return eventSource().getAssociatedResource(primaryResource);
28+
public Optional<R> getResource(P primaryResource) {
29+
return eventSource().getResource(primaryResource);
3030
}
3131
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public AbstractSimpleDependentResource(UpdatableCache<R> cache) {
3131
}
3232

3333
@Override
34-
public Optional<R> getAssociatedResource(HasMetadata primaryResource) {
34+
public Optional<R> getResource(HasMetadata primaryResource) {
3535
return cache.get(ResourceID.fromResource(primaryResource));
3636
}
3737

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/kubernetes/KubernetesDependentResource.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ public Result<R> match(R actualResource, P primary, Context<P> context) {
9797

9898
public void delete(P primary, Context<P> context) {
9999
if (!addOwnerReference()) {
100-
var resource = getAssociatedResource(primary);
100+
var resource = getResource(primary);
101101
resource.ifPresent(r -> client.resource(r).delete());
102102
}
103103
}
@@ -134,8 +134,8 @@ public Class<R> resourceType() {
134134
}
135135

136136
@Override
137-
public Optional<R> getAssociatedResource(P primaryResource) {
138-
return eventSource().getAssociatedResource(primaryResource);
137+
public Optional<R> getResource(P primaryResource) {
138+
return eventSource().getResource(primaryResource);
139139
}
140140

141141
@Override

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public Optional<R> getCachedValue(ResourceID resourceID) {
5454
}
5555

5656
@Override
57-
public Optional<R> getAssociatedResource(P primary) {
57+
public Optional<R> getResource(P primary) {
5858
return cache.get(ResourceID.fromResource(primary));
5959
}
6060

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ private void handleKubernetesClientException(Exception e) {
102102
}
103103

104104
@Override
105-
public Optional<T> getAssociatedResource(T primary) {
105+
public Optional<T> getResource(T primary) {
106106
return get(ResourceID.fromResource(primary));
107107
}
108108
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,7 @@ private void propagateEvent(R object) {
152152
* @return the informed resource associated with the specified primary resource
153153
*/
154154
@Override
155-
public Optional<R> getAssociatedResource(P resource) {
155+
public Optional<R> getResource(P resource) {
156156
final var id = configuration.getAssociatedResourceIdentifier().associatedSecondaryID(resource);
157157
return get(id);
158158
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ public Optional<R> get(ResourceID resourceID) {
9393
}
9494

9595
@Override
96-
public Optional<R> getAssociatedResource(P primary) {
96+
public Optional<R> getResource(P primary) {
9797
return get(ResourceID.fromResource(primary));
9898
}
9999

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
@@ -132,7 +132,7 @@ public void run() {
132132
* @return the related resource for this event source
133133
*/
134134
@Override
135-
public Optional<R> getAssociatedResource(P primary) {
135+
public Optional<R> getResource(P primary) {
136136
return getValueFromCacheOrSupplier(ResourceID.fromResource(primary));
137137
}
138138

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
@@ -98,7 +98,7 @@ public void stop() throws OperatorException {
9898
* @return related resource
9999
*/
100100
@Override
101-
public Optional<R> getAssociatedResource(P primary) {
101+
public Optional<R> getResource(P primary) {
102102
return getCachedValue(ResourceID.fromResource(primary));
103103
}
104104
}

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/api/config/UtilsTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ public ReconcileResult<Deployment> reconcile(TestCustomResource primary,
9898
}
9999

100100
@Override
101-
public Optional<Deployment> getAssociatedResource(TestCustomResource primaryResource) {
101+
public Optional<Deployment> getResource(TestCustomResource primaryResource) {
102102
return Optional.empty();
103103
}
104104

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/dependent/external/AbstractSimpleDependentResourceTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,14 +45,14 @@ void getsTheResourceFromSupplyIfReconciling() {
4545
simpleDependentResource.reconcile(TestUtils.testCustomResource1(), null);
4646

4747
verify(supplierMock, times(1)).get();
48-
assertThat(simpleDependentResource.getAssociatedResource(TestUtils.testCustomResource1()))
48+
assertThat(simpleDependentResource.getResource(TestUtils.testCustomResource1()))
4949
.isPresent()
5050
.isEqualTo(Optional.of(SampleExternalResource.testResource1()));
5151
}
5252

5353
@Test
5454
void getResourceReadsTheResourceFromCache() {
55-
simpleDependentResource.getAssociatedResource(TestUtils.testCustomResource1());
55+
simpleDependentResource.getResource(TestUtils.testCustomResource1());
5656

5757
verify(supplierMock, times(0)).get();
5858
verify(updatableCacheMock, times(1)).get(any());

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/standalonedependent/StandaloneDependentTestReconciler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ public UpdateControl<StandaloneDependentTestCustomResource> reconcile(
4848
StandaloneDependentTestCustomResource primary,
4949
Context<StandaloneDependentTestCustomResource> context) {
5050
deploymentDependent.reconcile(primary, context);
51-
Optional<Deployment> deployment = deploymentDependent.getAssociatedResource(primary);
51+
Optional<Deployment> deployment = deploymentDependent.getResource(primary);
5252
if (deployment.isEmpty()) {
5353
throw new IllegalStateException("Resource should not be empty after reconcile.");
5454
}

sample-operators/webpage/src/main/java/io/javaoperatorsdk/operator/sample/WebPageStandaloneDependentsReconciler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public UpdateControl<WebPage> reconcile(WebPage webPage, Context<WebPage> contex
6262

6363
webPage.setStatus(
6464
createStatus(
65-
configMapDR.getAssociatedResource(webPage).orElseThrow().getMetadata().getName()));
65+
configMapDR.getResource(webPage).orElseThrow().getMetadata().getName()));
6666
return UpdateControl.updateStatus(webPage);
6767
}
6868

0 commit comments

Comments
 (0)