Package org.apache.flink.kubernetes.operator.autoscaler

Class AutoscalerInfoManager

java.lang.Object

org.apache.flink.kubernetes.operator.autoscaler.AutoscalerInfoManager

public class AutoscalerInfoManager
extends java.lang.Object

Class responsible to managing the creation and retrieval of AutoScalerInfo objects.

Constructor Summary

Constructors

Constructor	Description
AutoscalerInfoManager()

Method Summary

Modifier and Type	Method	Description
java.util.Optional<AutoScalerInfo>	getInfo(AbstractFlinkResource<?,?> cr, io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)
protected java.util.Optional<io.fabric8.kubernetes.api.model.ConfigMap>	getInfoFromKubernetes(AbstractFlinkResource<?,?> cr, io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)
AutoScalerInfo	getOrCreateInfo(AbstractFlinkResource<?,?> cr, io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)
void	removeInfoFromCache(AbstractFlinkResource<?,?> cr)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AutoscalerInfoManager

public AutoscalerInfoManager()

Method Detail

getOrCreateInfo

public AutoScalerInfo getOrCreateInfo(AbstractFlinkResource<?,?> cr,
                                      io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)

getInfo

public java.util.Optional<AutoScalerInfo> getInfo(AbstractFlinkResource<?,?> cr,
                                                  io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)

removeInfoFromCache

public void removeInfoFromCache(AbstractFlinkResource<?,?> cr)

getInfoFromKubernetes

@VisibleForTesting
protected java.util.Optional<io.fabric8.kubernetes.api.model.ConfigMap> getInfoFromKubernetes(AbstractFlinkResource<?,?> cr,
                                                                                              io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)