Skip to content
Snippets Groups Projects
Commit e6f6209e authored by OZGCloud's avatar OZGCloud
Browse files

OZG-3961 differs scheduleDuration

parent aad53cc2
No related branches found
No related tags found
No related merge requests found
......@@ -28,6 +28,7 @@ import java.util.logging.Level;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import de.ozgcloud.operator.Config;
import de.ozgcloud.operator.keycloak.OzgCustomResourceStatus;
import io.javaoperatorsdk.operator.api.reconciler.Cleaner;
import io.javaoperatorsdk.operator.api.reconciler.Context;
......@@ -64,7 +65,7 @@ public class KeycloakUserReconciler implements Reconciler<OzgKeycloakUser>, Clea
return UserUpdateControlBuilder.fromResource(resource)
.withStatus(OzgCustomResourceStatus.IN_PROGRESS)
.withMessage(errorMessage)
.withReschedule()
.withReschedule(Config.RECONCILER_RETRY_SECONDS)
.build();
}
......@@ -80,7 +81,7 @@ public class KeycloakUserReconciler implements Reconciler<OzgKeycloakUser>, Clea
return UserUpdateControlBuilder.fromResource(resource)
.withStatus(OzgCustomResourceStatus.ERROR)
.withMessage(errorMessage)
.withReschedule()
.withReschedule(Config.RECONCILER_RETRY_SECONDS_ON_ERROR)
.build();
}
}
......
package de.ozgcloud.operator.keycloak.user;
import java.time.Duration;
import java.util.Optional;
import de.ozgcloud.operator.Config;
import de.ozgcloud.operator.keycloak.OzgCustomResourceStatus;
import io.javaoperatorsdk.operator.api.reconciler.UpdateControl;
......@@ -11,7 +11,8 @@ class UserUpdateControlBuilder {
private OzgKeycloakUser resource;
private OzgCustomResourceStatus status;
private Optional<String> message = Optional.empty();
private boolean reschedule;
private boolean reschedule = false;
private Duration scheduleDuration;
public UserUpdateControlBuilder(OzgKeycloakUser resource) {
this.resource = resource;
......@@ -31,8 +32,9 @@ class UserUpdateControlBuilder {
return this;
}
public UserUpdateControlBuilder withReschedule() {
public UserUpdateControlBuilder withReschedule(Duration duration) {
this.reschedule = true;
this.scheduleDuration = duration;
return this;
}
......@@ -50,7 +52,7 @@ class UserUpdateControlBuilder {
private UpdateControl<OzgKeycloakUser> buildUpdateControl() {
if (reschedule) {
UpdateControl.updateStatus(resource).rescheduleAfter(Config.RECONCILER_RETRY_SECONDS);
UpdateControl.updateStatus(resource).rescheduleAfter(scheduleDuration);
}
return UpdateControl.updateStatus(resource);
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment