Struct PvaServerBuilder 

pub struct PvaServerBuilder { /* private fields */ }

Builder for PvaServer.

let server = PvaServer::builder()
    .ai("TEMP:READBACK", 22.5)
    .ao("TEMP:SETPOINT", 25.0)
    .bo("HEATER:ON", false)
    .port(5075)
    .build();

Implementations

impl PvaServerBuilder

pub fn ai(self, name: impl Into<String>, initial: f64) -> Self

Add an ai (analog input, read-only) record.

pub fn ao(self, name: impl Into<String>, initial: f64) -> Self

Add an ao (analog output, writable) record.

pub fn bi(self, name: impl Into<String>, initial: bool) -> Self

Add a bi (binary input, read-only) record.

pub fn bo(self, name: impl Into<String>, initial: bool) -> Self

Add a bo (binary output, writable) record.

pub fn string_in( self, name: impl Into<String>, initial: impl Into<String>, ) -> Self

Add a stringin (string input, read-only) record.

pub fn string_out( self, name: impl Into<String>, initial: impl Into<String>, ) -> Self

Add a stringout (string output, writable) record.

pub fn waveform(self, name: impl Into<String>, data: ScalarArrayValue) -> Self

Add a waveform record (array) with the given initial data.

pub fn mbbi( self, name: impl Into<String>, choices: Vec<String>, initial: i32, ) -> Self

Add an mbbi (multi-bit binary input, read-only) NTEnum record.

pub fn mbbo( self, name: impl Into<String>, choices: Vec<String>, initial: i32, ) -> Self

Add an mbbo (multi-bit binary output, writable) NTEnum record.

pub fn generic( self, name: impl Into<String>, struct_id: impl Into<String>, fields: Vec<(String, PvValue)>, ) -> Self

Add a generic structure record with a custom struct ID and fields.

pub fn db_file(self, path: impl AsRef<str>) -> Self

Load records from an EPICS .db file.

pub fn db_string(self, content: &str) -> Self

Parse records from an EPICS .db string.

pub fn on_put<F>(self, name: impl Into<String>, callback: F) -> Self

where F: Fn(&str, &DecodedValue) + Send + Sync + 'static,

Register a callback invoked when a PUT is applied to the named PV.

pub fn scan<F>( self, name: impl Into<String>, period: Duration, callback: F, ) -> Self

where F: Fn(&str) -> ScalarValue + Send + Sync + 'static,

Register a periodic scan callback that produces a new value for a PV.

pub fn link<F>( self, output: impl Into<String>, inputs: &[&str], compute: F, ) -> Self

where F: Fn(&[ScalarValue]) -> ScalarValue + Send + Sync + 'static,

Link an output PV to one or more input PVs.

Whenever any input PV changes (via set_value, protocol PUT, or another link), the compute callback is invoked with the current values of all inputs (in order) and the result is written to the output PV.

.link("CALC:SUM", &["INPUT:A", "INPUT:B"], |values| {
    let a = values[0].as_f64().unwrap_or(0.0);
    let b = values[1].as_f64().unwrap_or(0.0);
    ScalarValue::F64(a + b)
})

pub fn port(self, port: u16) -> Self

Set the TCP port (default 5075).

pub fn udp_port(self, port: u16) -> Self

Set the UDP search port (default 5076).

pub fn listen_ip(self, ip: IpAddr) -> Self

Set the IP address to listen on.

pub fn advertise_ip(self, ip: IpAddr) -> Self

Set the IP address to advertise in search responses.

pub fn compute_alarms(self, enabled: bool) -> Self

Enable alarm computation from limits.

pub fn beacon_period(self, secs: u64) -> Self

Set the beacon broadcast period in seconds (default 15).

pub fn conn_timeout(self, timeout: Duration) -> Self

Set the idle connection timeout (default ~18 hours).

pub fn pvlist_mode(self, mode: PvListMode) -> Self

Set the PV list mode (default PvListMode::List).

pub fn pvlist_max(self, max: usize) -> Self

Set the maximum number of PV names in pvlist responses (default 1024).

pub fn pvlist_allow_pattern(self, pattern: Regex) -> Self

Set a regex filter for PV names exposed by pvlist.

pub fn build(self) -> PvaServer

Build the PvaServer.