Struct RateLimitInterceptor 

pub struct RateLimitInterceptor { /* private fields */ }

A fixed-window rate limiting ServerInterceptor.

Tracks request counts per caller key using a simple fixed-window counter. When the limit is exceeded, rejects the request with an A2A error.

Caller keys are derived in this order:

1. CallContext::caller_identity (set by auth interceptors)
2. x-forwarded-for HTTP header (first IP)
3. "anonymous" fallback

Implementations

impl RateLimitInterceptor

pub fn new(config: RateLimitConfig) -> Self

Creates a new rate limiter with the given configuration.

Trait Implementations

impl Debug for RateLimitInterceptor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ServerInterceptor for RateLimitInterceptor

fn before<'a>( &'a self, ctx: &'a CallContext, ) -> Pin<Box<dyn Future<Output = A2aResult<()>> + Send + 'a>>

Called before the request handler processes the method call.

fn after<'a>( &'a self, _ctx: &'a CallContext, ) -> Pin<Box<dyn Future<Output = A2aResult<()>> + Send + 'a>>

Called after the request handler has finished processing.