com.netflix.discovery.shared.transport.decorator

Class RetryableEurekaHttpClient

java.lang.Object

com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator

com.netflix.discovery.shared.transport.decorator.RetryableEurekaHttpClient

All Implemented Interfaces:

EurekaHttpClient

public class RetryableEurekaHttpClient
extends EurekaHttpClientDecorator

RetryableEurekaHttpClient retries failed requests on subsequent servers in the cluster. It maintains also simple quarantine list, so operations are not retried again on servers that are not reachable at the moment.

Quarantine

All the servers to which communication failed are put on the quarantine list. First successful execution clears this list, which makes those server eligible for serving future requests. The list is also cleared once all available servers are exhausted.

5xx

If 5xx status code is returned, ServerStatusEvaluator predicate evaluates if the retries should be retried on another server, or the response with this status code returned to the client.

Nested Class Summary

Nested classes/interfaces inherited from class com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator

EurekaHttpClientDecorator.RequestExecutor<R>, EurekaHttpClientDecorator.RequestType

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_NUMBER_OF_RETRIES

Constructor Summary

Constructors

Constructor and Description
RetryableEurekaHttpClient(java.lang.String name, EurekaTransportConfig transportConfig, ClusterResolver clusterResolver, TransportClientFactory clientFactory, ServerStatusEvaluator serverStatusEvaluator, int numberOfRetries)

Method Summary

Modifier and Type	Method and Description
static EurekaHttpClientFactory	createFactory(java.lang.String name, EurekaTransportConfig transportConfig, ClusterResolver<EurekaEndpoint> clusterResolver, TransportClientFactory delegateFactory, ServerStatusEvaluator serverStatusEvaluator)
protected <R> EurekaHttpResponse<R>	execute(EurekaHttpClientDecorator.RequestExecutor<R> requestExecutor)
long	getQuarantineSetSize()
void	shutdown()

Methods inherited from class com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator

cancel, deleteStatusOverride, getApplication, getApplications, getDelta, getInstance, getInstance, getSecureVip, getVip, register, sendHeartBeat, statusUpdate

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_NUMBER_OF_RETRIES

public static final int DEFAULT_NUMBER_OF_RETRIES

See Also:

Constant Field Values

Constructor Detail

RetryableEurekaHttpClient

public RetryableEurekaHttpClient(java.lang.String name,
                                 EurekaTransportConfig transportConfig,
                                 ClusterResolver clusterResolver,
                                 TransportClientFactory clientFactory,
                                 ServerStatusEvaluator serverStatusEvaluator,
                                 int numberOfRetries)

Method Detail

shutdown

public void shutdown()

execute

protected <R> EurekaHttpResponse<R> execute(EurekaHttpClientDecorator.RequestExecutor<R> requestExecutor)

Specified by:

execute in class EurekaHttpClientDecorator

createFactory

public static EurekaHttpClientFactory createFactory(java.lang.String name,
                                                    EurekaTransportConfig transportConfig,
                                                    ClusterResolver<EurekaEndpoint> clusterResolver,
                                                    TransportClientFactory delegateFactory,
                                                    ServerStatusEvaluator serverStatusEvaluator)

getQuarantineSetSize

@Monitor(name="eurekaClient.transport.quarantineSize",
         description="number of servers quarantined",
         type=GAUGE)
public long getQuarantineSetSize()