Package org.distributeme.core.routing.blacklisting.intervalbased.withblacklistingtimeout

Class ErrorsPerIntervalWithBlacklistTimeStrategy

java.lang.Object

org.distributeme.core.routing.blacklisting.intervalbased.withblacklistingtimeout.ErrorsPerIntervalWithBlacklistTimeStrategy

All Implemented Interfaces:

BlacklistingStrategy

public class ErrorsPerIntervalWithBlacklistTimeStrategy
extends Object
implements BlacklistingStrategy

A service instance is blacklisted after x successive intervals of length y, in which z failures occur. The blacklisting condition is fullfilled as soon as the error count is reached within the current interval. After blacklisting b seconds the service instance is going to be whitelisted again. During b no further error checks are done. After whitelisting, the error detection starts again. b=20, x=2, y=10, z=1

 0-----4------10-------16-----20------------30------36-----40(Seconds)->
       ^               ^                            ^
       |               |----------------------------|
     Error        Error ->  Blacklisted           Whitelisted again
 

b, x, y and z are configurable via configureme. b: blacklistTime x: requiredNumberOfIntervalsWithErrors y: intervalDurationInSeconds z: errorsPerIntervalThreshold If no valid configuration is given, then getDecision() always returns false.

Author:

rboehling

Constructor Summary

Constructors

Constructor	Description
ErrorsPerIntervalWithBlacklistTimeStrategy()

Method Summary

Modifier and Type	Method	Description
boolean	isBlacklisted(String instanceId)	Returns the blacklist decision for given service instanceID.
void	notifyCallFailed(ClientSideCallContext clientSideCallContext)	Called by the router when a call to service instance failed.
void	setConfiguration(GenericRouterConfiguration configuration)	Called by the router upon configuration change.

Methods inherited from class java.lang.Object

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

Constructor Details

ErrorsPerIntervalWithBlacklistTimeStrategy

public ErrorsPerIntervalWithBlacklistTimeStrategy()

Method Details

isBlacklisted

public boolean isBlacklisted(String instanceId)

Description copied from interface: BlacklistingStrategy

Returns the blacklist decision for given service instanceID.

Specified by:

isBlacklisted in interface BlacklistingStrategy

notifyCallFailed

public void notifyCallFailed(ClientSideCallContext clientSideCallContext)

Description copied from interface: BlacklistingStrategy

Called by the router when a call to service instance failed.

Specified by:

notifyCallFailed in interface BlacklistingStrategy

Parameters:

clientSideCallContext -

setConfiguration

public void setConfiguration(GenericRouterConfiguration configuration)

Description copied from interface: BlacklistingStrategy

Called by the router upon configuration change.

Specified by:

setConfiguration in interface BlacklistingStrategy

Parameters:

configuration -