com.netflix.discovery.shared.resolver

Class AsyncResolver<T extends EurekaEndpoint>

java.lang.Object

com.netflix.discovery.shared.resolver.AsyncResolver<T>

All Implemented Interfaces:

ClosableResolver<T>, ClusterResolver<T>

public class AsyncResolver<T extends EurekaEndpoint>
extends java.lang.Object
implements ClosableResolver<T>

An async resolver that keeps a cached version of the endpoint list value for gets, and updates this cache periodically in a different thread.

Constructor Summary

Constructors

Constructor and Description
AsyncResolver(java.lang.String name, ClusterResolver<T> delegate, int executorThreadPoolSize, int refreshIntervalMs, int warmUpTimeoutMs) Create an async resolver with an empty initial value.
AsyncResolver(java.lang.String name, ClusterResolver<T> delegate, java.util.List<T> initialValues, int executorThreadPoolSize, int refreshIntervalMs) Create an async resolver with a preset initial value.

Method Summary

Modifier and Type	Method and Description
java.util.List<T>	getClusterEndpoints()
long	getEndpointsSize()
long	getLastLoadTimestamp()
java.lang.String	getRegion()
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncResolver

public AsyncResolver(java.lang.String name,
                     ClusterResolver<T> delegate,
                     int executorThreadPoolSize,
                     int refreshIntervalMs,
                     int warmUpTimeoutMs)

Create an async resolver with an empty initial value. When this resolver is called for the first time, an initial warm up will be executed before scheduling the periodic update task.

AsyncResolver

public AsyncResolver(java.lang.String name,
                     ClusterResolver<T> delegate,
                     java.util.List<T> initialValues,
                     int executorThreadPoolSize,
                     int refreshIntervalMs)

Create an async resolver with a preset initial value. WHen this resolver is called for the first time, there will be no warm up and the initial value will be returned. The periodic update task will not be scheduled until after the first time getClusterEndpoints call.

Method Detail

shutdown

public void shutdown()

Specified by:

shutdown in interface ClosableResolver<T extends EurekaEndpoint>

getRegion

public java.lang.String getRegion()

Specified by:

getRegion in interface ClusterResolver<T extends EurekaEndpoint>

getClusterEndpoints

public java.util.List<T> getClusterEndpoints()

Specified by:

getClusterEndpoints in interface ClusterResolver<T extends EurekaEndpoint>

getLastLoadTimestamp

@Monitor(name="eurekaClient.resolver.lastLoadTimestamp",
         description="How much time has passed from last successful async load",
         type=GAUGE)
public long getLastLoadTimestamp()

getEndpointsSize

@Monitor(name="eurekaClient.resolver.endpointsSize",
         description="How many records are the in the endpoints ref",
         type=GAUGE)
public long getEndpointsSize()