Struct AdaptiveBandwidthAllocator 

pub struct AdaptiveBandwidthAllocator { /* private fields */ }

Adaptive bandwidth manager that dynamically allocates bandwidth across peers.

Tracks per-peer profiles, maintains a bounded event history, and supports five allocation policies via AdaptiveBandwidthAllocator::reallocate.

Implementations

impl AdaptiveBandwidthAllocator

pub const MAX_EVENT_HISTORY: usize = 200

Maximum number of events retained in the history ring-buffer.

pub fn new(config: AllocatorConfig) -> Self

Create a new allocator with the given configuration.

Returns AllocatorError::InvalidConfiguration if the config is logically inconsistent.

pub fn advance_time(&mut self, delta_ms: u64)

Advance the internal clock by delta_ms milliseconds. Useful in testing to create distinct timestamps without real-time delays.

pub fn add_peer( &mut self, peer_id: String, class: BandwidthClass, initial_bps: u64, ) -> Result<(), AllocatorError>

Add a peer with an initial bandwidth class and desired allocation.

Returns AllocatorError::AllocationExceedsCapacity if adding this allocation would exceed total_capacity_bps.

pub fn remove_peer( &mut self, peer_id: &str, ) -> Result<PeerBandwidthProfile, AllocatorError>

Remove a peer and release its bandwidth allocation.

Returns the removed PeerBandwidthProfile or AllocatorError::PeerNotFound.

pub fn update_measurement( &mut self, peer_id: &str, used_bps: u64, latency_ms: u64, packet_loss_ppm: u32, ) -> Result<BandwidthEvent, AllocatorError>

Record a live measurement for a peer.

Updates the rolling BandwidthWindow, stores latency and loss, and emits a BandwidthEvent::CongestionDetected when loss_ppm exceeds the configured threshold.

Returns the most pertinent event for the caller’s convenience.

pub fn reallocate(&mut self) -> Vec<BandwidthEvent>

Rebalance all peer allocations according to the configured policy.

Returns the list of BandwidthEvents produced (one AllocationRevised event at minimum, plus any CongestionDetected events for peers that are still over threshold after rebalancing).

pub fn get_allocation(&self, peer_id: &str) -> Result<u64, AllocatorError>

Return the current allocated bps for the given peer.

pub fn stats(&self) -> BandwidthStats

Return aggregate statistics including Jain’s fairness index.

pub fn congested_peers(&self) -> Vec<String>

Return peer IDs for all peers whose packet_loss_ppm exceeds the threshold.

pub fn events_since(&self, since_ms: u64) -> Vec<BandwidthEvent>

Return all events with timestamp >= since_ms.

pub fn drain_events(&mut self) -> Vec<BandwidthEvent>

Drain and return all buffered events, leaving the history empty.

pub fn peer_profile(&self, peer_id: &str) -> Option<&PeerBandwidthProfile>

Return a reference to the profile for peer_id, if present.

pub fn peer_count(&self) -> usize

Return the number of tracked peers.

pub fn total_capacity_bps(&self) -> u64

Return the total capacity configured for this allocator.

pub fn config(&self) -> &AllocatorConfig

Return a reference to the current configuration.