lb-sparkplugb-rs 0.1.0

Eclipse Sparkplug B 3.0.0 protocol library — payload codec, topic namespace, sequence/bdSeq, and (phased) edge & host roles, in Rust.
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

//! Build an NBIRTH-style payload, encode it, and decode it back.
//!
//! Run with: `cargo run --example encode_nbirth`

use sparkplug_b::{
    BDSEQ_METRIC_NAME, EncodeOptions, Metric, MetricValue, NODE_CONTROL_REBIRTH, Payload,
    SparkplugTopic, decode, encode,
};

fn main() {
    let topic = SparkplugTopic::parse("spBv1.0/Plant1/NBIRTH/Edge1").expect("valid topic");

    // An NBIRTH carries seq = 0, the bdSeq metric, the Node Control/Rebirth
    // metric (Boolean=false), and every metric the node will ever report.
    let payload = Payload::new()
        .with_timestamp(1_700_000_000_000)
        .with_seq(0)
        .with_metric(Metric::new(
            NODE_CONTROL_REBIRTH,
            MetricValue::Boolean(false),
        ))
        .with_metric(Metric::new(BDSEQ_METRIC_NAME, MetricValue::Int64(0)))
        .with_metric(
            Metric::new("Temperature", MetricValue::Double(21.5)).with_timestamp(1_700_000_000_000),
        );

    let bytes = encode(&payload, EncodeOptions::birth());
    println!("topic   : {topic}");
    println!("encoded : {} bytes", bytes.len());

    let decoded = decode(&bytes, None).expect("payload decodes");
    println!(
        "decoded : {} metrics; round-trip ok = {}",
        decoded.metrics.len(),
        decoded == payload
    );
}