Module context

Module context 

Source
Expand description

Manage operations on Context, create/delete/update Stream

Modules§

traits

Structs§

Context
A context which can perform jetstream scoped requests.
ContextBuilder
A builder for Context. Beyond what can be set by standard constructor, it allows tweaking pending publish ack backpressure settings.
No
PublishAckFuture
StreamNames
Streams
Yes

Enums§

AccountErrorKind
ConsumerInfoErrorKind
CreateKeyValueErrorKind
CreateStreamErrorKind
GetStreamByNameErrorKind
GetStreamErrorKind
KeyValueErrorKind
ObjectStoreErrorKind
PublishErrorKind
RequestErrorKind
UpdateKeyValueErrorKind

Traits§

ToAssign

Type Aliases§

AccountError
ConsumerInfoError
CreateKeyValueError
CreateObjectStoreError
CreateObjectStoreErrorKind
CreateStreamError
DeleteObjectStore
DeleteObjectStoreKind
DeleteStreamError
DeleteStreamErrorKind
GetStreamByNameError
GetStreamError
KeyValueError
ObjectStoreError
PublishDeprecated
Alias to avoid breaking changes. Please use jetstream::message::PublishMessage instead.
PublishError
RequestError
StreamsError
StreamsErrorKind
UpdateKeyValueError
UpdateStreamError
UpdateStreamErrorKind