Struct CrossProcessFlowEventStore 

pub struct CrossProcessFlowEventStore { /* private fields */ }

Cross-process serialized adapter for a local Flow event journal.

a3s-flow::LocalFileEventStore deliberately serializes writers only inside one process. Dynamic workflows can be resumed or controlled by a replacement process, so Code adds one small lock-file boundary around the same append-only journal. The adapter does not project or cache workflow state: Flow remains the sole event authority and its optimistic sequence checks still decide whether an append is accepted.

Implementations

impl CrossProcessFlowEventStore

pub fn new(root: impl Into<PathBuf>) -> Self

Create a cross-process event store rooted at root.

pub fn root(&self) -> &Path

Return the directory containing the journal files.

Trait Implementations

impl Clone for CrossProcessFlowEventStore

fn clone(&self) -> CrossProcessFlowEventStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CrossProcessFlowEventStore

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

Formats the value using the given formatter.

impl FlowEventStore for CrossProcessFlowEventStore

fn append<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, event: FlowEvent, ) -> Pin<Box<dyn Future<Output = Result<FlowEventEnvelope>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Append event to run_id and return its durable envelope.

fn append_if_sequence<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, expected_sequence: u64, event: FlowEvent, ) -> Pin<Box<dyn Future<Output = Result<FlowEventEnvelope>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Append event only when the run’s latest sequence equals expected_sequence.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, run_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<FlowEventEnvelope>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load the complete event history for run_id in sequence order.

fn list_run_ids<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all run IDs known to the store in stable order.

fn list_due_wakeups<'life0, 'async_trait>( &'life0 self, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<ScheduledWakeup>, FlowError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

List wait timers and delayed retries due at or before now.

fn next_scheduled_wakeup<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<ScheduledWakeup>, FlowError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Return the earliest wait timer or delayed retry across active runs.

fn find_active_hooks_by_token<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<ActiveHookSnapshot>, FlowError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Find active hooks that own an external callback token.

fn list_active_hooks<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ActiveHookSnapshot>, FlowError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

List active external callback hooks in stable run/hook order.