Struct LimiterMiddleware 

pub struct LimiterMiddleware {
    pub messages_per_second: f64,
}

Throughput limiter middleware configuration.

Applies a best-effort pacing delay so an endpoint does not exceed the configured message rate. For batch operations the limiter accounts for the number of messages in the batch, not just the batch count.

Fields

messages_per_second: f64

Target throughput in messages per second. Must be greater than zero.

Trait Implementations

impl Clone for LimiterMiddleware

fn clone(&self) -> LimiterMiddleware

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LimiterMiddleware

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for LimiterMiddleware

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for LimiterMiddleware

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.