Expand description
Rust SDK for the Adamo Network.
This crate is a safe, idiomatic wrapper over the precompiled Adamo
shared library (shipped via [adamo-sys]).
use adamo::Session;
let session = Session::open_default("my-api-key")?;
session.put("telemetry/heartbeat", b"hello", Default::default())?;Re-exports§
pub use control::ControlMessage;pub use control::JointState;pub use control::Joy;pub use control::JoystickCommand;pub use control::decode_control;pub use stats::LatencyStats;pub use stats::Regime;pub use stats::heartbeat_topic;pub use stats::ping_topic;pub use stats::pong_topic;
Modules§
Structs§
- Callback
Subscriber - A callback-based subscriber. Tied to its parent
Sessionby lifetime. - Liveliness
Subscriber - A liveliness watcher. Tied to its parent
Sessionby lifetime. - Liveliness
Token - A liveliness token. Drop it to undeclare the token.
- Priority
- Priority constants shared with the Python SDK.
- Publish
Options - Options for a one-shot
put. - Publisher
- A declared publisher. Tied to its parent
Sessionby lifetime. - Publisher
Options - Options for a persistent publisher.
- Sample
- An owned, decoded sample.
- Session
- An authenticated Adamo session.
- State
Store - A robot-owned retained key/value store. Tied to its parent
Sessionby lifetime. Read values back withSession::geton{robot}/state/{key}. - Stream
Error - Subscriber
- A pull-based subscriber.
- Task
Runner - A robot-owned, looping task run with an idle gap between reps. Tied to its
parent
Sessionby lifetime. Wire the pedal toadvance; read the run from{robot}/state/task_run.
Enums§
Functions§
- fabric_
now_ us - Microseconds since the Unix epoch on the adamo fabric clock — the shared time axis every robot, browser, and relay on this network sees.
- fabric_
synced trueonce the client has completed at least one ping/pong with the timehub plugin andfabric_now_usis reading from the synced clock rather than the local wall-clock fallback.