Struct FlowController 

pub struct FlowController { /* private fields */ }

Main flow controller

Coordinates rate limiting, queue management, and resource tracking for all peers.

Implementations

impl FlowController

pub fn new() -> FlowController

Create a new flow controller with default config

pub fn with_config(config: FlowControlConfig) -> FlowController

Create a new flow controller with custom config

pub fn check_sync_allowed( &self, peer_id: &PublicKey, doc_key: &str, ) -> Result<(), FlowControlError>

Check if a sync operation is allowed

Performs all flow control checks:

1. Rate limiting (token bucket)
2. Sync cooldown (storm prevention)
3. Resource limits (memory)

Returns Ok(()) if allowed, Err with specific reason if blocked.

pub fn record_sync(&self, peer_id: &PublicKey, doc_key: &str)

Record a successful sync operation

Updates cooldown tracker to prevent sync storms.

pub fn get_resource_tracker( &self, peer_id: &PublicKey, ) -> Arc<PeerResourceTracker>

Get or create resource tracker for peer

pub fn stats(&self) -> FlowControlStats

Get current statistics

pub fn cleanup(&self)

Clean up stale data

pub fn config(&self) -> &FlowControlConfig

Get current config

pub fn available_tokens(&self, peer_id: &PublicKey) -> u32

Get available tokens for a peer

Trait Implementations

impl Default for FlowController

fn default() -> FlowController

Returns the “default value” for a type.