Struct BulkFlowController 

pub struct BulkFlowController { /* private fields */ }

Clone this handle, rather than constructing a controller per transfer.

Implementations

impl BulkFlowController

pub fn new(rates: BulkRates) -> Result<Self, BulkFlowError>

pub fn configure(&self, rates: BulkRates) -> Result<(), BulkFlowError>

pub async fn acquire( &self, direction: BulkDirection, peer: &str, bytes: u64, ) -> Result<(), BulkFlowError>

pub async fn acquire_scoped( &self, direction: BulkDirection, peer: &str, scope: &str, bytes_per_second: Option<u64>, bytes: u64, ) -> Result<(), BulkFlowError>

Admit a body slice against both aggregate and immutable scoped rates in one decision. Reuse a stable scope across attempts; controls bypass it.

Trait Implementations

impl Clone for BulkFlowController

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.