switchyard-fs 1.0.0

Switchyard: safe, atomic, reversible filesystem swaps with policy and audit
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
36
37
38
39

use uuid::Uuid;

use crate::logging::{AuditSink, FactsEmitter};
use crate::types::Action;

use super::perf::PerfAgg;
use crate::api::apply::executors::ActionExecutor;
use crate::logging::audit::AuditCtx;
use crate::logging::StageLogger;

/// Handle an `EnsureSymlink` action: perform the operation and emit per-action facts.
/// Returns (`executed_action_if_success`, `error_message_if_failure`).
pub(crate) fn handle_ensure_symlink<E: FactsEmitter, A: AuditSink>(
    api: &super::super::Switchyard<E, A>,
    tctx: &AuditCtx<'_>,
    pid: &Uuid,
    act: &Action,
    idx: usize,
    dry: bool,
    _slog: &StageLogger<'_>,
) -> (Option<Action>, Option<String>, PerfAgg) {
    let exec = super::executors::ensure_symlink::EnsureSymlinkExec;
    exec.execute(api, tctx, pid, act, idx, dry)
}

/// Handle a `RestoreFromBackup` action: perform restore and emit per-action facts.
/// Returns (`executed_action_if_success`, `error_message_if_failure`).
pub(crate) fn handle_restore<E: FactsEmitter, A: AuditSink>(
    api: &super::super::Switchyard<E, A>,
    tctx: &AuditCtx<'_>,
    pid: &Uuid,
    act: &Action,
    idx: usize,
    dry: bool,
    _slog: &StageLogger<'_>,
) -> (Option<Action>, Option<String>, PerfAgg) {
    let exec = super::executors::restore::RestoreFromBackupExec;
    exec.execute(api, tctx, pid, act, idx, dry)
}