Package | Description |
---|---|
org.apache.flink.kubernetes.kubeclient | |
org.apache.flink.kubernetes.kubeclient.resources | |
org.apache.flink.kubernetes.utils |
Modifier and Type | Method and Description |
---|---|
Optional<KubernetesConfigMap> |
FlinkKubeClient.getConfigMap(String name)
Get the ConfigMap with specified name.
|
Optional<KubernetesConfigMap> |
Fabric8FlinkKubeClient.getConfigMap(String name) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
FlinkKubeClient.createConfigMap(KubernetesConfigMap configMap)
Create the ConfigMap with specified content.
|
CompletableFuture<Void> |
Fabric8FlinkKubeClient.createConfigMap(KubernetesConfigMap configMap) |
Modifier and Type | Method and Description |
---|---|
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.
|
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) |
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–2023 The Apache Software Foundation. All rights reserved.