pub struct SdkWaitRegistry { /* private fields */ }Expand description
Registry for daemon-backed SDK wait identities and cleanup accounting.
Implementations§
Source§impl SdkWaitRegistry
impl SdkWaitRegistry
Sourcepub fn allocate_id(&mut self, owner_id: SdkWaitOwnerId) -> SdkWaitId
pub fn allocate_id(&mut self, owner_id: SdkWaitOwnerId) -> SdkWaitId
Allocates the next wait id for one SDK owner.
IDs intentionally start at one so a zero value remains conspicuous in logs and diagnostics. The same numeric id can exist under different owners, which is the per-connection scoping contract.
Sourcepub fn register(
&mut self,
connection_id: u64,
owner_id: SdkWaitOwnerId,
wait_id: SdkWaitId,
) -> bool
pub fn register( &mut self, connection_id: u64, owner_id: SdkWaitOwnerId, wait_id: SdkWaitId, ) -> bool
Registers an active wait.
Returns false when the (owner_id, wait_id) pair is already active.
Duplicate registration is rejected without disturbing the existing
record.
Sourcepub fn remove(
&mut self,
owner_id: SdkWaitOwnerId,
wait_id: SdkWaitId,
) -> Option<SdkWaitRecord>
pub fn remove( &mut self, owner_id: SdkWaitOwnerId, wait_id: SdkWaitId, ) -> Option<SdkWaitRecord>
Removes one wait by owner and id.
Duplicate and late cancellations are idempotent: None means there was
no live wait to remove.
Sourcepub fn remove_connection(&mut self, connection_id: u64) -> Vec<SdkWaitRecord>
pub fn remove_connection(&mut self, connection_id: u64) -> Vec<SdkWaitRecord>
Removes every wait owned by an actual server connection.
Sourcepub fn get(
&self,
owner_id: SdkWaitOwnerId,
wait_id: SdkWaitId,
) -> Option<SdkWaitRecord>
pub fn get( &self, owner_id: SdkWaitOwnerId, wait_id: SdkWaitId, ) -> Option<SdkWaitRecord>
Returns a live wait record.
Trait Implementations§
Source§impl Clone for SdkWaitRegistry
impl Clone for SdkWaitRegistry
Source§fn clone(&self) -> SdkWaitRegistry
fn clone(&self) -> SdkWaitRegistry
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for SdkWaitRegistry
impl Debug for SdkWaitRegistry
Source§impl Default for SdkWaitRegistry
impl Default for SdkWaitRegistry
Source§fn default() -> SdkWaitRegistry
fn default() -> SdkWaitRegistry
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for SdkWaitRegistry
impl RefUnwindSafe for SdkWaitRegistry
impl Send for SdkWaitRegistry
impl Sync for SdkWaitRegistry
impl Unpin for SdkWaitRegistry
impl UnsafeUnpin for SdkWaitRegistry
impl UnwindSafe for SdkWaitRegistry
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more