Struct AsyncQueryContext 

pub struct AsyncQueryContext {
    pub deadline: Option<Instant>,
    pub cancellation: AsyncCancellationToken,
}

Fields

deadline: Option<Instant>

cancellation: AsyncCancellationToken

Implementations

impl AsyncQueryContext

pub fn with_timeout_ms(self, timeout_ms: u64) -> Self

pub fn with_deadline(self, deadline: Instant) -> Self

pub fn with_cancellation_token(self, token: AsyncCancellationToken) -> Self

pub fn is_cancelled(&self) -> bool

pub fn is_deadline_exceeded(&self) -> bool

pub fn ensure_active(&self) -> DataResult<()>

Trait Implementations

impl Clone for AsyncQueryContext

fn clone(&self) -> AsyncQueryContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AsyncQueryContext

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

Formats the value using the given formatter.

impl Default for AsyncQueryContext

fn default() -> AsyncQueryContext

Returns the “default value” for a type.