Enum QueueCommand 

pub enum QueueCommand {
    Push {
        queue: String,
        value: Value,
        side: QueueSide,
        priority: Option<i32>,
    },
    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,
    },
    Pending {
        queue: String,
        group: String,
    },
    Claim {
        queue: String,
        group: String,
        consumer: String,
        min_idle_ms: u64,
    },
    Ack {
        queue: String,
        group: String,
        message_id: String,
    },
    Nack {
        queue: String,
        group: String,
        message_id: String,
    },
    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>

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

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

Nack

Fields

queue: String

group: String

message_id: String

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

Formats the value using the given formatter.