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 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.