Struct ConversationState 

pub struct ConversationState {
    pub current_phase: ConversationPhase,
    pub context: Vec<ConversationContextEntry>,
    pub deadline: Option<Instant>,
    pub participants: Vec<ParticipantStatus>,
    pub mode: ChannelMode,
}

Queryable state snapshot owned by a conversation actor.

Fields

current_phase: ConversationPhase

Current lifecycle phase.

context: Vec<ConversationContextEntry>

Accumulated exchanged messages and lifecycle references.

deadline: Option<Instant>

Optional in-memory deadline.

participants: Vec<ParticipantStatus>

Last known participant liveness.

mode: ChannelMode

Durability mode marker retained for diagnostics and future resume work.

Implementations

impl ConversationState

pub fn from_config(config: &ConversationConfig, now: Instant) -> Self

Creates initial state for a conversation config.

pub fn activate(&mut self) -> Result<(), LiminalError>

Transitions Created to Active. Active is accepted as idempotent.

Errors

Returns LiminalError::ConversationFailed when the state cannot become active.

pub fn begin_completing(&mut self) -> Result<(), LiminalError>

Transitions Active to Completing.

Errors

Returns LiminalError::ConversationFailed when the state is not active.

pub fn close(&mut self) -> Result<(), LiminalError>

Transitions Completing to Closed.

Errors

Returns LiminalError::ConversationFailed when completion has not begun.

pub const fn fail(&mut self)

Transitions any phase to Failed.

pub fn record_sent(&mut self, envelope: Envelope)

Records an envelope sent into the conversation.

pub fn record_received(&mut self, envelope: Envelope)

Records an envelope received from the conversation.

pub fn record_participant_crash( &mut self, participant: ParticipantPid, policy: CrashPolicy, exited_at: Instant, )

Records participant crash handling and marks that participant dead, stamping exited_at as the instant the EXIT signal was observed.

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 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