public class KubernetesClientServiceDiscovery
extends org.apache.camel.impl.cloud.DefaultServiceDiscovery
Constructor and Description |
---|
KubernetesClientServiceDiscovery(KubernetesConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
protected void |
addServers(String name,
List<org.apache.camel.cloud.ServiceDefinition> servers,
io.fabric8.kubernetes.api.model.EndpointPort port,
io.fabric8.kubernetes.api.model.EndpointSubset subset) |
protected void |
doStart() |
protected void |
doStop() |
protected KubernetesConfiguration |
getConfiguration() |
String |
getNamespace() |
String |
getPortName() |
List<org.apache.camel.cloud.ServiceDefinition> |
getServices(String name) |
protected org.apache.camel.cloud.ServiceDefinition |
newServer(String serviceName,
io.fabric8.kubernetes.api.model.EndpointAddress address,
io.fabric8.kubernetes.api.model.EndpointPort port) |
String |
toString() |
getCamelContext, setCamelContext
public KubernetesClientServiceDiscovery(KubernetesConfiguration configuration)
public List<org.apache.camel.cloud.ServiceDefinition> getServices(String name)
getServices
in interface org.apache.camel.cloud.ServiceDiscovery
getServices
in class org.apache.camel.impl.cloud.DefaultServiceDiscovery
protected void addServers(String name, List<org.apache.camel.cloud.ServiceDefinition> servers, io.fabric8.kubernetes.api.model.EndpointPort port, io.fabric8.kubernetes.api.model.EndpointSubset subset)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.cloud.DefaultServiceDiscovery
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.cloud.DefaultServiceDiscovery
Exception
protected org.apache.camel.cloud.ServiceDefinition newServer(String serviceName, io.fabric8.kubernetes.api.model.EndpointAddress address, io.fabric8.kubernetes.api.model.EndpointPort port)
protected KubernetesConfiguration getConfiguration()
public String getNamespace()
public String getPortName()
Apache Camel