Struct NodeRegistry 

pub struct NodeRegistry {
    pub schema_version: u32,
    pub next_id: u32,
    pub path: PathBuf,
    /* private fields */
}

Persisted node registry (JSON file on disk).

Fields

schema_version: u32

next_id: u32

path: PathBuf

Path where this registry is persisted. Not serialized.

Implementations

impl NodeRegistry

pub fn load(path: &Path) -> Result<Self>

Load the registry from disk, or create an empty one if the file doesn’t exist.

pub fn load_locked(path: &Path) -> Result<(Self, File)>

Load the registry with an exclusive file lock.

Returns the registry and the lock file handle. The lock is held until the file handle is dropped, so callers should keep it alive for the duration of their read-modify-write cycle.

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

Save the registry to disk atomically.

Writes to a temporary file first, then renames to the target path. This prevents registry corruption if the process crashes mid-write.

pub fn get(&self, id: u32) -> Result<&NodeConfig>

Get a node by ID.

pub fn get_mut(&mut self, id: u32) -> Result<&mut NodeConfig>

Get a mutable reference to a node by ID.

pub fn add(&mut self, config: NodeConfig) -> u32

Add a node and return its assigned ID.

pub fn add_batch(&mut self, configs: Vec<NodeConfig>) -> Vec<u32>

Add multiple nodes at once and return their assigned IDs.

pub fn remove(&mut self, id: u32) -> Result<NodeConfig>

Remove a node by ID.

pub fn list(&self) -> Vec<&NodeConfig>

List all nodes.

pub fn find_by_service_name(&self, name: &str) -> Option<&NodeConfig>

Find a node by its service name.

pub fn len(&self) -> usize

Number of registered nodes.

pub fn is_empty(&self) -> bool

Whether the registry is empty.

pub fn clear(&mut self)

Clear all nodes and reset the next ID counter.

Trait Implementations

impl Clone for NodeRegistry

fn clone(&self) -> NodeRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeRegistry

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NodeRegistry

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for NodeRegistry

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

where __S: Serializer,

Serialize this value into the given Serde serializer.