Struct DurableConversation 

pub struct DurableConversation { /* private fields */ }

Haematite-backed event-sourced durable conversation.

Implementations

impl DurableConversation

pub fn new( conversation_id: impl Into<String>, store: Arc<dyn DurableStore>, ) -> Self

Creates a new durable conversation with empty replay state and expected sequence zero.

pub async fn recover( conversation_id: impl Into<String>, store: Arc<dyn DurableStore>, ) -> Result<Self, DurabilityError>

Recovers a durable conversation by replaying its full event log from sequence zero.

Errors

Propagates store read errors, event deserialization errors, and sequence overflow.

pub fn conversation_id(&self) -> &str

Returns the conversation stream key used for all appends and replay reads.

pub const fn state(&self) -> &ConversationState

Returns the current replay-derived state.

pub const fn expected_seq(&self) -> u64

Returns the next expected sequence used for optimistic append concurrency.

pub async fn receive_message( &mut self, message_id: impl Into<String>, received_at: u64, ) -> Result<RedeliveryDecision, DurabilityError>

Handles a message delivery using replay-derived duplicate detection.

Errors

Returns serialization or store append errors for never-seen messages, and returns DurabilityError::ConfigError if a partial message cannot advance its step index.

pub async fn record_message_received( &mut self, message_id: impl Into<String>, received_at: u64, ) -> Result<u64, DurabilityError>

Appends a MessageReceived event using the current expected sequence.

Errors

Propagates event serialization errors and all store append errors, including DurabilityError::SequenceConflict without retrying.

pub async fn record_processing_started( &mut self, message_id: impl Into<String>, ) -> Result<u64, DurabilityError>

Appends a ProcessingStarted event using the current expected sequence.

Errors

Propagates event serialization errors and all store append errors, including DurabilityError::SequenceConflict without retrying.

pub async fn record_step_completed( &mut self, message_id: impl Into<String>, step_index: u32, output: Vec<u8>, ) -> Result<u64, DurabilityError>

Appends a StepCompleted event using the current expected sequence.

Errors

Propagates event serialization errors and all store append errors, including DurabilityError::SequenceConflict without retrying.

pub async fn record_processing_finished( &mut self, message_id: impl Into<String>, ) -> Result<u64, DurabilityError>

Appends a ProcessingFinished event using the current expected sequence.

Errors

Propagates event serialization errors and all store append errors, including DurabilityError::SequenceConflict without retrying.

pub async fn record_error( &mut self, message_id: impl Into<String>, error: impl Into<String>, ) -> Result<u64, DurabilityError>

Appends an ErrorOccurred event using the current expected sequence.

Errors

Propagates event serialization errors and all store append errors, including DurabilityError::SequenceConflict without retrying.

Trait Implementations

impl Clone for DurableConversation

fn clone(&self) -> DurableConversation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DurableConversation

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

Formats the value using the given formatter.