Module async_nats::jetstream::consumer

Push and Pull Consumer API.

Modules

• pull
• push

Structs

• Config
  Configuration for consumers. From a high level, the durable_name and deliver_subject fields have a particularly strong influence on the consumer’s overall behavior.
• Consumer
• Info
  Information about a consumer
• SequenceInfo
  Information about a consumer and the stream it is consuming

Enums

• AckPolicy
  Determines whether messages will be acknowledged individually, in batches, or never.
• DeliverPolicy
  DeliverPolicy determines how the consumer should select the first message to deliver.
• ReplayPolicy
  ReplayPolicy controls whether messages are sent to a consumer as quickly as possible or at the rate that they were originally received at.
• StreamErrorKind

Traits

• FromConsumer
  Trait used to convert generic Stream Config into either Pull or Push config. It validates if given config is a valid target one.
• IntoConsumerConfig

Type Aliases

• OrderedPullConsumer
• OrderedPushConsumer
• PullConsumer
• PushConsumer
• StreamError