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

Class Bucket4jAgentRateLimiter

java.lang.Object

com.flowable.agent.engine.impl.sandbox.ratelimiter.bucket4j.Bucket4jAgentRateLimiter

All Implemented Interfaces:

AgentRateLimiter

public class Bucket4jAgentRateLimiter
extends Object
implements AgentRateLimiter

Field Summary

Fields

Modifier and Type	Field	Description
protected final AgentBucketConfigurationProvider	bucketConfigurationProvider
protected final io.github.bucket4j.distributed.proxy.ProxyManager<String>	proxyManager

Constructor Summary

Constructors

Constructor	Description
Bucket4jAgentRateLimiter(io.github.bucket4j.distributed.proxy.ProxyManager<String> proxyManager, AgentBucketConfigurationProvider bucketConfigurationProvider)

Method Summary

Modifier and Type	Method	Description
protected io.github.bucket4j.Bucket	getBucket(String bucketName, String tenantId, Function<String,io.github.bucket4j.BucketConfiguration> configurationSupplier)
AgentBucketConfigurationProvider	getBucketConfigurationProvider()
io.github.bucket4j.distributed.proxy.ProxyManager<String>	getProxyManager()
RateLimitationForAgentInvocation	validateAgentInvocation(String tenantId, int nrOfTokens)

Methods inherited from class java.lang.Object

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

Field Details

proxyManager

protected final io.github.bucket4j.distributed.proxy.ProxyManager<String> proxyManager

bucketConfigurationProvider

protected final AgentBucketConfigurationProvider bucketConfigurationProvider

Constructor Details

Bucket4jAgentRateLimiter

public Bucket4jAgentRateLimiter(io.github.bucket4j.distributed.proxy.ProxyManager<String> proxyManager,
 AgentBucketConfigurationProvider bucketConfigurationProvider)

Method Details

validateAgentInvocation

public RateLimitationForAgentInvocation validateAgentInvocation(String tenantId,
 int nrOfTokens)

Specified by:

validateAgentInvocation in interface AgentRateLimiter

getBucket

protected io.github.bucket4j.Bucket getBucket(String bucketName,
 String tenantId,
 Function<String,io.github.bucket4j.BucketConfiguration> configurationSupplier)

getProxyManager

public io.github.bucket4j.distributed.proxy.ProxyManager<String> getProxyManager()

getBucketConfigurationProvider

public AgentBucketConfigurationProvider getBucketConfigurationProvider()