@Deprecated public class KubernetesLeaderRetrievalDriverFactory extends Object implements LeaderRetrievalDriverFactory
LeaderRetrievalDriverFactory
implementation for Kubernetes.Constructor and Description |
---|
KubernetesLeaderRetrievalDriverFactory(KubernetesConfigMapSharedWatcher configMapSharedWatcher,
Executor watchExecutor,
String configMapName)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
KubernetesLeaderRetrievalDriver |
createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler,
FatalErrorHandler fatalErrorHandler)
Deprecated.
Create a specific
LeaderRetrievalDriver and start the necessary services. |
public KubernetesLeaderRetrievalDriverFactory(KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor, String configMapName)
public KubernetesLeaderRetrievalDriver createLeaderRetrievalDriver(LeaderRetrievalEventHandler leaderEventHandler, FatalErrorHandler fatalErrorHandler)
LeaderRetrievalDriverFactory
LeaderRetrievalDriver
and start the necessary services. For
example, NodeCache in Zookeeper, ConfigMap watcher in Kubernetes. They could get the leader
information change events and need to notify the leader listener by LeaderRetrievalEventHandler
.createLeaderRetrievalDriver
in interface LeaderRetrievalDriverFactory
leaderEventHandler
- handler for the leader retrieval driver to notify leader change
events.fatalErrorHandler
- fatal error handlerCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.