com.netflix.curator.x.discovery.details

Class ServiceProviderImpl<T>

java.lang.Object

com.netflix.curator.x.discovery.details.ServiceProviderImpl<T>

All Implemented Interfaces:

ServiceProvider<T>, java.io.Closeable, java.lang.AutoCloseable

public class ServiceProviderImpl<T>
extends java.lang.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

Constructor and Description
ServiceProviderImpl(ServiceDiscoveryImpl<T> discovery, java.lang.String serviceName, ProviderStrategy<T> providerStrategy, java.util.concurrent.ThreadFactory threadFactory, int refreshPaddingMs)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
ServiceInstance<T>	getInstance() Return an instance for a single use.
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 Detail

ServiceProviderImpl

public ServiceProviderImpl(ServiceDiscoveryImpl<T> discovery,
                   java.lang.String serviceName,
                   ProviderStrategy<T> providerStrategy,
                   java.util.concurrent.ThreadFactory threadFactory,
                   int refreshPaddingMs)

Method Detail

start

public void start()
           throws java.lang.Exception

The provider must be started before use

Specified by:

start in interface ServiceProvider<T>

Throws:

java.lang.Exception - any errors

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

getInstance

public ServiceInstance<T> getInstance()
                               throws java.lang.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:

java.lang.Exception - any errors