List of all items

Structs

• Auth
• AuthError
• ConnectInfo
• ConnectOptions
• PublishMessage
• ServerAddr
• ServerInfo
• Subscriber
• UnsubscribeError
• client::Client
• client::DrainError
• client::ReconnectError
• client::Request
• client::Statistics
• 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::InfoWithSubjects
• jetstream::stream::No
• jetstream::stream::PagedInfo
• 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::StreamInfoBuilder
• jetstream::stream::StreamInfoRequest
• jetstream::stream::SubjectTransform
• jetstream::stream::Yes
• message::Message
• service::Config
• service::EndpointBuilder
• service::Group
• service::Info
• service::PingResponse
• service::Request
• service::Service
• service::ServiceBuilder
• service::Stats
• service::StatsHandler
• service::endpoint::Endpoint
• service::endpoint::Info
• service::endpoint::Stats
• service::error::Error
• 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
• service::Verb

Traits

• ToServerAddrs
• header::IntoHeaderName
• header::IntoHeaderValue
• jetstream::consumer::FromConsumer
• jetstream::consumer::IntoConsumerConfig
• jetstream::object_store::AsObjectInfo
• jetstream::stream::ToAssign
• service::ServiceExt
• subject::ToSubject

Functions

• connect
• connect_with_options
• jetstream::new
• jetstream::with_domain
• jetstream::with_prefix

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
• service::NATS_SERVICE_ERROR
• service::NATS_SERVICE_ERROR_CODE