Modifier and Type | Method and Description |
---|---|
LeaderInformation |
KubernetesMultipleComponentLeaderRetrievalDriverFactory.extractLeaderInformation(KubernetesConfigMap configMap) |
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 |
---|---|
Optional<KubernetesConfigMap> |
Fabric8FlinkKubeClient.getConfigMap(String name) |
Optional<KubernetesConfigMap> |
FlinkKubeClient.getConfigMap(String name)
Get the ConfigMap with specified name.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
Fabric8FlinkKubeClient.createConfigMap(KubernetesConfigMap configMap) |
CompletableFuture<Void> |
FlinkKubeClient.createConfigMap(KubernetesConfigMap configMap)
Create the ConfigMap with specified content.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Boolean> |
Fabric8FlinkKubeClient.checkAndUpdateConfigMap(String configMapName,
java.util.function.Function<KubernetesConfigMap,Optional<KubernetesConfigMap>> updateFunction) |
CompletableFuture<Boolean> |
Fabric8FlinkKubeClient.checkAndUpdateConfigMap(String configMapName,
java.util.function.Function<KubernetesConfigMap,Optional<KubernetesConfigMap>> updateFunction) |
CompletableFuture<Boolean> |
FlinkKubeClient.checkAndUpdateConfigMap(String configMapName,
java.util.function.Function<KubernetesConfigMap,Optional<KubernetesConfigMap>> updateFunction)
Update an existing ConfigMap with the data.
|
CompletableFuture<Boolean> |
FlinkKubeClient.checkAndUpdateConfigMap(String configMapName,
java.util.function.Function<KubernetesConfigMap,Optional<KubernetesConfigMap>> updateFunction)
Update an existing ConfigMap with the data.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
KubernetesLeaderElector.hasLeadership(KubernetesConfigMap configMap,
String lockIdentity) |
Modifier and Type | Method and Description |
---|---|
static KubernetesConfigMap |
KubernetesUtils.checkConfigMaps(List<KubernetesConfigMap> configMaps,
String expectedConfigMapName)
Check the ConfigMap list should only contain the expected one.
|
Modifier and Type | Method and Description |
---|---|
static LeaderInformation |
KubernetesUtils.getLeaderInformationFromConfigMap(KubernetesConfigMap configMap)
Get the
LeaderInformation from ConfigMap. |
Modifier and Type | Method and Description |
---|---|
static KubernetesConfigMap |
KubernetesUtils.checkConfigMaps(List<KubernetesConfigMap> configMaps,
String expectedConfigMapName)
Check the ConfigMap list should only contain the expected one.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.