Skip to main content

Crate blazen_persist

Crate blazen_persist 

Source
Expand description

§Blazen Persistence

Provides checkpoint storage for workflow state, enabling pause/resume and crash recovery.

§Backends

Two storage backends are available behind feature flags:

FeatureBackendDescription
redb (default)RedbCheckpointStoreEmbedded, pure-Rust ACID key-value store
valkey[valkey::ValkeyCheckpointStore]Redis/ValKey server-backed store

§Quick start (redb)

use blazen_persist::{CheckpointStore, RedbCheckpointStore, WorkflowCheckpoint};

let store = RedbCheckpointStore::new("workflow.db")?;

// Save a checkpoint
store.save(&checkpoint).await?;

// Load it back
let loaded = store.load(&checkpoint.run_id).await?;

Re-exports§

pub use checkpoint::CheckpointStore;
pub use checkpoint::SerializedEvent;
pub use checkpoint::WorkflowCheckpoint;
pub use error::PersistError;
pub use checkpoint::RedbCheckpointStore;

Modules§

checkpoint
Checkpoint storage for workflow state persistence.
error
Error types for the persistence layer.