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_record(&self, name: &str) -> Option<RecordInstance>

Read a clone of the full RecordInstance backing a PV.

Used by RecordFieldSource to serve <name>.<FIELD> channels.

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 set_alarm( &self, name: &str, severity: i32, status: i32, message: &str, ) -> bool

Explicitly set a record’s alarm fields (severity/status/message), independent of its value. Unlike SimplePvStore::set_value, alarm transitions always post — there is no MDEL deadband gating and no link evaluation (alarm changes don’t propagate links). Returns false if the alarm state is unchanged (idempotent) or the record doesn’t support alarm fields (Table/NdArray/Generic) or doesn’t exist.

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

List all PV names.

Trait Implementations

impl Source for SimplePvStore

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.