services.moleculer.breaker

Class CircuitBreaker

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.service.ServiceInvoker

services.moleculer.service.DefaultServiceInvoker

services.moleculer.breaker.CircuitBreaker

All Implemented Interfaces:

java.lang.Runnable, MetricConstants, MoleculerLifecycle

public class CircuitBreaker
extends DefaultServiceInvoker
implements java.lang.Runnable, MetricConstants

Special service invoker with retry logic + circuit breaker.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	cleanup Cleanup period time, in SECONDS (0 = disable cleanup process)
protected java.util.HashMap<EndpointKey,ErrorCounter>	errorCounters
protected java.util.Set<java.lang.Class<? extends java.lang.Throwable>>	ignoredTypes
protected long	lastCleanup
protected long	lockTimeout Half-open timeout in MILLISECONDS
protected int	maxErrors Maximum number of errors in time-window
protected int	maxSameNodes Exit from "maxTries" loop, when strategy returns number of "maxSameNodes" corresponding node IDs
protected int	maxTries Number of max tries
protected Metrics	metrics
protected java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock	readLock
protected ServiceRegistry	serviceRegistry
protected java.util.concurrent.ScheduledFuture<?>	timer Cancelable timer
protected long	windowLength Length of time-window in MILLISECONDS
protected java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock	writeLock

Fields inherited from class services.moleculer.service.DefaultServiceInvoker

eventbus, maxCallLevel, retryLogic, uidGenerator, writeErrorsToLog

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Fields inherited from interface services.moleculer.metrics.MetricConstants

MOLECULER_CACHER_CLEAN_TIME, MOLECULER_CACHER_CLEAN_TIME_DESC, MOLECULER_CACHER_CLEAN_TOTAL, MOLECULER_CACHER_CLEAN_TOTAL_DESC, MOLECULER_CACHER_DEL_TIME, MOLECULER_CACHER_DEL_TIME_DESC, MOLECULER_CACHER_DEL_TOTAL, MOLECULER_CACHER_DEL_TOTAL_DESC, MOLECULER_CACHER_EXPIRED_TOTAL, MOLECULER_CACHER_EXPIRED_TOTAL_DESC, MOLECULER_CACHER_FOUND_TOTAL, MOLECULER_CACHER_FOUND_TOTAL_DESC, MOLECULER_CACHER_GET_TIME, MOLECULER_CACHER_GET_TIME_DESC, MOLECULER_CACHER_GET_TOTAL, MOLECULER_CACHER_GET_TOTAL_DESC, MOLECULER_CACHER_SET_TIME, MOLECULER_CACHER_SET_TIME_DESC, MOLECULER_CACHER_SET_TOTAL, MOLECULER_CACHER_SET_TOTAL_DESC, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL_DESC, MOLECULER_EVENT_BROADCAST_TOTAL, MOLECULER_EVENT_BROADCAST_TOTAL_DESC, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL_DESC, MOLECULER_EVENT_EMIT_TOTAL, MOLECULER_EVENT_EMIT_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_ACTIVE, MOLECULER_EVENT_RECEIVED_ACTIVE_DESC, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_TIME, MOLECULER_EVENT_RECEIVED_TIME_DESC, MOLECULER_EVENT_RECEIVED_TOTAL, MOLECULER_EVENT_RECEIVED_TOTAL_DESC, MOLECULER_EXECUTOR, MOLECULER_REQUEST_ACTIVE, MOLECULER_REQUEST_ACTIVE_DESC, MOLECULER_REQUEST_ERROR_TOTAL, MOLECULER_REQUEST_ERROR_TOTAL_DESC, MOLECULER_REQUEST_LEVELS, MOLECULER_REQUEST_LEVELS_DESC, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL_DESC, MOLECULER_REQUEST_TIME, MOLECULER_REQUEST_TIME_DESC, MOLECULER_REQUEST_TIMEOUT_TOTAL, MOLECULER_REQUEST_TIMEOUT_TOTAL_DESC, MOLECULER_REQUEST_TOTAL, MOLECULER_REQUEST_TOTAL_DESC, MOLECULER_SCHEDULER, MOLECULER_TRANSIT_CONNECTED, MOLECULER_TRANSIT_CONNECTED_DESC, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL_DESC, MOLECULER_TRANSIT_REQUESTS_ACTIVE, MOLECULER_TRANSIT_REQUESTS_ACTIVE_DESC, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL_DESC

Constructor Summary

Constructors

Constructor and Description
CircuitBreaker()

Method Summary

Modifier and Type	Method and Description
void	addIgnoredType(java.lang.Class<? extends java.lang.Throwable> type)
protected io.datatree.Promise	call(Context ctx, java.lang.String targetID, int remaining)
int	getCleanup()
protected ErrorCounter	getErrorCounter(EndpointKey endpointKey)
java.util.Set<java.lang.Class<? extends java.lang.Throwable>>	getIgnoredTypes()
long	getLockTimeout()
int	getMaxErrors()
int	getMaxSameNodes()
int	getMaxTries()
long	getWindowLength()
protected void	onError(ErrorCounter errorCounter, EndpointKey endpointKey, java.lang.Throwable cause)
void	removeIgnoredType(java.lang.Class<? extends java.lang.Throwable> type)
void	run()
void	setCleanup(int cleanup)
void	setIgnoredTypes(java.util.Set<java.lang.Class<? extends java.lang.Throwable>> ignoredTypes)
void	setLockTimeout(long lockTimeout)
void	setMaxErrors(int maxErrors)
void	setMaxSameNodes(int maxSameNodes)
void	setMaxTries(int maxTries)
void	setWindowLength(long windowLength)
void	started(ServiceBroker broker)
void	stopped()

Methods inherited from class services.moleculer.service.DefaultServiceInvoker

call, getMaxCallLevel, getRetryLogic, isWriteErrorsToLog, retry, setMaxCallLevel, setRetryLogic, setWriteErrorsToLog

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName

Methods inherited from class java.lang.Object

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

Field Detail

maxTries

protected int maxTries

Number of max tries

maxSameNodes

protected int maxSameNodes

Exit from "maxTries" loop, when strategy returns number of "maxSameNodes" corresponding node IDs

cleanup

protected int cleanup

Cleanup period time, in SECONDS (0 = disable cleanup process)

windowLength

protected long windowLength

Length of time-window in MILLISECONDS

maxErrors

protected int maxErrors

Maximum number of errors in time-window

lockTimeout

protected long lockTimeout

Half-open timeout in MILLISECONDS

serviceRegistry

protected ServiceRegistry serviceRegistry

metrics

protected Metrics metrics

ignoredTypes

protected java.util.Set<java.lang.Class<? extends java.lang.Throwable>> ignoredTypes

errorCounters

protected java.util.HashMap<EndpointKey,ErrorCounter> errorCounters

readLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock readLock

writeLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock writeLock

lastCleanup

protected long lastCleanup

timer

protected volatile java.util.concurrent.ScheduledFuture<?> timer

Cancelable timer

Constructor Detail

CircuitBreaker

public CircuitBreaker()

Method Detail

started

public void started(ServiceBroker broker)
             throws java.lang.Exception

Specified by:

started in interface MoleculerLifecycle

Overrides:

started in class DefaultServiceInvoker

Throws:

java.lang.Exception

stopped

public void stopped()

Specified by:

stopped in interface MoleculerLifecycle

Overrides:

stopped in class MoleculerComponent

run

public void run()

Specified by:

run in interface java.lang.Runnable

call

protected io.datatree.Promise call(Context ctx,
                                   java.lang.String targetID,
                                   int remaining)

Overrides:

call in class DefaultServiceInvoker

getErrorCounter

protected ErrorCounter getErrorCounter(EndpointKey endpointKey)

onError

protected void onError(ErrorCounter errorCounter,
                       EndpointKey endpointKey,
                       java.lang.Throwable cause)

addIgnoredType

public void addIgnoredType(java.lang.Class<? extends java.lang.Throwable> type)

removeIgnoredType

public void removeIgnoredType(java.lang.Class<? extends java.lang.Throwable> type)

getIgnoredTypes

public java.util.Set<java.lang.Class<? extends java.lang.Throwable>> getIgnoredTypes()

setIgnoredTypes

public void setIgnoredTypes(java.util.Set<java.lang.Class<? extends java.lang.Throwable>> ignoredTypes)

getMaxTries

public int getMaxTries()

setMaxTries

public void setMaxTries(int maxTries)

getMaxSameNodes

public int getMaxSameNodes()

setMaxSameNodes

public void setMaxSameNodes(int maxSameNodes)

getCleanup

public int getCleanup()

setCleanup

public void setCleanup(int cleanup)

getWindowLength

public long getWindowLength()

setWindowLength

public void setWindowLength(long windowLength)

getMaxErrors

public int getMaxErrors()

setMaxErrors

public void setMaxErrors(int maxErrors)

getLockTimeout

public long getLockTimeout()

setLockTimeout

public void setLockTimeout(long lockTimeout)