Struct RecordFieldSource 

pub struct RecordFieldSource { /* private fields */ }

A read-only Source serving <pvname>.<FIELD> channels derived from the records in a SimplePvStore.

Registered by PvaServer::run after the builtin store; the builtin only claims exact record names, so the two never compete.

Implementations

impl RecordFieldSource

pub fn new(store: Arc<SimplePvStore>) -> Self

Trait Implementations

impl Source for RecordFieldSource

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.