Module io.github.bucket4j.core

Package io.github.bucket4j.distributed.proxy.generic.compare_and_swap

Class AbstractCompareAndSwapBasedProxyManager<K>

java.lang.Object

io.github.bucket4j.distributed.proxy.AbstractProxyManager<K>

io.github.bucket4j.distributed.proxy.generic.compare_and_swap.AbstractCompareAndSwapBasedProxyManager<K>

Type Parameters:

K - the generic type for unique identifiers that used to point to the bucket in external storage.

All Implemented Interfaces:

ProxyManager<K>

public abstract class AbstractCompareAndSwapBasedProxyManager<K>
extends AbstractProxyManager<K>

The base class for proxy managers that built on top of idea that underlining storage provide transactions and locking.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractCompareAndSwapBasedProxyManager(ClientSideConfig clientSideConfig)

Method Summary

Modifier and Type	Method	Description
protected abstract AsyncCompareAndSwapOperation	beginAsyncCompareAndSwapOperation(K key)
protected abstract CompareAndSwapOperation	beginCompareAndSwapOperation(K key)
<T> CommandResult<T>	execute(K key, Request<T> request)
<T> CompletableFuture<CommandResult<T>>	executeAsync(K key, Request<T> request)

Methods inherited from class io.github.bucket4j.distributed.proxy.AbstractProxyManager

asAsync, builder, currentTimeNanos, getBackwardCompatibilityVersion, getClientSideConfig, getClientSideTime, getProxyConfiguration, removeAsync

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.github.bucket4j.distributed.proxy.ProxyManager

getProxy, isAsyncModeSupported, isExpireAfterWriteSupported, removeProxy, withMapper

Constructor Details

AbstractCompareAndSwapBasedProxyManager

protected AbstractCompareAndSwapBasedProxyManager(ClientSideConfig clientSideConfig)

Method Details

execute

public <T> CommandResult<T> execute(K key,
 Request<T> request)

Specified by:

execute in class AbstractProxyManager<K>

executeAsync

public <T> CompletableFuture<CommandResult<T>> executeAsync(K key,
 Request<T> request)

Specified by:

executeAsync in class AbstractProxyManager<K>

beginCompareAndSwapOperation

protected abstract CompareAndSwapOperation beginCompareAndSwapOperation(K key)

beginAsyncCompareAndSwapOperation

protected abstract AsyncCompareAndSwapOperation beginAsyncCompareAndSwapOperation(K key)