Struct DaemonSourceRegistry 

pub struct DaemonSourceRegistry { /* private fields */ }

Daemon-scoped registry of all dynamic sources across both external --source files and pipeline-embedded sources: blocks.

Construction enforces collision-error semantics: a source ID declared in two different sites (or twice in external files) is a hard startup error with the offending file paths quoted in the message.

Implementations

impl DaemonSourceRegistry

pub fn new( external: Vec<(DynamicSource, PathBuf)>, pipeline_sources: Vec<(DynamicSource, String)>, ) -> Result<Self, SourceCollisionError>

Build a registry from external sources and pipeline-declared sources.

Returns Err if any source ID appears more than once across all declaration sites.

pub fn from_external( external: Vec<(DynamicSource, PathBuf)>, ) -> Result<Self, SourceCollisionError>

Build a registry from only external sources (no pipeline sources).

pub fn empty() -> Self

Build an empty registry (no sources at all).

pub fn sources(&self) -> Vec<&DynamicSource>

All sources in the registry.

pub fn into_sources(self) -> Vec<DynamicSource>

All owned sources in the registry.

pub fn entries(&self) -> &[RegistryEntry]

All entries (source + origin) in the registry.

pub fn ids(&self) -> &HashSet<String>

The set of all declared source IDs.

pub fn is_empty(&self) -> bool

Whether the registry has any sources.

pub fn len(&self) -> usize

Number of sources in the registry.

pub fn get(&self, id: &str) -> Option<&RegistryEntry>

Look up a source by ID.

Trait Implementations

impl Clone for DaemonSourceRegistry

fn clone(&self) -> DaemonSourceRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DaemonSourceRegistry

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

Formats the value using the given formatter.