Package org.apache.beam.sdk.io.components.ratelimiter

Class EnvoyRateLimiter

java.lang.Object

org.apache.beam.sdk.io.components.ratelimiter.EnvoyRateLimiter

All Implemented Interfaces:

Serializable, AutoCloseable, RateLimiter

public class EnvoyRateLimiter
extends Object
implements RateLimiter

A lightweight handle for an Envoy-based rate limiter.

Delegates work to the EnvoyRateLimiterFactory using the baked-in EnvoyRateLimiterContext.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
EnvoyRateLimiter(EnvoyRateLimiterFactory factory, EnvoyRateLimiterContext context)

Method Summary

Modifier and Type	Method	Description
boolean	allow(int permits)	Blocks until the specified number of permits are acquired and returns true if the request was allowed or false if the request was rejected.
void	close()

Methods inherited from class java.lang.Object

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

Constructor Details

EnvoyRateLimiter

public EnvoyRateLimiter(EnvoyRateLimiterFactory factory,
 EnvoyRateLimiterContext context)

Method Details

allow

public boolean allow(int permits)
              throws IOException,
InterruptedException

Description copied from interface: RateLimiter

Blocks until the specified number of permits are acquired and returns true if the request was allowed or false if the request was rejected.

Specified by:

allow in interface RateLimiter

Parameters:

permits - Number of permits to acquire.

Returns:

true if the request was allowed, false if it was rejected (and retries exceeded).

Throws:

IOException - if there is an error communicating with the rate limiter service.

InterruptedException - if the thread is interrupted while waiting.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception