Package org.apache.curator.x.discovery.details

Class ServiceProviderImpl<T>

java.lang.Object

org.apache.curator.x.discovery.details.ServiceProviderImpl<T>

All Implemented Interfaces:

Closeable, AutoCloseable, ServiceProvider<T>

public class ServiceProviderImpl<T>
extends Object
implements ServiceProvider<T>

The main interface for Service Discovery. Encapsulates the discovery service for a particular named service along with a provider strategy.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ServiceProviderImpl(ServiceDiscoveryImpl<T> discovery, String serviceName, ProviderStrategy<T> providerStrategy, ThreadFactory threadFactory, ExecutorService executorService, List<InstanceFilter<T>> filters, DownInstancePolicy downInstancePolicy)
	ServiceProviderImpl(ServiceDiscoveryImpl<T> discovery, String serviceName, ProviderStrategy<T> providerStrategy, ThreadFactory threadFactory, List<InstanceFilter<T>> filters, DownInstancePolicy downInstancePolicy)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the provider.
Collection<ServiceInstance<T>>	getAllInstances()	Return the current available set of instances IMPORTANT: users should not hold on to the instance returned.
ServiceInstance<T>	getInstance()	Return an instance for a single use.
void	noteError(ServiceInstance<T> instance)	Take note of an error connecting to the given instance.
void	start()	The provider must be started before use

Methods inherited from class java.lang.Object

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

Constructor Details

ServiceProviderImpl

public ServiceProviderImpl(ServiceDiscoveryImpl<T> discovery,
 String serviceName,
 ProviderStrategy<T> providerStrategy,
 ThreadFactory threadFactory,
 List<InstanceFilter<T>> filters,
 DownInstancePolicy downInstancePolicy)

ServiceProviderImpl

protected ServiceProviderImpl(ServiceDiscoveryImpl<T> discovery,
 String serviceName,
 ProviderStrategy<T> providerStrategy,
 ThreadFactory threadFactory,
 ExecutorService executorService,
 List<InstanceFilter<T>> filters,
 DownInstancePolicy downInstancePolicy)

Method Details

start

public void start()
           throws Exception

The provider must be started before use

Specified by:

start in interface ServiceProvider<T>

Throws:

Exception - any errors

close

public void close()
           throws IOException

Close the provider. Note: it's the provider's responsibility to close any caches it manages

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface ServiceProvider<T>

Throws:

IOException

getAllInstances

public Collection<ServiceInstance<T>> getAllInstances()
                                               throws Exception

Return the current available set of instances IMPORTANT: users should not hold on to the instance returned. They should always get a fresh list.

Specified by:

getAllInstances in interface ServiceProvider<T>

Returns:

all known instances

Throws:

Exception - any errors

getInstance

public ServiceInstance<T> getInstance()
                               throws Exception

Return an instance for a single use. IMPORTANT: users should not hold on to the instance returned. They should always get a fresh instance.

Specified by:

getInstance in interface ServiceProvider<T>

Returns:

the instance to use

Throws:

Exception - any errors

noteError

public void noteError(ServiceInstance<T> instance)

Description copied from interface: ServiceProvider

Take note of an error connecting to the given instance. The instance will potentially be marked as "down" depending on the DownInstancePolicy.

Specified by:

noteError in interface ServiceProvider<T>

Parameters:

instance - instance that had an error