Struct FlowController 

pub struct FlowController { /* private fields */ }

Flow controller — manages the delta push pipeline.

Tracks in-flight deltas, computes RTT for adaptive batch sizing, and enforces pending queue bounds.

Implementations

impl FlowController

pub fn new(config: FlowControlConfig) -> Self

pub fn can_push(&self) -> bool

Check if the push pipeline can accept more deltas (flow control window).

pub fn next_batch_size(&self) -> usize

How many deltas should be pushed in the next batch. Returns 0 if the flow control window is full.

pub fn record_push(&mut self, mutation_ids: &[u64])

Record that deltas were pushed (track in-flight).

pub fn record_ack(&mut self, mutation_id: u64) -> Option<u64>

Record an ACK from Origin — update RTT, adjust batch size (AIMD).

Returns the measured RTT in milliseconds for this ACK.

pub fn record_reject(&mut self, mutation_id: u64)

Record a rejection from Origin — halve the batch size (AIMD multiplicative decrease).

pub fn update_pending(&mut self, count: usize, bytes: usize)

Update pending queue stats (called when deltas are added/removed).

pub fn is_queue_full(&self) -> bool

Check if the pending queue is at capacity.

pub fn in_flight_count(&self) -> usize

Current in-flight count.

pub fn avg_rtt_ms(&self) -> u64

Current EMA RTT in milliseconds.

pub fn current_batch_size(&self) -> usize

Current adaptive batch size.

pub fn pending_count(&self) -> usize

Pending count.

pub fn pending_bytes(&self) -> usize

Pending bytes.

pub fn cleanup_stale(&mut self, timeout: Duration) -> usize

Clean up in-flight entries older than a timeout (stale ACKs). Returns the number of timed-out entries cleaned.

pub fn snapshot( &self, state: &'static str, metrics: &SyncMetrics, ) -> SyncMetricsSnapshot

Build a snapshot of all sync metrics (for health API / monitoring).

pub fn reset(&mut self)

Reset flow control state on reconnect.

Trait Implementations

impl Default for FlowController

fn default() -> Self

Returns the “default value” for a type.