com.netflix.astyanax.connectionpool

Interface LatencyScoreStrategy

All Known Implementing Classes:

AbstractLatencyScoreStrategyImpl, EmaLatencyScoreStrategyImpl, EmptyLatencyScoreStrategyImpl, SmaLatencyScoreStrategyImpl

public interface LatencyScoreStrategy

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	LatencyScoreStrategy.Instance Single instance of this strategy associated with an endpoint
static interface	LatencyScoreStrategy.Listener

Method Summary

Methods

Modifier and Type	Method and Description
LatencyScoreStrategy.Instance	createInstance() Create a new instance to associate with an endpoint
int	getBlockedThreshold()
double	getKeepRatio()
int	getResetInterval()
double	getScoreThreshold()
int	getUpdateInterval()
void	removeInstance(LatencyScoreStrategy.Instance instance) Remove the instance for an endpoint that is no longer being tracked
void	reset() Reset all instance scores
void	shutdown() Shutdown the threads created by calling start()
<CL> java.util.List<HostConnectionPool<CL>>	sortAndfilterPartition(java.util.List<HostConnectionPool<CL>> pools, java.util.concurrent.atomic.AtomicBoolean prioritized) Sorts and filters a list of hosts by looking at their up state and score.
void	start(LatencyScoreStrategy.Listener listener) Start updating stats for instances created using createInstance.
void	update() Update all instance scores

Method Detail

getUpdateInterval

int getUpdateInterval()

Returns:

Return interval for updating the scores

getResetInterval

int getResetInterval()

Returns:

Return interval for clearing scores

getScoreThreshold

double getScoreThreshold()

Returns:

Return threshold after which hosts will be excluded if their score is getScoreThreshold() times larger than the best performing node

getBlockedThreshold

int getBlockedThreshold()

Returns:

Return threshold of blocked connections after which a host is excluded

getKeepRatio

double getKeepRatio()

Returns:

Get ratio for calculating minimum number of hosts that most remain in the pool

update

void update()

Update all instance scores

reset

void reset()

Reset all instance scores

createInstance

LatencyScoreStrategy.Instance createInstance()

Create a new instance to associate with an endpoint

Returns:

removeInstance

void removeInstance(LatencyScoreStrategy.Instance instance)

Remove the instance for an endpoint that is no longer being tracked

Parameters:

instance -

start

void start(LatencyScoreStrategy.Listener listener)

Start updating stats for instances created using createInstance. This usually spawns an update thread as well as a reset thread operating at configurable intervals

Parameters:

listener -

shutdown

void shutdown()

Shutdown the threads created by calling start()

sortAndfilterPartition

<CL> java.util.List<HostConnectionPool<CL>> sortAndfilterPartition(java.util.List<HostConnectionPool<CL>> pools,
                                                                 java.util.concurrent.atomic.AtomicBoolean prioritized)

Sorts and filters a list of hosts by looking at their up state and score.

Type Parameters:

CL -

Parameters:

pools -

prioritized - - Will be set to true if the filtered data is prioritized or not. If prioritized then the first element should be selected from by the load balancing strategy. Otherwise round robin could be used.

Returns: