Enum IngressEventSnapshot 

pub enum IngressEventSnapshot {
    Envelope(Vec<u8>),
    AppEvent {
        module_name: String,
        input_name: String,
        value_bytes: Vec<u8>,
    },
    Invoke {
        module_name: String,
        inputs: Vec<(String, Vec<u8>)>,
    },
    TimerMatured {
        at_ns: u64,
    },
    Completion {
        cmd_id: u64,
        results: Vec<Vec<u8>>,
    },
}

Serializable view of IngressEvent. Only the variants that can realistically survive a snapshot boundary are recorded; Waker / Control variants are dropped on snapshot.

Variants

Envelope(Vec<u8>)

Inbound envelope (encoded as raw bytes - the routing table re-routes on restore).

AppEvent

App-event delivery.

Fields

module_name: String

Module name.

input_name: String

Input port name.

value_bytes: Vec<u8>

Encoded payload bytes.

Invoke

Module invocation.

Fields

module_name: String

Module name.

inputs: Vec<(String, Vec<u8>)>

Input port + value-bytes pairs.

TimerMatured

Timer maturity signal.

Fields

at_ns: u64

Maturity timestamp (nanoseconds).

Completion

Async completion landing back at the engine.

Fields

cmd_id: u64

CommandId.0 being fulfilled.

results: Vec<Vec<u8>>

Encoded result payloads.

Trait Implementations

impl Clone for IngressEventSnapshot

fn clone(&self) -> IngressEventSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IngressEventSnapshot

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for IngressEventSnapshot

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for IngressEventSnapshot

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

where __S: Serializer,

Serialize this value into the given Serde serializer.