foxtive-supervisor 0.3.0

Foxtive Supervisor - Advanced task supervision for Rust applications
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
33
34
35

use serde::{Deserialize, Serialize};
use crate::enums::TaskState;

mod memory;
mod fs;

pub use memory::InMemoryStateStore;
pub use fs::FsStateStore;

/// State of a task that can be persisted across supervisor restarts
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct PersistedTaskState {
    pub task_id: String,
    pub last_run_timestamp_secs: Option<u64>,
    pub last_success_timestamp_secs: Option<u64>,
    pub failure_count: usize,
    pub current_attempt: usize,
    pub current_state: TaskState,
}

/// Trait for components that persist task state
#[async_trait::async_trait]
pub trait TaskStateStore: Send + Sync {
    /// Save the state of a task
    async fn save_state(&self, state: PersistedTaskState) -> anyhow::Result<()>;

    /// Load the state of a task by ID
    async fn load_state(&self, task_id: &str) -> anyhow::Result<Option<PersistedTaskState>>;

    /// Load all saved task states
    async fn load_all_states(&self) -> anyhow::Result<Vec<PersistedTaskState>>;

    /// Delete the state of a task
    async fn delete_state(&self, task_id: &str) -> anyhow::Result<()>;
}