datum_net/
lib.rs

1#![forbid(unsafe_code)]
2//! Network sources and sinks for Datum streams.
3//!
4//! `datum-net` is the network satellite crate for the Datum family. It provides
5//! TLS-wrapped TCP sources and sinks through [`TokioTls`] plus UDP datagram
6//! sources, sinks, and flows through [`TokioUdp`], and QUIC endpoint/stream
7//! helpers through [`TokioQuic`]. Connection lifecycle helpers
8//! add timeout, retry, and explicit half-close affordances for client
9//! connection flows.
10
11/// The `datum-net` crate version.
12pub const VERSION: &str = env!("CARGO_PKG_VERSION");
13
14pub(crate) mod async_carrier;
15pub mod connection;
16pub mod quic;
17pub mod stream_ref;
18pub mod tls;
19pub mod udp;
20
21pub use connection::{Connection, ConnectionLifecycleExt, ConnectionSettings, RetryPolicy};
22pub use quic::{
23    DEFAULT_CHUNK_SIZE as QUIC_DEFAULT_CHUNK_SIZE, Quic, QuicBidirectionalStream, QuicBinding,
24    QuicByteSink, QuicByteSource, QuicConnection, QuicIncomingConnection, QuicStream, TokioQuic,
25};
26pub use stream_ref::{
27    StreamRefProtocolDiagnostics, StreamRefProtocolMessageCounts, StreamRefQuicHandle,
28    StreamRefTcpBinding, StreamRefTcpHandle, serve_sink_ref_over_quic, serve_sink_ref_over_tcp,
29    serve_sink_ref_over_tcp_stream, serve_sink_ref_over_tcp_stream_with_diagnostics,
30    serve_sink_ref_over_tcp_with_diagnostics, serve_source_over_quic, serve_source_ref_over_quic,
31    serve_source_ref_over_tcp, serve_source_ref_over_tcp_stream,
32    serve_source_ref_over_tcp_stream_with_diagnostics, serve_source_ref_over_tcp_with_diagnostics,
33    sink_ref_over_quic, sink_ref_over_tcp, sink_ref_over_tcp_stream,
34    sink_ref_over_tcp_stream_with_diagnostics, sink_ref_over_tcp_with_diagnostics,
35    source_ref_over_quic, source_ref_over_tcp, source_ref_over_tcp_stream,
36    source_ref_over_tcp_stream_with_diagnostics, source_ref_over_tcp_with_diagnostics,
37};
38pub use tls::{
39    Tls, TlsBinding, TlsByteSink, TlsByteSource, TlsConnection, TlsIncomingConnection, TokioTls,
40};
41pub use udp::{
42    DEFAULT_MAX_DATAGRAM_SIZE, DEFAULT_RECEIVE_BUFFER, Datagram, TokioUdp, Udp, UdpBinding,
43    UdpConnection,
44};
45
46#[doc(hidden)]
47pub use async_carrier::{
48    ShardedTokioTestConfig, sharded_tokio_carrier_connection_count, with_sharded_tokio_test_config,
49};
datum_net/lib.rs

datum_net/
lib.rs
