List of all items

Structs

• ClientID
• Config
• Error
• F32
• PacketRx
• PacketTx
• Subscription
• Timer
• TopicFilter
• TopicName
• VarU32
• broker::Cluster
• broker::Config
• broker::ConfigNode
• broker::ConsensIO
• broker::Flusher
• broker::Handshake
• broker::KeepAlive
• broker::Listener
• broker::Miot
• broker::MsgRx
• broker::MsgTx
• broker::Node
• broker::PQueue
• broker::PQueueArgs
• broker::RetainedTrie
• broker::RouteIO
• broker::Session
• broker::SessionArgsMaster
• broker::SessionArgsReplica
• broker::Shard
• broker::Spinlock
• broker::SubscribedTrie
• broker::Thread
• broker::Ticker
• broker::Timestamp
• broker::rebalance::Rebalancer
• broker::rebalance::Topology
• v5::Auth
• v5::AuthProperties
• v5::Config
• v5::ConnAck
• v5::ConnAckFlags
• v5::ConnAckProperties
• v5::Connect
• v5::ConnectFlags
• v5::ConnectPayload
• v5::ConnectProperties
• v5::DisconnProperties
• v5::Disconnect
• v5::FixedHeader
• v5::PingReq
• v5::PingResp
• v5::Protocol
• v5::Pub
• v5::PubProperties
• v5::Publish
• v5::PublishProperties
• v5::Socket
• v5::SubAck
• v5::SubAckProperties
• v5::Subscribe
• v5::SubscribeFilter
• v5::SubscribeProperties
• v5::SubscriptionOpt
• v5::UnSubscribe
• v5::UnSubscribeProperties
• v5::UnsubAck
• v5::UnsubAckProperties
• v5::WillProperties
• v5::client::Client
• v5::client::ClientBuilder
• v5::client::ConnectOptions

Enums

• Blob
• ErrorKind
• PacketType
• Protocol
• QPacket
• QoS
• QueueStatus
• ReasonCode
• RetainForwardRule
• Socket
• broker::Message
• broker::Tx
• broker::rebalance::Algorithm
• v5::AuthReasonCode
• v5::ConnAckReasonCode
• v5::DisconnReasonCode
• v5::MQTTRead
• v5::MQTTWrite
• v5::MqttProtocol
• v5::Packet
• v5::PayloadFormat
• v5::Property
• v5::PropertyType
• v5::SubAckReasonCode
• v5::UnsubAckReasonCode
• v5::client::DisconnReasonCode

Traits

• IterTopicPath
• Packetize
• ToJson
• broker::ClusterAPI
• broker::Hostable
• broker::ShardAPI
• broker::Shardable
• broker::Threadable

Macros

• config_field
• err

Functions

• broker::msg_channel
• broker::rebalance::diff_topology
• broker::route_match
• new_packet_queue
• util::advance
• util::ceil_power_of_2
• util::is_power_of_2
• util::is_valid_utf8_code_point
• util::num_cores_ceiled

Type Aliases

• PacketID
• Result
• broker::AppTx
• broker::Rx
• v5::UserProperty

Constants

• SLEEP_10MS
• broker::CONTROL_CHAN_SIZE
• broker::POLL_EVENTS_SIZE
• v5::client::CLIENT_MAX_PACKET_SIZE