Expand description
Redis lists: a work queue whose every entry goes to one consumer.
- Lists:
RedisList, the simple form, at-most-once. - reliable:
RedisList::reliable, at-least-once through a processing list. - Recovery:
RedisList::recovery_zset, the watchdog that returns a dead consumer’s entries. - processing:
RedisList::processing, and the hash tag a cluster needs. - Framing:
RedisList::codec, the frame the headers travel in. - RedisListPublish:
Publish,LPUSHwith an optional key expiry. - Prelude:
prelude, everything a list service imports.
Re-exports§
pub use crate::list::RedisListPublish as Publish;
Modules§
- prelude
- The core prelude, the broker, the
RedisListdescriptor and this form’sPublishpolicy. A list carries no core capability traits.
Structs§
- List
Reader - A list subscription’s reader, as a pipelined subscription holds it: the wire and the entries its last read claimed.
- Redis
List - Describes one list subscription against a
ConnectedRedisBroker. - Redis
List Message - A list-queue delivery. In simple mode
ack/nackare unsupported; in reliable modeackremoves the entry from the processing list andnackeither returns it or drops it. - Redis
List Publish - The declaration half of the list publisher: envelope codec and key TTL, no connection.
- Redis
List Publisher - Publishes onto a list with
LPUSH, so right-popping consumers see FIFO order: aRedisListPublishpolicy paired with a connection. - Redis
List Subscriber - A list-backed work-queue subscription.