net.thevpc.nuts.runtime.standalone.concurrent

Class NConcurrentImpl

java.lang.Object

net.thevpc.nuts.runtime.standalone.concurrent.NConcurrentImpl

All Implemented Interfaces:

NConcurrent, NComponent, NScorable

public class NConcurrentImpl
extends Object
implements NConcurrent

Field Summary

Fields inherited from interface net.thevpc.nuts.util.NScorable

CUSTOM_SCORE, DEFAULT_SCORE, UNSUPPORTED_SCORE

Constructor Summary

Constructors

Constructor and Description
NConcurrentImpl()

Method Summary

Modifier and Type	Method and Description
NBulkheadCallFactory	bulkheadCallFactory()
<T> NCachedValue<T>	cachedValue(String id, Supplier<T> supplier)
<T> NCachedValue<T>	cachedValue(Supplier<T> supplier)
NCachedValueFactory	cachedValueFactory()
<T> NCircuitBreakerCall<T>	circuitBreakerCall(NCallable<T> callable)
<T> NCircuitBreakerCall<T>	circuitBreakerCall(String id, NCallable<T> callable)
NCircuitBreakerCallFactory	circuitBreakerCallFactory()
NBulkheadCallFactory	defaultBulkheadCallFactory()
NCachedValueFactory	defaultCachedValueFactory()
NCircuitBreakerCallFactory	defaultCircuitBreakerCallFactory()
NRateLimitValueFactory	defaultRateLimitValueFactory()
NRetryCallFactory	defaultRetryCallFactory()
NSagaCallableFactory	defaultSagaFactory()
NStableValueFactory	defaultStableValueFactory()
NWorkBalancerFactory	defaultWorkBalancerFactory()
ExecutorService	executorService()
int	getScore(NScorableContext context)
NBulkheadCallFactory	memoryBulkheadCallFactory()
NCachedValueFactory	memoryCachedValueFactory()
NCircuitBreakerCallFactory	memoryCircuitBreakerCallFactory()
NRateLimitValueFactory	memoryRateLimitValueFactory()
NRetryCallFactory	memoryRetryCallFactory()
NSagaCallableFactory	memorySagaFactory()
NStableValueFactory	memoryStableValueFactory()
NWorkBalancerFactory	memoryWorkBalancerFactory()
NRateLimitValueFactory	rateLimitValueFactory()
<T> NRetryCall<T>	retryCall(NCallable<T> callable)
<T> NRetryCall<T>	retryCall(String id, NCallable<T> callable)
NRetryCallFactory	retryCallFactory()
IntFunction<NDuration>	retryFixedPeriod(NDuration period)
IntFunction<NDuration>	retryFixedPeriods(NDuration... periods)
IntFunction<NDuration>	retryMultipliedPeriod(NDuration base, double multiplier)
NSagaCallableBuilder	sagaCallBuilder()
NSagaCallableFactory	sagaFactory()
NConcurrent	setBulkheadCallFactory(NBulkheadCallFactory bulkheadCallFactory)
NConcurrent	setCachedValueFactory(NCachedValueFactory cachedValueFactory)
NConcurrent	setCircuitBreakerCallFactory(NCircuitBreakerCallFactory circuitBreakerCallFactory)
NConcurrent	setRateLimitValueFactory(NRateLimitValueFactory factory)
NConcurrent	setRetryCallFactory(NRetryCallFactory retryCallFactory)
NConcurrent	setStableValueFactory(NStableValueFactory stableValueFactory)
NConcurrent	setWorkBalancerCallFactory(NWorkBalancerFactory workBalancerCallFactory)
NConcurrent	sleep(Duration durationMillis)
NConcurrent	sleep(long durationMillis)
NConcurrent	sleep(NDuration durationMillis)
<T> NStableValue<T>	stableValue(String id, Supplier<T> supplier)
<T> NStableValue<T>	stableValue(Supplier<T> supplier)
NStableValueFactory	stableValueFactory()
NTaskSet	taskSet()
NWorkBalancerFactory	workBalancerFactory()

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.NConcurrent

of

Methods inherited from interface net.thevpc.nuts.util.NScorable

isValidScore, query, query

Constructor Detail

NConcurrentImpl

public NConcurrentImpl()

Method Detail

getScore

public int getScore(NScorableContext context)

Specified by:

getScore in interface NComponent

Specified by:

getScore in interface NScorable

setCachedValueFactory

public NConcurrent setCachedValueFactory(NCachedValueFactory cachedValueFactory)

Specified by:

setCachedValueFactory in interface NConcurrent

memoryCachedValueFactory

public NCachedValueFactory memoryCachedValueFactory()

Specified by:

memoryCachedValueFactory in interface NConcurrent

defaultCachedValueFactory

public NCachedValueFactory defaultCachedValueFactory()

Specified by:

defaultCachedValueFactory in interface NConcurrent

cachedValueFactory

public NCachedValueFactory cachedValueFactory()

Specified by:

cachedValueFactory in interface NConcurrent

setRetryCallFactory

public NConcurrent setRetryCallFactory(NRetryCallFactory retryCallFactory)

Specified by:

setRetryCallFactory in interface NConcurrent

memoryRetryCallFactory

public NRetryCallFactory memoryRetryCallFactory()

Specified by:

memoryRetryCallFactory in interface NConcurrent

defaultRetryCallFactory

public NRetryCallFactory defaultRetryCallFactory()

Specified by:

defaultRetryCallFactory in interface NConcurrent

retryCallFactory

public NRetryCallFactory retryCallFactory()

Specified by:

retryCallFactory in interface NConcurrent

setStableValueFactory

public NConcurrent setStableValueFactory(NStableValueFactory stableValueFactory)

Specified by:

setStableValueFactory in interface NConcurrent

memoryStableValueFactory

public NStableValueFactory memoryStableValueFactory()

Specified by:

memoryStableValueFactory in interface NConcurrent

defaultStableValueFactory

public NStableValueFactory defaultStableValueFactory()

Specified by:

defaultStableValueFactory in interface NConcurrent

stableValueFactory

public NStableValueFactory stableValueFactory()

Specified by:

stableValueFactory in interface NConcurrent

defaultRateLimitValueFactory

public NRateLimitValueFactory defaultRateLimitValueFactory()

Specified by:

defaultRateLimitValueFactory in interface NConcurrent

defaultSagaFactory

public NSagaCallableFactory defaultSagaFactory()

Specified by:

defaultSagaFactory in interface NConcurrent

memorySagaFactory

public NSagaCallableFactory memorySagaFactory()

Specified by:

memorySagaFactory in interface NConcurrent

memoryRateLimitValueFactory

public NRateLimitValueFactory memoryRateLimitValueFactory()

Specified by:

memoryRateLimitValueFactory in interface NConcurrent

setRateLimitValueFactory

public NConcurrent setRateLimitValueFactory(NRateLimitValueFactory factory)

Specified by:

setRateLimitValueFactory in interface NConcurrent

rateLimitValueFactory

public NRateLimitValueFactory rateLimitValueFactory()

Specified by:

rateLimitValueFactory in interface NConcurrent

sagaFactory

public NSagaCallableFactory sagaFactory()

Specified by:

sagaFactory in interface NConcurrent

cachedValue

public <T> NCachedValue<T> cachedValue(Supplier<T> supplier)

Specified by:

cachedValue in interface NConcurrent

stableValue

public <T> NStableValue<T> stableValue(Supplier<T> supplier)

Specified by:

stableValue in interface NConcurrent

cachedValue

public <T> NCachedValue<T> cachedValue(String id,
                                       Supplier<T> supplier)

Specified by:

cachedValue in interface NConcurrent

stableValue

public <T> NStableValue<T> stableValue(String id,
                                       Supplier<T> supplier)

Specified by:

stableValue in interface NConcurrent

retryCall

public <T> NRetryCall<T> retryCall(String id,
                                   NCallable<T> callable)

Specified by:

retryCall in interface NConcurrent

retryCall

public <T> NRetryCall<T> retryCall(NCallable<T> callable)

Specified by:

retryCall in interface NConcurrent

circuitBreakerCall

public <T> NCircuitBreakerCall<T> circuitBreakerCall(NCallable<T> callable)

Specified by:

circuitBreakerCall in interface NConcurrent

circuitBreakerCall

public <T> NCircuitBreakerCall<T> circuitBreakerCall(String id,
                                                     NCallable<T> callable)

Specified by:

circuitBreakerCall in interface NConcurrent

setCircuitBreakerCallFactory

public NConcurrent setCircuitBreakerCallFactory(NCircuitBreakerCallFactory circuitBreakerCallFactory)

Specified by:

setCircuitBreakerCallFactory in interface NConcurrent

memoryCircuitBreakerCallFactory

public NCircuitBreakerCallFactory memoryCircuitBreakerCallFactory()

Specified by:

memoryCircuitBreakerCallFactory in interface NConcurrent

defaultCircuitBreakerCallFactory

public NCircuitBreakerCallFactory defaultCircuitBreakerCallFactory()

Specified by:

defaultCircuitBreakerCallFactory in interface NConcurrent

circuitBreakerCallFactory

public NCircuitBreakerCallFactory circuitBreakerCallFactory()

Specified by:

circuitBreakerCallFactory in interface NConcurrent

executorService

public ExecutorService executorService()

Specified by:

executorService in interface NConcurrent

sagaCallBuilder

public NSagaCallableBuilder sagaCallBuilder()

Specified by:

sagaCallBuilder in interface NConcurrent

defaultWorkBalancerFactory

public NWorkBalancerFactory defaultWorkBalancerFactory()

Specified by:

defaultWorkBalancerFactory in interface NConcurrent

memoryWorkBalancerFactory

public NWorkBalancerFactory memoryWorkBalancerFactory()

Specified by:

memoryWorkBalancerFactory in interface NConcurrent

workBalancerFactory

public NWorkBalancerFactory workBalancerFactory()

Specified by:

workBalancerFactory in interface NConcurrent

setWorkBalancerCallFactory

public NConcurrent setWorkBalancerCallFactory(NWorkBalancerFactory workBalancerCallFactory)

Specified by:

setWorkBalancerCallFactory in interface NConcurrent

sleep

public NConcurrent sleep(NDuration durationMillis)
                  throws NInterruptedException

Specified by:

sleep in interface NConcurrent

Throws:

NInterruptedException

sleep

public NConcurrent sleep(Duration durationMillis)
                  throws NInterruptedException

Specified by:

sleep in interface NConcurrent

Throws:

NInterruptedException

sleep

public NConcurrent sleep(long durationMillis)
                  throws NInterruptedException

Specified by:

sleep in interface NConcurrent

Throws:

NInterruptedException

taskSet

public NTaskSet taskSet()

Specified by:

taskSet in interface NConcurrent

retryFixedPeriod

public IntFunction<NDuration> retryFixedPeriod(NDuration period)

Specified by:

retryFixedPeriod in interface NConcurrent

retryFixedPeriods

public IntFunction<NDuration> retryFixedPeriods(NDuration... periods)

Specified by:

retryFixedPeriods in interface NConcurrent

retryMultipliedPeriod

public IntFunction<NDuration> retryMultipliedPeriod(NDuration base,
                                                    double multiplier)

Specified by:

retryMultipliedPeriod in interface NConcurrent

defaultBulkheadCallFactory

public NBulkheadCallFactory defaultBulkheadCallFactory()

Specified by:

defaultBulkheadCallFactory in interface NConcurrent

memoryBulkheadCallFactory

public NBulkheadCallFactory memoryBulkheadCallFactory()

Specified by:

memoryBulkheadCallFactory in interface NConcurrent

bulkheadCallFactory

public NBulkheadCallFactory bulkheadCallFactory()

Specified by:

bulkheadCallFactory in interface NConcurrent

setBulkheadCallFactory

public NConcurrent setBulkheadCallFactory(NBulkheadCallFactory bulkheadCallFactory)

Specified by:

setBulkheadCallFactory in interface NConcurrent