Enum QueuedEvent 

pub enum QueuedEvent {
    DataPoint {
        source: String,
        data: KindedSlot,
    },
    Timer {
        id: u64,
    },
    External {
        payload: Vec<u8>,
    },
    Subscription {
        subscription_id: u64,
        source: String,
        data: KindedSlot,
    },
    Error {
        source: String,
        message: String,
    },
    Shutdown,
}

Events that can be queued for processing

Variants

DataPoint

New data point arrived from a data source

Fields

source: String

Name of the data source (e.g., “data”, “iot_sensors”)

data: KindedSlot

The data payload

Timer

Timer fired

Fields

id: u64

Timer ID for matching with awaiting code

External

External signal from a plugin or external system

Fields

payload: Vec<u8>

Raw payload bytes (typically MessagePack encoded)

Subscription

Subscription update (streaming data)

Fields

subscription_id: u64

Subscription ID

source: String

Source name

data: KindedSlot

Data payload

Error

Error from a data source or plugin

Fields

source: String

Source of the error

message: String

Error message

Shutdown

Shutdown request

Trait Implementations

impl Clone for QueuedEvent

fn clone(&self) -> QueuedEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueuedEvent

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

Formats the value using the given formatter.