List of all items

Structs

• BackoffMultiplier
• ClientOptions
• ConnectionStateWatch
• ConnectionStatusStream
• EventLoopHandle
• Jitter
• Message
• MessageStream
• MqttBytes
• MqttBytesBuf
• MqttClient
• MqttStr
• MqttString
• NonZeroVbi
• PacketId
• PublishBuilder
• PublishFuture
• PublishOptions
• QueuedPublishFuture
• QueuedSubscribeFuture
• QueuedUnsubscribeFuture
• ReconnectOptions
• SubscribeBuilder
• SubscribeFuture
• Subscription
• Topic
• TopicBuf
• TopicFilter
• TopicFilterBuf
• UnsubscribeBuilder
• UnsubscribeFuture
• WillOptions
• builder::ClientBuilder
• client::MqttClient
• connection::commands::PendingAck
• connection::commands::PendingPublish
• connection::event_loop::ConnectionResult
• connection::event_loop::LoopState
• connection::event_loop::aliases::InboundAliases
• connection::event_loop::aliases::OutboundAliases
• connection::event_loop::backoff::XorShift32
• connection::event_loop::connect::EstablishedConnection
• connection::event_loop::pending::Pending
• handle::EventLoopHandle
• message::Message
• message::MessageStream
• options::BackoffMultiplier
• options::ClientOptions
• options::Jitter
• options::ReconnectOptions
• options::WillOptions
• persistence::FilePersistence
• persistence::SessionPersistence
• persistence::TursoPersistence
• persistence::file::FilePersistence
• persistence::file::FileStore
• persistence::file::journal::Writer
• persistence::file::journal::backup::BackupId
• persistence::file::journal::file::AppendGuard
• persistence::file::journal::file::JournalFile
• persistence::turso::TursoPersistence
• persistence::turso::schema::Tables
• persistence::turso::store::FilterColumns
• persistence::turso::store::Selects
• persistence::turso::store::Statements
• persistence::turso::store::TursoStore
• publish::builder::PublishBuilder
• publish::builder::PublishOptions
• publish::futures::PublishFuture
• publish::futures::QueuedPublishFuture
• status::ConnectionStateWatch
• status::ConnectionStatusStream
• subscribe::QueuedSubscribeFuture
• subscribe::QueuedUnsubscribeFuture
• subscribe::SubscribeBuilder
• subscribe::SubscribeFuture
• subscribe::UnsubscribeBuilder
• subscribe::UnsubscribeFuture
• subscription::Subscription
• transport::TcpTransport
• transport::TlsTransport
• transport::tcp::TcpTransport
• transport::tls::TlsTransport

Enums

• CleanStart
• ConnectionStatus
• DisconnectCause
• PayloadFormat
• PublishProgress
• QoS
• ReasonCode
• RetainHandling
• TopicError
• connection::commands::AckCompletion
• connection::commands::Command
• connection::event_loop::DisconnectReason
• connection::event_loop::write::Wrote
• dispatch::DispatchState
• error::ClientError
• error::DecodeError
• error::EncodeError
• error::Error
• error::PropertiesBufError
• options::CleanStart
• persistence::Inner
• persistence::Persistence
• persistence::file::journal::CompactOutcome
• persistence::file::journal::read::Outcome
• persistence::turso::Source
• publish::futures::PublishProgress
• status::ConnectionStatus
• status::DisconnectCause

Traits

• transport::Transport

Functions

• connection::event_loop::aliases::resolve_inbound_alias
• connection::event_loop::backoff::apply_jitter
• connection::event_loop::backoff::next_delay
• connection::event_loop::connect::build_connect
• connection::event_loop::connect::establish_connection
• connection::event_loop::connect::is_fatal_rejection
• connection::event_loop::disconnect_packet
• connection::event_loop::enqueue
• connection::event_loop::inbound::handle_incoming
• connection::event_loop::inbound::process_inbound
• connection::event_loop::jitter_seed
• connection::event_loop::offline::drain_queued_commands
• connection::event_loop::offline::process_command_offline
• connection::event_loop::offline::record_offline_ack
• connection::event_loop::outbound::handle_command
• connection::event_loop::outbound::pump_session
• connection::event_loop::outbound::register_ack
• connection::event_loop::outbound::resubscribe_confirmed
• connection::event_loop::outbound::send_subscribe
• connection::event_loop::outbound::send_unsubscribe
• connection::event_loop::pending::ack_queued
• connection::event_loop::pending::disarm
• connection::event_loop::pending::dispatch_ack
• connection::event_loop::pending::fail_op
• connection::event_loop::pending::fail_superseded_acks
• connection::event_loop::pending::park_queued
• connection::event_loop::pending::rearm
• connection::event_loop::pending::reject_offline
• connection::event_loop::persist_and_ack
• connection::event_loop::run
• connection::event_loop::run_connection
• connection::event_loop::shutdown_requested
• connection::event_loop::write::deliver_and_flush
• connection::event_loop::write::write_or_flush
• connection::io::read_packet
• connection::io::write_packet
• dispatch::poll_dispatch_then
• dispatch::poll_oneshot
• persistence::file::journal::backup::backup_and_reset
• persistence::file::journal::backup::prune_old_backups
• persistence::file::journal::blocking
• persistence::file::journal::file::sync_parent_dir
• persistence::file::journal::file::tmp_path_for
• persistence::file::journal::file::truncate
• persistence::file::journal::file::write_framed
• persistence::file::journal::read::load
• persistence::file::journal::read::load_blocking
• persistence::file::journal::read::read_header_blocking
• persistence::file::journal::read::read_journal_blocking
• persistence::turso::convert::invalid_data
• persistence::turso::convert::packet_id_param
• persistence::turso::convert::packet_id_value
• persistence::turso::convert::row_blob
• persistence::turso::convert::row_i64
• persistence::turso::convert::row_opt_u32
• persistence::turso::convert::row_packet_id
• persistence::turso::convert::row_text
• persistence::turso::convert::row_u8
• persistence::turso::convert::row_value
• persistence::turso::convert::to_io
• persistence::turso::open_local
• persistence::turso::schema::apply
• persistence::turso::schema::apply_inner
• persistence::turso::schema::current_version
• persistence::turso::schema::initial_schema
• persistence::turso::schema::migrate
• persistence::turso::schema::validate_prefix
• persistence::turso::store::apply_packet_id_rows
• persistence::turso::store::assert_persist_future_send
• persistence::turso::store::decode_filter_state
• persistence::turso::store::exec_pid
• persistence::turso::store::filter_columns
• persistence::turso::store::options_value
• persistence::turso::store::prepare
• persistence::turso::store::row_index
• persistence::turso::store::row_options
• persistence::turso::store::sub_id_value
• transport::connect_nodelay

Type Aliases

• connection::event_loop::Outbound
• connection::event_loop::pending::QueuedWaiters

Constants

• DEFAULT_CONNECT_TIMEOUT
• DEFAULT_MAX_PACKET_SIZE
• builder::DEFAULT_COMMAND_CHANNEL_CAPACITY
• builder::DEFAULT_MESSAGE_CHANNEL_CAPACITY
• connection::event_loop::MSG_QUEUE_BOUND
• connection::event_loop::OFFLINE_QUEUE_LIMIT
• connection::event_loop::OUTBOUND_BYTE_LIMIT
• connection::event_loop::READ_BUFFER_CAPACITY
• connection::event_loop::READ_CHUNK
• connection::event_loop::write::GRACEFUL_FLUSH_TIMEOUT
• options::DEFAULT_CONNECT_TIMEOUT
• options::DEFAULT_MAX_PACKET_SIZE
• persistence::file::journal::backup::MAX_BACKUPS
• persistence::turso::DEFAULT_TABLE_PREFIX
• persistence::turso::schema::MIGRATIONS