Struct BackpressureAwareProducer 

pub struct BackpressureAwareProducer { /* private fields */ }

A rate-aware producer that respects backpressure.

Implementations

impl BackpressureAwareProducer

pub fn new(strategy: BackpressureStrategy, capacity: usize) -> Self

Creates a new backpressure-aware producer.

pub fn with_adaptive(self) -> Self

Enables adaptive rate control.

pub fn update(&mut self, fill_level: usize)

Updates the fill level and adjusts state.

pub fn state(&self) -> BackpressureState

Returns the current state.

pub fn recommended_delay(&self) -> Duration

Returns the recommended delay before the next send.

pub fn record_dropped(&self, count: u64)

Records dropped items.

pub fn stats(&self) -> BackpressureStats

Returns statistics.