List of all items
Structs
- Memberlist
- Options
- delegate::CompositeDelegate
- delegate::Event
- delegate::EventSubscriber
- delegate::SubscribleEventDelegate
- delegate::VoidDelegate
- delegate::VoidDelegateError
- keyring::Keyring
- proto::Ack
- proto::AckRef
- proto::AddrParseError
- proto::Alive
- proto::AliveRef
- proto::BrotliAlgorithm
- proto::CIDRsPolicy
- proto::ChecksumHint
- proto::CompressHint
- proto::Dead
- proto::EncryptionHint
- proto::ErrorResponse
- proto::ErrorResponseRef
- proto::IndirectPing
- proto::InvalidKeyLength
- proto::Ipv4AddrRange
- proto::Ipv4Net
- proto::Ipv4Subnets
- proto::Ipv6AddrRange
- proto::Ipv6Net
- proto::Ipv6Subnets
- proto::Label
- proto::LargeMeta
- proto::LargeVec
- proto::MediumVec
- proto::MessagesDecoder
- proto::MessagesDecoderIter
- proto::Meta
- proto::MetricLabels
- proto::Nack
- proto::Node
- proto::NodeId
- proto::NodeState
- proto::NodeStateRef
- proto::OneOrMore
- proto::ParseBrotliAlgorithmError
- proto::ParseChecksumAlgorithmError
- proto::ParseCompressAlgorithmError
- proto::ParseDomainError
- proto::ParseEncryptionAlgorithmError
- proto::ParseZstdCompressionLevelError
- proto::Payload
- proto::Ping
- proto::PrefixLenError
- proto::ProtoDecoder
- proto::ProtoEncoder
- proto::ProtoHint
- proto::PushNodeState
- proto::PushNodeStateRef
- proto::PushPull
- proto::PushPullRef
- proto::RepeatedDecoder
- proto::RepeatedDecoderIter
- proto::SecretKeys
- proto::SmallVec
- proto::Suspect
- proto::TinyVec
- proto::TriVec
- proto::TupleEncoder
- proto::XLargeVec
- proto::XXLargeVec
- proto::XXXLargeVec
- proto::ZstdCompressionLevel
- proto::bytes::Bytes
- proto::bytes::BytesMut
- proto::bytes::TryGetError
- proto::bytes::buf::Chain
- proto::bytes::buf::IntoIter
- proto::bytes::buf::Limit
- proto::bytes::buf::Reader
- proto::bytes::buf::Take
- proto::bytes::buf::UninitSlice
- proto::bytes::buf::Writer
- proto::checksum::ParseChecksumAlgorithmError
- proto::compression::BrotliAlgorithm
- proto::compression::ParseBrotliAlgorithmError
- proto::compression::ParseCompressAlgorithmError
- proto::compression::ParseZstdCompressionLevelError
- proto::compression::ZstdCompressionLevel
- proto::either::IterEither
- proto::encryption::InvalidKeyLength
- proto::encryption::ParseEncryptionAlgorithmError
- proto::encryption::SecretKeys
- queue::TransmitLimitedQueue
- transport::Node
- transport::NodeId
- transport::NodeIdRef
- transport::Packet
- transport::PacketProducer
- transport::PacketSubscriber
- transport::RecvError
- transport::SendError
- transport::StreamProducer
- transport::StreamSubscriber
- transport::futures::channel::mpsc::Receiver
- transport::futures::channel::mpsc::Recv
- transport::futures::channel::mpsc::RecvError
- transport::futures::channel::mpsc::SendError
- transport::futures::channel::mpsc::Sender
- transport::futures::channel::mpsc::TrySendError
- transport::futures::channel::mpsc::UnboundedReceiver
- transport::futures::channel::mpsc::UnboundedSender
- transport::futures::channel::oneshot::Canceled
- transport::futures::channel::oneshot::Cancellation
- transport::futures::channel::oneshot::Receiver
- transport::futures::channel::oneshot::Sender
- transport::futures::executor::BlockingStream
- transport::futures::executor::Enter
- transport::futures::executor::EnterError
- transport::futures::executor::LocalPool
- transport::futures::executor::LocalSpawner
- transport::futures::io::AllowStdIo
- transport::futures::io::BufReader
- transport::futures::io::BufWriter
- transport::futures::io::Chain
- transport::futures::io::Close
- transport::futures::io::Copy
- transport::futures::io::CopyBuf
- transport::futures::io::CopyBufAbortable
- transport::futures::io::Cursor
- transport::futures::io::Empty
- transport::futures::io::Error
- transport::futures::io::FillBuf
- transport::futures::io::Flush
- transport::futures::io::IntoSink
- transport::futures::io::IoSlice
- transport::futures::io::IoSliceMut
- transport::futures::io::LineWriter
- transport::futures::io::Lines
- transport::futures::io::Read
- transport::futures::io::ReadExact
- transport::futures::io::ReadHalf
- transport::futures::io::ReadLine
- transport::futures::io::ReadToEnd
- transport::futures::io::ReadToString
- transport::futures::io::ReadUntil
- transport::futures::io::ReadVectored
- transport::futures::io::Repeat
- transport::futures::io::ReuniteError
- transport::futures::io::SeeKRelative
- transport::futures::io::Seek
- transport::futures::io::Sink
- transport::futures::io::Take
- transport::futures::io::Window
- transport::futures::io::Write
- transport::futures::io::WriteAll
- transport::futures::io::WriteHalf
- transport::futures::io::WriteVectored
- transport::futures::lock::MappedMutexGuard
- transport::futures::lock::Mutex
- transport::futures::lock::MutexGuard
- transport::futures::lock::MutexLockFuture
- transport::futures::lock::OwnedMutexGuard
- transport::futures::lock::OwnedMutexLockFuture
- transport::futures::prelude::future::AbortHandle
- transport::futures::prelude::future::AbortRegistration
- transport::futures::prelude::future::Abortable
- transport::futures::prelude::future::Aborted
- transport::futures::prelude::future::AlwaysReady
- transport::futures::prelude::future::AndThen
- transport::futures::prelude::future::CatchUnwind
- transport::futures::prelude::future::ErrInto
- transport::futures::prelude::future::Flatten
- transport::futures::prelude::future::FlattenSink
- transport::futures::prelude::future::FlattenStream
- transport::futures::prelude::future::Fuse
- transport::futures::prelude::future::FutureObj
- transport::futures::prelude::future::Inspect
- transport::futures::prelude::future::InspectErr
- transport::futures::prelude::future::InspectOk
- transport::futures::prelude::future::IntoFuture
- transport::futures::prelude::future::IntoStream
- transport::futures::prelude::future::Join
- transport::futures::prelude::future::Join3
- transport::futures::prelude::future::Join4
- transport::futures::prelude::future::Join5
- transport::futures::prelude::future::JoinAll
- transport::futures::prelude::future::Lazy
- transport::futures::prelude::future::LocalFutureObj
- transport::futures::prelude::future::Map
- transport::futures::prelude::future::MapErr
- transport::futures::prelude::future::MapInto
- transport::futures::prelude::future::MapOk
- transport::futures::prelude::future::MapOkOrElse
- transport::futures::prelude::future::NeverError
- transport::futures::prelude::future::OkInto
- transport::futures::prelude::future::OptionFuture
- transport::futures::prelude::future::OrElse
- transport::futures::prelude::future::Pending
- transport::futures::prelude::future::PollFn
- transport::futures::prelude::future::PollImmediate
- transport::futures::prelude::future::Ready
- transport::futures::prelude::future::Remote
- transport::futures::prelude::future::RemoteHandle
- transport::futures::prelude::future::Select
- transport::futures::prelude::future::SelectAll
- transport::futures::prelude::future::SelectOk
- transport::futures::prelude::future::Shared
- transport::futures::prelude::future::Then
- transport::futures::prelude::future::TryFlatten
- transport::futures::prelude::future::TryFlattenStream
- transport::futures::prelude::future::TryJoin
- transport::futures::prelude::future::TryJoin3
- transport::futures::prelude::future::TryJoin4
- transport::futures::prelude::future::TryJoin5
- transport::futures::prelude::future::TryJoinAll
- transport::futures::prelude::future::TrySelect
- transport::futures::prelude::future::UnitError
- transport::futures::prelude::future::UnwrapOrElse
- transport::futures::prelude::future::WeakShared
- transport::futures::prelude::sink::Buffer
- transport::futures::prelude::sink::Close
- transport::futures::prelude::sink::Drain
- transport::futures::prelude::sink::Fanout
- transport::futures::prelude::sink::Feed
- transport::futures::prelude::sink::Flush
- transport::futures::prelude::sink::Send
- transport::futures::prelude::sink::SendAll
- transport::futures::prelude::sink::SinkErrInto
- transport::futures::prelude::sink::SinkMapErr
- transport::futures::prelude::sink::Unfold
- transport::futures::prelude::sink::With
- transport::futures::prelude::sink::WithFlatMap
- transport::futures::prelude::stream::AbortHandle
- transport::futures::prelude::stream::AbortRegistration
- transport::futures::prelude::stream::Abortable
- transport::futures::prelude::stream::Aborted
- transport::futures::prelude::stream::All
- transport::futures::prelude::stream::AndThen
- transport::futures::prelude::stream::Any
- transport::futures::prelude::stream::BufferUnordered
- transport::futures::prelude::stream::Buffered
- transport::futures::prelude::stream::CatchUnwind
- transport::futures::prelude::stream::Chain
- transport::futures::prelude::stream::Chunks
- transport::futures::prelude::stream::Collect
- transport::futures::prelude::stream::Concat
- transport::futures::prelude::stream::Count
- transport::futures::prelude::stream::Cycle
- transport::futures::prelude::stream::Empty
- transport::futures::prelude::stream::Enumerate
- transport::futures::prelude::stream::ErrInto
- transport::futures::prelude::stream::Filter
- transport::futures::prelude::stream::FilterMap
- transport::futures::prelude::stream::FlatMap
- transport::futures::prelude::stream::FlatMapUnordered
- transport::futures::prelude::stream::Flatten
- transport::futures::prelude::stream::Fold
- transport::futures::prelude::stream::ForEach
- transport::futures::prelude::stream::ForEachConcurrent
- transport::futures::prelude::stream::Forward
- transport::futures::prelude::stream::Fuse
- transport::futures::prelude::stream::FuturesOrdered
- transport::futures::prelude::stream::FuturesUnordered
- transport::futures::prelude::stream::Inspect
- transport::futures::prelude::stream::InspectErr
- transport::futures::prelude::stream::InspectOk
- transport::futures::prelude::stream::IntoAsyncRead
- transport::futures::prelude::stream::IntoStream
- transport::futures::prelude::stream::Iter
- transport::futures::prelude::stream::Map
- transport::futures::prelude::stream::MapErr
- transport::futures::prelude::stream::MapOk
- transport::futures::prelude::stream::Next
- transport::futures::prelude::stream::NextIf
- transport::futures::prelude::stream::NextIfEq
- transport::futures::prelude::stream::Once
- transport::futures::prelude::stream::OrElse
- transport::futures::prelude::stream::Peek
- transport::futures::prelude::stream::PeekMut
- transport::futures::prelude::stream::Peekable
- transport::futures::prelude::stream::Pending
- transport::futures::prelude::stream::PollFn
- transport::futures::prelude::stream::PollImmediate
- transport::futures::prelude::stream::ReadyChunks
- transport::futures::prelude::stream::Repeat
- transport::futures::prelude::stream::RepeatWith
- transport::futures::prelude::stream::ReuniteError
- transport::futures::prelude::stream::Scan
- transport::futures::prelude::stream::Select
- transport::futures::prelude::stream::SelectAll
- transport::futures::prelude::stream::SelectNextSome
- transport::futures::prelude::stream::SelectWithStrategy
- transport::futures::prelude::stream::Skip
- transport::futures::prelude::stream::SkipWhile
- transport::futures::prelude::stream::SplitSink
- transport::futures::prelude::stream::SplitStream
- transport::futures::prelude::stream::StreamFuture
- transport::futures::prelude::stream::Take
- transport::futures::prelude::stream::TakeUntil
- transport::futures::prelude::stream::TakeWhile
- transport::futures::prelude::stream::Then
- transport::futures::prelude::stream::TryAll
- transport::futures::prelude::stream::TryAny
- transport::futures::prelude::stream::TryBufferUnordered
- transport::futures::prelude::stream::TryBuffered
- transport::futures::prelude::stream::TryChunks
- transport::futures::prelude::stream::TryChunksError
- transport::futures::prelude::stream::TryCollect
- transport::futures::prelude::stream::TryConcat
- transport::futures::prelude::stream::TryFilter
- transport::futures::prelude::stream::TryFilterMap
- transport::futures::prelude::stream::TryFlatten
- transport::futures::prelude::stream::TryFlattenUnordered
- transport::futures::prelude::stream::TryFold
- transport::futures::prelude::stream::TryForEach
- transport::futures::prelude::stream::TryForEachConcurrent
- transport::futures::prelude::stream::TryNext
- transport::futures::prelude::stream::TryReadyChunks
- transport::futures::prelude::stream::TryReadyChunksError
- transport::futures::prelude::stream::TrySkipWhile
- transport::futures::prelude::stream::TryTakeWhile
- transport::futures::prelude::stream::TryUnfold
- transport::futures::prelude::stream::Unfold
- transport::futures::prelude::stream::Unzip
- transport::futures::prelude::stream::Zip
- transport::futures::prelude::stream::futures_unordered::FuturesUnordered
- transport::futures::prelude::stream::futures_unordered::IntoIter
- transport::futures::prelude::stream::futures_unordered::Iter
- transport::futures::prelude::stream::futures_unordered::IterMut
- transport::futures::prelude::stream::futures_unordered::IterPinMut
- transport::futures::prelude::stream::futures_unordered::IterPinRef
- transport::futures::prelude::stream::select_all::IntoIter
- transport::futures::prelude::stream::select_all::Iter
- transport::futures::prelude::stream::select_all::IterMut
- transport::futures::prelude::stream::select_all::SelectAll
- transport::futures::task::AtomicWaker
- transport::futures::task::Context
- transport::futures::task::FutureObj
- transport::futures::task::LocalFutureObj
- transport::futures::task::RawWaker
- transport::futures::task::RawWakerVTable
- transport::futures::task::SpawnError
- transport::futures::task::Waker
- transport::futures::task::WakerRef
- transport::hostaddr::Buffer
- transport::hostaddr::Domain
- transport::hostaddr::HostAddr
- transport::hostaddr::ParseAsciiDomainError
- transport::hostaddr::ParseAsciiHostError
- transport::hostaddr::ParseDomainError
- transport::hostaddr::ParseHostError
- transport::hostaddr::TryUnwrapError
- transport::resolver::address::HostAddrResolver
- transport::resolver::address::HostAddrResolverOptions
- transport::resolver::socket_addr::SocketAddrResolver
- transport::unimplemented::UnimplementedConnection
- transport::unimplemented::UnimplementedReader
- transport::unimplemented::UnimplementedStream
- transport::unimplemented::UnimplementedTransport
- transport::unimplemented::UnimplementedTransportError
- transport::unimplemented::UnimplementedWriter
- util::InsufficientData
- util::InsufficientSpace
- util::MapDecoder
- util::SequenceDecoder
- util::utils::Buffer
Enums
- delegate::DelegateError
- delegate::EventKind
- error::EncryptionError
- error::Error
- keyring::KeyringError
- proto::BrotliQuality
- proto::BrotliWindow
- proto::ChecksumAlgorithm
- proto::ChecksumError
- proto::CompressAlgorithm
- proto::CompressError
- proto::CompressionError
- proto::DecodeError
- proto::DecompressError
- proto::DelegateVersion
- proto::EncodeError
- proto::EncryptionAlgorithm
- proto::EncryptionError
- proto::IpAddrRange
- proto::IpNet
- proto::IpSubnets
- proto::LabelError
- proto::MaybeResolvedAddress
- proto::Message
- proto::MessageRef
- proto::MessageType
- proto::ParseHostAddrError
- proto::ParseLabelError
- proto::ParseNodeIdError
- proto::ParseSecretKeyError
- proto::ProtoDecoderError
- proto::ProtoEncoderError
- proto::ProtocolVersion
- proto::SecretKey
- proto::State
- proto::WireType
- proto::checksum::ChecksumAlgorithm
- proto::checksum::ChecksumError
- proto::compression::BrotliQuality
- proto::compression::BrotliWindow
- proto::compression::CompressAlgorithm
- proto::compression::CompressError
- proto::compression::CompressionError
- proto::compression::DecompressError
- proto::either::Either
- proto::encryption::EncryptionAlgorithm
- proto::encryption::EncryptionError
- proto::encryption::ParseSecretKeyError
- proto::encryption::SecretKey
- tests::AddressKind
- transport::ParseNodeIdError
- transport::TryRecvError
- transport::TrySendError
- transport::futures::channel::mpsc::TryRecvError
- transport::futures::io::ErrorKind
- transport::futures::io::SeekFrom
- transport::futures::prelude::future::Either
- transport::futures::prelude::future::MaybeDone
- transport::futures::prelude::future::TryMaybeDone
- transport::futures::prelude::stream::PollNext
- transport::futures::task::Poll
- transport::hostaddr::Host
- transport::hostaddr::ParseAsciiHostAddrError
- transport::hostaddr::ParseHostAddrError
- util::ConstDecodeError
- util::ConstEncodeError
- util::DecodeError
- util::EncodeError
Traits
- Broadcast
- CheapClone
- delegate::AliveDelegate
- delegate::ConflictDelegate
- delegate::Delegate
- delegate::EventDelegate
- delegate::MergeDelegate
- delegate::NodeDelegate
- delegate::PingDelegate
- proto::CheapClone
- proto::Data
- proto::DataRef
- proto::IpAdd
- proto::IpBitAnd
- proto::IpBitOr
- proto::IpSub
- proto::ProtoReader
- proto::ProtoWriter
- proto::bytes::Buf
- proto::bytes::BufMut
- proto::bytes::buf::Buf
- proto::bytes::buf::BufMut
- proto::either::IntoEither
- queue::NodeCalculator
- transport::Address
- transport::AddressResolver
- transport::CheapClone
- transport::Connection
- transport::Id
- transport::Transport
- transport::TransportError
- transport::futures::AsyncBufRead
- transport::futures::AsyncBufReadExt
- transport::futures::AsyncRead
- transport::futures::AsyncReadExt
- transport::futures::AsyncSeek
- transport::futures::AsyncSeekExt
- transport::futures::AsyncWrite
- transport::futures::AsyncWriteExt
- transport::futures::Future
- transport::futures::FutureExt
- transport::futures::Sink
- transport::futures::SinkExt
- transport::futures::Stream
- transport::futures::StreamExt
- transport::futures::TryFuture
- transport::futures::TryFutureExt
- transport::futures::TryStream
- transport::futures::TryStreamExt
- transport::futures::io::AsyncBufRead
- transport::futures::io::AsyncBufReadExt
- transport::futures::io::AsyncRead
- transport::futures::io::AsyncReadExt
- transport::futures::io::AsyncSeek
- transport::futures::io::AsyncSeekExt
- transport::futures::io::AsyncWrite
- transport::futures::io::AsyncWriteExt
- transport::futures::prelude::AsyncBufRead
- transport::futures::prelude::AsyncRead
- transport::futures::prelude::AsyncSeek
- transport::futures::prelude::AsyncWrite
- transport::futures::prelude::Future
- transport::futures::prelude::Sink
- transport::futures::prelude::Stream
- transport::futures::prelude::TryFuture
- transport::futures::prelude::TryStream
- transport::futures::prelude::_
- transport::futures::prelude::future::FusedFuture
- transport::futures::prelude::future::Future
- transport::futures::prelude::future::FutureExt
- transport::futures::prelude::future::TryFuture
- transport::futures::prelude::future::TryFutureExt
- transport::futures::prelude::future::UnsafeFutureObj
- transport::futures::prelude::sink::Sink
- transport::futures::prelude::sink::SinkExt
- transport::futures::prelude::stream::FusedStream
- transport::futures::prelude::stream::Stream
- transport::futures::prelude::stream::StreamExt
- transport::futures::prelude::stream::TryStream
- transport::futures::prelude::stream::TryStreamExt
- transport::futures::task::ArcWake
- transport::futures::task::LocalSpawn
- transport::futures::task::LocalSpawnExt
- transport::futures::task::Spawn
- transport::futures::task::SpawnExt
- transport::futures::task::UnsafeFutureObj
- transport::resolver::AddressResolver
- transport::resolver::Runtime
- transport::resolver::RuntimeLite
- util::IsGlobalIp
- util::Varint
- util::packable::Packable
Macros
- proto::either::for_both
- proto::either::try_left
- proto::either::try_right
- proto::smallvec_wrapper
- transport::futures::join
- transport::futures::pending
- transport::futures::pin_mut
- transport::futures::poll
- transport::futures::ready
- transport::futures::select
- transport::futures::select_biased
- transport::futures::stream_select
- transport::futures::try_join
Functions
- proto::either::serde_untagged::deserialize
- proto::either::serde_untagged::serialize
- proto::either::serde_untagged_optional::deserialize
- proto::either::serde_untagged_optional::serialize
- proto::ip_mask_to_prefix
- proto::ipv4_mask_to_prefix
- proto::ipv6_mask_to_prefix
- proto::utils::merge
- proto::utils::skip
- proto::utils::split
- tests::get_memberlist
- tests::initialize_tests_tracing
- tests::memberlist::memberlist_conflict_delegate
- tests::memberlist::memberlist_create
- tests::memberlist::memberlist_create_shutdown
- tests::memberlist::memberlist_join
- tests::memberlist::memberlist_join_cancel
- tests::memberlist::memberlist_join_cancel_passive
- tests::memberlist::memberlist_join_shutdown
- tests::memberlist::memberlist_join_with_labels
- tests::memberlist::memberlist_leave
- tests::memberlist::memberlist_node_delegate_meta
- tests::memberlist::memberlist_node_delegate_meta_update
- tests::memberlist::memberlist_ping_delegate
- tests::memberlist::memberlist_send
- tests::memberlist::memberlist_send_many
- tests::memberlist::memberlist_send_reliable
- tests::memberlist::memberlist_shutdown_cleanup
- tests::memberlist::memberlist_shutdown_cleanup2
- tests::memberlist::memberlist_user_data
- tests::memberlist::wait_for_condition
- tests::memberlist::wait_until_size
- tests::next_socket_addr_v4
- tests::next_socket_addr_v6
- tests::run
- tests::state::alive_node_change_meta
- tests::state::alive_node_conflict
- tests::state::alive_node_idempotent
- tests::state::alive_node_new_node
- tests::state::alive_node_refute
- tests::state::alive_node_suspect_node
- tests::state::dead_node
- tests::state::dead_node_alive_replay
- tests::state::dead_node_double
- tests::state::dead_node_left
- tests::state::dead_node_no_node
- tests::state::dead_node_old_dead
- tests::state::dead_node_refute
- tests::state::gossip
- tests::state::gossip_to_dead
- tests::state::invoke_ack_handler
- tests::state::invoke_ack_handler_channel_ack
- tests::state::invoke_ack_handler_channel_nack
- tests::state::merge_state
- tests::state::ping
- tests::state::probe
- tests::state::probe_node
- tests::state::probe_node_awareness_degraded
- tests::state::probe_node_awareness_improved
- tests::state::probe_node_awareness_missed_nack
- tests::state::probe_node_buddy
- tests::state::probe_node_dogpile
- tests::state::probe_node_suspect
- tests::state::push_pull
- tests::state::reset_nodes
- tests::state::set_ack_handler
- tests::state::set_probe_channels
- tests::state::suspect_node
- tests::state::suspect_node_double_suspect
- tests::state::suspect_node_no_node
- tests::state::suspect_node_old_suspect
- tests::state::suspect_node_refute
- transport::futures::channel::mpsc::channel
- transport::futures::channel::mpsc::unbounded
- transport::futures::channel::oneshot::channel
- transport::futures::executor::block_on
- transport::futures::executor::block_on_stream
- transport::futures::executor::enter
- transport::futures::io::copy
- transport::futures::io::copy_buf
- transport::futures::io::copy_buf_abortable
- transport::futures::io::empty
- transport::futures::io::repeat
- transport::futures::io::sink
- transport::futures::prelude::future::abortable
- transport::futures::prelude::future::always_ready
- transport::futures::prelude::future::err
- transport::futures::prelude::future::join
- transport::futures::prelude::future::join3
- transport::futures::prelude::future::join4
- transport::futures::prelude::future::join5
- transport::futures::prelude::future::join_all
- transport::futures::prelude::future::lazy
- transport::futures::prelude::future::maybe_done
- transport::futures::prelude::future::ok
- transport::futures::prelude::future::pending
- transport::futures::prelude::future::poll_fn
- transport::futures::prelude::future::poll_immediate
- transport::futures::prelude::future::ready
- transport::futures::prelude::future::select
- transport::futures::prelude::future::select_all
- transport::futures::prelude::future::select_ok
- transport::futures::prelude::future::try_join
- transport::futures::prelude::future::try_join3
- transport::futures::prelude::future::try_join4
- transport::futures::prelude::future::try_join5
- transport::futures::prelude::future::try_join_all
- transport::futures::prelude::future::try_maybe_done
- transport::futures::prelude::future::try_select
- transport::futures::prelude::sink::drain
- transport::futures::prelude::sink::unfold
- transport::futures::prelude::stream::abortable
- transport::futures::prelude::stream::empty
- transport::futures::prelude::stream::iter
- transport::futures::prelude::stream::once
- transport::futures::prelude::stream::pending
- transport::futures::prelude::stream::poll_fn
- transport::futures::prelude::stream::poll_immediate
- transport::futures::prelude::stream::repeat
- transport::futures::prelude::stream::repeat_with
- transport::futures::prelude::stream::select
- transport::futures::prelude::stream::select_all
- transport::futures::prelude::stream::select_all::select_all
- transport::futures::prelude::stream::select_with_strategy
- transport::futures::prelude::stream::try_unfold
- transport::futures::prelude::stream::unfold
- transport::futures::task::noop_waker
- transport::futures::task::noop_waker_ref
- transport::futures::task::waker
- transport::futures::task::waker_ref
- transport::hostaddr::verify_ascii_domain
- transport::hostaddr::verify_ascii_domain_allow_percent_encoding
- transport::hostaddr::verify_domain
- transport::packet_stream
- transport::promised_stream
- util::consume_varint
- util::consume_varint_checked
- util::decode_char
- util::decode_duration
- util::decode_f32_varint
- util::decode_f64_varint
- util::decode_i128_varint
- util::decode_i16_varint
- util::decode_i32_varint
- util::decode_i64_varint
- util::decode_i8_varint
- util::decode_map
- util::decode_sequence
- util::decode_u128_varint
- util::decode_u16_varint
- util::decode_u32_varint
- util::decode_u64_varint
- util::decode_u8_varint
- util::encode_char
- util::encode_char_to
- util::encode_duration
- util::encode_duration_to
- util::encode_f32_sequence_to
- util::encode_f32_varint
- util::encode_f32_varint_to
- util::encode_f64_sequence_to
- util::encode_f64_varint
- util::encode_f64_varint_to
- util::encode_i128_sequence_to
- util::encode_i128_varint
- util::encode_i128_varint_to
- util::encode_i16_sequence_to
- util::encode_i16_varint
- util::encode_i16_varint_to
- util::encode_i32_sequence_to
- util::encode_i32_varint
- util::encode_i32_varint_to
- util::encode_i64_sequence_to
- util::encode_i64_varint
- util::encode_i64_varint_to
- util::encode_i8_sequence_to
- util::encode_i8_varint
- util::encode_i8_varint_to
- util::encode_map
- util::encode_sequence
- util::encode_u128_sequence_to
- util::encode_u128_varint
- util::encode_u128_varint_to
- util::encode_u16_sequence_to
- util::encode_u16_varint
- util::encode_u16_varint_to
- util::encode_u32_sequence_to
- util::encode_u32_varint
- util::encode_u32_varint_to
- util::encode_u64_sequence_to
- util::encode_u64_varint
- util::encode_u64_varint_to
- util::encode_u8_sequence_to
- util::encode_u8_varint
- util::encode_u8_varint_to
- util::encoded_char_len
- util::encoded_duration_len
- util::encoded_f32_sequence_len
- util::encoded_f32_varint_len
- util::encoded_f64_sequence_len
- util::encoded_f64_varint_len
- util::encoded_i128_sequence_len
- util::encoded_i128_varint_len
- util::encoded_i16_sequence_len
- util::encoded_i16_varint_len
- util::encoded_i32_sequence_len
- util::encoded_i32_varint_len
- util::encoded_i64_sequence_len
- util::encoded_i64_varint_len
- util::encoded_i8_sequence_len
- util::encoded_i8_varint_len
- util::encoded_map_len
- util::encoded_sequence_len
- util::encoded_u128_sequence_len
- util::encoded_u128_varint_len
- util::encoded_u16_sequence_len
- util::encoded_u16_varint_len
- util::encoded_u32_sequence_len
- util::encoded_u32_varint_len
- util::encoded_u64_sequence_len
- util::encoded_u64_varint_len
- util::encoded_u8_sequence_len
- util::encoded_u8_varint_len
- util::hostname
- util::map_decoder
- util::sequence_decoder
- util::try_consume_varint
- util::utils::pack_i16
- util::utils::pack_i16_i32
- util::utils::pack_i16_i64
- util::utils::pack_i16_i8
- util::utils::pack_i16_u16
- util::utils::pack_i16_u32
- util::utils::pack_i16_u64
- util::utils::pack_i16_u8
- util::utils::pack_i32
- util::utils::pack_i32_i16
- util::utils::pack_i32_i64
- util::utils::pack_i32_i8
- util::utils::pack_i32_u16
- util::utils::pack_i32_u32
- util::utils::pack_i32_u64
- util::utils::pack_i32_u8
- util::utils::pack_i64
- util::utils::pack_i64_i16
- util::utils::pack_i64_i32
- util::utils::pack_i64_i8
- util::utils::pack_i64_u16
- util::utils::pack_i64_u32
- util::utils::pack_i64_u64
- util::utils::pack_i64_u8
- util::utils::pack_i8
- util::utils::pack_i8_i16
- util::utils::pack_i8_i32
- util::utils::pack_i8_i64
- util::utils::pack_i8_u16
- util::utils::pack_i8_u32
- util::utils::pack_i8_u64
- util::utils::pack_i8_u8
- util::utils::pack_u16
- util::utils::pack_u16_i16
- util::utils::pack_u16_i32
- util::utils::pack_u16_i64
- util::utils::pack_u16_i8
- util::utils::pack_u16_u32
- util::utils::pack_u16_u64
- util::utils::pack_u16_u8
- util::utils::pack_u32
- util::utils::pack_u32_i16
- util::utils::pack_u32_i32
- util::utils::pack_u32_i64
- util::utils::pack_u32_i8
- util::utils::pack_u32_u16
- util::utils::pack_u32_u64
- util::utils::pack_u32_u8
- util::utils::pack_u64
- util::utils::pack_u64_i16
- util::utils::pack_u64_i32
- util::utils::pack_u64_i64
- util::utils::pack_u64_i8
- util::utils::pack_u64_u16
- util::utils::pack_u64_u32
- util::utils::pack_u64_u8
- util::utils::pack_u8
- util::utils::pack_u8_i16
- util::utils::pack_u8_i32
- util::utils::pack_u8_i64
- util::utils::pack_u8_i8
- util::utils::pack_u8_u16
- util::utils::pack_u8_u32
- util::utils::pack_u8_u64
- util::utils::unpack_i16
- util::utils::unpack_i16_i32
- util::utils::unpack_i16_i64
- util::utils::unpack_i16_i8
- util::utils::unpack_i16_u16
- util::utils::unpack_i16_u32
- util::utils::unpack_i16_u64
- util::utils::unpack_i16_u8
- util::utils::unpack_i32
- util::utils::unpack_i32_i16
- util::utils::unpack_i32_i64
- util::utils::unpack_i32_i8
- util::utils::unpack_i32_u16
- util::utils::unpack_i32_u32
- util::utils::unpack_i32_u64
- util::utils::unpack_i32_u8
- util::utils::unpack_i64
- util::utils::unpack_i64_i16
- util::utils::unpack_i64_i32
- util::utils::unpack_i64_i8
- util::utils::unpack_i64_u16
- util::utils::unpack_i64_u32
- util::utils::unpack_i64_u64
- util::utils::unpack_i64_u8
- util::utils::unpack_i8
- util::utils::unpack_i8_i16
- util::utils::unpack_i8_i32
- util::utils::unpack_i8_i64
- util::utils::unpack_i8_u16
- util::utils::unpack_i8_u32
- util::utils::unpack_i8_u64
- util::utils::unpack_i8_u8
- util::utils::unpack_u16
- util::utils::unpack_u16_i16
- util::utils::unpack_u16_i32
- util::utils::unpack_u16_i64
- util::utils::unpack_u16_i8
- util::utils::unpack_u16_u32
- util::utils::unpack_u16_u64
- util::utils::unpack_u16_u8
- util::utils::unpack_u32
- util::utils::unpack_u32_i16
- util::utils::unpack_u32_i32
- util::utils::unpack_u32_i64
- util::utils::unpack_u32_i8
- util::utils::unpack_u32_u16
- util::utils::unpack_u32_u64
- util::utils::unpack_u32_u8
- util::utils::unpack_u64
- util::utils::unpack_u64_i16
- util::utils::unpack_u64_i32
- util::utils::unpack_u64_i64
- util::utils::unpack_u64_i8
- util::utils::unpack_u64_u16
- util::utils::unpack_u64_u32
- util::utils::unpack_u64_u8
- util::utils::unpack_u8
- util::utils::unpack_u8_i16
- util::utils::unpack_u8_i32
- util::utils::unpack_u8_i64
- util::utils::unpack_u8_i8
- util::utils::unpack_u8_u16
- util::utils::unpack_u8_u32
- util::utils::unpack_u8_u64
- util::utils::zigzag_decode_i128
- util::utils::zigzag_decode_i16
- util::utils::zigzag_decode_i32
- util::utils::zigzag_decode_i64
- util::utils::zigzag_decode_i8
- util::utils::zigzag_encode_i128
- util::utils::zigzag_encode_i16
- util::utils::zigzag_encode_i32
- util::utils::zigzag_encode_i64
- util::utils::zigzag_encode_i8
Type Aliases
- proto::Domain
- proto::DomainBuffer
- proto::HostAddr
- proto::HostAddrBuffer
- tests::AnyError
- transport::Domain
- transport::DomainBuffer
- transport::HostAddr
- transport::HostAddrBuffer
- transport::futures::io::Result
- transport::futures::never::Never
- transport::futures::prelude::future::BoxFuture
- transport::futures::prelude::future::LocalBoxFuture
- transport::futures::prelude::stream::BoxStream
- transport::futures::prelude::stream::FlattenUnordered
- transport::futures::prelude::stream::LocalBoxStream
- util::CharBuffer