Skip to content

Commit 9bedbca

Browse files
committed
fix: Stablond web reconciler
1 parent e453a38 commit 9bedbca

File tree

1 file changed

+11
-15
lines changed

1 file changed

+11
-15
lines changed

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

Lines changed: 11 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package io.javaoperatorsdk.operator.sample;
22

3+
import java.util.Arrays;
34
import java.util.Map;
45

56
import org.slf4j.Logger;
@@ -56,12 +57,12 @@ public UpdateControl<WebPage> reconcile(WebPage webPage, Context<WebPage> contex
5657
throws Exception {
5758
simulateErrorIfRequested(webPage);
5859

59-
configMapDR.reconcile(webPage, context);
60-
deploymentDR.reconcile(webPage, context);
61-
serviceDR.reconcile(webPage, context);
60+
Arrays.asList(configMapDR, deploymentDR, serviceDR)
61+
.forEach(dr -> dr.reconcile(webPage, context));
6262

6363
webPage.setStatus(
64-
createStatus(configMapDR.getResource(webPage).orElseThrow().getMetadata().getName()));
64+
createStatus(
65+
configMapDR.getAssociatedResource(webPage).orElseThrow().getMetadata().getName()));
6566
return UpdateControl.updateStatus(webPage);
6667
}
6768

@@ -73,18 +74,13 @@ public ErrorStatusUpdateControl<WebPage> updateErrorStatus(
7374

7475
private void createDependentResources(KubernetesClient client) {
7576
this.configMapDR = new ConfigMapDependentResource();
76-
this.configMapDR.setKubernetesClient(client);
77-
configMapDR.configureWith(new KubernetesDependentResourceConfig()
78-
.setLabelSelector(DEPENDENT_RESOURCE_LABEL_SELECTOR));
79-
8077
this.deploymentDR = new DeploymentDependentResource();
81-
deploymentDR.setKubernetesClient(client);
82-
deploymentDR.configureWith(new KubernetesDependentResourceConfig()
83-
.setLabelSelector(DEPENDENT_RESOURCE_LABEL_SELECTOR));
84-
8578
this.serviceDR = new ServiceDependentResource();
86-
serviceDR.setKubernetesClient(client);
87-
serviceDR.configureWith(new KubernetesDependentResourceConfig()
88-
.setLabelSelector(DEPENDENT_RESOURCE_LABEL_SELECTOR));
79+
80+
Arrays.asList(configMapDR, deploymentDR, serviceDR).forEach(dr -> {
81+
dr.setKubernetesClient(client);
82+
dr.configureWith(new KubernetesDependentResourceConfig()
83+
.setLabelSelector(DEPENDENT_RESOURCE_LABEL_SELECTOR));
84+
});
8985
}
9086
}

0 commit comments

Comments
 (0)