Struct WorkQueue 

pub struct WorkQueue<T> {
    pub commands: Node<WorkQueueCommand<T>>,
    pub records: Node<WorkQueueRecord<T>>,
    pub status: Node<WorkQueueStatus>,
    pub issues: Node<DataIssue>,
    /* private fields */
}

WorkQueue data container.

Fields

commands: Node<WorkQueueCommand<T>>

commands field for commands.

records: Node<WorkQueueRecord<T>>

records field for records.

status: Node<WorkQueueStatus>

status field for status.

issues: Node<DataIssue>

issues field for issues.

Implementations

impl<T: Clone + 'static> WorkQueue<T>

pub fn submit( &self, payload: T, opts: WorkQueueSubmitOptions, ) -> MessageBusCommand<WorkQueueSubmit<T>>

Updates or reads submit.

pub fn claim(&self, opts: WorkQueueClaimOptions) -> WorkQueueCommand<T>

Updates or reads claim.

pub fn renew_lease( &self, work_id: impl Into<String>, lease_id: impl Into<String>, attempt: u32, worker_id: impl Into<String>, command_id: impl Into<String>, ) -> WorkQueueCommand<T>

Updates or reads renew_lease.

pub fn release( &self, work_id: impl Into<String>, lease_id: impl Into<String>, attempt: u32, worker_id: impl Into<String>, command_id: impl Into<String>, ) -> WorkQueueCommand<T>

Updates or reads release.

pub fn complete( &self, work_id: impl Into<String>, lease_id: impl Into<String>, attempt: u32, worker_id: impl Into<String>, command_id: impl Into<String>, result: Option<String>, ) -> WorkQueueCommand<T>

Updates or reads complete.

pub fn fail( &self, work_id: impl Into<String>, lease_id: impl Into<String>, attempt: u32, worker_id: impl Into<String>, command_id: impl Into<String>, retryable: Option<bool>, ) -> WorkQueueCommand<T>

Updates or reads fail.

pub fn cancel( &self, work_id: impl Into<String>, command_id: impl Into<String>, reason: Option<String>, ) -> WorkQueueCommand<T>

Updates or reads cancel.

pub fn schedule( &self, work_id: impl Into<String>, not_before_ms: u64, command_id: impl Into<String>, ) -> WorkQueueCommand<T>

Updates or reads schedule.

pub fn expire_leases( &self, command_id: impl Into<String>, ) -> WorkQueueCommand<T>

Updates or reads expire_leases.

pub fn available(&self) -> WorkQueueAvailableProjection<T>

Updates or reads available.

pub fn available_named( &self, name: Option<impl Into<String>>, ) -> WorkQueueAvailableProjection<T>

Updates or reads available_named.

pub fn work( &self, work_id: impl Into<String>, ) -> WorkQueueProjection<WorkQueueWorkSnapshot<T>>

Updates or reads work.

pub fn work_named( &self, work_id: impl Into<String>, name: Option<impl Into<String>>, ) -> WorkQueueProjection<WorkQueueWorkSnapshot<T>>

Updates or reads work_named.

pub fn dead_letter(&self) -> WorkQueueProjection<WorkQueueDeadLetterPage<T>>

Updates or reads dead_letter.

pub fn dead_letter_named( &self, name: Option<impl Into<String>>, ) -> WorkQueueProjection<WorkQueueDeadLetterPage<T>>

Updates or reads dead_letter_named.

Trait Implementations

impl<T: Clone> Clone for WorkQueue<T>

fn clone(&self) -> WorkQueue<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.