List of all items

Structs

• alloc::IoArena
• alloc::SlabMut
• backpressure::NoOpPermits
• backpressure::Permit
• backpressure::SemaphorePermits
• buffer::SegmentedBuffer
• config::BufferConfig
• message_builder::Message
• options::SocketOptions
• poison::PoisonGuard
• pubsub::hub::PubSubHub
• pubsub::index::SubscriptionIndex
• reconnect::ReconnectState
• router::RouterHub
• subscription::Subscription
• subscription::SubscriptionTrie

Enums

• endpoint::Endpoint
• endpoint::EndpointError
• error::MonocoqueError
• monitor::SocketEvent
• pubsub::hub::PubSubCmd
• pubsub::hub::PubSubEvent
• reconnect::ReconnectError
• router::HubEvent
• router::PeerCmd
• router::RouterBehavior
• router::RouterCmd
• socket_type::SocketType
• subscription::SubscriptionEvent

Traits

• backpressure::BytePermits
• error::ResultExt

Functions

• inproc::bind_inproc
• inproc::bind_inproc_bidi
• inproc::connect_inproc
• inproc::connect_inproc_bidi
• inproc::list_inproc_endpoints
• inproc::unbind_inproc
• ipc::accept
• ipc::bind
• ipc::connect
• monitor::create_monitor
• tcp::configure_tcp_keepalive
• tcp::enable_tcp_nodelay
• timeout::read_exact_with_timeout
• timeout::write_all_with_timeout

Type Aliases

• error::Result
• inproc::InprocMessage
• inproc::InprocReceiver
• inproc::InprocSender
• monitor::SocketEventSender
• monitor::SocketMonitor
• pubsub::index::PeerKey

Constants

• alloc::PAGE_ALIGN
• alloc::PAGE_SIZE
• config::DEFAULT_READ_BUF_SIZE
• config::DEFAULT_WRITE_BUF_SIZE
• config::LARGE_READ_BUF_SIZE
• config::LARGE_WRITE_BUF_SIZE
• config::SMALL_READ_BUF_SIZE
• config::SMALL_WRITE_BUF_SIZE
• config::STAGING_BUF_INITIAL_CAP