Module 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