org.apache.flink.kubernetes.highavailability

Class KubernetesMultipleComponentLeaderElectionDriver

java.lang.Object

org.apache.flink.kubernetes.highavailability.KubernetesMultipleComponentLeaderElectionDriver

All Implemented Interfaces:

MultipleComponentLeaderElectionDriver

public class KubernetesMultipleComponentLeaderElectionDriver
extends Object
implements MultipleComponentLeaderElectionDriver

MultipleComponentLeaderElectionDriver for Kubernetes.

Nested Class Summary

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

MultipleComponentLeaderElectionDriver.Listener

Constructor Summary

Constructors

Constructor and Description
KubernetesMultipleComponentLeaderElectionDriver(KubernetesLeaderElectionConfiguration leaderElectionConfiguration, FlinkKubeClient kubeClient, MultipleComponentLeaderElectionDriver.Listener leaderElectionListener, KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor, FatalErrorHandler fatalErrorHandler)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the driver.
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.

Methods inherited from class java.lang.Object

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

Constructor Detail

KubernetesMultipleComponentLeaderElectionDriver

public KubernetesMultipleComponentLeaderElectionDriver(KubernetesLeaderElectionConfiguration leaderElectionConfiguration,
                                                       FlinkKubeClient kubeClient,
                                                       MultipleComponentLeaderElectionDriver.Listener leaderElectionListener,
                                                       KubernetesConfigMapSharedWatcher configMapSharedWatcher,
                                                       Executor watchExecutor,
                                                       FatalErrorHandler fatalErrorHandler)

Method Detail

close

public void close()
           throws Exception

Description copied from interface: MultipleComponentLeaderElectionDriver

Closes the driver.

Specified by:

close in interface MultipleComponentLeaderElectionDriver

Throws:

Exception - if closing this driver fails

hasLeadership

public boolean hasLeadership()

Description copied from interface: MultipleComponentLeaderElectionDriver

Returns whether the driver has currently leadership.

Specified by:

hasLeadership in interface MultipleComponentLeaderElectionDriver

Returns:

true if the driver has leadership, otherwise false

publishLeaderInformation

public void publishLeaderInformation(String componentId,
                                     LeaderInformation leaderInformation)
                              throws Exception

Description copied from interface: MultipleComponentLeaderElectionDriver

Publishes the leader information for the given component.

Specified by:

publishLeaderInformation in interface MultipleComponentLeaderElectionDriver

Parameters:

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

leaderInformation - leader information of the respective component

Throws:

Exception - if publishing fails

deleteLeaderInformation

public void deleteLeaderInformation(String componentId)
                             throws Exception

Description copied from interface: MultipleComponentLeaderElectionDriver

Deletes the leader information for the given component.

Specified by:

deleteLeaderInformation in interface MultipleComponentLeaderElectionDriver

Parameters:

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

Throws:

Exception - if deleting fails