Struct SourceRegistry 

pub struct SourceRegistry { /* private fields */ }

A dynamic, priority-ordered registry of Source providers.

PV name resolution iterates sources from lowest order to highest and delegates to the first source that claims the name.

Implementations

impl SourceRegistry

pub fn new() -> Self

Create an empty registry.

pub async fn add( &self, label: impl Into<String>, order: i32, source: Arc<dyn Source>, )

Register a new source at the given priority.

Lower order values are queried first.

pub async fn remove(&self, label: &str)

Remove all sources with the given label.

pub async fn claim(&self, name: &str) -> Option<PvInfo>

Find the first source that claims name and return its metadata.

pub async fn has_pv(&self, name: &str) -> bool

Check whether any source claims the given PV name.

pub async fn get(&self, name: &str) -> Option<NtPayload>

Get the value from the first source that claims the PV.

pub async fn get_descriptor(&self, name: &str) -> Option<StructureDesc>

Get the structure descriptor from the first source that claims the PV.

pub async fn is_writable(&self, name: &str) -> bool

Check if the PV is writable (via the first claiming source).

pub async fn put( &self, name: &str, value: &DecodedValue, ) -> Result<Vec<(String, NtPayload)>, String>

Delegate a PUT to the first source that claims the PV.

pub async fn subscribe(&self, name: &str) -> Option<Receiver<NtPayload>>

Subscribe via the first source that claims the PV.

pub async fn rpc( &self, name: &str, args: &DecodedValue, ) -> Result<NtPayload, String>

Execute an RPC call via the first source that claims the channel.

pub async fn names(&self) -> Vec<String>

Collect all PV names from every registered source.

Trait Implementations

impl Default for SourceRegistry

fn default() -> Self

Returns the “default value” for a type.