org.apache.dubbo.registry.kubernetes

Class KubernetesServiceDiscovery

java.lang.Object

org.apache.dubbo.registry.client.AbstractServiceDiscovery

org.apache.dubbo.registry.kubernetes.KubernetesServiceDiscovery

All Implemented Interfaces:

Comparable<Prioritized>, Prioritized, ServiceDiscovery, RegistryService

public class KubernetesServiceDiscovery
extends AbstractServiceDiscovery

Field Summary

Fields

Modifier and Type	Field and Description
static String	KUBERNETES_PROPERTIES_KEY

Fields inherited from interface org.apache.dubbo.common.lang.Prioritized

COMPARATOR, MAX_PRIORITY, MIN_PRIORITY, NORMAL_PRIORITY

Constructor Summary

Constructors

Constructor and Description
KubernetesServiceDiscovery(ApplicationModel applicationModel, URL registryURL)

Method Summary

Modifier and Type	Method and Description
void	addServiceInstancesChangedListener(ServiceInstancesChangedListener listener)
void	doDestroy()
void	doRegister(ServiceInstance serviceInstance)
void	doUnregister(ServiceInstance serviceInstance)
void	doUpdate(ServiceInstance serviceInstance) Comparing to AbstractServiceDiscovery.doUpdate(ServiceInstance), unregister() is unnecessary here.
List<ServiceInstance>	getInstances(String serviceName)
Set<String>	getServices()
URL	getUrl()
void	setCurrentHostname(String currentHostname) Deprecated.
void	setKubernetesClient(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient) Deprecated.

Methods inherited from class org.apache.dubbo.registry.client.AbstractServiceDiscovery

destroy, getLocalInstance, getLocalMetadata, getRemoteMetadata, getRemoteMetadata, isDestroy, lookup, register, register, subscribe, unregister, unregister, unsubscribe, update

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.dubbo.registry.client.ServiceDiscovery

createListener, getDelay, removeServiceInstancesChangedListener, toString

Methods inherited from interface org.apache.dubbo.common.lang.Prioritized

compareTo, getPriority

Field Detail

KUBERNETES_PROPERTIES_KEY

public static final String KUBERNETES_PROPERTIES_KEY

See Also:

Constant Field Values

Constructor Detail

KubernetesServiceDiscovery

public KubernetesServiceDiscovery(ApplicationModel applicationModel,
                                  URL registryURL)

Method Detail

doDestroy

public void doDestroy()

Specified by:

doDestroy in class AbstractServiceDiscovery

doRegister

public void doRegister(ServiceInstance serviceInstance)
                throws RuntimeException

Specified by:

doRegister in class AbstractServiceDiscovery

Throws:

RuntimeException

doUpdate

public void doUpdate(ServiceInstance serviceInstance)
              throws RuntimeException

Comparing to AbstractServiceDiscovery.doUpdate(ServiceInstance), unregister() is unnecessary here.

Overrides:

doUpdate in class AbstractServiceDiscovery

Throws:

RuntimeException

doUnregister

public void doUnregister(ServiceInstance serviceInstance)
                  throws RuntimeException

Specified by:

doUnregister in class AbstractServiceDiscovery

Throws:

RuntimeException

getServices

public Set<String> getServices()

getInstances

public List<ServiceInstance> getInstances(String serviceName)
                                   throws NullPointerException

Throws:

NullPointerException

addServiceInstancesChangedListener

public void addServiceInstancesChangedListener(ServiceInstancesChangedListener listener)
                                        throws NullPointerException,
                                               IllegalArgumentException

Throws:

NullPointerException

IllegalArgumentException

getUrl

public URL getUrl()

Specified by:

getUrl in interface ServiceDiscovery

Overrides:

getUrl in class AbstractServiceDiscovery

setCurrentHostname

@Deprecated
public void setCurrentHostname(String currentHostname)

Deprecated.

UT used only

setKubernetesClient

@Deprecated
public void setKubernetesClient(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient)

Deprecated.

UT used only