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.