Struct CapabilityRegistry 

pub struct CapabilityRegistry { /* private fields */ }

Implementations

impl CapabilityRegistry

pub fn new( session_generation: SessionGeneration, ledger: Arc<ResourceLedger>, ) -> Self

pub fn session_generation(&self) -> SessionGeneration

pub fn resources(&self) -> Arc<ResourceLedger>

pub fn reserve( &self, kind: CapabilityKind, ) -> Result<PendingCapability, CapabilityError>

Acquire every count permit before allocating the descriptor/backend.

pub async fn reserve_when_available( &self, kind: CapabilityKind, ) -> Result<PendingCapability, CapabilityError>

Pause an async source at admission instead of accepting/reading and then queueing uncharged state. The notification is armed before each retry so a concurrent release cannot be missed.

pub fn snapshot(&self, id: CapabilityId) -> Option<CapabilitySnapshot>

pub fn snapshots(&self) -> Vec<CapabilitySnapshot>

pub fn close_admission(&self) -> Result<(), CapabilityError>

pub fn active_len(&self) -> usize

pub fn outstanding_len(&self) -> usize

pub async fn wait_empty(&self)

Trait Implementations

impl Clone for CapabilityRegistry

fn clone(&self) -> CapabilityRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CapabilityRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.