Struct InflightRegistry 

pub struct InflightRegistry { /* private fields */ }

Registry of requests that are currently active within a session.

Implementations

impl InflightRegistry

pub fn track( &self, context: &OperationContext, operation_kind: OperationKind, session_anchor_id: &str, cancellable: bool, ) -> Result<(), SessionError>

pub fn complete( &self, request_id: &RequestId, ) -> Result<InflightRequest, SessionError>

pub fn mark_cancellation_requested( &self, request_id: &RequestId, ) -> Result<(), SessionError>

pub fn get(&self, request_id: &RequestId) -> Option<InflightRequest>

pub fn mark_execution_nonce_pending( &self, request_id: &RequestId, nonce_id: &str, ) -> Result<(), SessionError>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn clear(&self)

Trait Implementations

impl Clone for InflightRegistry

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InflightRegistry

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

Formats the value using the given formatter.

impl Default for InflightRegistry

fn default() -> Self

Returns the “default value” for a type.