liminal-server 0.24.1

Standalone server for the liminal messaging bus
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

//! The console's live streams (SRV-011 R1 and R2).
//!
//! The server publishes them as the participant `liminal.<device>` on the
//! ordinary transport:
//! `console.topology` (one full topology record per change event; a reader's
//! snapshot is the stream's latest record) and `console.tap.<target>` (one
//! record per tap batch for the node or stream `<target>`).
//!
//! Nothing here reads a store row: the topology is built from the channel
//! roster and the responder registry the server already holds, and the tap is
//! fed at the publish return.

pub mod counts;
pub mod error;
pub mod hub;
pub mod model;
pub mod publisher;

pub mod readings;
pub mod records;
pub(crate) mod tap_placement;
pub mod topology;
pub mod wall;

pub use counts::ConsoleCountsSnapshot;
pub use error::ConsoleError;
pub use hub::{
    ConsoleHub, MAX_LIVE_TAPS, PumpReport, TAP_SUBJECT_PREFIX, TOPOLOGY_SUBJECT, tappable,
};
pub use model::{FlowRole, ThisDevice, TopologyChange, TopologyModel};
pub use publisher::ServerPublisher;
pub use readings::{
    Origin, READINGS_SUBJECT, Reading, ReadingValue, ReadingsRecord, Source, TargetKind,
};
pub use records::StationActivity;
pub use topology::{ChannelNode, TopologySnapshot, snapshot};

#[cfg(test)]
mod hub_tests;
#[cfg(test)]
mod model_tests;

#[cfg(test)]
mod readings_tests;
#[cfg(test)]
mod records_tests;
#[cfg(test)]
mod tests;

#[cfg(test)]
mod service_line_tests;
#[cfg(test)]
mod tap_placement_tests;