net.thevpc.nuts.runtime.standalone.concurrent

Class NCircuitBreakerCallImpl<T>

java.lang.Object

net.thevpc.nuts.runtime.standalone.concurrent.NCircuitBreakerCallImpl<T>

All Implemented Interfaces:

Callable<T>, net.thevpc.nuts.concurrent.NCallable<T>, net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>, net.thevpc.nuts.elem.NDescribable, net.thevpc.nuts.elem.NRedescribable<net.thevpc.nuts.concurrent.NCallable<T>>

public class NCircuitBreakerCallImpl<T>
extends Object
implements net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>

Nested Class Summary

Nested classes/interfaces inherited from interface net.thevpc.nuts.concurrent.NCircuitBreakerCall

net.thevpc.nuts.concurrent.NCircuitBreakerCall.Status

Constructor Summary

Constructors

Constructor and Description
NCircuitBreakerCallImpl(String id, net.thevpc.nuts.concurrent.NCallable<T> callable, net.thevpc.nuts.reflect.NBeanContainer beanContainer, net.thevpc.nuts.concurrent.NCircuitBreakerCallStore store)

Method Summary

Modifier and Type	Method and Description
T	call()
T	call(boolean useFallback)
T	callOrElse(net.thevpc.nuts.concurrent.NCallable<T> recover)
T	callOrLast()
net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>	failureRetryPeriod(IntFunction<net.thevpc.nuts.time.NDuration> retryPeriod)
net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>	failureThreshold(int failureThreshold)
void	reload()
net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>	successRetryPeriod(IntFunction<net.thevpc.nuts.time.NDuration> retryPeriod)
net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>	successThreshold(int successThreshold)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.thevpc.nuts.concurrent.NCircuitBreakerCall

of, of

Methods inherited from interface net.thevpc.nuts.concurrent.NCallable

of, withDescription

Methods inherited from interface net.thevpc.nuts.elem.NDescribable

describe

Constructor Detail

NCircuitBreakerCallImpl

public NCircuitBreakerCallImpl(String id,
                               net.thevpc.nuts.concurrent.NCallable<T> callable,
                               net.thevpc.nuts.reflect.NBeanContainer beanContainer,
                               net.thevpc.nuts.concurrent.NCircuitBreakerCallStore store)

Method Detail

reload

public void reload()

failureThreshold

public net.thevpc.nuts.concurrent.NCircuitBreakerCall<T> failureThreshold(int failureThreshold)

Specified by:

failureThreshold in interface net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>

successThreshold

public net.thevpc.nuts.concurrent.NCircuitBreakerCall<T> successThreshold(int successThreshold)

Specified by:

successThreshold in interface net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>

successRetryPeriod

public net.thevpc.nuts.concurrent.NCircuitBreakerCall<T> successRetryPeriod(IntFunction<net.thevpc.nuts.time.NDuration> retryPeriod)

Specified by:

successRetryPeriod in interface net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>

failureRetryPeriod

public net.thevpc.nuts.concurrent.NCircuitBreakerCall<T> failureRetryPeriod(IntFunction<net.thevpc.nuts.time.NDuration> retryPeriod)

Specified by:

failureRetryPeriod in interface net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>

callOrElse

public T callOrElse(net.thevpc.nuts.concurrent.NCallable<T> recover)

Specified by:

callOrElse in interface net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>

call

public T call()

Specified by:

call in interface Callable<T>

Specified by:

call in interface net.thevpc.nuts.concurrent.NCallable<T>

callOrLast

public T callOrLast()

Specified by:

callOrLast in interface net.thevpc.nuts.concurrent.NCircuitBreakerCall<T>

call

public T call(boolean useFallback)