Enum QueueCommand 

pub enum QueueCommand {
    Push {
        queue: String,
        value: Value,
        side: QueueSide,
        priority: Option<i32>,
        available: Option<QueueAvailability>,
    },
    Pop {
        queue: String,
        side: QueueSide,
        count: usize,
    },
    Peek {
        queue: String,
        count: usize,
    },
    Len {
        queue: String,
    },
    Purge {
        queue: String,
    },
    GroupCreate {
        queue: String,
        group: String,
    },
    GroupRead {
        queue: String,
        group: Option<String>,
        consumer: String,
        count: usize,
        wait_ms: Option<u64>,
    },
    Pending {
        queue: String,
        group: String,
    },
    Claim {
        queue: String,
        group: String,
        consumer: String,
        min_idle_ms: u64,
    },
    Ack {
        queue: String,
        group: String,
        message_id: String,
        delivery_id: Option<String>,
    },
    Nack {
        queue: String,
        group: String,
        message_id: String,
        delivery_id: Option<String>,
        delay_ms: Option<u64>,
    },
    Move {
        source: String,
        destination: String,
        filter: Option<Filter>,
        limit: usize,
    },
}

Queue operation commands

Variants

Push

Fields

queue: String

value: Value

side: QueueSide

priority: Option<i32>

available: Option<QueueAvailability>

Per-message delayed availability (issue #722). None means the message is deliverable immediately. Some(_) resolves to an available_at_ns metadata field at push time; delivery paths (QUEUE READ, QUEUE POP, QUEUE READ … WAIT) refuse to deliver the message until that instant.

Pop

Fields

queue: String

side: QueueSide

count: usize

Peek

Fields

queue: String

count: usize

Len

Fields

queue: String

Purge

Fields

queue: String

GroupCreate

Fields

queue: String

group: String

GroupRead

Fields

queue: String

group: Option<String>

consumer: String

count: usize

wait_ms: Option<u64>

Optional blocking-read deadline in milliseconds (PRD #718 slice A: QUEUE READ … WAIT <duration>). None means classic non-blocking semantics. The runtime currently honors the field synchronously — the actual wait registry lands in slice C.

Pending

Fields

queue: String

group: String

Claim

Fields

queue: String

group: String

consumer: String

min_idle_ms: u64

Ack

Fields

queue: String

group: String

message_id: String

delivery_id: Option<String>

Server-issued opaque base32 delivery handle (ADR 0026). When present, takes precedence over the legacy tuple; the tuple is kept for one minor release as a wire-compat bridge.

Nack

Fields

queue: String

group: String

message_id: String

delivery_id: Option<String>

delay_ms: Option<u64>

Per-failure retry delay override (issue #723). Some(ms) requests that the failed message become re-deliverable only after ms milliseconds; takes precedence over the queue’s default retry_delay_ms. Authorization is enforced at the runtime layer: requests from a read-only identity are rejected.

Move

Fields

source: String

destination: String

filter: Option<Filter>

limit: usize

Trait Implementations

impl Clone for QueueCommand

fn clone(&self) -> QueueCommand

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueCommand

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

Formats the value using the given formatter.