Struct GroupSource 

pub struct GroupSource { /* private fields */ }

A Source that serves group PVs composed from multiple member PVs.

Group PV names are resolved by fetching each member PV from the underlying SourceRegistry and composing them into an NtPayload::Generic. Non-group names are not claimed.

Implementations

impl GroupSource

pub fn new( sources: Arc<SourceRegistry>, groups: HashMap<String, GroupPvDef>, ) -> Self

Create a new group source backed by sources with the given group definitions.

Trait Implementations

impl Source for GroupSource

fn claim( &self, name: &str, ) -> Pin<Box<dyn Future<Output = Option<PvInfo>> + Send + '_>>

Check whether this source owns name and, if so, return its metadata.

fn get( &self, name: &str, ) -> Pin<Box<dyn Future<Output = Option<NtPayload>> + Send + '_>>

Read the current value of a PV.

fn put( &self, name: &str, value: &DecodedValue, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, NtPayload)>, String>> + Send + '_>>

Apply a PUT value to a PV.

fn subscribe( &self, name: &str, ) -> Pin<Box<dyn Future<Output = Option<Receiver<NtPayload>>> + Send + '_>>

Subscribe to value-change notifications on a PV.

fn names(&self) -> Pin<Box<dyn Future<Output = Vec<String>> + Send + '_>>

List all PV names provided by this source.

fn rpc( &self, _name: &str, _args: &DecodedValue, ) -> Pin<Box<dyn Future<Output = Result<NtPayload, String>> + Send + '_>>

Execute an RPC call on a channel.