consortium-crate 0.2.0

Core library — Rust implementation of ClusterShell
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

//! Cache strategy trait for skipping already-completed tasks.

use std::any::Any;

use crate::dag::context::DagContext;
use crate::dag::types::TaskId;

/// Trait for determining whether a task can be skipped.
///
/// Implementors check external state (nix store, file system, etc.)
/// and return the cached output if available.
pub trait CacheStrategy: Send + Sync + 'static {
    /// Check if the task's output already exists.
    /// Returns `Some(output)` if cached (task will be skipped),
    /// `None` if the task must execute.
    fn check(&self, task_id: &TaskId, ctx: &DagContext) -> Option<Box<dyn Any + Send>>;
}

/// Never cache — always execute tasks.
pub struct NoCache;

impl CacheStrategy for NoCache {
    fn check(&self, _task_id: &TaskId, _ctx: &DagContext) -> Option<Box<dyn Any + Send>> {
        None
    }
}