liminal_server/console/
mod.rs

1//! The console's live streams (SRV-011 R1 and R2).
2//!
3//! The server publishes them as the participant `liminal.<device>` on the
4//! ordinary transport:
5//! `console.topology` (one full topology record per change event; a reader's
6//! snapshot is the stream's latest record) and `console.tap.<target>` (one
7//! record per tap batch for the node or stream `<target>`).
8//!
9//! Nothing here reads a store row: the topology is built from the channel
10//! roster and the responder registry the server already holds, and the tap is
11//! fed at the publish return.
12
13pub mod counts;
14pub mod error;
15pub mod hub;
16pub mod model;
17pub mod publisher;
18
19pub mod readings;
20pub mod records;
21pub mod topology;
22pub mod wall;
23
24pub use counts::ConsoleCountsSnapshot;
25pub use error::ConsoleError;
26pub use hub::{
27    ConsoleHub, MAX_LIVE_TAPS, PumpReport, TAP_SUBJECT_PREFIX, TOPOLOGY_SUBJECT, tappable,
28};
29pub use model::{FlowRole, ThisDevice, TopologyChange, TopologyModel};
30pub use publisher::ServerPublisher;
31pub use readings::{
32    Origin, READINGS_SUBJECT, Reading, ReadingValue, ReadingsRecord, Source, TargetKind,
33};
34pub use records::StationActivity;
35pub use topology::{ChannelNode, TopologySnapshot, snapshot};
36
37#[cfg(test)]
38mod hub_tests;
39#[cfg(test)]
40mod model_tests;
41
42#[cfg(test)]
43mod readings_tests;
44#[cfg(test)]
45mod records_tests;
46#[cfg(test)]
47mod tests;
liminal_server/console/mod.rs

liminal_server/console/
mod.rs
