Struct ServiceDefinitionLoader 

pub struct ServiceDefinitionLoader { /* private fields */ }

Loader rooted at one v2 service-definition directory.

Cheap to clone (PathBuf plus nothing else). Intended pattern: construct once at broker startup, hold across the broker’s lifetime, call Self::load per Hello message.

Implementations

impl ServiceDefinitionLoader

pub fn new(root: impl Into<PathBuf>) -> Self

Create a loader for root.

pub fn default_root() -> Self

Create a loader for the platform default v2 service-definition directory (service_definition_dir_v2).

pub fn root(&self) -> &Path

Directory this loader reads from.

pub fn load( &self, service_name: &str, ) -> Result<ServiceDefinition, ServiceDefinitionError>

Load and validate one service definition from disk.

Re-reads the file on every call — matches v1’s reload-on-Hello semantics. Slow paths (validation, prost decode) live here so the broker’s accept loop stays allocation-free in the steady state.

Errors

• ServiceDefinitionError::InvalidName when service_name fails the shared validator.
• ServiceDefinitionError::InsecureDirectory when root exists but has world/group write bits.
• ServiceDefinitionError::Io for missing-file / permission / I/O failures.
• ServiceDefinitionError::Decode for a corrupt or non-v2 servicedef file.
• ServiceDefinitionError::ServiceNameMismatch when the filename-derived service name doesn’t match the decoded service_name field — catches a typo’d or tampered file.

pub fn reload( &self, service_name: &str, ) -> Result<ServiceDefinition, ServiceDefinitionError>

Alias for Self::load for parity with v1’s loader API.

Errors

See Self::load.

pub fn lookup_or_reload( &self, service_name: &str, ) -> Result<ServiceDefinition, ServiceDefinitionError>

Lookup that always re-reads — mirrors v1’s lookup_or_reload. Future caching can be inserted under this method without changing the call-site contract.

Errors

See Self::load.

pub fn enumerate(&self) -> Vec<ServiceDefinition>

Enumerate every parseable .servicedef.v2 file in the root.

Files that fail validation or decode are SKIPPED, not bubbled — broker discovery wants the parseable subset, not a hard failure on one corrupt entry. Use Self::scan when callers need per-file error details.

pub fn scan(&self) -> Vec<ServiceDefinitionScanEntry>

Scan every .servicedef.v2 entry in the root with per-file errors.

Returns the entries sorted by path so the result is deterministic for snapshot tests + diff-friendly broker reflection APIs.

Trait Implementations

impl Clone for ServiceDefinitionLoader

fn clone(&self) -> ServiceDefinitionLoader

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServiceDefinitionLoader

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

Formats the value using the given formatter.