Enum SystemSignal 

pub enum SystemSignal {
    NodeOverloaded {
        node_id: NodeId,
        queue_id: Option<QueueId>,
    },
    NodeIdle {
        node_id: NodeId,
        queue_id: Option<QueueId>,
    },
    TaskDequeuedByWorker {
        node_id: NodeId,
        task_id: TaskId,
    },
    TaskProcessed {
        node_id: NodeId,
        task_id: TaskId,
        duration_micros: u64,
    },
}

Represents operational events that are passed within the system.

These signals provide real-time feedback from nodes to the central system, allowing it to monitor health and make load-balancing decisions.

Variants

NodeOverloaded

Sent when a node’s task queue is nearing its capacity.

Fields

node_id: NodeId

queue_id: Option<QueueId>

NodeIdle

Sent when a previously overloaded node has cleared enough space in its queue.

Fields

node_id: NodeId

queue_id: Option<QueueId>

TaskDequeuedByWorker

Sent by a worker just before it begins executing a task.

Fields

node_id: NodeId

task_id: TaskId

TaskProcessed

Sent by a worker after it has finished executing a task.

Fields

node_id: NodeId

task_id: TaskId

duration_micros: u64

The total time it took to execute the task, in microseconds.

Implementations

impl SystemSignal

pub fn get_node_id(&self) -> NodeId

A convenience method to get the NodeId from any signal type.

Trait Implementations

impl Clone for SystemSignal

fn clone(&self) -> SystemSignal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SystemSignal

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

Formats the value using the given formatter.