Struct StateFile 

pub struct StateFile {
    pub daemons: BTreeMap<DaemonId, Daemon>,
    pub disabled: BTreeSet<DaemonId>,
    pub shell_dirs: BTreeMap<String, PathBuf>,
    pub project_sessions: BTreeMap<String, BTreeMap<PathBuf, ProjectSession>>,
    /* private fields */
}

Fields

daemons: BTreeMap<DaemonId, Daemon>

disabled: BTreeSet<DaemonId>

shell_dirs: BTreeMap<String, PathBuf>

project_sessions: BTreeMap<String, BTreeMap<PathBuf, ProjectSession>>

Project sessions keyed by host PID (as string, matching shell_dirs) and then by canonical directory. #[serde(default)] keeps older state files (that predate project sessions) parseable.

Implementations

impl StateFile

pub fn new(path: PathBuf) -> Self

pub fn get() -> &'static Self

pub fn read<P: AsRef<Path>>(path: P) -> Result<Self>

pub fn is_dirty(&self) -> bool

Check whether the state file needs to be flushed.

pub fn insert_daemon(&mut self, id: &DaemonId, daemon: Daemon)

Insert or replace a daemon entry and mark the state dirty.

pub fn set_status(&mut self, id: &DaemonId, status: DaemonStatus) -> bool

Set a daemon’s status, marking the state dirty. Returns whether the daemon exists.

pub fn clear_proxy_idle_timeout(&mut self, id: &DaemonId) -> bool

Clear a daemon’s idle-shutdown ownership, marking the state dirty if it had any. Returns true if it did.

pub fn remove_daemon(&mut self, id: &DaemonId)

Remove a daemon entry and mark the state dirty if the daemon existed.

pub fn disable_daemon(&mut self, id: &DaemonId) -> bool

Disable a daemon (add to disabled set) and mark the state dirty. Returns true if the daemon was not already disabled.

pub fn enable_daemon(&mut self, id: &DaemonId) -> bool

Enable a daemon (remove from disabled set) and mark the state dirty. Returns true if the daemon was previously disabled.

pub fn set_active_port(&mut self, id: &DaemonId, port: u16) -> bool

Set the active port for a daemon and mark the state dirty. Returns true if the daemon was found and updated.

pub fn clear_active_port(&mut self, id: &DaemonId) -> bool

Clear the active port for a daemon and mark the state dirty. Returns true if the daemon was found and updated.

pub fn set_last_cron_triggered( &mut self, id: &DaemonId, time: DateTime<Local>, ) -> bool

Update the last cron trigger time for a daemon and mark the state dirty. Returns true if the daemon was found and updated.

pub fn set_last_cron_run( &mut self, id: &DaemonId, time: DateTime<Local>, ) -> bool

Record that the cron watcher actually started a daemon, and mark the state dirty. Returns true if the daemon was found and updated.

Separate from set_last_cron_triggered because a tick and a run are not the same event: see Daemon::last_cron_run.

pub fn set_shell_dir(&mut self, shell_pid: u32, dir: PathBuf)

Set a shell working directory and mark the state dirty.

pub fn remove_shell_dir(&mut self, shell_pid: u32) -> bool

Remove a shell working directory and mark the state dirty. Returns true if the entry existed.

pub fn set_project_session( &mut self, pid: u32, dir: PathBuf, session: ProjectSession, ) -> Option<ProjectSession>

Insert or replace a project session for the given host PID and directory and mark the state dirty. Returns the previous session, if any.

pub fn remove_project_session( &mut self, pid: u32, dir: &Path, ) -> Option<ProjectSession>

Remove a project session for the given host PID and directory and mark the state dirty if it existed. Returns the removed session, if any. Empty per-PID subtables are pruned so the persisted TOML stays tidy.

pub fn get_project_session( &self, pid: u32, dir: &Path, ) -> Option<&ProjectSession>

Look up a project session for the given host PID and directory.

pub fn active_directories(&self) -> Vec<PathBuf>

Flat iterator over all project sessions yielding (pid_str, dir, session) for every entry. Used by the supervisor refresh loop to evaluate liveness. Every directory a tracked shell or project session is in.

pub fn iter_project_sessions(&self) -> Vec<(&str, &PathBuf, &ProjectSession)>

pub fn retain_daemons<F>(&mut self, f: F)

where F: FnMut(&DaemonId, &Daemon) -> bool,

Retain only daemons matching the predicate and mark the state dirty if any were removed.

pub fn write(&self) -> Result<()>

Synchronous force-write. Clears the dirty flag. If the serialized content matches the last written content, the disk write is skipped to avoid unnecessary I/O. Used during shutdown and migration where async flushing is not available.

Trait Implementations

impl Debug for StateFile

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StateFile

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StateFile

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.