datum-net 0.9.0

Network sources and sinks for Datum streams, built on datum-core
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

#![forbid(unsafe_code)]
//! Network sources and sinks for Datum streams.
//!
//! `datum-net` is the network satellite crate for the Datum family. It provides
//! TLS-wrapped TCP sources and sinks through [`TokioTls`] plus UDP datagram
//! sources, sinks, and flows through [`TokioUdp`], and QUIC endpoint/stream
//! helpers through [`TokioQuic`]. Connection lifecycle helpers
//! add timeout, retry, and explicit half-close affordances for client
//! connection flows.

/// The `datum-net` crate version.
pub const VERSION: &str = env!("CARGO_PKG_VERSION");

pub(crate) mod async_carrier;
pub mod connection;
pub mod quic;
pub mod stream_ref;
pub mod tls;
pub mod udp;

pub use connection::{Connection, ConnectionLifecycleExt, ConnectionSettings, RetryPolicy};
pub use quic::{
    DEFAULT_CHUNK_SIZE as QUIC_DEFAULT_CHUNK_SIZE, Quic, QuicBidirectionalStream, QuicBinding,
    QuicByteSink, QuicByteSource, QuicConnection, QuicIncomingConnection, QuicStream, TokioQuic,
};
pub use stream_ref::{
    StreamRefProtocolDiagnostics, StreamRefProtocolMessageCounts, StreamRefQuicHandle,
    StreamRefTcpBinding, StreamRefTcpHandle, serve_sink_ref_over_quic, serve_sink_ref_over_tcp,
    serve_sink_ref_over_tcp_stream, serve_sink_ref_over_tcp_stream_with_diagnostics,
    serve_sink_ref_over_tcp_with_diagnostics, serve_source_over_quic, serve_source_ref_over_quic,
    serve_source_ref_over_tcp, serve_source_ref_over_tcp_stream,
    serve_source_ref_over_tcp_stream_with_diagnostics, serve_source_ref_over_tcp_with_diagnostics,
    sink_ref_over_quic, sink_ref_over_tcp, sink_ref_over_tcp_stream,
    sink_ref_over_tcp_stream_with_diagnostics, sink_ref_over_tcp_with_diagnostics,
    source_ref_over_quic, source_ref_over_tcp, source_ref_over_tcp_stream,
    source_ref_over_tcp_stream_with_diagnostics, source_ref_over_tcp_with_diagnostics,
};
pub use tls::{
    Tls, TlsBinding, TlsByteSink, TlsByteSource, TlsConnection, TlsIncomingConnection, TokioTls,
};
pub use udp::{
    DEFAULT_MAX_DATAGRAM_SIZE, DEFAULT_RECEIVE_BUFFER, Datagram, TokioUdp, Udp, UdpBinding,
    UdpConnection,
};

#[doc(hidden)]
pub use async_carrier::{
    ShardedTokioTestConfig, sharded_tokio_carrier_connection_count, with_sharded_tokio_test_config,
};