List of all items

Structs

• ack::Ack
• ack::AckManager
• broker::broker::PublishOutcome
• broker::fanout::FanoutEngine
• broker::fanout::Subscription
• broker::fanout::SubscriptionId
• broker::fanout::test_sink::CountingSink
• broker::memory_broker::InMemoryBroker
• broker::router::LocalRouter
• broker::router::Route
• codec::cbor::CborCodec
• codec::json::JsonCodec
• config::ServerConfig
• connection::Connection
• error::BoxedStdError
• flow::backpressure::BackpressureController
• frame::envelope::Frame
• frame::types::FrameFlags
• message::command::Command
• message::command::Reply
• message::command::ReplyError
• message::datagram::Datagram
• message::event::Event
• message::snapshot::Snapshot
• message::state::Presence
• message::state::State
• message::stream::StreamSegment
• metrics::Metrics
• protocol::heartbeat::HeartbeatPolicy
• protocol::hello::Hello
• protocol::hello::Ready
• protocol::hello::SdkInfo
• protocol::hello::Welcome
• server::RiftServer
• server::RiftServerBuilder
• session::auth::AllowAllAuth
• session::auth::AuthContext
• session::auth::AuthHints
• session::auth::TokenAuth
• session::offset_tracker::OffsetTracker
• session::resume::ResumeManager
• session::session::ClientId
• session::session::Session
• session::session::SessionId
• session::store::SessionStore
• storage::dedupe::MemoryDedupeStore
• storage::engine::MemoryEngine
• storage::log::MemoryLogStore
• storage::offset::MemoryOffsetStore
• storage::snapshot::MemorySnapshotStore
• storage::snapshot::StoredSnapshot
• topic::profile::TopicProfile
• topic::store::LogEntry
• topic::store::SubscriberId
• topic::store::TopicEntry
• topic::store::TopicStore
• transport::websocket::WebSocketConnection
• transport::websocket::WebSocketTransport

Enums

• ack::AckPolicy
• ack::AckStatus
• broker::fanout::FanoutError
• broker::fanout::SubscribeIntent
• error::AuthReject
• error::ConfigError
• error::FrameReject
• error::MessageReject
• error::RiftError
• error::SessionReject
• error::SystemReject
• error::TopicReject
• flow::backpressure::BackpressureAction
• flow::backpressure::BackpressureStrategy
• frame::types::Codec
• frame::types::FrameType
• frame::types::Priority
• message::DeliveryMode
• message::Message
• message::MessageClass
• message::SubscribeResult
• message::command::ReplyStatus
• protocol::close::CloseCode
• protocol::error_code::ErrorCode
• protocol::hello::AuthMode
• protocol::hello::ResumeResult
• session::offset_tracker::ResumeDecision
• session::session::SessionState
• topic::ordering::OrderingPolicy
• topic::retention::RetentionPolicy

Traits

• broker::broker::Broker
• broker::fanout::FanoutSink
• broker::router::TopicRouter
• codec::codec::Codec
• codec::codec::CodecExt
• session::auth::AuthProvider
• storage::dedupe::DedupeStore
• storage::engine::StorageEngine
• storage::log::LogStore
• storage::offset::OffsetStore
• storage::snapshot::SnapshotStore
• transport::Transport
• transport::TransportConnection
• transport::TransportListener

Functions

• broker::broker::serialize_frame_for_fanout
• broker::fanout::new_sink_id
• codec::codec::negotiate
• message::command::decode_command
• message::command::decode_reply
• message::command::encode_command
• message::command::encode_reply
• message::datagram::decode_datagram
• message::datagram::encode_datagram
• message::event::decode_event_body
• message::event::encode_event_body
• message::snapshot::decode_snapshot
• message::snapshot::encode_snapshot
• message::state::decode_presence
• message::state::decode_state
• message::state::encode_presence
• message::state::encode_state
• message::stream::decode_stream
• message::stream::encode_stream
• protocol::version::encoded_version
• protocol::version::negotiate_major
• session::auth::shared
• session::offset_tracker::decide
• storage::encode::dedupe_key
• storage::encode::dedupe_prefix
• storage::encode::log_key
• storage::encode::log_prefix
• storage::encode::log_range_end
• storage::encode::log_range_start
• storage::encode::offset_key
• storage::encode::offset_prefix
• storage::encode::snapshot_key
• storage::encode::snapshot_prefix
• topic::store::validate_name
• transport::frame_codec::decode_binary_frame
• transport::frame_codec::decode_text_frame
• transport::frame_codec::encode_frame

Type Aliases

• ack::SharedAckManager
• broker::broker::BrokerSubscription
• broker::fanout::ConnectionSink
• broker::memory_broker::DefaultBroker
• error::Result
• storage::engine::SharedEngine

Constants

• ack::DEFAULT_MAX_OUTSTANDING_PER_SESSION
• ack::DEFAULT_MAX_SESSIONS
• protocol::version::PROTOCOL_MAJOR
• protocol::version::PROTOCOL_MINOR
• protocol::version::PROTOCOL_NAME
• protocol::version::SUPPORTED_MAJOR
• session::offset_tracker::MAX_TOPICS_PER_SESSION
• storage::encode::SEP
• transport::frame_codec::DEFAULT_MAX_BINARY_PAYLOAD