Skip to content

Commit 30576b4

Browse files
committed
Resolve remaining issues
1 parent c565cc1 commit 30576b4

File tree

3 files changed

+9
-3
lines changed

3 files changed

+9
-3
lines changed

operator/src/main/java/oracle/kubernetes/operator/OperatorMain.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -276,8 +276,8 @@ void completeBegin() {
276276
int recheckInterval = TuningParameters.getInstance().getDomainNamespaceRecheckIntervalSeconds();
277277
int stuckPodInterval = TuningParameters.getInstance().getStuckPodRecheckSeconds();
278278
Collection<Cancellable> futures = List.of(
279-
mainDelegate.scheduleWithFixedDelay(recheckDomains(), recheckInterval, recheckInterval, TimeUnit.SECONDS),
280-
mainDelegate.scheduleWithFixedDelay(checkStuckPods(), stuckPodInterval, stuckPodInterval, TimeUnit.SECONDS));
279+
mainDelegate.scheduleWithFixedDelay(recheckDomains(), recheckInterval, recheckInterval, TimeUnit.SECONDS),
280+
mainDelegate.scheduleWithFixedDelay(checkStuckPods(), stuckPodInterval, stuckPodInterval, TimeUnit.SECONDS));
281281

282282
markReadyAndStartLivenessThread(futures);
283283

operator/src/main/java/oracle/kubernetes/operator/calls/ResponseStep.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@
66
import java.util.Optional;
77
import java.util.Random;
88
import java.util.Set;
9-
import java.util.function.Supplier;
109
import java.util.concurrent.TimeUnit;
10+
import java.util.function.Supplier;
1111
import javax.annotation.Nonnull;
1212

1313
import io.kubernetes.client.common.KubernetesType;

operator/src/main/java/oracle/kubernetes/operator/work/Cancellable.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,14 @@
77

88
public interface Cancellable {
99
boolean cancel();
10+
1011
boolean isDoneOrCancelled();
1112

13+
/**
14+
* Create instance wrapping a ScheduledFuture.
15+
* @param future Scheduled future instance
16+
* @return Cancellable wrapping scheduled future
17+
*/
1218
static Cancellable createCancellable(ScheduledFuture<?> future) {
1319
return new Cancellable() {
1420
@Override

0 commit comments

Comments
 (0)