ironflow 0.6.0

Event-sourced workflow engine for durable, long-running processes
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

//! Runtime for executing workflow effects.
//!
//! This module provides the infrastructure for processing effects from the outbox:
//!
//! - [`WorkflowRuntime`] — Main coordinator that runs effect and timer workers
//! - [`WorkflowBuilder`] — Builder for registering workflows and configuring the runtime
//! - [`RuntimeConfig`] — Configuration for polling intervals, timeouts, etc.
//!
//! # Example
//!
//! ```ignore
//! use ironflow::runtime::{RuntimeConfig, WorkflowRuntime};
//!
//! let runtime = WorkflowRuntime::builder(pool, WorkflowServiceConfig::default())
//!     .register::<OrderWorkflow>(order_handler)
//!     .register::<InventoryWorkflow>(inventory_handler)
//!     .config(RuntimeConfig::default())
//!     .build_runtime()?;
//!
//! runtime.run(shutdown_signal).await?;
//! ```

mod config;
mod effect_worker;
pub(crate) mod registry;
mod timer_worker;

pub use config::RuntimeConfig;
pub use registry::{WorkflowBuilder, WorkflowRuntime};