thunder-rpc 0.2.2

HiveLLM binary RPC — one crate: wire codec (v1, frozen), multiplexed client, and the family server hot path, behind features (SPEC-001/003/004)
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

//! Thunder RPC server — the one listener every family server derives from.
//!
//! Products integrate by implementing [`Dispatch`] (SRV-020) and calling
//! [`spawn_listener`] with their [`Config`](crate::wire::Config);
//! everything else is Thunder's:
//!
//! - lifecycle — accept loop, per-connection writer task, graceful drain,
//!   per-connection failure isolation (SRV-001..005);
//! - the Synap-derived hot path — `BufWriter` + drain-then-flush, exactly
//!   one serialization per response, `TCP_NODELAY`, per-read idle timeout
//!   (SRV-006..009);
//! - sessions and profile enforcement — lock-free auth flag, handshake
//!   gating, Thunder-built HELLO replies, PUSH_ID policy
//!   (SRV-010..014, PRO-030/031);
//! - plain-atomic metrics recorded after successful writes (SRV-030).
//!
//! Contract: `docs/specs/SPEC-004-server.md`. TLS (SRV-040) is pending the
//! T0 family decision and is intentionally not wired yet.

mod dispatch;
mod errors;
mod listener;
mod metrics;
mod observer;
mod session;

pub use dispatch::{AuthError, Credentials, Dispatch, Principal};
pub use errors::{format_bracket_code, format_err, NOAUTH, NOPERM, WRONGPASS};
pub use listener::{spawn_listener, ListenerConfig, ListenerHandle, MetricsRef, ServerInfo};
pub use metrics::MetricsSnapshot;
pub use observer::MetricsObserver;
pub use session::{PushClosed, PushSender, Session};

#[cfg(test)]
#[allow(clippy::unwrap_used, clippy::expect_used)]
mod tests;