Struct TokioTls 

pub struct TokioTls;

TLS-over-TCP stream entry points.

Implementations

impl TokioTls

pub fn outgoing_connection_with_lifecycle<A>( addr: A, server_name: ServerName<'static>, client_config: Arc<ClientConfig>, settings: ConnectionSettings, ) -> Flow<Vec<u8>, Vec<u8>, StreamCompletion<TlsConnection>>

where A: ToSocketAddrs + Clone + Send + Sync + 'static,

Opens a lifecycle-aware TLS client connection using the default 8 KiB chunk size.

TCP connect and TLS handshake are bounded by ConnectionSettings and retried according to its RetryPolicy. A timeout or final retry failure surfaces as a StreamError through the materialized StreamCompletion and through the stream.

pub fn outgoing_connection_with_lifecycle_and_chunk_size<A>( addr: A, server_name: ServerName<'static>, client_config: Arc<ClientConfig>, settings: ConnectionSettings, chunk_size: usize, ) -> Flow<Vec<u8>, Vec<u8>, StreamCompletion<TlsConnection>>

where A: ToSocketAddrs + Clone + Send + Sync + 'static,

Opens a lifecycle-aware TLS client connection with an explicit chunk size.

impl TokioTls

pub fn outgoing_connection<A>( addr: A, server_name: ServerName<'static>, client_config: Arc<ClientConfig>, chunk_size: usize, ) -> Flow<Vec<u8>, Vec<u8>, StreamCompletion<TlsConnection>>

where A: ToSocketAddrs + Clone + Send + Sync + 'static,

Opens a TLS client connection as a coupled byte flow.

TCP connect and the TLS client handshake run when the flow is materialized. The caller-provided rustls::ClientConfig controls root trust, protocol versions, ALPN, and certificate verification policy.

pub fn outgoing_connection_default<A>( addr: A, server_name: ServerName<'static>, client_config: Arc<ClientConfig>, ) -> Flow<Vec<u8>, Vec<u8>, StreamCompletion<TlsConnection>>

where A: ToSocketAddrs + Clone + Send + Sync + 'static,

Opens a TLS client connection using the default 8 KiB chunk size.

pub fn bind<A>( addr: A, server_config: Arc<ServerConfig>, chunk_size: usize, ) -> Source<TlsIncomingConnection, StreamCompletion<TlsBinding>>

where A: ToSocketAddrs + Clone + Send + Sync + 'static,

Binds a TLS server listener and emits accepted TLS connections.

The TCP listener binds when the source is materialized. Each downstream pull permits TCP accepts plus TLS server handshakes until a connection succeeds. Per-connection handshake failures are logged and skipped.

pub fn bind_with_diagnostics<A>( addr: A, server_config: Arc<ServerConfig>, chunk_size: usize, diagnostics: TlsCarrierDiagnostics, ) -> Source<TlsIncomingConnection, StreamCompletion<TlsBinding>>

where A: ToSocketAddrs + Clone + Send + Sync + 'static,

Binds a TLS server listener and records skipped accept/handshake failures.

pub fn bind_default<A>( addr: A, server_config: Arc<ServerConfig>, ) -> Source<TlsIncomingConnection, StreamCompletion<TlsBinding>>

where A: ToSocketAddrs + Clone + Send + Sync + 'static,

Binds a TLS server listener using the default 8 KiB chunk size.