Module async_nats::jetstream::stream

Manage operations on a Stream, create/delete/update Consumer.

Structs

• ClusterInfo
  Information about the stream’s, consumer’s associated JetStream cluster
• Config
  StreamConfig determines the properties for a stream. There are sensible defaults for most. If no subjects are given the name will be used as the only subject.
• ConsumerError
• ConsumerNames
• Consumers
• DeleteMessageError
• DeleteStatus
• DirectGetError
• External
• Info
  Shows config and current state for this stream.
• LastRawMessageError
• No
• PeerInfo
  The members of the RAFT cluster
• Purge
• PurgeError
• PurgeRequest
  The payload used to generate a purge request.
• PurgeResponse
  The response generated by trying to purge a stream.
• RawMessage
  A raw stream message in the representation it is stored.
• Republish
• Source
• State
  information about the given stream.
• Stream
  Handle to operations that can be performed on a Stream.
• SubjectTransform
• Yes

Enums

• ConsumerErrorKind
• DeleteMessageErrorKind
• DirectGetErrorKind
• DiscardPolicy
  DiscardPolicy determines how we proceed when limits of messages or bytes are hit. The default, Old will remove older messages. New will fail to store the new message.
• LastRawMessageErrorKind
• PurgeErrorKind
• RetentionPolicy
  RetentionPolicy determines how messages in a set are retained.
• StorageType
  determines how messages are stored for retention.

Traits

• ToAssign

Type Definitions

• ConsumersError
• InfoError