nightly_async_nats::jetstream

Module stream

Source
Expand description

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

Structs§

  • Information about the stream’s, consumer’s associated JetStream cluster
  • 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.
  • Shows config and current state for this stream.
  • The members of the RAFT cluster
  • The payload used to generate a purge request.
  • The response generated by trying to purge a stream.
  • A raw stream message in the representation it is stored.
  • information about the given stream.
  • Handle to operations that can be performed on a Stream.

Enums§

  • 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.
  • RetentionPolicy determines how messages in a set are retained.
  • determines how messages are stored for retention.

Traits§