subc-daemon 0.20.26

Embeddable subc daemon: bootstrap, module supervision, and opaque-byte splice routing.
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71

//! subc daemon core.
//!
//! This crate owns the loopback TCP transport and the thin splice-router core:
//! routing decisions are made from the 21-byte envelope header, while message
//! bodies are carried as opaque bytes and are never deserialized by the router.

#![forbid(unsafe_code)]

pub mod bootstrap;
pub(crate) mod capability_requirements;
mod child_roster;
mod clock;
pub mod control;
pub mod daemon_config;
#[cfg(test)]
pub(crate) mod dispatch_spike;
pub mod fleet_lint;
pub mod forwarding;
pub mod identity;
pub mod machine_id;
pub mod observability;
#[allow(dead_code)]
mod provenance;
pub mod registry;
pub mod router;
pub mod server;
pub mod stderr_tail;
pub mod supervise;
mod terminal_journal;
pub mod terminal_ring;
#[cfg(any(test, feature = "test-support"))]
pub mod test_support;
pub mod watchdog;

#[cfg(feature = "bench-harness")]
pub mod bench_harness;

pub use control::{ControlHandler, MIN_SUPPORTED_VERSION};
pub use forwarding::{ForwardingError, ForwardingTable, ModuleEndpointId};
// The frame codec now lives in its natural homes: the `Frame` data type in
// subc-protocol (pure, with the envelope it accompanies) and the async I/O loop
// in subc-transport (with the authenticated stream). Re-exported here for
// callers that use the daemon library to build and exchange frames.
pub use control::{
    DEFAULT_ROUTE_BIND_BREAKER_COOLDOWN, DEFAULT_ROUTE_BIND_BREAKER_THRESHOLD,
    DEFAULT_ROUTE_BIND_RELAY_TIMEOUT,
};
pub use identity::{IdentityError, ProjectRootId, RequestIdentity, SessionId};
pub use observability::{ConnectedClients, DaemonCounters};
pub use registry::{ChannelState, ConnectionId, ModuleRegistration, Registry, RegistryError};
pub use router::{
    Backend, EchoBackend, ForwardBackend, FrameSink, RouteCtx, Router, RouterConnection,
    RouterError,
};
pub use server::{
    handle_connection, serve_listener, serve_listeners, ConnectionError, ServerAuth, ServerError,
    DEFAULT_AUTH_DEADLINE, DEFAULT_MAX_UNAUTHENTICATED_CONNECTIONS,
};
pub use subc_protocol::{Frame, FrameBuildError};
pub use subc_transport::{read_frame, write_frame, FrameIoError, ReadStage};
pub use supervise::{
    ExitKind, ExitReport, HealthAction, HealthConfig, ModuleHealthStatus, ModuleOverlap,
    ModuleProcessLiveness, ModuleSpec, ModuleState, ModuleStatus, RestartPolicy, SuperviseError,
    SupervisedModule, Supervisor, SupervisorHandle, SupervisorProcessLiveness, SwapFailureArm,
    SwapRefusal, DEFAULT_DRAIN_TIMEOUT, DEFAULT_SWAP_READY_TIMEOUT, SPAWN_ROLE_SWAP_CANDIDATE,
    SUBC_ARG, SUBC_SPAWN_ROLE_ENV,
};
pub use watchdog::{
    DaemonSelfWatchdog, DaemonSelfWatchdogConfig, WatchdogStage, WatchdogTickError,
    DEFAULT_SELF_WATCHDOG_DEADLINE, DEFAULT_SELF_WATCHDOG_INTERVAL,
};