Struct ConcurrencyController 

pub struct ConcurrencyController { /* private fields */ }

Implementations

impl ConcurrencyController

pub fn new(exec_options: &Options) -> Self

pub async fn acquire( &self, bytes_fn: Option<impl FnOnce() -> usize>, ) -> Result<ConcurrencyControllerPermit, AcquireError>

If bytes_fn is None, it means the number of bytes is not known yet. The controller will reserve a minimum number of bytes. The caller should call acquire_bytes_with_reservation with the actual number of bytes later.

pub async fn acquire_bytes_with_reservation( &self, bytes_fn: impl FnOnce() -> usize, ) -> Result<Option<OwnedSemaphorePermit>, AcquireError>