Class KubernetesClientUtils
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils
-
public class KubernetesClientUtils extends java.lang.Object
Kubernetes client utils.
-
-
Constructor Summary
Constructors Constructor Description KubernetesClientUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T extends AbstractFlinkResource<?,?>>
voidapplyToStoredCr(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, T cr, java.util.function.Consumer<T> function)
static io.fabric8.kubernetes.client.KubernetesClient
getKubernetesClient(FlinkOperatorConfiguration operatorConfig, org.apache.flink.metrics.MetricGroup metricGroup)
static io.fabric8.kubernetes.client.KubernetesClient
getKubernetesClient(FlinkOperatorConfiguration operatorConfig, org.apache.flink.metrics.MetricGroup metricGroup, io.fabric8.kubernetes.client.Config kubernetesClientConfig)
-
-
-
Method Detail
-
getKubernetesClient
public static io.fabric8.kubernetes.client.KubernetesClient getKubernetesClient(FlinkOperatorConfiguration operatorConfig, org.apache.flink.metrics.MetricGroup metricGroup)
-
getKubernetesClient
@VisibleForTesting public static io.fabric8.kubernetes.client.KubernetesClient getKubernetesClient(FlinkOperatorConfiguration operatorConfig, org.apache.flink.metrics.MetricGroup metricGroup, io.fabric8.kubernetes.client.Config kubernetesClientConfig)
-
applyToStoredCr
public static <T extends AbstractFlinkResource<?,?>> void applyToStoredCr(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, T cr, java.util.function.Consumer<T> function)
-
-