Struct PeerBandwidthAllocator 

pub struct PeerBandwidthAllocator {
    pub peers: HashMap<String, PeerAllocation>,
    pub total_bps: u64,
    pub strategy: AllocationStrategy,
}

Allocates outbound bandwidth fairly across peers.

Fields

peers: HashMap<String, PeerAllocation>

All tracked peers, keyed by peer_id.

total_bps: u64

Total available bandwidth budget in bps.

strategy: AllocationStrategy

Active allocation strategy.

Implementations

impl PeerBandwidthAllocator

pub fn new(total_bps: u64, strategy: AllocationStrategy) -> Self

Creates a new allocator with the given budget and strategy.

pub fn add_peer( &mut self, peer_id: String, weight: f64, min_bps: u64, max_bps: u64, )

Registers a new peer. If the peer already exists it is updated in place.

pub fn remove_peer(&mut self, peer_id: &str) -> bool

Removes a peer and returns true if it existed.

pub fn run_allocation(&mut self)

Runs the configured allocation strategy and stores results in each peer’s allocated_bps field.

pub fn allocation_for(&self, peer_id: &str) -> Option<u64>

Returns the last allocated bandwidth for peer_id, or None if unknown.

pub fn stats(&self) -> AllocationStats

Returns aggregate statistics for the current state.