Struct CqrsWorkQueueRecipeOptions 

pub struct CqrsWorkQueueRecipeOptions<TCommand> {
    pub name: String,
    pub records: Node<WorkQueueRecord<CqrsQueuedCommandPayload<TCommand>>>,
    pub status: Node<CqrsStatus>,
    pub errors: Option<Node<CqrsError<TCommand>>>,
    pub worker_id: Option<String>,
    pub policy: CqrsWorkQueuePolicy,
}

CqrsWorkQueueRecipeOptions data container.

Fields

name: String

name field for name.

records: Node<WorkQueueRecord<CqrsQueuedCommandPayload<TCommand>>>

records field for records.

status: Node<CqrsStatus>

status field for status.

errors: Option<Node<CqrsError<TCommand>>>

errors field for errors.

worker_id: Option<String>

worker_id field for worker id.

policy: CqrsWorkQueuePolicy

policy field for policy.

Implementations

impl<TCommand> CqrsWorkQueueRecipeOptions<TCommand>

pub fn new( records: Node<WorkQueueRecord<CqrsQueuedCommandPayload<TCommand>>>, status: Node<CqrsStatus>, ) -> Self

Creates or computes new.

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

Updates or reads named.

pub fn with_errors(self, errors: Node<CqrsError<TCommand>>) -> Self

Updates or reads with_errors.

pub fn for_worker(self, worker_id: impl Into<String>) -> Self

Updates or reads for_worker.

pub fn with_policy(self, policy: CqrsWorkQueuePolicy) -> Self

Updates or reads with_policy.

Trait Implementations

impl<TCommand: Clone> Clone for CqrsWorkQueueRecipeOptions<TCommand>

fn clone(&self) -> CqrsWorkQueueRecipeOptions<TCommand>

Returns a duplicate of the value.

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

Performs copy-assignment from source.