Skip to content

Commit 4511728

Browse files
committed
fix, operator api update for retry
1 parent 95450aa commit 4511728

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

operator-framework/src/main/java/io/javaoperatorsdk/operator/Operator.java

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,11 +36,22 @@ public Operator(KubernetesClient k8sClient) {
3636
this.k8sClient = k8sClient;
3737
}
3838

39+
public <R extends CustomResource> void registerControllerForAllNamespaces(
40+
ResourceController<R> controller, Retry retry) throws OperatorException {
41+
registerController(controller, true, retry);
42+
}
43+
3944
public <R extends CustomResource> void registerControllerForAllNamespaces(
4045
ResourceController<R> controller) throws OperatorException {
4146
registerController(controller, true, null);
4247
}
4348

49+
public <R extends CustomResource> void registerController(
50+
ResourceController<R> controller, Retry retry, String... targetNamespaces)
51+
throws OperatorException {
52+
registerController(controller, false, retry, targetNamespaces);
53+
}
54+
4455
public <R extends CustomResource> void registerController(
4556
ResourceController<R> controller, String... targetNamespaces) throws OperatorException {
4657
registerController(controller, false, null, targetNamespaces);

operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/DefaultEventHandler.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,7 @@ void eventProcessingFinished(
109109

110110
if (retry != null && postExecutionControl.exceptionDuringExecution()) {
111111
handleRetryOnException(executionScope, postExecutionControl);
112+
return;
112113
} else if (retry != null) {
113114
handleSuccessfulExecutionRegardingRetry(executionScope);
114115
}

0 commit comments

Comments
 (0)