Struct BandwidthThrottle 

pub struct BandwidthThrottle { /* private fields */ }

Bandwidth throttler using token bucket algorithm

Implementations

impl BandwidthThrottle

pub fn new(config: ThrottleConfig) -> Result<Self, ThrottleError>

Create a new bandwidth throttle with the given configuration

pub fn check_and_consume( &self, direction: TrafficDirection, bytes: u64, ) -> Result<(), ThrottleError>

Check if data transfer is allowed Returns Ok(()) if allowed, or Err with retry duration

pub fn available_bandwidth(&self, direction: TrafficDirection) -> Option<u64>

Get available bandwidth in bytes for the given direction

pub fn set_enabled(&mut self, enabled: bool)

Enable or disable throttling

pub fn is_enabled(&self) -> bool

Check if throttling is enabled

pub fn config(&self) -> &ThrottleConfig

Get the current configuration

pub fn update_config( &mut self, config: ThrottleConfig, ) -> Result<(), ThrottleError>

Update throttle configuration

Trait Implementations

impl Clone for BandwidthThrottle

fn clone(&self) -> BandwidthThrottle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.