Struct WorkflowJournal 

pub struct WorkflowJournal<I: WorkflowJournalIntent> { /* private fields */ }

Exclusive writer for one exact local operator workflow.

Implementations

impl<I: WorkflowJournalIntent> WorkflowJournal<I>

pub async fn open_or_create( path: impl AsRef<Path>, intent: I, ) -> Result<WorkflowJournalReplay<I>, WorkflowJournalError>

Creates or exactly resumes and locks one workflow journal.

pub const fn transaction_id(&self) -> WorkflowTransactionId

pub const fn intent_digest(&self) -> [u8; 32]

pub async fn append( &self, transition: I::Transition, ) -> Result<WorkflowJournalRecordReceipt, WorkflowJournalError>

Appends and synchronizes one transition before returning its receipt.

Any publication error poisons this handle because the create-new link may have committed. Drop and reopen the journal to resolve it by replay.