Struct LoopRegistry 

pub struct LoopRegistry { /* private fields */ }

Registry for tracking active Ralph loops.

Provides thread-safe registration and discovery of running loops.

Implementations

impl LoopRegistry

pub const REGISTRY_FILE: &'static str = ".ralph/loops.json"

The relative path to the registry file within the workspace.

pub fn new(workspace_root: impl AsRef<Path>) -> Self

Creates a new registry instance for the given workspace.

pub fn register(&self, entry: LoopEntry) -> Result<String, RegistryError>

Registers a new loop entry.

Returns the entry’s ID for later deregistration.

pub fn deregister(&self, id: &str) -> Result<(), RegistryError>

Deregisters a loop by ID.

pub fn get(&self, id: &str) -> Result<Option<LoopEntry>, RegistryError>

Gets a loop entry by ID.

pub fn list(&self) -> Result<Vec<LoopEntry>, RegistryError>

Lists all active loops (after cleaning stale entries).

pub fn clean_stale(&self) -> Result<usize, RegistryError>

Cleans stale entries (dead PIDs) and returns the number removed.

pub fn deregister_current_process(&self) -> Result<bool, RegistryError>

Deregisters all entries for the current process.

This is useful for cleanup on termination, since each process can only have one active loop entry.