Enum ControlCommand 

pub enum ControlCommand {
    Ping {
        reply_to: String,
    },
    Inspect(InspectCommand),
    Shutdown {
        timeout: Option<u64>,
    },
    Revoke {
        task_id: Uuid,
        terminate: bool,
        signal: Option<String>,
    },
    RateLimit {
        task_name: String,
        rate: Option<f64>,
    },
    TimeLimit {
        task_name: String,
        soft: Option<u64>,
        hard: Option<u64>,
    },
    AddConsumer {
        queue: String,
    },
    CancelConsumer {
        queue: String,
    },
    Queue(QueueCommand),
    BulkRevoke {
        task_ids: Vec<Uuid>,
        terminate: bool,
    },
    RevokeByPattern {
        pattern: String,
        terminate: bool,
    },
}

Control commands that can be sent to workers

Variants

Ping

Ping the worker to check if it’s alive

Fields

reply_to: String

Unique ID for this ping request

Inspect(InspectCommand)

Inspect worker state

Shutdown

Shutdown the worker gracefully

Fields

timeout: Option<u64>

Optional timeout in seconds

Revoke

Revoke a task

Fields

task_id: Uuid

Task ID to revoke

terminate: bool

Whether to terminate the task if already running

signal: Option<String>

Whether to send SIGKILL (true) or SIGTERM (false)

RateLimit

Set rate limit for a task type

Fields

task_name: String

Task name to rate limit

rate: Option<f64>

Maximum tasks per second (None to remove limit)

TimeLimit

Set time limit for a task type

Fields

task_name: String

Task name to limit

soft: Option<u64>

Soft time limit in seconds (warning)

hard: Option<u64>

Hard time limit in seconds (kill)

AddConsumer

Add consumer for a queue

Fields

queue: String

Queue name to consume from

CancelConsumer

Cancel consumer for a queue

Fields

queue: String

Queue name to stop consuming

Queue(QueueCommand)

Queue control commands

BulkRevoke

Bulk revoke tasks

Fields

task_ids: Vec<Uuid>

Task IDs to revoke

terminate: bool

Whether to terminate running tasks

RevokeByPattern

Revoke tasks matching a pattern

Fields

pattern: String

Pattern to match task names (glob format)

terminate: bool

Whether to terminate running tasks

Implementations

impl ControlCommand

pub fn ping(reply_to: impl Into<String>) -> Self

Create a ping command

pub fn inspect_active() -> Self

Create an inspect active command

pub fn inspect_scheduled() -> Self

Create an inspect scheduled command

pub fn inspect_reserved() -> Self

Create an inspect reserved command

pub fn inspect_revoked() -> Self

Create an inspect revoked command

pub fn inspect_registered() -> Self

Create an inspect registered command

pub fn inspect_stats() -> Self

Create an inspect stats command

pub fn inspect_queue_info() -> Self

Create an inspect queue info command

pub fn shutdown(timeout: Option<u64>) -> Self

Create a shutdown command

pub fn revoke(task_id: Uuid, terminate: bool) -> Self

Create a revoke command

pub fn bulk_revoke(task_ids: Vec<Uuid>, terminate: bool) -> Self

Create a bulk revoke command

pub fn revoke_by_pattern(pattern: impl Into<String>, terminate: bool) -> Self

Create a revoke by pattern command

pub fn queue_purge(queue: impl Into<String>) -> Self

Create a queue purge command

pub fn queue_length(queue: impl Into<String>) -> Self

Create a queue length command

pub fn queue_delete( queue: impl Into<String>, if_empty: bool, if_unused: bool, ) -> Self

Create a queue delete command

pub fn queue_bind( queue: impl Into<String>, exchange: impl Into<String>, routing_key: impl Into<String>, ) -> Self

Create a queue bind command

pub fn queue_unbind( queue: impl Into<String>, exchange: impl Into<String>, routing_key: impl Into<String>, ) -> Self

Create a queue unbind command

pub fn queue_declare( queue: impl Into<String>, durable: bool, exclusive: bool, auto_delete: bool, ) -> Self

Create a queue declare command

Trait Implementations

impl Clone for ControlCommand

fn clone(&self) -> ControlCommand

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ControlCommand

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ControlCommand

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ControlCommand

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.