Struct Event 

pub struct Event {
    pub kind: String,
    pub id: String,
    pub payload: Value,
    pub meta: Value,
    pub ack_tx: Option<AckSender>,
}

A normalized event flowing through the bus.

Ownership: produced by a Source, moved through a bounded mpsc::Sender<Event> into the single dispatcher loop. The dispatcher consumes the ack_tx (via Option::take) to send the handler’s return value back to the source.

Fields

kind: String

Dispatch key. Matched against bus.on(kind, fn) registrations.

id: String

Correlation id (source-assigned). Used in tracing/logging.

payload: Value

Source-defined payload. Converted to Lua table at dispatch time.

meta: Value

Source-defined metadata (e.g. mesh from, timestamps). Converted to Lua table at dispatch time.

ack_tx: Option<AckSender>

Optional one-shot channel used to return the Lua handler’s result. None for fire-and-forget sources.

Implementations

impl Event

pub fn fire_and_forget( kind: impl Into<String>, id: impl Into<String>, payload: Value, ) -> Self

Construct a new event without an ack channel (fire-and-forget).

Intended for ST4 adapters (webhook broadcast / timer). Not used by the ST3 mesh path (which needs the ack round-trip).

pub fn with_ack( kind: impl Into<String>, id: impl Into<String>, payload: Value, meta: Value, ) -> (Self, AckReceiver)

Construct a new event paired with a fresh ack channel. Returns the event (to be pushed to the bus) and the receiver half (to be awaited by the source).

Used by the dispatcher’s in-crate tests and by forthcoming ST4 adapters. The ST3 mesh adapter constructs Event directly to keep control over the meta map and ack sender lifetime.

pub fn deliver_ack(&mut self, result: AckResult) -> Result<(), BlockError>

Send result on ack_tx if it is still present. Logs a warning when the receiver has been dropped (tracing-missing-on-err policy).

Returns Ok(()) when the ack was delivered or the event was fire-and-forget. Returns Err(BlockError::Bus) only when the receiver had been dropped — the caller can decide whether to treat that as fatal.

Trait Implementations

impl Debug for Event

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

Formats the value using the given formatter.