List of all items
Structs
- backpressure::NoOpPermits
- backpressure::Permit
- backpressure::SemaphorePermits
- buffer::SegmentedBuffer
- config::BufferConfig
- ipc::IpcListener
- message_builder::Message
- options::SocketOptions
- poison::PoisonGuard
- pubsub::hub::PubSubHub
- pubsub::index::SubscriptionIndex
- reconnect::ReconnectState
- router::RouterHub
- rt::LocalRuntime
- rt::TcpListener
- rt::TcpStream
- rt::UnixListener
- rt::UnixStream
- 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
Functions
- inproc::bind_inproc
- inproc::bind_inproc_bidi
- inproc::connect_inproc
- inproc::connect_inproc_bidi
- inproc::list_inproc_endpoints
- inproc::unbind_inproc
- io::fill_read
- io::take_read_buffer
- io::with_vectored_slices
- ipc::accept
- ipc::bind
- ipc::connect
- monitor::create_monitor
- monitor::emit
- rt::bind_reuseport
- rt::join
- rt::sleep
- rt::spawn
- rt::spawn_blocking
- rt::spawn_detached
- rt::timeout
- subscription::topic_matches_prefixes
- tcp::configure_socket_buffers
- tcp::configure_tcp_keepalive
- tcp::enable_tcp_nodelay
- tcp::reuseport_listener
- 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
- rt::JoinHandle
- rt::OwnedReadHalf
- rt::OwnedWriteHalf