List of all items

Structs

• Backoff
• Client
• ClientConfig
• ClientInfo
• ConnectResult
• Error
• FilterError
• FilterValue
• HistoryResult
• Presence
• PresenceResult
• PresenceStats
• Publication
• RpcResult
• StreamPosition
• SubRefreshResult
• SubscribeResult
• Subscription
• SubscriptionConfig
• SubscriptionFilter
• TokenError
• backoff::Backoff
• client::Client
• client::ClientInner
• client::CommandRequest
• client::DisconnectAdvice
• client::PendingRefresh
• client::RunGuard
• client::config::ClientConfig
• error::Error
• filter::FilterError
• filter::FilterValue
• filter::SubscriptionFilter
• presence::Presence
• proto::ClientInfo
• proto::Command
• proto::Connect
• proto::ConnectRequest
• proto::ConnectResult
• proto::Disconnect
• proto::Error
• proto::FilterNode
• proto::HistoryRequest
• proto::HistoryResult
• proto::Join
• proto::Leave
• proto::Message
• proto::PingRequest
• proto::PingResult
• proto::PresenceRequest
• proto::PresenceResult
• proto::PresenceStatsRequest
• proto::PresenceStatsResult
• proto::Publication
• proto::PublishRequest
• proto::PublishResult
• proto::Push
• proto::Refresh
• proto::RefreshRequest
• proto::RefreshResult
• proto::Reply
• proto::RpcRequest
• proto::RpcResult
• proto::SendRequest
• proto::StreamPosition
• proto::SubRefreshRequest
• proto::SubRefreshResult
• proto::Subscribe
• proto::SubscribeRequest
• proto::SubscribeResult
• proto::Unsubscribe
• proto::UnsubscribeRequest
• proto::UnsubscribeResult
• subscription::Subscription
• subscription::SubscriptionConfig
• subscription::SubscriptionInner
• token::Claims
• token::TokenError
• transport::Transport
• types::ClientInfo
• types::ConnectResult
• types::HistoryResult
• types::PresenceResult
• types::PresenceStats
• types::Publication
• types::RpcResult
• types::StreamPosition
• types::SubRefreshResult
• types::SubscribeResult

Enums

• ClientEvent
• ClientState
• SubscriptionEvent
• SubscriptionState
• client::ClientState
• client::ConnectionExit
• error::ErrorKind
• filter::Comparison
• filter::FilterErrorKind
• filter::FilterExpression
• filter::FilterValueKind
• subscription::SubscriptionState
• types::ClientEvent
• types::SubscriptionEvent

Functions

• backoff::jittered_delay
• client::check_reply
• client::format_ttl
• client::log_command_send_failed
• client::log_connection_lost
• client::log_disconnected
• client::log_no_ping
• client::log_reconnect
• client::log_token_refresh_failed
• client::ttl_to_instant
• filter::fmt_joined
• filter::fmt_membership
• filter::json_string
• filter::logical_node
• filter::set_value
• filter::set_values
• filter::validate_identifier
• generate_token
• token::generate_token
• transport::decode_reply
• transport::ensure_crypto_provider
• transport::http_to_ws
• transport::log_server_close
• transport::log_server_close_without_frame
• transport::next_ws_message

Type Aliases

• Result
• client::PendingRequest
• client::config::BoxFuture
• client::config::TokenCallback
• transport::WsStream

Statics

• transport::CRYPTO_INIT

Constants

• backoff::BACKOFF_MULTIPLIER
• backoff::DEFAULT_MAX_DELAY
• backoff::DEFAULT_MIN_DELAY
• client::BACKOFF_RESET_THRESHOLD
• client::COMMAND_CHANNEL_BUFFER
• client::EVENT_CHANNEL_BUFFER
• client::MAX_SERVER_PING_DELAY
• client::TOKEN_REFRESH_TIMEOUT
• client::commands::DEFAULT_TIMEOUT
• client::config::DEFAULT_MAX_RECONNECT_DELAY
• client::config::DEFAULT_MIN_RECONNECT_DELAY
• codes::disconnect::BAD_REQUEST
• codes::disconnect::CHANNEL_LIMIT
• codes::disconnect::CONNECTION_LIMIT
• codes::disconnect::EXPIRED
• codes::disconnect::FORCE_DISCONNECT
• codes::disconnect::INSUFFICIENT_STATE
• codes::disconnect::INVALID_TOKEN
• codes::disconnect::NORMAL
• codes::disconnect::SERVER_ERROR
• codes::disconnect::SHUTDOWN
• codes::disconnect::SUBSCRIPTION_EXPIRED
• codes::disconnect::TOO_MANY_REQUESTS
• codes::error::ALREADY_SUBSCRIBED
• codes::error::BAD_REQUEST
• codes::error::EXPIRED
• codes::error::INTERNAL
• codes::error::LIMIT_EXCEEDED
• codes::error::METHOD_NOT_FOUND
• codes::error::NOT_AVAILABLE
• codes::error::PERMISSION_DENIED
• codes::error::TOKEN_EXPIRED
• codes::error::TOO_MANY_REQUESTS
• codes::error::UNAUTHORIZED
• codes::error::UNKNOWN_CHANNEL
• codes::error::UNRECOVERABLE_POSITION
• codes::unsubscribe::INSUFFICIENT_STATE
• codes::unsubscribe::SERVER
• codes::ws_close::BAD_REQUEST
• codes::ws_close::NORMAL
• disconnect::BAD_REQUEST
• disconnect::CHANNEL_LIMIT
• disconnect::CONNECTION_LIMIT
• disconnect::EXPIRED
• disconnect::FORCE_DISCONNECT
• disconnect::INSUFFICIENT_STATE
• disconnect::INVALID_TOKEN
• disconnect::NORMAL
• disconnect::SERVER_ERROR
• disconnect::SHUTDOWN
• disconnect::SUBSCRIPTION_EXPIRED
• disconnect::TOO_MANY_REQUESTS
• error::TEMPORARY_ERROR_CODE_THRESHOLD
• error_codes::ALREADY_SUBSCRIBED
• error_codes::BAD_REQUEST
• error_codes::EXPIRED
• error_codes::INTERNAL
• error_codes::LIMIT_EXCEEDED
• error_codes::METHOD_NOT_FOUND
• error_codes::NOT_AVAILABLE
• error_codes::PERMISSION_DENIED
• error_codes::TOKEN_EXPIRED
• error_codes::TOO_MANY_REQUESTS
• error_codes::UNAUTHORIZED
• error_codes::UNKNOWN_CHANNEL
• error_codes::UNRECOVERABLE_POSITION
• filter::PRECEDENCE_AND
• filter::PRECEDENCE_COMPARISON
• filter::PRECEDENCE_NOT
• filter::PRECEDENCE_OR
• subscription::DEFAULT_MAX_RESUBSCRIBE_DELAY
• subscription::DEFAULT_MIN_RESUBSCRIBE_DELAY
• subscription::FLAG_CHANNEL_COMPACTION
• transport::HANDSHAKE_TIMEOUT
• unsubscribe::INSUFFICIENT_STATE
• unsubscribe::SERVER
• ws_close::BAD_REQUEST
• ws_close::NORMAL