List of all items

Structs

• AuthError
• Client
• ConnectInfo
• ConnectOptions
• PublishError
• Request
• ServerAddr
• ServerInfo
• Subscriber
• header::HeaderMap
• header::HeaderName
• header::HeaderValue
• header::ParseError
• 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::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::Store
• jetstream::kv::Watch
• jetstream::kv::bucket::Status
• jetstream::message::Info
• jetstream::message::Message
• jetstream::object_store::Config
• jetstream::object_store::List
• jetstream::object_store::Object
• jetstream::object_store::ObjectInfo
• jetstream::object_store::ObjectLink
• jetstream::object_store::ObjectMeta
• jetstream::object_store::ObjectStore
• jetstream::object_store::Watch
• jetstream::publish::PublishAck
• jetstream::response::Error
• jetstream::stream::ClusterInfo
• jetstream::stream::Config
• jetstream::stream::DeleteStatus
• jetstream::stream::External
• jetstream::stream::Info
• jetstream::stream::No
• jetstream::stream::PeerInfo
• jetstream::stream::Purge
• jetstream::stream::PurgeRequest
• jetstream::stream::PurgeResponse
• jetstream::stream::RawMessage
• jetstream::stream::Republish
• jetstream::stream::Source
• jetstream::stream::State
• jetstream::stream::Stream
• jetstream::stream::Yes
• message::Message
• status::InvalidStatusCode
• status::StatusCode

Enums

• CallbackError
• ClientError
• ClientOp
• Command
• Event
• Protocol
• ServerError
• connection::State
• jetstream::consumer::AckPolicy
• jetstream::consumer::DeliverPolicy
• jetstream::consumer::ReplayPolicy
• jetstream::kv::Operation
• jetstream::message::AckKind
• jetstream::response::Response
• jetstream::stream::DiscardPolicy
• jetstream::stream::RetentionPolicy
• jetstream::stream::StorageType

Traits

• ToServerAddrs
• header::IntoHeaderName
• header::IntoHeaderValue
• jetstream::consumer::FromConsumer
• jetstream::consumer::IntoConsumerConfig
• jetstream::stream::ToAssign

Functions

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

Type Definitions

• Error
• jetstream::consumer::OrderedPushConsumer
• jetstream::consumer::PullConsumer
• jetstream::consumer::PushConsumer

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