Enum QueueEvent 

pub enum QueueEvent {
    JobInserted(Ulid),
    JobCompleted(Ulid, JobStatus, JobResult),
    JobFailed(Ulid, u32),
    JobReady(Ulid),
    JobCancelled(Ulid),
}

Events published by the QueueStore via broadcast.

Consumed by:

• SSE endpoint GET /api/v1/jobs/events
• Cascade engine (find_awaiting + set_pending)
• Real-time monitoring dashboard

Variants

JobInserted(Ulid)

New job inserted — Pending or Waiting.

JobCompleted(Ulid, JobStatus, JobResult)

Job completed — Done or DLQ.

JobFailed(Ulid, u32)

Job failed — Failed + attempt number.

JobReady(Ulid)

Job transitioned Waiting → Pending (cascade satisfied).

JobCancelled(Ulid)

Job cancelled — deadline or orphaned.

Trait Implementations

impl Clone for QueueEvent

fn clone(&self) -> QueueEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for QueueEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for QueueEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.