ironflow-store

Storage abstraction for the ironflow workflow engine. This crate provides the RunStore trait and data entities for persisting workflow runs and steps.

Implementations

Quick start

use ironflow_store::prelude::*;
use serde_json::json;

# async fn example() -> Result<(), ironflow_store::error::StoreError> {
let store = InMemoryStore::new();

let run = store.create_run(NewRun {
    workflow_name: "deploy".to_string(),
    trigger: TriggerKind::Manual,
    payload: json!({}),
    max_retries: 3,
}).await?;

println!("Run {} is {:?}", run.id, run.status);
# Ok(())
# }