org.apache.flink.kubernetes.highavailability

Class KubernetesLeaderElectionDriver

java.lang.Object

org.apache.flink.kubernetes.highavailability.KubernetesLeaderElectionDriver

All Implemented Interfaces:

AutoCloseable, LeaderElectionDriver

public class KubernetesLeaderElectionDriver
extends Object
implements LeaderElectionDriver

LeaderElectionDriver for Kubernetes.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.leaderelection.LeaderElectionDriver

LeaderElectionDriver.Listener

Constructor Summary

Constructors

Constructor and Description
KubernetesLeaderElectionDriver(KubernetesLeaderElectionConfiguration leaderElectionConfiguration, FlinkKubeClient kubeClient, LeaderElectionDriver.Listener leaderElectionListener, KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor)

Method Summary

Modifier and Type	Method and Description
void	close()
void	deleteLeaderInformation(String componentId) Deletes the leader information for the given component.
boolean	hasLeadership() Returns whether the driver has currently leadership.
void	publishLeaderInformation(String componentId, LeaderInformation leaderInformation) Publishes the leader information for the given component.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesLeaderElectionDriver

public KubernetesLeaderElectionDriver(KubernetesLeaderElectionConfiguration leaderElectionConfiguration,
                                      FlinkKubeClient kubeClient,
                                      LeaderElectionDriver.Listener leaderElectionListener,
                                      KubernetesConfigMapSharedWatcher configMapSharedWatcher,
                                      Executor watchExecutor)

Method Detail

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

hasLeadership

public boolean hasLeadership()

Description copied from interface: LeaderElectionDriver

Returns whether the driver has currently leadership.

Specified by:

hasLeadership in interface LeaderElectionDriver

Returns:

true if the driver has leadership, otherwise false

publishLeaderInformation

public void publishLeaderInformation(String componentId,
                                     LeaderInformation leaderInformation)

Description copied from interface: LeaderElectionDriver

Publishes the leader information for the given component.

Specified by:

publishLeaderInformation in interface LeaderElectionDriver

Parameters:

componentId - identifying the component for which to publish the leader information

leaderInformation - leader information of the respective component

deleteLeaderInformation

public void deleteLeaderInformation(String componentId)

Description copied from interface: LeaderElectionDriver

Deletes the leader information for the given component.

Specified by:

deleteLeaderInformation in interface LeaderElectionDriver

Parameters:

componentId - identifying the component for which to delete the leader information

toString

public String toString()

Overrides:

toString in class Object