Struct ConversationState 

pub struct ConversationState {
    pub received_messages: HashSet<String>,
    pub in_progress: HashSet<String>,
    pub completed_steps: HashMap<(String, u32), Vec<u8>>,
    pub finished_messages: HashSet<String>,
    pub errored_messages: HashMap<String, String>,
}

Replay-derived durable conversation processing state.

Fields

received_messages: HashSet<String>

Messages that have MessageReceived events.

in_progress: HashSet<String>

Messages with ProcessingStarted and no later terminal event.

completed_steps: HashMap<(String, u32), Vec<u8>>

Completed step outputs indexed by (message_id, step_index).

finished_messages: HashSet<String>

Messages that have ProcessingFinished events.

errored_messages: HashMap<String, String>

Messages that have ErrorOccurred events, mapped to the recorded error.

Implementations

impl ConversationState

pub fn replay(events: &[ConversationEvent]) -> Self

Replays events into a fresh conversation state.

pub fn apply(&mut self, event: &ConversationEvent)

Applies one event to this state using idempotent set/map updates.

pub fn is_fully_processed(&self, message_id: &str) -> bool

Returns true when the replayed log contains ProcessingFinished for the message.

pub fn last_completed_step(&self, message_id: &str) -> Option<u32>

Returns the highest completed step for message_id, if any.

Trait Implementations

impl Clone for ConversationState

fn clone(&self) -> ConversationState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConversationState

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

Formats the value using the given formatter.

impl Default for ConversationState

fn default() -> ConversationState

Returns the “default value” for a type.

impl Eq for ConversationState

impl PartialEq for ConversationState

fn eq(&self, other: &ConversationState) -> 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 ConversationState