io.soabase.zookeeper.discovery

Class ZooKeeperDiscovery

java.lang.Object

com.google.common.cache.CacheLoader<String,org.apache.curator.x.discovery.ServiceProvider<Payload>>

io.soabase.zookeeper.discovery.ZooKeeperDiscovery

All Implemented Interfaces:

com.google.common.cache.RemovalListener<String,org.apache.curator.x.discovery.ServiceProvider<Payload>>, io.dropwizard.lifecycle.Managed, Discovery, ExtendedDiscovery

public class ZooKeeperDiscovery
extends com.google.common.cache.CacheLoader<String,org.apache.curator.x.discovery.ServiceProvider<Payload>>
implements ExtendedDiscovery, io.dropwizard.lifecycle.Managed, com.google.common.cache.RemovalListener<String,org.apache.curator.x.discovery.ServiceProvider<Payload>>

Nested Class Summary

Nested classes/interfaces inherited from class com.google.common.cache.CacheLoader

com.google.common.cache.CacheLoader.InvalidCacheLoadException, com.google.common.cache.CacheLoader.UnsupportedLoadingOperationException

Constructor Summary

Constructors

Constructor and Description
ZooKeeperDiscovery(org.apache.curator.framework.CuratorFramework curator, ZooKeeperDiscoveryFactory factory, SoaInfo soaInfo, io.dropwizard.setup.Environment environment, Collection<String> instanceDeploymentGroups)

Method Summary

Modifier and Type	Method and Description
Collection<DiscoveryInstance>	getAllInstances(String serviceName)
DiscoveryInstance	getInstance(String serviceName)
Collection<String>	getServiceNames()
org.apache.curator.x.discovery.ServiceProvider<Payload>	load(String serviceName)
void	noteError(String serviceName, DiscoveryInstance errorInstance, int statusCode, Throwable exception)
void	noteSuccess(String serviceName, DiscoveryInstance instance, int statusCode)
void	onRemoval(com.google.common.cache.RemovalNotification<String,org.apache.curator.x.discovery.ServiceProvider<Payload>> notification)
Collection<DiscoveryInstance>	queryForAllInstances(String serviceName)
Collection<String>	queryForServiceNames()
void	setForcedState(String serviceName, String instanceId, ForcedState forcedState)
void	setHealthyState(HealthyState newHealthyState)
void	setMetaData(Map<String,String> newMetaData)
void	start()
void	stop()

Methods inherited from class com.google.common.cache.CacheLoader

asyncReloading, from, from, loadAll, reload

Methods inherited from class java.lang.Object

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

Constructor Detail

ZooKeeperDiscovery

public ZooKeeperDiscovery(org.apache.curator.framework.CuratorFramework curator,
                          ZooKeeperDiscoveryFactory factory,
                          SoaInfo soaInfo,
                          io.dropwizard.setup.Environment environment,
                          Collection<String> instanceDeploymentGroups)

Method Detail

getServiceNames

public Collection<String> getServiceNames()

Specified by:

getServiceNames in interface Discovery

queryForServiceNames

public Collection<String> queryForServiceNames()

Specified by:

queryForServiceNames in interface ExtendedDiscovery

setHealthyState

public void setHealthyState(HealthyState newHealthyState)

Specified by:

setHealthyState in interface Discovery

setMetaData

public void setMetaData(Map<String,String> newMetaData)

Specified by:

setMetaData in interface Discovery

setForcedState

public void setForcedState(String serviceName,
                           String instanceId,
                           ForcedState forcedState)

Specified by:

setForcedState in interface ExtendedDiscovery

load

public org.apache.curator.x.discovery.ServiceProvider<Payload> load(String serviceName)
                                                             throws Exception

Specified by:

load in class com.google.common.cache.CacheLoader<String,org.apache.curator.x.discovery.ServiceProvider<Payload>>

Throws:

Exception

onRemoval

public void onRemoval(com.google.common.cache.RemovalNotification<String,org.apache.curator.x.discovery.ServiceProvider<Payload>> notification)

Specified by:

onRemoval in interface com.google.common.cache.RemovalListener<String,org.apache.curator.x.discovery.ServiceProvider<Payload>>

queryForAllInstances

public Collection<DiscoveryInstance> queryForAllInstances(String serviceName)

Specified by:

queryForAllInstances in interface ExtendedDiscovery

getAllInstances

public Collection<DiscoveryInstance> getAllInstances(String serviceName)

Specified by:

getAllInstances in interface Discovery

getInstance

public DiscoveryInstance getInstance(String serviceName)

Specified by:

getInstance in interface Discovery

noteError

public void noteError(String serviceName,
                      DiscoveryInstance errorInstance,
                      int statusCode,
                      Throwable exception)

Specified by:

noteError in interface Discovery

noteSuccess

public void noteSuccess(String serviceName,
                        DiscoveryInstance instance,
                        int statusCode)

Specified by:

noteSuccess in interface Discovery

start

public void start()
           throws Exception

Specified by:

start in interface io.dropwizard.lifecycle.Managed

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface io.dropwizard.lifecycle.Managed

Throws:

Exception