Struct QueuedRequest

pub struct QueuedRequest {
    pub kind: QueuedRequestKind,
    pub transaction_id: OwnedTransactionId,
    pub error: Option<QueueWedgeError>,
    pub priority: usize,
    pub created_at: MilliSecondsSinceUnixEpoch,
}

A request to be sent with a send queue.

Fields

kind: QueuedRequestKind

The kind of queued request we’re going to send.

transaction_id: OwnedTransactionId

Unique transaction id for the queued request, acting as a key.

error: Option<QueueWedgeError>

Error returned when the request couldn’t be sent and is stuck in the unrecoverable state.

None if the request is in the queue, waiting to be sent.

priority: usize

At which priority should this be handled?

The bigger the value, the higher the priority at which this request should be handled.

created_at: MilliSecondsSinceUnixEpoch

The time that the request was originally attempted.

Implementations

impl QueuedRequest

pub fn as_event(&self) -> Option<&SerializableEventContent>

Returns Some if the queued request is about sending an event.

pub fn is_wedged(&self) -> bool

True if the request couldn’t be sent because of an unrecoverable API error. See Self::error for more details on the reason.

Trait Implementations

impl Clone for QueuedRequest

fn clone(&self) -> QueuedRequest

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for QueuedRequest

Available on non-tarpaulin_include only.

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

Formats the value using the given formatter.