Class LeaderElectionInitiatorUtil

java.lang.Object

org.springframework.cloud.kubernetes.commons.leader.election.LeaderElectionInitiatorUtil

public final class LeaderElectionInitiatorUtil
extends Object

Author:

wind57

Method Summary

Modifier and Type	Method	Description
static CompletableFuture<?>	attachReadinessLoggerPipeline(CompletableFuture<?> innerPodReadyFuture, String candidateIdentity)	if 'ready' is already completed at this point, thread will run this, otherwise it will attach the pipeline and move on to 'blockReadinessCheck'.
static void	blockReadinessCheck(CompletableFuture<?> ready)
static void	shutDownExecutor(ExecutorService podReadyWaitingExecutor, String candidateIdentity)
static void	sleep(LeaderElectionProperties leaderElectionProperties)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

blockReadinessCheck

public static void blockReadinessCheck(CompletableFuture<?> ready)

shutDownExecutor

public static void shutDownExecutor(ExecutorService podReadyWaitingExecutor,
 String candidateIdentity)

attachReadinessLoggerPipeline

public static CompletableFuture<?> attachReadinessLoggerPipeline(CompletableFuture<?> innerPodReadyFuture,
 String candidateIdentity)

if 'ready' is already completed at this point, thread will run this, otherwise it will attach the pipeline and move on to 'blockReadinessCheck'.

sleep

public static void sleep(LeaderElectionProperties leaderElectionProperties)