soma_fleet/
lib.rs

1//! Neutral host topology, connection, transfer, and bounded fanout contracts.
2//!
3//! `soma-fleet` defines transport-independent identities, topology snapshots,
4//! request bounds, execution ports, revision-keyed connection caching, and a
5//! cancellation-aware fanout scheduler. Product configuration, authorization,
6//! command allowlists, and concrete SSH clients live above or behind this crate.
7
8#![forbid(unsafe_code)]
9#![warn(missing_docs)]
10
11mod cache;
12mod command;
13mod endpoint;
14mod error;
15mod event;
16mod fanout;
17#[cfg(all(feature = "openssh-driver", unix))]
18mod forward;
19mod identity;
20#[cfg(any(feature = "openssh-driver", feature = "process-driver"))]
21mod io;
22#[cfg(all(feature = "openssh-driver", unix))]
23mod openssh_connector;
24#[cfg(all(feature = "openssh-driver", unix))]
25mod openssh_driver;
26mod pool;
27mod ports;
28#[cfg(feature = "process-driver")]
29mod process_driver;
30mod request;
31#[cfg(all(feature = "openssh-driver", unix))]
32mod runtime;
33mod topology;
34mod transfer;
35mod transfer_guard;
36
37pub use cache::ConnectionCache;
38pub use command::{CommandOutput, CommandRequest};
39pub use endpoint::{HostEndpoint, HttpEndpoint, SshEndpoint};
40pub use error::{FleetError, FleetResult};
41pub use event::{FleetEvent, FleetEventKind, FleetEventSink, NoopFleetEventSink};
42pub use fanout::{
43    FanoutPolicy, FanoutPolicyError, FanoutReport, FanoutScheduler, TargetOutcome,
44    TargetOutcomeKind,
45};
46#[cfg(all(feature = "openssh-driver", unix))]
47pub use forward::{ForwardedUnixSocket, forwarded_socket_path};
48pub use identity::{CapabilityName, HostId, IdentityError, PoolKey, TopologyRevision};
49#[cfg(all(feature = "openssh-driver", unix))]
50pub use openssh_connector::{OpenSshConnectPlan, OpenSshConnection, OpenSshConnector};
51#[cfg(all(feature = "openssh-driver", unix))]
52pub use openssh_driver::OpenSshDriver;
53pub use pool::ConnectionPool;
54pub use ports::{
55    CommandExecutor, ConnectionFactory, FileTransfer, FleetClock, HostRepository, SystemFleetClock,
56};
57#[cfg(feature = "process-driver")]
58pub use process_driver::LocalProcessDriver;
59pub use request::RequestError;
60pub use topology::{HostRecord, TopologyError, TopologySnapshot};
61pub use transfer::{TransferReceipt, TransferRequest};
62pub use transfer_guard::{TransferGuard, TransferGuardState, TransferLifecycle};
soma_fleet/lib.rs

soma_fleet/
lib.rs
