services.moleculer.breaker

Class CircuitBreaker

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.service.ServiceInvoker

services.moleculer.breaker.CircuitBreaker

public class CircuitBreaker
extends ServiceInvoker

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 ContextFactory	contextFactory
protected java.util.concurrent.ConcurrentHashMap<EndpointKey,ErrorCounter>	errorCounters
protected java.util.Set<java.lang.Class<? extends java.lang.Throwable>>	ignoredTypes
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 ServiceRegistry	serviceRegistry
protected long	windowLength Length of time-window in MILLISECONDS

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

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)
io.datatree.Promise	call(java.lang.String name, io.datatree.Tree params, CallOptions.Options opts, Context parent)
protected io.datatree.Promise	call(java.lang.String name, io.datatree.Tree params, CallOptions.Options opts, Context parent, java.lang.String targetID, int remaining)
int	getCleanup()
java.util.Set<java.lang.Class<? extends java.lang.Throwable>>	getIgnoredTypes()
int	getMaxErrors()
int	getMaxSameNodes()
int	getMaxTries()
long	getWindowLength()
protected void	increment(ErrorCounter errorCounter, EndpointKey endpointKey, java.lang.Throwable cause, long now)
void	removeIgnoredType(java.lang.Class<? extends java.lang.Throwable> type)
protected io.datatree.Promise	retry(java.lang.Throwable cause, java.lang.String name, io.datatree.Tree params, CallOptions.Options opts, Context parent, java.lang.String targetID, int remaining)
void	setCleanup(int cleanup)
void	setIgnoredTypes(java.util.Set<java.lang.Class<? extends java.lang.Throwable>> ignoredTypes)
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.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

contextFactory

protected ContextFactory contextFactory

ignoredTypes

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

errorCounters

protected java.util.concurrent.ConcurrentHashMap<EndpointKey,ErrorCounter> errorCounters

Constructor Detail

CircuitBreaker

public CircuitBreaker()

Method Detail

started

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

Overrides:

started in class MoleculerComponent

Throws:

java.lang.Exception

stopped

public void stopped()

Overrides:

stopped in class MoleculerComponent

call

public io.datatree.Promise call(java.lang.String name,
                                io.datatree.Tree params,
                                CallOptions.Options opts,
                                Context parent)

Specified by:

call in class ServiceInvoker

call

protected io.datatree.Promise call(java.lang.String name,
                                   io.datatree.Tree params,
                                   CallOptions.Options opts,
                                   Context parent,
                                   java.lang.String targetID,
                                   int remaining)

retry

protected io.datatree.Promise retry(java.lang.Throwable cause,
                                    java.lang.String name,
                                    io.datatree.Tree params,
                                    CallOptions.Options opts,
                                    Context parent,
                                    java.lang.String targetID,
                                    int remaining)

increment

protected void increment(ErrorCounter errorCounter,
                         EndpointKey endpointKey,
                         java.lang.Throwable cause,
                         long now)

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)