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 an adapter that broadcasts without waiting (webhook broadcast / timer). Not used by the 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 an adapter that wants the ack without assembling the channel itself. The mesh adapter constructs Event directly instead, to keep control over the meta map and the ack sender’s 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.