Enum ConversationEvent 

pub enum ConversationEvent {
    MessageReceived {
        message_id: String,
        received_at: u64,
    },
    ProcessingStarted {
        message_id: String,
    },
    StepCompleted {
        message_id: String,
        step_index: u32,
        output: Vec<u8>,
    },
    ProcessingFinished {
        message_id: String,
    },
    ErrorOccurred {
        message_id: String,
        error: String,
    },
}

Event-sourced durable conversation state transition.

Variants

MessageReceived

A message entered the conversation.

Fields

message_id: String

Stable message identifier used to correlate all later events.

received_at: u64

Caller-provided epoch-millisecond receive timestamp.

ProcessingStarted

Processing started for a received message.

Fields

message_id: String

Stable message identifier used to correlate all later events.

StepCompleted

One processing step completed successfully.

Fields

message_id: String

Stable message identifier used to correlate all later events.

step_index: u32

Zero-based step index completed by the conversation worker.

output: Vec<u8>

Opaque, deterministic output checkpoint for the completed step.

ProcessingFinished

Processing finished for a message.

Fields

message_id: String

Stable message identifier used to correlate all later events.

ErrorOccurred

Processing failed for a message.

Fields

message_id: String

Stable message identifier used to correlate all later events.

error: String

Error text recorded for replay and operator visibility.

Implementations

impl ConversationEvent

pub fn serialize(&self) -> Result<Vec<u8>, DurabilityError>

Serializes this event into deterministic storage bytes.

Errors

Returns DurabilityError::EnvelopeError when a field length cannot be encoded.

pub fn deserialize(bytes: &[u8]) -> Result<Self, DurabilityError>

Deserializes an event previously produced by Self::serialize.

Errors

Returns DurabilityError::EnvelopeError when bytes are malformed, truncated, contain invalid UTF-8, use an unknown tag, or carry trailing data.

impl ConversationEvent

pub fn message_id(&self) -> &str

Returns the message identifier carried by every event variant.

Trait Implementations

impl Clone for ConversationEvent

fn clone(&self) -> ConversationEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConversationEvent

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

Formats the value using the given formatter.

impl Eq for ConversationEvent

impl PartialEq for ConversationEvent

fn eq(&self, other: &ConversationEvent) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ConversationEvent