org.apache.flink.kubernetes.kubeclient.services

Class LoadBalancerService

java.lang.Object

org.apache.flink.kubernetes.kubeclient.services.ServiceType

org.apache.flink.kubernetes.kubeclient.services.LoadBalancerService

public class LoadBalancerService
extends ServiceType

The service type of LoadBalancer.

Field Summary

Fields

Modifier and Type	Field and Description
static LoadBalancerService	INSTANCE

Constructor Summary

Constructors

Constructor and Description
LoadBalancerService()

Method Summary

Modifier and Type	Method and Description
io.fabric8.kubernetes.api.model.Service	buildUpInternalService(KubernetesJobManagerParameters kubernetesJobManagerParameters) Build up the internal service template, according to the jobManager parameters.
Optional<Endpoint>	getRestEndpoint(io.fabric8.kubernetes.api.model.Service targetService, io.fabric8.kubernetes.client.NamespacedKubernetesClient internalClient, KubernetesConfigOptions.NodePortAddressType nodePortAddressType) Gets the rest endpoint from the kubernetes service.
int	getRestPort(io.fabric8.kubernetes.api.model.ServicePort port) Gets the rest port from the service port.
String	getType() Gets the type of the target kubernetes service.

Methods inherited from class org.apache.flink.kubernetes.kubeclient.services.ServiceType

buildUpExternalRestService, classify, getRestPortFromExternalService

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final LoadBalancerService INSTANCE

Constructor Detail

LoadBalancerService

public LoadBalancerService()

Method Detail

buildUpInternalService

public io.fabric8.kubernetes.api.model.Service buildUpInternalService(KubernetesJobManagerParameters kubernetesJobManagerParameters)

Description copied from class: ServiceType

Build up the internal service template, according to the jobManager parameters.

Specified by:

buildUpInternalService in class ServiceType

Parameters:

kubernetesJobManagerParameters - the parameters of jobManager.

Returns:

the internal service

getRestEndpoint

public Optional<Endpoint> getRestEndpoint(io.fabric8.kubernetes.api.model.Service targetService,
                                          io.fabric8.kubernetes.client.NamespacedKubernetesClient internalClient,
                                          KubernetesConfigOptions.NodePortAddressType nodePortAddressType)

Description copied from class: ServiceType

Gets the rest endpoint from the kubernetes service.

Specified by:

getRestEndpoint in class ServiceType

Parameters:

targetService - the target service to retrieve from.

internalClient - the client to interact with api server.

nodePortAddressType - the target address type of the node.

Returns:

the rest endpoint.

getRestPort

public int getRestPort(io.fabric8.kubernetes.api.model.ServicePort port)

Description copied from class: ServiceType

Gets the rest port from the service port.

Specified by:

getRestPort in class ServiceType

Parameters:

port - the target service port.

Returns:

the rest port.

getType

public String getType()

Description copied from class: ServiceType

Gets the type of the target kubernetes service.

Specified by:

getType in class ServiceType

Returns:

the type of the target kubernetes service.