Skip to content

Commit 6b3cc1d

Browse files
committed
Kubernetes Client Facade instead of Reconcile Utils
Signed-off-by: Attila Mészáros <a_meszaros@apple.com>
1 parent f105902 commit 6b3cc1d

File tree

6 files changed

+853
-891
lines changed

6 files changed

+853
-891
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,8 @@ default <R> Stream<R> getSecondaryResourcesAsStream(Class<R> expectedType) {
5858

5959
KubernetesClient getClient();
6060

61+
KubernetesClientFacade<P> getClientFacade();
62+
6163
/** ExecutorService initialized by framework for workflows. Used for workflow standalone mode. */
6264
ExecutorService getWorkflowExecutorService();
6365

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

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,7 @@ public class DefaultContext<P extends HasMetadata> implements Context<P> {
4646
private final boolean primaryResourceDeleted;
4747
private final boolean primaryResourceFinalStateUnknown;
4848
private final Map<DependentResource<?, P>, Object> desiredStates = new ConcurrentHashMap<>();
49+
private final KubernetesClientFacade<P> clientFacade;
4950

5051
public DefaultContext(
5152
RetryInfo retryInfo,
@@ -61,6 +62,7 @@ public DefaultContext(
6162
this.primaryResourceFinalStateUnknown = primaryResourceFinalStateUnknown;
6263
this.defaultManagedDependentResourceContext =
6364
new DefaultManagedWorkflowAndDependentResourceContext<>(controller, primaryResource, this);
65+
this.clientFacade = new KubernetesClientFacade<>(this);
6466
}
6567

6668
@Override
@@ -124,6 +126,11 @@ public KubernetesClient getClient() {
124126
return controller.getClient();
125127
}
126128

129+
@Override
130+
public KubernetesClientFacade<P> getClientFacade() {
131+
return null;
132+
}
133+
127134
@Override
128135
public ExecutorService getWorkflowExecutorService() {
129136
// note that this should be always received from executor service manager, so we are able to do

0 commit comments

Comments
 (0)