List of all items
Structs
- FeedEnded
- collection::snapshot::SnapUpdates
- collection::snapshot::Snapshot
- metric::Field
- metric::Metric
- metric::Tag
- protocol::http::private::RequestSigner
- protocol::http::private::encoder::Base64Encoder
- protocol::http::private::encoder::HexEncoder
- protocol::http::public::PublicNoHeaders
- protocol::http::rest::client::RestClient
- protocol::websocket::WebSocketProtobufParser
- protocol::websocket::WebSocketSerdeParser
- protocol::websocket::WsParser
- serde::de::DeJson
- serde::de::DeProtobuf
- serde::de::error::DeBinaryError
- serde::se::SeJsonBytes
- serde::se::SeJsonString
- socket::backoff::DefaultBackoff
- socket::on_connect_err::ConnectError
- socket::on_connect_err::OnConnectErr
- socket::on_stream_err::OnStreamErr
- socket::on_stream_err_filter::OnStreamErrFilter
- stream::ExchangeStream
- stream::data::DataArgs
- stream::data::Historical
- stream::data::Live
- stream::ext::forward_by::ForwardBy
- stream::ext::forward_clone_by::ForwardCloneBy
- stream::ext::indexed::IndexedStream
- subscription::SubscriptionId
Enums
- Admin
- Message
- collection::none_one_or_many::NoneOneOrMany
- collection::one_or_many::OneOrMany
- error::SocketError
- metric::Value
- protocol::websocket::AdminWs
- serde::de::error::DeBinaryErrorKind
- serde::se::error::SeError
- socket::on_connect_err::ConnectErrorAction
- socket::on_connect_err::ConnectErrorKind
- socket::on_stream_err::StreamErrorAction
- socket::update::SocketUpdate
Traits
- Terminal
- Transformer
- Unrecoverable
- Validator
- protocol::StreamParser
- protocol::http::BuildStrategy
- protocol::http::HttpParser
- protocol::http::private::Signer
- protocol::http::private::encoder::Encoder
- protocol::http::rest::RestRequest
- serde::de::Deserialiser
- socket::ReconnectingSocket
- socket::backoff::ReconnectBackoff
- socket::on_connect_err::ConnectErrorHandler
- socket::on_stream_err::StreamErrorHandler
- stream::data::DataStream
- stream::ext::BarterStreamExt
- stream::ext::indexed::Indexer
Functions
- protocol::websocket::connect
- protocol::websocket::is_websocket_disconnected
- protocol::websocket::process_binary
- protocol::websocket::process_close_frame
- protocol::websocket::process_frame
- protocol::websocket::process_ping
- protocol::websocket::process_pong
- protocol::websocket::process_text
- serde::de::datetime_utc_from_epoch_duration
- serde::de::de_str
- serde::de::de_str_f64_epoch_ms_as_datetime_utc
- serde::de::de_str_f64_epoch_s_as_datetime_utc
- serde::de::de_str_u64_epoch_ms_as_datetime_utc
- serde::de::de_u64_epoch_ms_as_datetime_utc
- serde::de::extract_next
- serde::se::se_element_to_vector
- socket::init_reconnecting_socket
- stream::util::merge::merge