Struct SyncCooldownTracker 

pub struct SyncCooldownTracker { /* private fields */ }

Sync cooldown tracker for storm prevention

Tracks last sync time for each (peer, document) pair to prevent rapid repeated syncs that could indicate a sync storm.

Implementations

impl SyncCooldownTracker

pub fn new(cooldown: Duration) -> SyncCooldownTracker

Create a new cooldown tracker

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

Check if sync is allowed (not in cooldown)

Returns Ok(()) if sync is allowed, Err with remaining time if in cooldown.

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

Record a sync operation (updates last sync time)

pub fn blocked_count(&self) -> u64

Get count of syncs blocked by cooldown

pub fn cleanup(&mut self)

Clean up old entries (entries older than 10x cooldown)

Trait Implementations

impl Debug for SyncCooldownTracker

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.