Package com.flowable.platform.engine.impl.sandbox.ratelimiter.bucket4j

Class LocalMapProxyManager

java.lang.Object
io.github.bucket4j.distributed.proxy.AbstractProxyManager<String>
com.flowable.platform.engine.impl.sandbox.ratelimiter.bucket4j.LocalMapProxyManager
All Implemented Interfaces:
io.github.bucket4j.distributed.proxy.ProxyManager<String>
public class LocalMapProxyManager extends io.github.bucket4j.distributed.proxy.AbstractProxyManager<String>
Author:
Filip Hrisafov

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final Map<String,io.github.bucket4j.distributed.remote.RemoteBucketState>
    buckets
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    LocalMapProxyManager()
     
    LocalMapProxyManager(io.github.bucket4j.distributed.proxy.ClientSideConfig clientSideConfig)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    clear()
     
    protected <T> io.github.bucket4j.distributed.remote.CommandResult<T>
    execute(String key, io.github.bucket4j.distributed.remote.Request<T> request)
     
    protected <T> CompletableFuture<io.github.bucket4j.distributed.remote.CommandResult<T>>
    executeAsync(String key, io.github.bucket4j.distributed.remote.Request<T> request)
     
    boolean
    isAsyncModeSupported()
     
    protected CompletableFuture<Void>
    removeAsync(String key)
     
    void
    removeProxy(String key)
     

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

    asAsync, builder, getBackwardCompatibilityVersion, getClientSideConfig, getClientSideTime, getProxyConfiguration

    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

    withMapper

  • Field Details

    • buckets

      protected final Map<String,io.github.bucket4j.distributed.remote.RemoteBucketState> buckets

  • Constructor Details

    • LocalMapProxyManager

      public LocalMapProxyManager()

    • LocalMapProxyManager

      public LocalMapProxyManager(io.github.bucket4j.distributed.proxy.ClientSideConfig clientSideConfig)

  • Method Details

    • execute

      protected <T> io.github.bucket4j.distributed.remote.CommandResult<T> execute(String key, io.github.bucket4j.distributed.remote.Request<T> request)
      Specified by:
      execute in class io.github.bucket4j.distributed.proxy.AbstractProxyManager<String>

    • executeAsync

      protected <T> CompletableFuture<io.github.bucket4j.distributed.remote.CommandResult<T>> executeAsync(String key, io.github.bucket4j.distributed.remote.Request<T> request)
      Specified by:
      executeAsync in class io.github.bucket4j.distributed.proxy.AbstractProxyManager<String>

    • removeAsync

      protected CompletableFuture<Void> removeAsync(String key)
      Specified by:
      removeAsync in class io.github.bucket4j.distributed.proxy.AbstractProxyManager<String>

    • removeProxy

      public void removeProxy(String key)

    • isAsyncModeSupported

      public boolean isAsyncModeSupported()

    • clear

      public void clear()