Struct IngestRateLimit 

pub struct IngestRateLimit { /* private fields */ }

Available on crate feature ingest only.

Per-connection sliding-window ingress rate limiter (bytes/second).

Implementations

impl IngestRateLimit

pub fn new(max_bytes_per_sec: u64) -> Self

A new limiter allowing up to max_bytes_per_sec bytes per rolling second.

pub fn allow(&mut self, len: usize) -> bool

Record len ingested bytes; returns false if the per-second budget is exceeded (the caller should drop the connection or backpressure).

Trait Implementations

impl Debug for IngestRateLimit

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

Formats the value using the given formatter.