spvirit-py 0.1.14

Python bindings for spvirit PVAccess client and server.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

//! spvirit — Python bindings for PVAccess client and server.

use pyo3::prelude::*;

mod convert;
mod errors;
mod runtime;

pub mod channel;
pub mod client;
pub mod codec;
pub mod discovery;
pub mod nt;
pub mod packet;
pub mod pv;
pub mod server;
pub mod source;

#[pymodule]
fn spvirit(m: &Bound<'_, PyModule>) -> PyResult<()> {
    // Install the async bridge onto our shared Tokio runtime.
    runtime::init_async_runtime();

    // Error types
    errors::register(m)?;

    // Client classes
    m.add_class::<client::PyClient>()?;
    m.add_class::<client::PyClientBuilder>()?;
    m.add_class::<client::PyGetResult>()?;
    m.add_class::<client::PyDiscoveredServer>()?;
    m.add_class::<client::PySubscription>()?;

    // Server classes
    m.add_class::<server::PyServerBuilder>()?;
    m.add_class::<server::PyServer>()?;
    m.add_class::<server::PyStore>()?;

    // Dynamic-source classes
    source::register(m)?;

    // NT classes
    m.add_class::<nt::PyAlarm>()?;
    m.add_class::<nt::PyTimeStamp>()?;
    m.add_class::<nt::PyDisplay>()?;
    m.add_class::<nt::PyControl>()?;
    m.add_class::<nt::PyNtScalar>()?;
    m.add_class::<nt::PyNtScalarArray>()?;
    m.add_class::<nt::PyNtTable>()?;
    m.add_class::<nt::PyNtNdArray>()?;

    // Typed PV handles
    m.add_class::<pv::PyPv>()?;
    m.add_function(wrap_pyfunction!(pv::ai, m)?)?;
    m.add_function(wrap_pyfunction!(pv::ao, m)?)?;
    m.add_function(wrap_pyfunction!(pv::bi, m)?)?;
    m.add_function(wrap_pyfunction!(pv::bo, m)?)?;
    m.add_function(wrap_pyfunction!(pv::string_in, m)?)?;
    m.add_function(wrap_pyfunction!(pv::string_out, m)?)?;
    m.add_function(wrap_pyfunction!(pv::longin, m)?)?;
    m.add_function(wrap_pyfunction!(pv::longout, m)?)?;
    m.add_function(wrap_pyfunction!(pv::mbbi, m)?)?;
    m.add_function(wrap_pyfunction!(pv::mbbo, m)?)?;
    m.add_function(wrap_pyfunction!(pv::waveform, m)?)?;
    m.add_function(wrap_pyfunction!(pv::aai, m)?)?;
    m.add_function(wrap_pyfunction!(pv::aao, m)?)?;
    m.add_function(wrap_pyfunction!(pv::calc, m)?)?;
    m.add_function(wrap_pyfunction!(pv::pv, m)?)?;

    // Module-level functions
    m.add_function(wrap_pyfunction!(client::py_discover_servers, m)?)?;

    // Submodule: spvirit.codec — standalone encode/decode helpers.
    codec::register(m)?;

    // Submodule: spvirit.lowlevel — persistent channel & primitives.
    channel::register(m)?;

    Ok(())
}