oino-extension 1.0.0

Guest SDK for Oino WASM component extensions (oino:extension@2.0.0)
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

//! Event bus: deliveries arrive as `oino_bus` events.

use serde::Serialize;
use serde_json::Value;

use crate::Result;
use crate::bindings::oino::extension::bus as wb;

/// Publishes `data` on `topic` (`sticky` keeps the last value for `get`).
pub fn publish(topic: &str, data: &impl Serialize, sticky: bool) -> Result<()> {
    wb::publish(topic, &serde_json::to_string(data)?, sticky);
    Ok(())
}
/// Subscribes to an exact topic or `prefix:*`.
pub fn subscribe(pattern: &str) {
    wb::subscribe(pattern);
}
/// Unsubscribes.
pub fn unsubscribe(pattern: &str) {
    wb::unsubscribe(pattern);
}
/// Last sticky value.
#[must_use]
pub fn get(topic: &str) -> Option<Value> {
    wb::get(topic).and_then(|t| serde_json::from_str(&t).ok())
}