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 one TCP accept plus TLS server handshake. TLS handshake failures surface as StreamError values in the stream.

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.