Struct WorkQueueOptions 

pub struct WorkQueueOptions<T> {
    pub queue_id: String,
    pub bus: MessageBus<WorkQueueSubmit<T>>,
    pub topic: String,
    pub subscription_id: String,
    pub from: MessageBusSubscriptionFrom,
    pub name: Option<String>,
    pub now: Rc<dyn Fn() -> u64>,
    pub lease_duration_ms: u64,
    pub retry: RetryPolicy,
}

WorkQueueOptions data container.

Fields

queue_id: String

queue_id field for queue id.

bus: MessageBus<WorkQueueSubmit<T>>

bus field for bus.

topic: String

topic field for topic.

subscription_id: String

subscription_id field for subscription id.

from: MessageBusSubscriptionFrom

from field for from.

name: Option<String>

name field for name.

now: Rc<dyn Fn() -> u64>

now field for now.

lease_duration_ms: u64

lease_duration_ms field for lease duration ms.

retry: RetryPolicy

retry field for retry.

Implementations

impl<T> WorkQueueOptions<T>

pub fn new( queue_id: impl Into<String>, bus: MessageBus<WorkQueueSubmit<T>>, topic: impl Into<String>, subscription_id: impl Into<String>, ) -> Self

Creates or computes new.

pub fn named(self, name: impl Into<String>) -> Self

Updates or reads named.

pub fn with_now(self, now: impl Fn() -> u64 + 'static) -> Self

Updates or reads with_now.

pub fn with_lease_duration_ms(self, lease_duration_ms: u64) -> Self

Updates or reads with_lease_duration_ms.

pub fn with_retry(self, retry: RetryPolicy) -> Self

Updates or reads with_retry.

Trait Implementations

impl<T: Clone> Clone for WorkQueueOptions<T>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.