List of all items
Structs
- Auth
- AuthError
- ConnectInfo
- ConnectOptions
- PublishMessage
- ServerAddr
- ServerInfo
- Subscriber
- UnsubscribeError
- client::Client
- client::ReconnectError
- client::Request
- client::SubscribeError
- error::Error
- header::GetAll
- header::HeaderMap
- header::HeaderName
- header::HeaderValue
- header::ParseHeaderNameError
- header::ParseHeaderValueError
- jetstream::Error
- jetstream::ErrorCode
- jetstream::account::Account
- jetstream::account::Limits
- jetstream::account::Requests
- jetstream::account::Tier
- jetstream::consumer::Config
- jetstream::consumer::Consumer
- jetstream::consumer::Info
- jetstream::consumer::SequenceInfo
- jetstream::consumer::pull::Batch
- jetstream::consumer::pull::BatchBuilder
- jetstream::consumer::pull::BatchConfig
- jetstream::consumer::pull::Config
- jetstream::consumer::pull::FetchBuilder
- jetstream::consumer::pull::Ordered
- jetstream::consumer::pull::OrderedConfig
- jetstream::consumer::pull::Sequence
- jetstream::consumer::pull::Stream
- jetstream::consumer::pull::StreamBuilder
- jetstream::consumer::push::Config
- jetstream::consumer::push::Messages
- jetstream::consumer::push::Ordered
- jetstream::consumer::push::OrderedConfig
- jetstream::context::Context
- jetstream::context::Publish
- jetstream::context::PublishAckFuture
- jetstream::context::StreamNames
- jetstream::context::Streams
- jetstream::kv::Config
- jetstream::kv::Entry
- jetstream::kv::History
- jetstream::kv::Keys
- jetstream::kv::ParseOperationError
- jetstream::kv::Store
- jetstream::kv::Watch
- jetstream::kv::bucket::Status
- jetstream::message::Acker
- jetstream::message::Info
- jetstream::message::Message
- jetstream::message::StreamMessage
- jetstream::object_store::Config
- jetstream::object_store::List
- jetstream::object_store::Object
- jetstream::object_store::ObjectInfo
- jetstream::object_store::ObjectLink
- jetstream::object_store::ObjectMetadata
- jetstream::object_store::ObjectOptions
- jetstream::object_store::ObjectStore
- jetstream::object_store::UpdateMetadata
- jetstream::object_store::Watch
- jetstream::publish::PublishAck
- jetstream::stream::ClusterInfo
- jetstream::stream::Config
- jetstream::stream::ConsumerLimits
- jetstream::stream::ConsumerNames
- jetstream::stream::Consumers
- jetstream::stream::DeleteStatus
- jetstream::stream::External
- jetstream::stream::Info
- jetstream::stream::No
- jetstream::stream::PeerInfo
- jetstream::stream::Placement
- jetstream::stream::Purge
- jetstream::stream::PurgeRequest
- jetstream::stream::PurgeResponse
- jetstream::stream::RawMessage
- jetstream::stream::Republish
- jetstream::stream::Source
- jetstream::stream::SourceInfo
- jetstream::stream::State
- jetstream::stream::Stream
- jetstream::stream::SubjectTransform
- jetstream::stream::Yes
- message::Message
- status::InvalidStatusCode
- status::StatusCode
- subject::Subject
Enums
- CallbackError
- ClientError
- ConnectErrorKind
- Event
- Protocol
- ServerError
- client::FlushErrorKind
- client::PublishErrorKind
- client::RequestErrorKind
- connection::ShouldFlush
- connection::State
- jetstream::consumer::AckPolicy
- jetstream::consumer::DeliverPolicy
- jetstream::consumer::ReplayPolicy
- jetstream::consumer::StreamErrorKind
- jetstream::consumer::pull::BatchErrorKind
- jetstream::consumer::pull::BatchRequestErrorKind
- jetstream::consumer::pull::ConsumerRecreateErrorKind
- jetstream::consumer::pull::MessagesErrorKind
- jetstream::consumer::pull::OrderedErrorKind
- jetstream::consumer::push::ConsumerRecreateErrorKind
- jetstream::consumer::push::MessagesErrorKind
- jetstream::consumer::push::OrderedErrorKind
- jetstream::context::AccountErrorKind
- jetstream::context::CreateKeyValueErrorKind
- jetstream::context::CreateStreamErrorKind
- jetstream::context::GetStreamByNameErrorKind
- jetstream::context::GetStreamErrorKind
- jetstream::context::KeyValueErrorKind
- jetstream::context::ObjectStoreErrorKind
- jetstream::context::PublishErrorKind
- jetstream::context::RequestErrorKind
- jetstream::kv::CreateErrorKind
- jetstream::kv::EntryErrorKind
- jetstream::kv::Operation
- jetstream::kv::PutErrorKind
- jetstream::kv::StatusErrorKind
- jetstream::kv::UpdateErrorKind
- jetstream::kv::WatchErrorKind
- jetstream::kv::WatcherErrorKind
- jetstream::message::AckKind
- jetstream::message::StreamMessageErrorKind
- jetstream::object_store::AddLinkErrorKind
- jetstream::object_store::DeleteErrorKind
- jetstream::object_store::GetErrorKind
- jetstream::object_store::InfoErrorKind
- jetstream::object_store::PutErrorKind
- jetstream::object_store::SealErrorKind
- jetstream::object_store::UpdateMetadataErrorKind
- jetstream::object_store::WatchErrorKind
- jetstream::object_store::WatcherErrorKind
- jetstream::response::Response
- jetstream::stream::Compression
- jetstream::stream::ConsumerCreateStrictErrorKind
- jetstream::stream::ConsumerErrorKind
- jetstream::stream::ConsumerUpdateErrorKind
- jetstream::stream::DeleteMessageErrorKind
- jetstream::stream::DirectGetErrorKind
- jetstream::stream::DiscardPolicy
- jetstream::stream::LastRawMessageErrorKind
- jetstream::stream::PurgeErrorKind
- jetstream::stream::RetentionPolicy
- jetstream::stream::StorageType
Traits
- ToServerAddrs
- header::IntoHeaderName
- header::IntoHeaderValue
- jetstream::consumer::FromConsumer
- jetstream::consumer::IntoConsumerConfig
- jetstream::object_store::AsObjectInfo
- jetstream::stream::ToAssign
- subject::ToSubject
Functions
Type Aliases
- ConnectError
- Error
- client::FlushError
- client::PublishError
- client::RequestError
- jetstream::consumer::OrderedPullConsumer
- jetstream::consumer::OrderedPushConsumer
- jetstream::consumer::PullConsumer
- jetstream::consumer::PushConsumer
- jetstream::consumer::StreamError
- jetstream::consumer::pull::BatchError
- jetstream::consumer::pull::BatchRequestError
- jetstream::consumer::pull::ConsumerRecreateError
- jetstream::consumer::pull::MessagesError
- jetstream::consumer::pull::OrderedError
- jetstream::consumer::push::ConsumerRecreateError
- jetstream::consumer::push::MessagesError
- jetstream::consumer::push::OrderedError
- jetstream::context::AccountError
- jetstream::context::CreateKeyValueError
- jetstream::context::CreateObjectStoreError
- jetstream::context::CreateObjectStoreErrorKind
- jetstream::context::CreateStreamError
- jetstream::context::DeleteObjectStore
- jetstream::context::DeleteObjectStoreKind
- jetstream::context::DeleteStreamError
- jetstream::context::DeleteStreamErrorKind
- jetstream::context::GetStreamByNameError
- jetstream::context::GetStreamError
- jetstream::context::KeyValueError
- jetstream::context::ObjectStoreError
- jetstream::context::PublishError
- jetstream::context::RequestError
- jetstream::context::StreamsError
- jetstream::context::StreamsErrorKind
- jetstream::context::UpdateStreamError
- jetstream::context::UpdateStreamErrorKind
- jetstream::kv::CreateError
- jetstream::kv::DeleteError
- jetstream::kv::DeleteErrorKind
- jetstream::kv::EntryError
- jetstream::kv::HistoryError
- jetstream::kv::HistoryErrorKind
- jetstream::kv::PurgeError
- jetstream::kv::PurgeErrorKind
- jetstream::kv::PutError
- jetstream::kv::StatusError
- jetstream::kv::UpdateError
- jetstream::kv::WatchError
- jetstream::kv::WatcherError
- jetstream::message::StreamMessageError
- jetstream::object_store::AddLinkError
- jetstream::object_store::DeleteError
- jetstream::object_store::GetError
- jetstream::object_store::InfoError
- jetstream::object_store::ListError
- jetstream::object_store::ListErrorKind
- jetstream::object_store::ListerError
- jetstream::object_store::ListerErrorKind
- jetstream::object_store::PutError
- jetstream::object_store::SealError
- jetstream::object_store::UpdateMetadataError
- jetstream::object_store::WatchError
- jetstream::object_store::WatcherError
- jetstream::stream::ConsumerCreateStrictError
- jetstream::stream::ConsumerError
- jetstream::stream::ConsumerUpdateError
- jetstream::stream::ConsumersError
- jetstream::stream::ConsumersErrorKind
- jetstream::stream::DeleteMessageError
- jetstream::stream::DirectGetError
- jetstream::stream::InfoError
- jetstream::stream::LastRawMessageError
- jetstream::stream::PurgeError
- jetstream::stream::RawMessageError
- jetstream::stream::RawMessageErrorKind
Constants
- header::NATS_EXPECTED_LAST_MESSAGE_ID
- header::NATS_EXPECTED_LAST_SEQUENCE
- header::NATS_EXPECTED_LAST_SUBJECT_SEQUENCE
- header::NATS_EXPECTED_STREAM
- header::NATS_LAST_CONSUMER
- header::NATS_LAST_SEQUENCE
- header::NATS_LAST_STREAM
- header::NATS_MESSAGE_ID
- header::NATS_SEQUENCE
- header::NATS_STREAM
- header::NATS_SUBJECT
- header::NATS_TIME_STAMP