Struct LocalLogSpooler 

pub struct LocalLogSpooler { /* private fields */ }

Local-only log spooler.

Phase 1 is responsible for local directory existence and deterministic path generation. Later phases will stream remote stdout/stderr into these files and use the registry to serve check_process.

Implementations

impl LocalLogSpooler

pub fn new(base_dir: PathBuf) -> Self

pub fn new_default() -> Self

pub fn base_dir(&self) -> &Path

pub async fn ensure_dir(&self) -> Result<()>

pub fn log_path_for(&self, job_id: &str) -> Result<PathBuf>

pub fn state_path_for(&self, job_id: &str) -> Result<PathBuf>

pub async fn persist_job_state(&self, job: &JobState) -> Result<()>

pub async fn load_job_state(&self, job_id: &str) -> Result<Option<JobState>>

pub async fn cleanup_old_logs(&self, max_age: Duration) -> Result<usize>

Trait Implementations

impl Clone for LocalLogSpooler

fn clone(&self) -> LocalLogSpooler

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LocalLogSpooler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.