com.netflix.discovery.shared.transport.decorator

Class SessionedEurekaHttpClient

java.lang.Object

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

com.netflix.discovery.shared.transport.decorator.SessionedEurekaHttpClient

All Implemented Interfaces:

EurekaHttpClient

public class SessionedEurekaHttpClient
extends EurekaHttpClientDecorator

SessionedEurekaHttpClient enforces full reconnect at a regular interval (a session), preventing a client to sticking to a particular Eureka server instance forever. This in turn guarantees even load distribution in case of cluster topology change.

Nested Class Summary

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

EurekaHttpClientDecorator.RequestExecutor<R>, EurekaHttpClientDecorator.RequestType

Constructor Summary

Constructors

Constructor and Description
SessionedEurekaHttpClient(java.lang.String name, EurekaHttpClientFactory clientFactory, long sessionDurationMs)

Method Summary

Modifier and Type	Method and Description
protected <R> EurekaHttpResponse<R>	execute(EurekaHttpClientDecorator.RequestExecutor<R> requestExecutor)
long	getCurrentSessionDuration()
protected long	randomizeSessionDuration(long sessionDurationMs)
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

Constructor Detail

SessionedEurekaHttpClient

public SessionedEurekaHttpClient(java.lang.String name,
                                 EurekaHttpClientFactory clientFactory,
                                 long sessionDurationMs)

Method Detail

execute

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

Specified by:

execute in class EurekaHttpClientDecorator

shutdown

public void shutdown()

randomizeSessionDuration

protected long randomizeSessionDuration(long sessionDurationMs)

Returns:

a randomized sessionDuration in ms calculated as +/- an additional amount in [0, sessionDurationMs/2]

getCurrentSessionDuration

@Monitor(name="eurekaClient.transport.currentSessionDuration",
         description="Duration of the current session",
         type=GAUGE)
public long getCurrentSessionDuration()