a3s_flow/
lib.rs

1//! Durable workflow engine core for A3S.
2//!
3//! `a3s-flow` models the Workflow SDK style of durable execution as a Rust
4//! core: workflow runs are event-sourced, step results are persisted, waits and
5//! hooks suspend without burning compute, and the actual workflow interpreter is
6//! a pluggable runtime. The native TypeScript runtime boundary compiles source
7//! once, then invokes the compiled executable through a small JSON protocol.
8
9mod context;
10mod engine;
11mod error;
12mod model;
13mod observe;
14mod protocol;
15mod runtime;
16mod scheduler;
17mod store;
18mod worker;
19
20pub use context::WorkflowContext;
21pub use engine::{FlowEngine, FlowEngineBuilder};
22pub use error::{FlowError, Result};
23pub use model::{
24    ActiveHookSnapshot, CancellationRequest, CancellationRequestSnapshot, ChildOperationReference,
25    FlowEvent, FlowEventEnvelope, HookCallbackRoute, HookMetadata, HookSnapshot, HookStatus,
26    JsonValue, RetryPolicy, RuntimeCommand, RuntimeKind, RuntimeSpec, StepCommand,
27    StepFailureAction, StepSnapshot, StepStatus, WaitSnapshot, WaitStatus, WorkflowProgress,
28    WorkflowRunSnapshot, WorkflowRunStatus, WorkflowRunSummary, WorkflowRunSuspension,
29    WorkflowSpec, WorkflowTerminalOutcome,
30};
31#[cfg(feature = "a3s-event")]
32pub use observe::A3sEventBusFlowEventSink;
33pub use observe::{
34    A3sFlowEvent, A3sFlowEventBridge, A3sFlowEventSink, A3sFlowEventSubject,
35    FanoutFlowEventObserver, FlowEventObserver, FlowWorkflowIdentity, InMemoryA3sFlowEventSink,
36    InMemoryFlowEventObserver, LocalFileA3sFlowEventSink, NoopFlowEventObserver,
37};
38pub use protocol::{
39    NativeRuntimeKind, NativeRuntimeRequest, NativeRuntimeResponse, NATIVE_RUNTIME_PROTOCOL,
40};
41pub use runtime::{
42    FlowRuntime, NativeTsRuntime, NativeTsRuntimeConfig, NativeTsRuntimePreflight, StepInvocation,
43    WorkflowInvocation,
44};
45pub use scheduler::{FlowScheduler, FlowSchedulerTick};
46#[cfg(feature = "sqlite")]
47pub use store::SqliteEventStore;
48pub use store::{FlowEventStore, InMemoryEventStore, LocalFileEventStore};
49#[cfg(feature = "postgres")]
50pub use store::{
51    FlowHistoryHold, FlowHistoryRetentionPolicy, FlowHistoryRetentionReport, FlowHistoryTombstone,
52    PostgresEventStore,
53};
54#[cfg(feature = "boot")]
55pub use worker::BootFlowTaskManager;
56pub use worker::{
57    FlowTask, FlowTaskDispatcher, FlowTaskLease, FlowTaskOutcome, FlowTaskQueue, FlowWorker,
58    InMemoryFlowTaskQueue, LocalFileDeadLetteredTask, LocalFileFlowTaskQueue,
59};
60#[cfg(feature = "postgres")]
61pub use worker::{PostgresDeadLetteredTask, PostgresFlowTaskQueue};
a3s_flow/lib.rs

a3s_flow/
lib.rs
