Struct SimplePvStore 

pub struct SimplePvStore { /* private fields */ }

A simple in-memory PV store.

Implementations

impl SimplePvStore

pub async fn set_registry(&self, registry: Arc<MonitorRegistry>)

Attach the MonitorRegistry so that set_value can push updates to PVAccess monitor clients. Called automatically by [PvaServer::run].

pub async fn insert(&self, name: String, record: RecordInstance)

Insert or replace a PV record at runtime.

pub async fn get_value(&self, name: &str) -> Option<ScalarValue>

Read the current ScalarValue of a PV.

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

Read the full NtPayload of a PV.

pub async fn set_value(&self, name: &str, value: ScalarValue) -> bool

Write a ScalarValue to a PV (bypasses on_put).

pub async fn set_array_value(&self, name: &str, value: ScalarArrayValue) -> bool

Write a ScalarArrayValue to an array PV (bypasses on_put).

pub async fn put_nt(&self, name: &str, payload: NtPayload) -> bool

Write a full NtPayload to a PV (bypasses on_put).

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

List all PV names.

Trait Implementations

impl PvStore for SimplePvStore

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.