public class KubernetesMultipleComponentLeaderElectionDriverFactory extends Object implements MultipleComponentLeaderElectionDriverFactory
KubernetesMultipleComponentLeaderElectionDriver
.Constructor and Description |
---|
KubernetesMultipleComponentLeaderElectionDriverFactory(FlinkKubeClient kubeClient,
KubernetesLeaderElectionConfiguration kubernetesLeaderElectionConfiguration,
KubernetesConfigMapSharedWatcher configMapSharedWatcher,
Executor watchExecutor) |
Modifier and Type | Method and Description |
---|---|
KubernetesMultipleComponentLeaderElectionDriver |
create(MultipleComponentLeaderElectionDriver.Listener leaderElectionListener,
FatalErrorHandler fatalErrorHandler)
Creates a
MultipleComponentLeaderElectionDriver for the given leader contender
description. |
public KubernetesMultipleComponentLeaderElectionDriverFactory(FlinkKubeClient kubeClient, KubernetesLeaderElectionConfiguration kubernetesLeaderElectionConfiguration, KubernetesConfigMapSharedWatcher configMapSharedWatcher, Executor watchExecutor)
public KubernetesMultipleComponentLeaderElectionDriver create(MultipleComponentLeaderElectionDriver.Listener leaderElectionListener, FatalErrorHandler fatalErrorHandler) throws Exception
MultipleComponentLeaderElectionDriverFactory
MultipleComponentLeaderElectionDriver
for the given leader contender
description. Moreover, it registers the given leader election listener with the service.create
in interface MultipleComponentLeaderElectionDriverFactory
leaderElectionListener
- listener for the callbacks of the MultipleComponentLeaderElectionDriver
fatalErrorHandler
- component for handling fatal errors.MultipleComponentLeaderElectionDriver
instanceException
- if the creation failsCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.