io.github.bucket4j.distributed.proxy

Class AbstractProxyManager<K>

java.lang.Object

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

All Implemented Interfaces:

ProxyManager<K>

Direct Known Subclasses:

AbstractCompareAndSwapBasedProxyManager, AbstractLockBasedProxyManager, AbstractSelectForUpdateBasedProxyManager

public abstract class AbstractProxyManager<K>
extends Object
implements ProxyManager<K>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractProxyManager(ClientSideConfig clientSideConfig)

Method Summary

Modifier and Type	Method and Description
AsyncProxyManager<K>	asAsync() Returns asynchronous API for this proxy manager.
RemoteBucketBuilder<K>	builder()
protected abstract <T> CommandResult<T>	execute(K key, Request<T> request)
protected abstract <T> CompletableFuture<CommandResult<T>>	executeAsync(K key, Request<T> request)
protected Version	getBackwardCompatibilityVersion()
protected ClientSideConfig	getClientSideConfig()
protected Long	getClientSideTime()
Optional<BucketConfiguration>	getProxyConfiguration(K key) Locates configuration of bucket which actually stored in the underlying storage.
protected abstract CompletableFuture<Void>	removeAsync(K key)

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

isAsyncModeSupported, isExpireAfterWriteSupported, removeProxy, withMapper

Constructor Detail

AbstractProxyManager

protected AbstractProxyManager(ClientSideConfig clientSideConfig)

Method Detail

asAsync

public AsyncProxyManager<K> asAsync()

Description copied from interface: ProxyManager

Returns asynchronous API for this proxy manager.

Specified by:

asAsync in interface ProxyManager<K>

Returns:

asynchronous API for this proxy manager.

builder

public RemoteBucketBuilder<K> builder()

Specified by:

builder in interface ProxyManager<K>

getProxyConfiguration

public Optional<BucketConfiguration> getProxyConfiguration(K key)

Description copied from interface: ProxyManager

Locates configuration of bucket which actually stored in the underlying storage.

Specified by:

getProxyConfiguration in interface ProxyManager<K>

Parameters:

key - the unique identifier used to point to the bucket in external storage.

Returns:

Optional surround the configuration or empty optional if bucket with specified key is not stored.

execute

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

executeAsync

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

removeAsync

protected abstract CompletableFuture<Void> removeAsync(K key)

getClientSideConfig

protected ClientSideConfig getClientSideConfig()

getBackwardCompatibilityVersion

protected Version getBackwardCompatibilityVersion()

getClientSideTime

protected Long getClientSideTime()