Modifier and Type | Method and Description |
---|---|
LeaderInformation |
KubernetesMultipleComponentLeaderRetrievalDriverFactory.extractLeaderInformation(KubernetesConfigMap configMap) |
Modifier and Type | Method and Description |
---|---|
void |
KubernetesMultipleComponentLeaderElectionDriver.publishLeaderInformation(String componentId,
LeaderInformation leaderInformation) |
void |
KubernetesLeaderElectionDriver.writeLeaderInformation(LeaderInformation leaderInformation)
Deprecated.
|
Constructor and Description |
---|
KubernetesLeaderRetrievalDriver(FlinkKubeClient kubeClient,
KubernetesConfigMapSharedWatcher configMapSharedWatcher,
Executor watchExecutor,
String configMapName,
LeaderRetrievalEventHandler leaderRetrievalEventHandler,
java.util.function.Function<KubernetesConfigMap,LeaderInformation> leaderInformationExtractor,
FatalErrorHandler fatalErrorHandler) |
Modifier and Type | Method and Description |
---|---|
static LeaderInformation |
KubernetesUtils.getLeaderInformationFromConfigMap(KubernetesConfigMap configMap)
Get the
LeaderInformation from ConfigMap. |
Modifier and Type | Method and Description |
---|---|
static Optional<LeaderInformation> |
KubernetesUtils.parseLeaderInformationSafely(String value) |
Modifier and Type | Method and Description |
---|---|
static String |
KubernetesUtils.encodeLeaderInformation(LeaderInformation leaderInformation) |
Modifier and Type | Method and Description |
---|---|
static LeaderInformation |
LeaderInformation.empty() |
static LeaderInformation |
LeaderInformation.known(UUID leaderSessionID,
String leaderAddress) |
Modifier and Type | Method and Description |
---|---|
static LeaderInformationWithComponentId |
LeaderInformationWithComponentId.create(String componentId,
LeaderInformation leaderInformation) |
void |
DefaultMultipleComponentLeaderElectionService.notifyLeaderInformationChange(String componentId,
LeaderInformation leaderInformation) |
void |
MultipleComponentLeaderElectionDriver.Listener.notifyLeaderInformationChange(String componentId,
LeaderInformation leaderInformation)
Notifies the listener about a changed leader information for the given component.
|
void |
DefaultLeaderElectionService.onLeaderInformationChange(LeaderInformation leaderInformation) |
void |
LeaderElectionEventHandler.onLeaderInformationChange(LeaderInformation leaderInformation)
Called by specific
LeaderElectionDriver when the leader information is changed. |
void |
ZooKeeperMultipleComponentLeaderElectionDriver.publishLeaderInformation(String componentId,
LeaderInformation leaderInformation) |
void |
DefaultMultipleComponentLeaderElectionService.publishLeaderInformation(String componentId,
LeaderInformation leaderInformation) |
void |
MultipleComponentLeaderElectionService.publishLeaderInformation(String componentId,
LeaderInformation leaderInformation)
Publishes the given leader information for the component identified by the given leader name.
|
void |
MultipleComponentLeaderElectionDriver.publishLeaderInformation(String componentId,
LeaderInformation leaderInformation)
Publishes the leader information for the given component.
|
void |
ZooKeeperLeaderElectionDriver.writeLeaderInformation(LeaderInformation leaderInformation)
Deprecated.
Writes the current leader's address as well the given leader session ID to ZooKeeper.
|
void |
LeaderElectionDriver.writeLeaderInformation(LeaderInformation leaderInformation)
Write the current leader information to external persistent storage(e.g.
|
Modifier and Type | Method and Description |
---|---|
void |
LeaderRetrievalEventHandler.notifyLeaderAddress(LeaderInformation leaderInformation)
Called by specific
LeaderRetrievalDriver to notify leader address. |
void |
DefaultLeaderRetrievalService.notifyLeaderAddress(LeaderInformation leaderInformation)
Called by specific
LeaderRetrievalDriver to notify leader address. |
Modifier and Type | Method and Description |
---|---|
static LeaderInformation |
ZooKeeperUtils.readLeaderInformation(byte[] data) |
Modifier and Type | Method and Description |
---|---|
static void |
ZooKeeperUtils.writeLeaderInformationToZooKeeper(LeaderInformation leaderInformation,
org.apache.flink.shaded.curator5.org.apache.curator.framework.CuratorFramework curatorFramework,
java.util.function.BooleanSupplier hasLeadershipCheck,
String connectionInformationPath) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.