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

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

Defines ratelimiter utilities for Beam DoFn and IO components.

Class	Description
EnvoyRateLimiter	A lightweight handle for an Envoy-based rate limiter.
EnvoyRateLimiterContext	Context for an Envoy Rate Limiter call.
EnvoyRateLimiterContext.Builder
EnvoyRateLimiterFactory	A RateLimiterFactory for Envoy Rate Limit Service.
RateLimiter	A RateLimiter allows to fetch permits from a rate limiter service and blocks execution when the rate limit is exceeded.
RateLimiterClientCache	A static cache for ManagedChannels to Rate Limit Service.
RateLimiterContext	A marker interface for context data required to check ratelimit.
RateLimiterFactory	A factory that manages connections to rate limit service and creates lightweight handles.
RateLimiterOptions	Configuration options for RateLimiterFactory.
RateLimiterOptions.Builder