Module stream 

Redis Streams: a stream read through a consumer group, the durable form.

• RedisStream: RedisStream, fresh entries off the tail with RedisStream::new.
• reclaim: RedisStream::reclaim, the entries another consumer fetched and never acked.
• claiming: RedisStream::claiming, pending and fresh entries in one read (Redis 8.4 and later).
• StreamStart: StreamStart, where a group starts when it is created.
• RedisPublish: Publish, XADD to a stream.
• Transactions: TransactionalPublish, the same publisher for replies committed in one MULTI / EXEC block; a cluster refuses it at startup.
• Prelude: prelude, everything a Redis Streams service imports.

Modules

prelude

The core prelude plus everything a Redis Streams service writes.

Structs

Publish

This form’s publish policy, RedisPublish, under the mount-site name every form gives its own. The declaration half of the stream publisher: pure policy, constructible anywhere.

RedisStream

Describes one Redis Streams subscription against a ConnectedRedisBroker.

TransactionalPublish

This form’s transactional publish policy, RedisTransactionalPublish, under the mount-site name: the same live publisher as Publish, refused at startup on a cluster. The stream publisher’s policy for a mount that publishes in transactions: it pairs into the same RedisPublisher as RedisPublish, and only where the topology can run one.

Enums

StreamStart

Where a freshly created consumer group starts reading from. Only consulted when the group does not yet exist; an existing group keeps its own cursor.