Struct GroupPvStore 

pub struct GroupPvStore<S: PvStore> { /* private fields */ }

A PvStore wrapper that adds group-PV support on top of an inner store.

Group PV names are resolved by fetching each member PV from the inner store and composing them into an NtPayload::Generic. Non-group PV names are forwarded to the inner store unchanged.

Implementations

impl<S: PvStore> GroupPvStore<S>

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

Create a new wrapper around inner with the given group definitions.

Trait Implementations

impl<S: PvStore> PvStore for GroupPvStore<S>

fn has_pv(&self, name: &str) -> impl Future<Output = bool> + Send

Check whether a PV name exists in this store.

fn get_snapshot( &self, name: &str, ) -> impl Future<Output = Option<NtPayload>> + Send

Get the current value of a PV as an NtPayload snapshot.

fn get_descriptor( &self, name: &str, ) -> impl Future<Output = Option<StructureDesc>> + Send

Get the structure descriptor for a PV (used by GET init and GET_FIELD).

fn put_value( &self, name: &str, value: &DecodedValue, ) -> impl Future<Output = Result<Vec<(String, NtPayload)>, String>> + Send

Apply a PUT value to a PV. Returns the list of (pv_name, updated_payload) pairs for all PVs that changed as a result (e.g. forward-link processing may cause multiple PVs to update).

fn is_writable(&self, name: &str) -> impl Future<Output = bool> + Send

Check whether a PV is writable.

fn list_pvs(&self) -> impl Future<Output = Vec<String>> + Send

List all PV names available in this store.

fn subscribe( &self, name: &str, ) -> impl Future<Output = Option<Receiver<NtPayload>>> + Send

Subscribe to value-change notifications on a PV. Returns a receiver that yields NtPayload snapshots whenever the PV is updated. Returns None if the PV does not exist.