floxide-redis 3.2.2

Redis implementation for Floxide distributed workflow system
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
30
31
32

//! Redis implementation for Floxide distributed workflow system.
//!
//! This crate provides Redis-backed implementations of the distributed system
//! interfaces defined in floxide-core, including:
//!
//! - `RedisWorkQueue`: A Redis-backed work queue for distributed workflow execution
//! - `RedisCheckpointStore`: A Redis-backed checkpoint store for workflow state persistence
//! - `RedisRunInfoStore`: A Redis-backed store for workflow run metadata
//! - `RedisMetricsStore`: A Redis-backed store for workflow metrics
//! - `RedisErrorStore`: A Redis-backed store for workflow errors
//! - `RedisLivenessStore`: A Redis-backed store for worker liveness tracking
//! - `RedisWorkItemStateStore`: A Redis-backed store for work item state tracking

mod client;
mod config;
mod context_store;
mod error_store;
mod liveness_store;
mod metrics_store;
mod run_info_store;
mod work_item_store;
mod work_queue;

pub use client::{RedisClient, RedisClientError};
pub use config::RedisConfig;
pub use context_store::RedisContextStore;
pub use error_store::RedisErrorStore;
pub use liveness_store::RedisLivenessStore;
pub use metrics_store::RedisMetricsStore;
pub use run_info_store::RedisRunInfoStore;
pub use work_item_store::RedisWorkItemStateStore;
pub use work_queue::RedisWorkQueue;