pub mod tst_tcp
pub mod tst_tcp::builder
pub struct tst_tcp::builder::TcpListenerBuilder
impl tst_tcp::builder::TcpListenerBuilder
pub fn tst_tcp::builder::TcpListenerBuilder::build(self) -> core::result::Result<tst_tcp::listener::TcpListener, tst_tcp::error::TcpError>
pub fn tst_tcp::builder::TcpListenerBuilder::from_url(&str) -> core::result::Result<Self, tst_tcp::url::TcpUrlError>
pub fn tst_tcp::builder::TcpListenerBuilder::nodelay(&mut self, bool) -> &mut Self
pub fn tst_tcp::builder::TcpListenerBuilder::pkt_size(&mut self, usize) -> &mut Self
pub fn tst_tcp::builder::TcpListenerBuilder::rcvbuf(&mut self, usize) -> &mut Self
pub fn tst_tcp::builder::TcpListenerBuilder::sndbuf(&mut self, usize) -> &mut Self
impl core::clone::Clone for tst_tcp::builder::TcpListenerBuilder
pub fn tst_tcp::builder::TcpListenerBuilder::clone(&self) -> tst_tcp::builder::TcpListenerBuilder
impl core::fmt::Debug for tst_tcp::builder::TcpListenerBuilder
pub fn tst_tcp::builder::TcpListenerBuilder::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_tcp::builder::TcpListenerBuilder
impl core::marker::Send for tst_tcp::builder::TcpListenerBuilder
impl core::marker::Sync for tst_tcp::builder::TcpListenerBuilder
impl core::marker::Unpin for tst_tcp::builder::TcpListenerBuilder
impl core::marker::UnsafeUnpin for tst_tcp::builder::TcpListenerBuilder
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::builder::TcpListenerBuilder
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::builder::TcpListenerBuilder
pub struct tst_tcp::builder::TcpTransportBuilder
impl tst_tcp::builder::TcpTransportBuilder
pub fn tst_tcp::builder::TcpTransportBuilder::build(self) -> core::result::Result<tst_tcp::transport::TcpTransport, tst_tcp::error::TcpError>
pub fn tst_tcp::builder::TcpTransportBuilder::connect_timeout(&mut self, core::time::Duration) -> &mut Self
pub fn tst_tcp::builder::TcpTransportBuilder::from_url(&str) -> core::result::Result<Self, tst_tcp::url::TcpUrlError>
pub fn tst_tcp::builder::TcpTransportBuilder::keepalive(&mut self, core::time::Duration) -> &mut Self
pub fn tst_tcp::builder::TcpTransportBuilder::nodelay(&mut self, bool) -> &mut Self
pub fn tst_tcp::builder::TcpTransportBuilder::pkt_size(&mut self, usize) -> &mut Self
pub fn tst_tcp::builder::TcpTransportBuilder::rcvbuf(&mut self, usize) -> &mut Self
pub fn tst_tcp::builder::TcpTransportBuilder::sndbuf(&mut self, usize) -> &mut Self
impl core::clone::Clone for tst_tcp::builder::TcpTransportBuilder
pub fn tst_tcp::builder::TcpTransportBuilder::clone(&self) -> tst_tcp::builder::TcpTransportBuilder
impl core::fmt::Debug for tst_tcp::builder::TcpTransportBuilder
pub fn tst_tcp::builder::TcpTransportBuilder::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_tcp::builder::TcpTransportBuilder
impl core::marker::Send for tst_tcp::builder::TcpTransportBuilder
impl core::marker::Sync for tst_tcp::builder::TcpTransportBuilder
impl core::marker::Unpin for tst_tcp::builder::TcpTransportBuilder
impl core::marker::UnsafeUnpin for tst_tcp::builder::TcpTransportBuilder
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::builder::TcpTransportBuilder
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::builder::TcpTransportBuilder
pub mod tst_tcp::config
#[non_exhaustive] pub struct tst_tcp::config::SocketConfig
pub tst_tcp::config::SocketConfig::connect_timeout: core::option::Option<core::time::Duration>
pub tst_tcp::config::SocketConfig::keepalive: core::option::Option<core::time::Duration>
pub tst_tcp::config::SocketConfig::nodelay: core::option::Option<bool>
pub tst_tcp::config::SocketConfig::pkt_size: core::option::Option<usize>
pub tst_tcp::config::SocketConfig::rcvbuf: core::option::Option<usize>
pub tst_tcp::config::SocketConfig::sndbuf: core::option::Option<usize>
impl tst_tcp::config::SocketConfig
pub const tst_tcp::config::SocketConfig::DEFAULT_PKT_SIZE: usize
pub fn tst_tcp::config::SocketConfig::connect_timeout_or_default(&self) -> core::time::Duration
pub fn tst_tcp::config::SocketConfig::merge_from_url(&mut self, &tst_tcp::url::TcpUrl)
pub fn tst_tcp::config::SocketConfig::pkt_size_or_default(&self) -> usize
impl core::clone::Clone for tst_tcp::config::SocketConfig
pub fn tst_tcp::config::SocketConfig::clone(&self) -> tst_tcp::config::SocketConfig
impl core::default::Default for tst_tcp::config::SocketConfig
pub fn tst_tcp::config::SocketConfig::default() -> tst_tcp::config::SocketConfig
impl core::fmt::Debug for tst_tcp::config::SocketConfig
pub fn tst_tcp::config::SocketConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_tcp::config::SocketConfig
impl core::marker::Send for tst_tcp::config::SocketConfig
impl core::marker::Sync for tst_tcp::config::SocketConfig
impl core::marker::Unpin for tst_tcp::config::SocketConfig
impl core::marker::UnsafeUnpin for tst_tcp::config::SocketConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::config::SocketConfig
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::config::SocketConfig
pub mod tst_tcp::error
#[non_exhaustive] pub enum tst_tcp::error::TcpError
pub tst_tcp::error::TcpError::Closed
pub tst_tcp::error::TcpError::ConnectTimeout
pub tst_tcp::error::TcpError::ConnectTimeout::seconds: u64
pub tst_tcp::error::TcpError::InvalidConfig(alloc::string::String)
pub tst_tcp::error::TcpError::Io(core::io::error::Error)
pub tst_tcp::error::TcpError::PayloadTooLarge
pub tst_tcp::error::TcpError::PayloadTooLarge::len: usize
pub tst_tcp::error::TcpError::PayloadTooLarge::max: usize
pub tst_tcp::error::TcpError::Tls(alloc::string::String)
pub tst_tcp::error::TcpError::TlsDisabled
pub tst_tcp::error::TcpError::Url(tst_tcp::url::TcpUrlError)
impl tst_tcp::error::TcpError
pub fn tst_tcp::error::TcpError::kind(&self) -> tst_tcp::error::TcpErrorKind
impl core::convert::From<core::io::error::Error> for tst_tcp::error::TcpError
pub fn tst_tcp::error::TcpError::from(core::io::error::Error) -> Self
impl core::convert::From<tst_tcp::url::TcpUrlError> for tst_tcp::error::TcpError
pub fn tst_tcp::error::TcpError::from(tst_tcp::url::TcpUrlError) -> Self
impl core::error::Error for tst_tcp::error::TcpError
pub fn tst_tcp::error::TcpError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_tcp::error::TcpError
pub fn tst_tcp::error::TcpError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_tcp::error::TcpError
pub fn tst_tcp::error::TcpError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_tcp::error::TcpError
impl core::marker::Send for tst_tcp::error::TcpError
impl core::marker::Sync for tst_tcp::error::TcpError
impl core::marker::Unpin for tst_tcp::error::TcpError
impl core::marker::UnsafeUnpin for tst_tcp::error::TcpError
impl !core::panic::unwind_safe::RefUnwindSafe for tst_tcp::error::TcpError
impl !core::panic::unwind_safe::UnwindSafe for tst_tcp::error::TcpError
#[non_exhaustive] #[repr(u32)] pub enum tst_tcp::error::TcpErrorKind
pub tst_tcp::error::TcpErrorKind::Closed = 4
pub tst_tcp::error::TcpErrorKind::ConnectTimeout = 5
pub tst_tcp::error::TcpErrorKind::InvalidConfig = 6
pub tst_tcp::error::TcpErrorKind::Io = 2
pub tst_tcp::error::TcpErrorKind::PayloadTooLarge = 3
pub tst_tcp::error::TcpErrorKind::Tls = 7
pub tst_tcp::error::TcpErrorKind::TlsDisabled = 8
pub tst_tcp::error::TcpErrorKind::Url = 1
impl core::clone::Clone for tst_tcp::error::TcpErrorKind
pub fn tst_tcp::error::TcpErrorKind::clone(&self) -> tst_tcp::error::TcpErrorKind
impl core::cmp::Eq for tst_tcp::error::TcpErrorKind
impl core::cmp::PartialEq for tst_tcp::error::TcpErrorKind
pub fn tst_tcp::error::TcpErrorKind::eq(&self, &tst_tcp::error::TcpErrorKind) -> bool
impl core::fmt::Debug for tst_tcp::error::TcpErrorKind
pub fn tst_tcp::error::TcpErrorKind::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for tst_tcp::error::TcpErrorKind
pub fn tst_tcp::error::TcpErrorKind::hash<__H: core::hash::Hasher>(&self, &mut __H)
impl core::marker::Copy for tst_tcp::error::TcpErrorKind
impl core::marker::StructuralPartialEq for tst_tcp::error::TcpErrorKind
impl core::marker::Freeze for tst_tcp::error::TcpErrorKind
impl core::marker::Send for tst_tcp::error::TcpErrorKind
impl core::marker::Sync for tst_tcp::error::TcpErrorKind
impl core::marker::Unpin for tst_tcp::error::TcpErrorKind
impl core::marker::UnsafeUnpin for tst_tcp::error::TcpErrorKind
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::error::TcpErrorKind
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::error::TcpErrorKind
pub mod tst_tcp::listener
pub struct tst_tcp::listener::TcpListener
impl tst_tcp::listener::TcpListener
pub fn tst_tcp::listener::TcpListener::accept_blocking(&self) -> core::result::Result<tst_tcp::transport::TcpTransport, tst_tcp::error::TcpError>
pub fn tst_tcp::listener::TcpListener::bind(core::net::socket_addr::SocketAddr) -> core::result::Result<Self, tst_tcp::error::TcpError>
pub fn tst_tcp::listener::TcpListener::config_mut(&mut self) -> &mut tst_tcp::config::SocketConfig
pub fn tst_tcp::listener::TcpListener::from_url(&str) -> core::result::Result<Self, tst_tcp::error::TcpError>
pub fn tst_tcp::listener::TcpListener::local_addr(&self) -> core::io::error::Result<core::net::socket_addr::SocketAddr>
impl core::marker::Freeze for tst_tcp::listener::TcpListener
impl core::marker::Send for tst_tcp::listener::TcpListener
impl core::marker::Sync for tst_tcp::listener::TcpListener
impl core::marker::Unpin for tst_tcp::listener::TcpListener
impl core::marker::UnsafeUnpin for tst_tcp::listener::TcpListener
impl !core::panic::unwind_safe::RefUnwindSafe for tst_tcp::listener::TcpListener
impl !core::panic::unwind_safe::UnwindSafe for tst_tcp::listener::TcpListener
pub mod tst_tcp::stats
#[non_exhaustive] pub struct tst_tcp::stats::TcpStats
pub tst_tcp::stats::TcpStats::bytes_received: u64
pub tst_tcp::stats::TcpStats::bytes_sent: u64
pub tst_tcp::stats::TcpStats::recv_calls: u64
pub tst_tcp::stats::TcpStats::recv_errors: u64
pub tst_tcp::stats::TcpStats::send_calls: u64
pub tst_tcp::stats::TcpStats::send_errors: u64
impl tst_tcp::stats::TcpStats
pub fn tst_tcp::stats::TcpStats::to_socket_stats(&self) -> tst_core::transport::SocketStats
impl core::clone::Clone for tst_tcp::stats::TcpStats
pub fn tst_tcp::stats::TcpStats::clone(&self) -> tst_tcp::stats::TcpStats
impl core::default::Default for tst_tcp::stats::TcpStats
pub fn tst_tcp::stats::TcpStats::default() -> tst_tcp::stats::TcpStats
impl core::fmt::Debug for tst_tcp::stats::TcpStats
pub fn tst_tcp::stats::TcpStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_tcp::stats::TcpStats
impl core::marker::Freeze for tst_tcp::stats::TcpStats
impl core::marker::Send for tst_tcp::stats::TcpStats
impl core::marker::Sync for tst_tcp::stats::TcpStats
impl core::marker::Unpin for tst_tcp::stats::TcpStats
impl core::marker::UnsafeUnpin for tst_tcp::stats::TcpStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::stats::TcpStats
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::stats::TcpStats
pub mod tst_tcp::tls
pub enum tst_tcp::tls::TlsStream
pub tst_tcp::tls::TlsStream::Client(rustls::stream::StreamOwned<rustls::client::client_conn::connection::ClientConnection, std::net::tcp::TcpStream>)
pub tst_tcp::tls::TlsStream::Server(rustls::stream::StreamOwned<rustls::server::server_conn::connection::ServerConnection, std::net::tcp::TcpStream>)
impl tst_tcp::tls::TlsStream
pub fn tst_tcp::tls::TlsStream::read(&mut self, &mut [u8]) -> core::io::error::Result<usize>
pub fn tst_tcp::tls::TlsStream::write(&mut self, &[u8]) -> core::io::error::Result<usize>
impl core::marker::Freeze for tst_tcp::tls::TlsStream
impl core::marker::Send for tst_tcp::tls::TlsStream
impl core::marker::Sync for tst_tcp::tls::TlsStream
impl core::marker::Unpin for tst_tcp::tls::TlsStream
impl core::marker::UnsafeUnpin for tst_tcp::tls::TlsStream
impl !core::panic::unwind_safe::RefUnwindSafe for tst_tcp::tls::TlsStream
impl !core::panic::unwind_safe::UnwindSafe for tst_tcp::tls::TlsStream
pub fn tst_tcp::tls::accept_tls(std::net::tcp::TcpStream, core::net::socket_addr::SocketAddr, &tst_tcp::config::SocketConfig, alloc::sync::Arc<rustls::server::server_conn::ServerConfig>) -> core::result::Result<tst_tcp::transport::TcpTransport, tst_tcp::error::TcpError>
pub fn tst_tcp::tls::connect_tls(&tst_tcp::url::TcpUrl, &tst_tcp::config::SocketConfig) -> core::result::Result<tst_tcp::transport::TcpTransport, tst_tcp::error::TcpError>
pub fn tst_tcp::tls::load_server_config(&str, &str) -> core::result::Result<rustls::server::server_conn::ServerConfig, tst_tcp::error::TcpError>
pub mod tst_tcp::transport
pub struct tst_tcp::transport::TcpCancelHandle
impl tst_tcp::transport::TcpCancelHandle
pub fn tst_tcp::transport::TcpCancelHandle::cancel(&self)
pub fn tst_tcp::transport::TcpCancelHandle::is_cancelled(&self) -> bool
impl core::clone::Clone for tst_tcp::transport::TcpCancelHandle
pub fn tst_tcp::transport::TcpCancelHandle::clone(&self) -> tst_tcp::transport::TcpCancelHandle
impl core::fmt::Debug for tst_tcp::transport::TcpCancelHandle
pub fn tst_tcp::transport::TcpCancelHandle::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_tcp::transport::TcpCancelHandle
impl core::marker::Send for tst_tcp::transport::TcpCancelHandle
impl core::marker::Sync for tst_tcp::transport::TcpCancelHandle
impl core::marker::Unpin for tst_tcp::transport::TcpCancelHandle
impl core::marker::UnsafeUnpin for tst_tcp::transport::TcpCancelHandle
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::transport::TcpCancelHandle
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::transport::TcpCancelHandle
pub struct tst_tcp::transport::TcpTransport
impl tst_tcp::transport::TcpTransport
pub fn tst_tcp::transport::TcpTransport::cancel_handle(&self) -> tst_tcp::transport::TcpCancelHandle
pub fn tst_tcp::transport::TcpTransport::connect(&str) -> core::result::Result<Self, tst_tcp::error::TcpError>
pub fn tst_tcp::transport::TcpTransport::connect_with_config(&tst_tcp::url::TcpUrl, &tst_tcp::config::SocketConfig) -> core::result::Result<Self, tst_tcp::error::TcpError>
pub fn tst_tcp::transport::TcpTransport::peer(&self) -> core::net::socket_addr::SocketAddr
pub fn tst_tcp::transport::TcpTransport::stats(&self) -> tst_tcp::stats::TcpStats
impl tst_core::transport::RecvTransport for tst_tcp::transport::TcpTransport
pub fn tst_tcp::transport::TcpTransport::close(&mut self)
pub fn tst_tcp::transport::TcpTransport::is_alive(&self) -> bool
pub fn tst_tcp::transport::TcpTransport::max_payload(&self) -> usize
pub fn tst_tcp::transport::TcpTransport::recv_bytes(&mut self, &mut [u8]) -> core::result::Result<usize, tst_core::transport::TransportError>
pub fn tst_tcp::transport::TcpTransport::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
impl tst_core::transport::Transport for tst_tcp::transport::TcpTransport
pub fn tst_tcp::transport::TcpTransport::close(&mut self)
pub fn tst_tcp::transport::TcpTransport::is_alive(&self) -> bool
pub fn tst_tcp::transport::TcpTransport::max_payload(&self) -> usize
pub fn tst_tcp::transport::TcpTransport::send_bytes(&mut self, &[u8]) -> core::result::Result<(), tst_core::transport::TransportError>
pub fn tst_tcp::transport::TcpTransport::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
impl core::marker::Freeze for tst_tcp::transport::TcpTransport
impl core::marker::Send for tst_tcp::transport::TcpTransport
impl core::marker::Sync for tst_tcp::transport::TcpTransport
impl core::marker::Unpin for tst_tcp::transport::TcpTransport
impl core::marker::UnsafeUnpin for tst_tcp::transport::TcpTransport
impl !core::panic::unwind_safe::RefUnwindSafe for tst_tcp::transport::TcpTransport
impl !core::panic::unwind_safe::UnwindSafe for tst_tcp::transport::TcpTransport
pub mod tst_tcp::url
#[non_exhaustive] pub enum tst_tcp::url::TcpUrlError
pub tst_tcp::url::TcpUrlError::BadHost(alloc::string::String)
pub tst_tcp::url::TcpUrlError::BadQueryValue
pub tst_tcp::url::TcpUrlError::BadQueryValue::detail: alloc::string::String
pub tst_tcp::url::TcpUrlError::BadQueryValue::key: alloc::string::String
pub tst_tcp::url::TcpUrlError::BadQueryValue::value: alloc::string::String
pub tst_tcp::url::TcpUrlError::BadScheme(alloc::string::String)
pub tst_tcp::url::TcpUrlError::MissingPort
pub tst_tcp::url::TcpUrlError::Parse(tst_core::url::common::UrlError)
impl core::convert::From<tst_core::url::common::UrlError> for tst_tcp::url::TcpUrlError
pub fn tst_tcp::url::TcpUrlError::from(tst_core::url::common::UrlError) -> Self
impl core::convert::From<tst_tcp::url::TcpUrlError> for tst_tcp::error::TcpError
pub fn tst_tcp::error::TcpError::from(tst_tcp::url::TcpUrlError) -> Self
impl core::error::Error for tst_tcp::url::TcpUrlError
pub fn tst_tcp::url::TcpUrlError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_tcp::url::TcpUrlError
pub fn tst_tcp::url::TcpUrlError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_tcp::url::TcpUrlError
pub fn tst_tcp::url::TcpUrlError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_tcp::url::TcpUrlError
impl core::marker::Send for tst_tcp::url::TcpUrlError
impl core::marker::Sync for tst_tcp::url::TcpUrlError
impl core::marker::Unpin for tst_tcp::url::TcpUrlError
impl core::marker::UnsafeUnpin for tst_tcp::url::TcpUrlError
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::url::TcpUrlError
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::url::TcpUrlError
pub struct tst_tcp::url::TcpUrl
pub tst_tcp::url::TcpUrl::ca: core::option::Option<alloc::string::String>
pub tst_tcp::url::TcpUrl::cert: core::option::Option<alloc::string::String>
pub tst_tcp::url::TcpUrl::connect_timeout: core::option::Option<core::time::Duration>
pub tst_tcp::url::TcpUrl::host: alloc::string::String
pub tst_tcp::url::TcpUrl::keepalive: core::option::Option<core::time::Duration>
pub tst_tcp::url::TcpUrl::key: core::option::Option<alloc::string::String>
pub tst_tcp::url::TcpUrl::listen: bool
pub tst_tcp::url::TcpUrl::nodelay: core::option::Option<bool>
pub tst_tcp::url::TcpUrl::port: u16
pub tst_tcp::url::TcpUrl::rcvbuf: core::option::Option<usize>
pub tst_tcp::url::TcpUrl::sndbuf: core::option::Option<usize>
pub tst_tcp::url::TcpUrl::tls: bool
impl tst_tcp::url::TcpUrl
pub fn tst_tcp::url::TcpUrl::parse(&str) -> core::result::Result<Self, tst_tcp::url::TcpUrlError>
impl core::clone::Clone for tst_tcp::url::TcpUrl
pub fn tst_tcp::url::TcpUrl::clone(&self) -> tst_tcp::url::TcpUrl
impl core::fmt::Debug for tst_tcp::url::TcpUrl
pub fn tst_tcp::url::TcpUrl::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_tcp::url::TcpUrl
impl core::marker::Send for tst_tcp::url::TcpUrl
impl core::marker::Sync for tst_tcp::url::TcpUrl
impl core::marker::Unpin for tst_tcp::url::TcpUrl
impl core::marker::UnsafeUnpin for tst_tcp::url::TcpUrl
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::url::TcpUrl
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::url::TcpUrl
#[non_exhaustive] pub struct tst_tcp::SocketConfig
pub tst_tcp::SocketConfig::connect_timeout: core::option::Option<core::time::Duration>
pub tst_tcp::SocketConfig::keepalive: core::option::Option<core::time::Duration>
pub tst_tcp::SocketConfig::nodelay: core::option::Option<bool>
pub tst_tcp::SocketConfig::pkt_size: core::option::Option<usize>
pub tst_tcp::SocketConfig::rcvbuf: core::option::Option<usize>
pub tst_tcp::SocketConfig::sndbuf: core::option::Option<usize>
impl tst_tcp::config::SocketConfig
pub const tst_tcp::config::SocketConfig::DEFAULT_PKT_SIZE: usize
pub fn tst_tcp::config::SocketConfig::connect_timeout_or_default(&self) -> core::time::Duration
pub fn tst_tcp::config::SocketConfig::merge_from_url(&mut self, &tst_tcp::url::TcpUrl)
pub fn tst_tcp::config::SocketConfig::pkt_size_or_default(&self) -> usize
impl core::clone::Clone for tst_tcp::config::SocketConfig
pub fn tst_tcp::config::SocketConfig::clone(&self) -> tst_tcp::config::SocketConfig
impl core::default::Default for tst_tcp::config::SocketConfig
pub fn tst_tcp::config::SocketConfig::default() -> tst_tcp::config::SocketConfig
impl core::fmt::Debug for tst_tcp::config::SocketConfig
pub fn tst_tcp::config::SocketConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_tcp::config::SocketConfig
impl core::marker::Send for tst_tcp::config::SocketConfig
impl core::marker::Sync for tst_tcp::config::SocketConfig
impl core::marker::Unpin for tst_tcp::config::SocketConfig
impl core::marker::UnsafeUnpin for tst_tcp::config::SocketConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::config::SocketConfig
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::config::SocketConfig
pub struct tst_tcp::TcpCancelHandle
impl tst_tcp::transport::TcpCancelHandle
pub fn tst_tcp::transport::TcpCancelHandle::cancel(&self)
pub fn tst_tcp::transport::TcpCancelHandle::is_cancelled(&self) -> bool
impl core::clone::Clone for tst_tcp::transport::TcpCancelHandle
pub fn tst_tcp::transport::TcpCancelHandle::clone(&self) -> tst_tcp::transport::TcpCancelHandle
impl core::fmt::Debug for tst_tcp::transport::TcpCancelHandle
pub fn tst_tcp::transport::TcpCancelHandle::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_tcp::transport::TcpCancelHandle
impl core::marker::Send for tst_tcp::transport::TcpCancelHandle
impl core::marker::Sync for tst_tcp::transport::TcpCancelHandle
impl core::marker::Unpin for tst_tcp::transport::TcpCancelHandle
impl core::marker::UnsafeUnpin for tst_tcp::transport::TcpCancelHandle
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::transport::TcpCancelHandle
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::transport::TcpCancelHandle
pub struct tst_tcp::TcpListener
impl tst_tcp::listener::TcpListener
pub fn tst_tcp::listener::TcpListener::accept_blocking(&self) -> core::result::Result<tst_tcp::transport::TcpTransport, tst_tcp::error::TcpError>
pub fn tst_tcp::listener::TcpListener::bind(core::net::socket_addr::SocketAddr) -> core::result::Result<Self, tst_tcp::error::TcpError>
pub fn tst_tcp::listener::TcpListener::config_mut(&mut self) -> &mut tst_tcp::config::SocketConfig
pub fn tst_tcp::listener::TcpListener::from_url(&str) -> core::result::Result<Self, tst_tcp::error::TcpError>
pub fn tst_tcp::listener::TcpListener::local_addr(&self) -> core::io::error::Result<core::net::socket_addr::SocketAddr>
impl core::marker::Freeze for tst_tcp::listener::TcpListener
impl core::marker::Send for tst_tcp::listener::TcpListener
impl core::marker::Sync for tst_tcp::listener::TcpListener
impl core::marker::Unpin for tst_tcp::listener::TcpListener
impl core::marker::UnsafeUnpin for tst_tcp::listener::TcpListener
impl !core::panic::unwind_safe::RefUnwindSafe for tst_tcp::listener::TcpListener
impl !core::panic::unwind_safe::UnwindSafe for tst_tcp::listener::TcpListener
pub struct tst_tcp::TcpListenerBuilder
impl tst_tcp::builder::TcpListenerBuilder
pub fn tst_tcp::builder::TcpListenerBuilder::build(self) -> core::result::Result<tst_tcp::listener::TcpListener, tst_tcp::error::TcpError>
pub fn tst_tcp::builder::TcpListenerBuilder::from_url(&str) -> core::result::Result<Self, tst_tcp::url::TcpUrlError>
pub fn tst_tcp::builder::TcpListenerBuilder::nodelay(&mut self, bool) -> &mut Self
pub fn tst_tcp::builder::TcpListenerBuilder::pkt_size(&mut self, usize) -> &mut Self
pub fn tst_tcp::builder::TcpListenerBuilder::rcvbuf(&mut self, usize) -> &mut Self
pub fn tst_tcp::builder::TcpListenerBuilder::sndbuf(&mut self, usize) -> &mut Self
impl core::clone::Clone for tst_tcp::builder::TcpListenerBuilder
pub fn tst_tcp::builder::TcpListenerBuilder::clone(&self) -> tst_tcp::builder::TcpListenerBuilder
impl core::fmt::Debug for tst_tcp::builder::TcpListenerBuilder
pub fn tst_tcp::builder::TcpListenerBuilder::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_tcp::builder::TcpListenerBuilder
impl core::marker::Send for tst_tcp::builder::TcpListenerBuilder
impl core::marker::Sync for tst_tcp::builder::TcpListenerBuilder
impl core::marker::Unpin for tst_tcp::builder::TcpListenerBuilder
impl core::marker::UnsafeUnpin for tst_tcp::builder::TcpListenerBuilder
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::builder::TcpListenerBuilder
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::builder::TcpListenerBuilder
#[non_exhaustive] pub struct tst_tcp::TcpStats
pub tst_tcp::TcpStats::bytes_received: u64
pub tst_tcp::TcpStats::bytes_sent: u64
pub tst_tcp::TcpStats::recv_calls: u64
pub tst_tcp::TcpStats::recv_errors: u64
pub tst_tcp::TcpStats::send_calls: u64
pub tst_tcp::TcpStats::send_errors: u64
impl tst_tcp::stats::TcpStats
pub fn tst_tcp::stats::TcpStats::to_socket_stats(&self) -> tst_core::transport::SocketStats
impl core::clone::Clone for tst_tcp::stats::TcpStats
pub fn tst_tcp::stats::TcpStats::clone(&self) -> tst_tcp::stats::TcpStats
impl core::default::Default for tst_tcp::stats::TcpStats
pub fn tst_tcp::stats::TcpStats::default() -> tst_tcp::stats::TcpStats
impl core::fmt::Debug for tst_tcp::stats::TcpStats
pub fn tst_tcp::stats::TcpStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_tcp::stats::TcpStats
impl core::marker::Freeze for tst_tcp::stats::TcpStats
impl core::marker::Send for tst_tcp::stats::TcpStats
impl core::marker::Sync for tst_tcp::stats::TcpStats
impl core::marker::Unpin for tst_tcp::stats::TcpStats
impl core::marker::UnsafeUnpin for tst_tcp::stats::TcpStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::stats::TcpStats
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::stats::TcpStats
pub struct tst_tcp::TcpTransport
impl tst_tcp::transport::TcpTransport
pub fn tst_tcp::transport::TcpTransport::cancel_handle(&self) -> tst_tcp::transport::TcpCancelHandle
pub fn tst_tcp::transport::TcpTransport::connect(&str) -> core::result::Result<Self, tst_tcp::error::TcpError>
pub fn tst_tcp::transport::TcpTransport::connect_with_config(&tst_tcp::url::TcpUrl, &tst_tcp::config::SocketConfig) -> core::result::Result<Self, tst_tcp::error::TcpError>
pub fn tst_tcp::transport::TcpTransport::peer(&self) -> core::net::socket_addr::SocketAddr
pub fn tst_tcp::transport::TcpTransport::stats(&self) -> tst_tcp::stats::TcpStats
impl tst_core::transport::RecvTransport for tst_tcp::transport::TcpTransport
pub fn tst_tcp::transport::TcpTransport::close(&mut self)
pub fn tst_tcp::transport::TcpTransport::is_alive(&self) -> bool
pub fn tst_tcp::transport::TcpTransport::max_payload(&self) -> usize
pub fn tst_tcp::transport::TcpTransport::recv_bytes(&mut self, &mut [u8]) -> core::result::Result<usize, tst_core::transport::TransportError>
pub fn tst_tcp::transport::TcpTransport::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
impl tst_core::transport::Transport for tst_tcp::transport::TcpTransport
pub fn tst_tcp::transport::TcpTransport::close(&mut self)
pub fn tst_tcp::transport::TcpTransport::is_alive(&self) -> bool
pub fn tst_tcp::transport::TcpTransport::max_payload(&self) -> usize
pub fn tst_tcp::transport::TcpTransport::send_bytes(&mut self, &[u8]) -> core::result::Result<(), tst_core::transport::TransportError>
pub fn tst_tcp::transport::TcpTransport::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
impl core::marker::Freeze for tst_tcp::transport::TcpTransport
impl core::marker::Send for tst_tcp::transport::TcpTransport
impl core::marker::Sync for tst_tcp::transport::TcpTransport
impl core::marker::Unpin for tst_tcp::transport::TcpTransport
impl core::marker::UnsafeUnpin for tst_tcp::transport::TcpTransport
impl !core::panic::unwind_safe::RefUnwindSafe for tst_tcp::transport::TcpTransport
impl !core::panic::unwind_safe::UnwindSafe for tst_tcp::transport::TcpTransport
pub struct tst_tcp::TcpTransportBuilder
impl tst_tcp::builder::TcpTransportBuilder
pub fn tst_tcp::builder::TcpTransportBuilder::build(self) -> core::result::Result<tst_tcp::transport::TcpTransport, tst_tcp::error::TcpError>
pub fn tst_tcp::builder::TcpTransportBuilder::connect_timeout(&mut self, core::time::Duration) -> &mut Self
pub fn tst_tcp::builder::TcpTransportBuilder::from_url(&str) -> core::result::Result<Self, tst_tcp::url::TcpUrlError>
pub fn tst_tcp::builder::TcpTransportBuilder::keepalive(&mut self, core::time::Duration) -> &mut Self
pub fn tst_tcp::builder::TcpTransportBuilder::nodelay(&mut self, bool) -> &mut Self
pub fn tst_tcp::builder::TcpTransportBuilder::pkt_size(&mut self, usize) -> &mut Self
pub fn tst_tcp::builder::TcpTransportBuilder::rcvbuf(&mut self, usize) -> &mut Self
pub fn tst_tcp::builder::TcpTransportBuilder::sndbuf(&mut self, usize) -> &mut Self
impl core::clone::Clone for tst_tcp::builder::TcpTransportBuilder
pub fn tst_tcp::builder::TcpTransportBuilder::clone(&self) -> tst_tcp::builder::TcpTransportBuilder
impl core::fmt::Debug for tst_tcp::builder::TcpTransportBuilder
pub fn tst_tcp::builder::TcpTransportBuilder::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_tcp::builder::TcpTransportBuilder
impl core::marker::Send for tst_tcp::builder::TcpTransportBuilder
impl core::marker::Sync for tst_tcp::builder::TcpTransportBuilder
impl core::marker::Unpin for tst_tcp::builder::TcpTransportBuilder
impl core::marker::UnsafeUnpin for tst_tcp::builder::TcpTransportBuilder
impl core::panic::unwind_safe::RefUnwindSafe for tst_tcp::builder::TcpTransportBuilder
impl core::panic::unwind_safe::UnwindSafe for tst_tcp::builder::TcpTransportBuilder
