Constructor and Description |
---|
KubernetesLeaderElectionDriver(FlinkKubeClient kubeClient,
KubernetesLeaderElectionConfiguration leaderConfig,
LeaderElectionEventHandler leaderElectionEventHandler,
FatalErrorHandler fatalErrorHandler) |
KubernetesLeaderElectionDriverFactory(FlinkKubeClient kubeClient,
KubernetesLeaderElectionConfiguration leaderConfig) |
Modifier and Type | Method and Description |
---|---|
KubernetesLeaderElector |
FlinkKubeClient.createLeaderElector(KubernetesLeaderElectionConfiguration leaderElectionConfiguration,
KubernetesLeaderElector.LeaderCallbackHandler leaderCallbackHandler)
Create a leader elector service based on Kubernetes api.
|
KubernetesLeaderElector |
Fabric8FlinkKubeClient.createLeaderElector(KubernetesLeaderElectionConfiguration leaderElectionConfiguration,
KubernetesLeaderElector.LeaderCallbackHandler leaderCallbackHandler) |
Constructor and Description |
---|
KubernetesLeaderElector(io.fabric8.kubernetes.client.NamespacedKubernetesClient kubernetesClient,
KubernetesLeaderElectionConfiguration leaderConfig,
KubernetesLeaderElector.LeaderCallbackHandler leaderCallbackHandler) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.