List of all items

Structs

• ConnectProperties
• ConnectResult
• FixedHeader
• Message
• MessageProperties
• Properties
• PublishOptions
• PublishProperties
• RestrictiveValidator
• StandardValidator
• SubscribeOptions
• WillMessage
• WillProperties
• broker::acl::AclManager
• broker::acl::AclRule
• broker::acl::FederatedRoleEntry
• broker::acl::Role
• broker::acl::RoleRule
• broker::auth::AllowAllAuthProvider
• broker::auth::AuthRateLimiter
• broker::auth::AuthResult
• broker::auth::CertificateAuthProvider
• broker::auth::CompositeAuthProvider
• broker::auth::ComprehensiveAuthProvider
• broker::auth::EnhancedAuthResult
• broker::auth::PasswordAuthProvider
• broker::auth::RateLimitedAuthProvider
• broker::auth_mechanisms::jwks::JwkKey
• broker::auth_mechanisms::jwks::JwksCache
• broker::auth_mechanisms::jwks::JwksEndpointConfig
• broker::auth_mechanisms::jwt::JwtAuthProvider
• broker::auth_mechanisms::jwt::JwtClaims
• broker::auth_mechanisms::jwt::JwtHeader
• broker::auth_mechanisms::jwt::JwtVerifier
• broker::auth_mechanisms::jwt_federated::FederatedJwtAuthProvider
• broker::auth_mechanisms::plain::PlainAuthProvider
• broker::auth_mechanisms::scram::FileBasedScramCredentialStore
• broker::auth_mechanisms::scram::ScramCredentials
• broker::auth_mechanisms::scram::ScramSha256AuthProvider
• broker::bridge::BridgeStats
• broker::bridge::config::BridgeConfig
• broker::bridge::config::TopicMapping
• broker::bridge::connection::BridgeConnection
• broker::bridge::loop_prevention::LoopPrevention
• broker::bridge::loop_prevention::MessageFingerprint
• broker::bridge::manager::BridgeManager
• broker::client_handler::ClientHandler
• broker::config::AuthConfig
• broker::config::BrokerConfig
• broker::config::ChangeOnlyDeliveryConfig
• broker::config::ClusterListenerConfig
• broker::config::EchoSuppressionConfig
• broker::config::FederatedJwtConfig
• broker::config::JwtConfig
• broker::config::JwtIssuerConfig
• broker::config::JwtRoleMapping
• broker::config::LoadBalancerConfig
• broker::config::QuicConfig
• broker::config::RateLimitConfig
• broker::config::StorageConfig
• broker::config::TlsConfig
• broker::config::WebSocketConfig
• broker::events::ClientConnectEvent
• broker::events::ClientDisconnectEvent
• broker::events::ClientPublishEvent
• broker::events::ClientSubscribeEvent
• broker::events::ClientUnsubscribeEvent
• broker::events::MessageDeliveredEvent
• broker::events::RetainedSetEvent
• broker::events::SubscriptionInfo
• broker::hot_reload::ConfigChangeEvent
• broker::hot_reload::ConfigSubscriber
• broker::hot_reload::HotReloadManager
• broker::hot_reload::HotReloadStats
• broker::quic_acceptor::QuicAcceptorConfig
• broker::quic_acceptor::QuicStreamWrapper
• broker::resource_monitor::ResourceLimits
• broker::resource_monitor::ResourceMonitor
• broker::resource_monitor::ResourceStats
• broker::router::ClientInfo
• broker::router::MessageRouter
• broker::router::RoutableMessage
• broker::router::Subscription
• broker::server::BrokerShutdownHandle
• broker::server::MqttBroker
• broker::storage::ChangeOnlyState
• broker::storage::ClientSession
• broker::storage::InflightMessage
• broker::storage::QueuedMessage
• broker::storage::RetainedMessage
• broker::storage::Storage
• broker::storage::StoredSubscription
• broker::storage::file_backend::FileBackend
• broker::storage::memory_backend::MemoryBackend
• broker::storage::queue::MessageQueue
• broker::storage::retained::RetainedMessages
• broker::storage::sessions::SessionManager
• broker::sys_topics::BrokerStats
• broker::sys_topics::SysTopicsProvider
• broker::tls_acceptor::TlsAcceptorConfig
• broker::tls_acceptor::TlsStreamWrapper
• broker::websocket_server::WebSocketServerConfig
• broker::websocket_server::WebSocketStreamWrapper
• callback::CallbackManager
• client::AckToken
• client::ErrorRecoveryConfig
• client::MqttClient
• client::ReconnectConfig
• client::RetryState
• client::auth_handlers::jwt::JwtAuthHandler
• client::auth_handlers::plain::PlainAuthHandler
• client::auth_handlers::scram::ScramSha256AuthHandler
• client::mock::MockMqttClient
• client::mock::MockResponses
• codec::CodecRegistry
• encoding::MqttBinary
• encoding::MqttString
• encoding::VariableInt
• encoding::mqtt_binary::MqttBinary
• encoding::mqtt_string::MqttString
• encoding::variable_int::VariableInt
• packet::AckPacketHeader
• packet::FixedHeader
• packet::MqttTypeAndFlags
• packet::auth::AuthPacket
• packet::connack::ConnAckPacket
• packet::connect::ConnectPacket
• packet::disconnect::DisconnectPacket
• packet::pingreq::PingReqPacket
• packet::pingresp::PingRespPacket
• packet::puback::PubAckPacket
• packet::pubcomp::PubCompPacket
• packet::publish::PublishPacket
• packet::pubrec::PubRecPacket
• packet::pubrel::PubRelPacket
• packet::suback::SubAckPacket
• packet::subscribe::SubscribePacket
• packet::subscribe::SubscriptionOptions
• packet::subscribe::SubscriptionOptionsBits
• packet::subscribe::TopicFilter
• packet::subscribe_options::SubscriptionOptions
• packet::subscribe_options::SubscriptionOptionsBits
• packet::unsuback::UnsubAckPacket
• packet::unsubscribe::UnsubscribePacket
• packet_id::PacketIdGenerator
• protocol::v5::properties::Properties
• session::ExpiringMessage
• session::FlowControlConfig
• session::FlowControlStats
• session::LimitsConfig
• session::LimitsManager
• session::MessageQueue
• session::QueueResult
• session::QueueStats
• session::QueuedMessage
• session::Subscription
• session::SubscriptionManager
• session::TopicAliasManager
• session::flow_control::FlowControlConfig
• session::flow_control::FlowControlManager
• session::flow_control::FlowControlStats
• session::flow_control::PendingPublish
• session::flow_control::TopicAliasManager
• session::limits::ExpiringMessage
• session::limits::LimitsConfig
• session::limits::LimitsManager
• session::queue::MessageQueue
• session::queue::QueueResult
• session::queue::QueueStats
• session::queue::QueuedMessage
• session::quic_flow::FlowRegistry
• session::quic_flow::FlowState
• session::retained::RetainedMessage
• session::retained::RetainedMessageStore
• session::state::SessionConfig
• session::state::SessionState
• session::state::SessionStats
• session::subscription::Subscription
• session::subscription::SubscriptionManager
• test_utils::TestClientBuilder
• test_utils::TestData
• test_utils::TestMessageBuilder
• time::Duration
• time::Instant
• time::SystemTime
• transport::client_config::ClientTransportConfig
• transport::flow::ControlFlowHeader
• transport::flow::DataFlowHeader
• transport::flow::FlowFlags
• transport::flow::FlowId
• transport::flow::FlowIdGenerator
• transport::manager::ConnectionStats
• transport::manager::ManagerConfig
• transport::manager::TransportManager
• transport::quic::QuicConfig
• transport::quic::QuicSplitResult
• transport::quic::QuicTransport
• transport::quic_stream_manager::QuicStreamManager
• transport::tcp::TcpConfig
• transport::tcp::TcpTransport
• transport::tls::TlsConfig
• transport::tls::TlsTransport
• transport::websocket::WebSocketConfig
• transport::websocket::WebSocketReadHandle
• transport::websocket::WebSocketTransport
• transport::websocket::WebSocketWriteHandle
• types::ConnectOptions
• types::ConnectProperties
• types::ConnectResult
• types::ConnectionStats
• types::KeepaliveConfig
• types::Message
• types::MessageProperties
• types::PublishOptions
• types::PublishProperties
• types::ReconnectConfig
• types::SubscribeOptions
• types::WillMessage
• types::WillProperties
• validation::RestrictiveValidator
• validation::StandardValidator
• validation::namespace::NamespaceValidator

Enums

• ConnectionEvent
• DisconnectReason
• MqttError
• Packet
• PacketType
• PropertyId
• PropertyValue
• PropertyValueType
• ProtocolVersion
• PublishResult
• QoS
• RetainHandling
• broker::QoS
• broker::acl::Permission
• broker::auth::AuthorizationMode
• broker::auth::EnhancedAuthStatus
• broker::auth_mechanisms::jwks::JwksError
• broker::auth_mechanisms::jwt::JwtVerifierKey
• broker::bridge::BridgeDirection
• broker::bridge::BridgeError
• broker::bridge::config::BridgeDirection
• broker::bridge::config::BridgeProtocol
• broker::bridge::config::MqttVersion
• broker::bridge::connection::ConnectedBroker
• broker::config::AuthMethod
• broker::config::ClaimPattern
• broker::config::ClusterTransport
• broker::config::FederatedAuthMode
• broker::config::JwtAlgorithm
• broker::config::JwtKeySource
• broker::config::RoleMergeMode
• broker::config::ServerDeliveryStrategy
• broker::config::StorageBackend
• broker::events::PublishAction
• broker::events::SubAckReasonCode
• broker::hot_reload::ConfigChangeType
• broker::storage::DynamicStorage
• broker::storage::InflightDirection
• broker::storage::InflightPhase
• broker::transport::BrokerTransport
• client::AuthResponse
• client::ConnectionEvent
• client::DisconnectReason
• client::RecoverableError
• client::mock::MockCall
• error::MqttError
• flags::ConnAckFlags
• flags::ConnectFlags
• flags::PublishFlags
• packet::Packet
• packet::PacketType
• packet::suback::SubAckReasonCode
• packet::subscribe::RetainHandling
• packet::subscribe_options::RetainHandling
• packet::unsuback::UnsubAckReasonCode
• protocol::v5::properties::PropertyId
• protocol::v5::properties::PropertyValue
• protocol::v5::properties::PropertyValueType
• protocol::v5::reason_codes::ReasonCode
• session::quic_flow::FlowLifecycle
• session::quic_flow::FlowType
• session::state::AckResolution
• transport::TransportType
• transport::client_config::StreamStrategy
• transport::flow::FlowHeader
• transport::manager::ConnectionState
• transport::quic_error::QuicCloseReason
• transport::quic_error::StreamResetReason
• transport::quic_error::StreamStopReason
• types::ProtocolVersion
• types::PublishResult
• types::ReasonCode
• types::RetainHandling

Traits

• TopicValidator
• Transport
• broker::auth::AuthProvider
• broker::auth_mechanisms::plain::PasswordCredentialStore
• broker::auth_mechanisms::scram::ScramCredentialStore
• broker::events::BrokerEventHandler
• broker::storage::StorageBackend
• broker::transport::WebSocketTransport
• client::AuthHandler
• client::trait::MqttClientTrait
• codec::PayloadCodec
• packet::MqttPacket
• test_utils::TestPacketBuilder
• transport::packet_io::PacketIo
• transport::packet_io::PacketReader
• transport::packet_io::PacketWriter
• validation::TopicValidator

Macros

• test_timeout

Functions

• broker::auth_mechanisms::scram::generate_scram_credential_line
• broker::auth_mechanisms::scram::generate_scram_credential_line_with_iterations
• broker::quic_acceptor::accept_quic_connection
• broker::quic_acceptor::accept_quic_stream
• broker::quic_acceptor::run_quic_cluster_connection_handler
• broker::quic_acceptor::run_quic_connection_handler
• broker::tls_acceptor::accept_tls_connection
• broker::websocket_server::accept_websocket_connection
• client::is_recoverable
• client::retry_delay
• encoding::binary::binary_len
• encoding::binary::decode_binary
• encoding::binary::encode_binary
• encoding::binary::encode_optional_binary
• encoding::binary::optional_binary_len
• encoding::binary_len
• encoding::decode_binary
• encoding::decode_string
• encoding::decode_variable_int
• encoding::encode_binary
• encoding::encode_optional_binary
• encoding::encode_string
• encoding::encode_variable_int
• encoding::encoded_variable_int_len
• encoding::mqtt_binary::binary_len
• encoding::mqtt_binary::decode_binary
• encoding::mqtt_binary::encode_binary
• encoding::mqtt_binary::encode_optional_binary
• encoding::mqtt_binary::optional_binary_len
• encoding::mqtt_string::decode_string
• encoding::mqtt_string::encode_string
• encoding::mqtt_string::string_len
• encoding::optional_binary_len
• encoding::string_len
• encoding::variable_int::decode_variable_int
• encoding::variable_int::encode_variable_int
• encoding::variable_int::encoded_variable_int_len
• encoding::variable_int::variable_int_len
• encoding::variable_int_len
• is_path_safe_client_id
• is_valid_client_id
• is_valid_topic_filter
• is_valid_topic_name
• packet::is_valid_publish_ack_reason_code
• packet::is_valid_pubrel_reason_code
• parse_shared_subscription
• strip_shared_subscription_prefix
• test_utils::assert_packets_equal
• test_utils::connect_with_retry
• test_utils::create_connected_client
• test_utils::create_test_client
• test_utils::create_test_connack
• test_utils::create_test_connect
• test_utils::create_test_publish
• test_utils::create_test_subscribe
• test_utils::encode_packet
• test_utils::run_with_timeout
• test_utils::test_client_id
• test_utils::test_expiring_message
• test_utils::test_retained_message
• time::is_using_web_time
• topic_matches_filter
• topic_matching::is_valid_filter
• topic_matching::is_valid_topic
• topic_matching::matches
• topic_matching::validate_filter
• topic_matching::validate_topic
• transport::flow::decode_varint
• transport::flow::encode_varint
• transport::flow::varint_len
• transport::packet_io::encode_packet_to_buffer
• transport::packet_io::read_packet_reusing_buffer
• transport::quic_error::parse_connection_error
• transport::quic_error::parse_read_error
• transport::quic_error::parse_write_error
• validate_client_id
• validate_topic_filter
• validate_topic_name
• validation::is_path_safe_client_id
• validation::is_valid_client_id
• validation::is_valid_topic_filter
• validation::is_valid_topic_name
• validation::parse_shared_subscription
• validation::strip_shared_subscription_prefix
• validation::topic_matches_filter
• validation::validate_client_id
• validation::validate_topic_filter
• validation::validate_topic_name

Type Aliases

• Result
• broker::bridge::Result
• callback::CallbackId
• callback::PublishCallback
• client::ConnectionEventCallback
• client::ErrorCallback
• error::Result
• telemetry::propagation::UserProperty
• transport::tls::TlsReadHalf
• transport::tls::TlsWriteHalf

Constants

• constants::buffer::DEFAULT_BUFFER_SIZE
• constants::buffer::DEFAULT_CAPACITY
• constants::buffer::HUGE_BUFFER_SIZE
• constants::buffer::LARGE_BUFFER_SIZE
• constants::buffer::MAX_BUFFER_SIZE
• constants::buffer::VERY_LARGE_BUFFER_SIZE
• constants::connect_flags::WILL_QOS_CLEAR_MASK
• constants::connect_flags::WILL_QOS_MASK
• constants::connect_flags::WILL_QOS_SHIFT
• constants::fixed_header::AUTH
• constants::fixed_header::CONNACK
• constants::fixed_header::CONNECT
• constants::fixed_header::DISCONNECT
• constants::fixed_header::PINGREQ
• constants::fixed_header::PINGRESP
• constants::fixed_header::PUBACK
• constants::fixed_header::PUBCOMP
• constants::fixed_header::PUBLISH_BASE
• constants::fixed_header::PUBREC
• constants::fixed_header::PUBREL
• constants::fixed_header::SUBACK
• constants::fixed_header::SUBSCRIBE
• constants::fixed_header::UNSUBACK
• constants::fixed_header::UNSUBSCRIBE
• constants::limits::MAX_BINARY_LENGTH
• constants::limits::MAX_CLIENT_ID_LENGTH
• constants::limits::MAX_PACKET_SIZE
• constants::limits::MAX_STRING_LENGTH
• constants::masks::CONTINUATION_BIT
• constants::masks::FLAGS
• constants::masks::PACKET_TYPE
• constants::masks::VARIABLE_BYTE_VALUE
• constants::packets::PINGREQ_BYTES
• constants::packets::PINGRESP_BYTES
• constants::publish_flags::QOS_CLEAR_MASK
• constants::publish_flags::QOS_MASK
• constants::publish_flags::QOS_SHIFT
• constants::subscription::NO_LOCAL_MASK
• constants::subscription::QOS_MASK
• constants::subscription::RESERVED_BITS_MASK
• constants::subscription::RETAIN_AS_PUBLISHED_MASK
• constants::subscription::RETAIN_HANDLING_MASK
• constants::subscription::RETAIN_HANDLING_SHIFT
• constants::time::DEFAULT_KEEP_ALIVE
• constants::time::DEFAULT_SESSION_EXPIRY
• constants::variable_byte::MAX_VALUE
• constants::variable_byte::SINGLE_BYTE_MAX
• constants::version::MQTT_V5
• encoding::VARIABLE_BYTE_INT_MAX
• encoding::VARIABLE_INT_MAX
• encoding::variable_int::VARIABLE_BYTE_INT_MAX
• encoding::variable_int::VARIABLE_INT_MAX
• protocol::PROTOCOL_VERSION_311
• protocol::PROTOCOL_VERSION_5
• protocol::v5::reason_codes::GRANTED_QOS_0
• protocol::v5::reason_codes::NORMAL_DISCONNECTION
• time::UNIX_EPOCH
• transport::flow::FLOW_TYPE_CLIENT_DATA
• transport::flow::FLOW_TYPE_CONTROL
• transport::flow::FLOW_TYPE_SERVER_DATA
• transport::flow::FLOW_TYPE_USER_DEFINED
• transport::quic::ALPN_MQTT
• transport::quic::ALPN_MQTT_NEXT