Skip to main content

Module flow_control

Module flow_control 

Source
Expand description

Flow control, adaptive batching, and sync metrics.

Manages the delta push pipeline with:

  • ACK-based flow control: in-flight window limits concurrent unACK’d deltas
  • Adaptive batch sizing: AIMD algorithm adjusts batch size based on observed RTT
  • Bounded pending queue: configurable limits on pending delta count and bytes
  • Sync metrics: structured, observable sync state for monitoring

All state is behind tokio::sync::Mutex for use from the async sync transport.

Structs§

FlowControlConfig
Flow control configuration.
FlowController
Flow controller — manages the delta push pipeline.
SyncMetrics
Sync metrics — atomic counters for lock-free concurrent access.
SyncMetricsSnapshot
Observable sync metrics — all atomic for lock-free reads.