Struct FlowController 

pub struct FlowController { /* private fields */ }

Flow controller for managing stream throughput.

Implementations

impl FlowController

pub fn new(config: FlowControlConfig) -> Self

Create a new flow controller.

pub async fn acquire(&self, count: usize) -> Result<()>

Acquire permission to process elements.

pub async fn try_acquire(&self, count: usize) -> bool

Try to acquire without blocking.

pub async fn record_latency(&self, latency: Duration)

Record processing latency.

pub async fn adjust_rate_adaptive(&self)

Adjust rate based on observed latency.

pub async fn metrics(&self) -> FlowControlMetrics

Get current metrics.

pub async fn reset_metrics(&self)

Reset metrics.

pub async fn current_rate(&self) -> f64

Get current rate.