Module async_nats::jetstream::consumer
source · [−]Expand description
Push and Pull Consumer API.
Modules
Structs
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.
Information about a consumer
Information about a consumer and the stream it is consuming
Enums
Determines whether messages will be acknowledged individually, in batches, or never.
DeliverPolicy determines how the consumer should select the first message to deliver.
ReplayPolicy controls whether messages are sent to a consumer
as quickly as possible or at the rate that they were originally received at.
Traits
Trait used to convert generic Stream Config into either Pull or Push config. It validates if given config is a valid target one.