Module tempest_source_redis::prelude

Structs

RedisStreamPendingHandler	Redis streams require additional work for cleaning up pending (unacknowledged) messages. RedisStreamPendingHandler configures actions for handling pending messages after some length of time or number of times a message was previously delivered.
RedisStreamSource	The main data structure for interacting with Redis Streams. This controls reading and acking messages, actions for dealing with pending messages, and group creation.
RedisStreamSourceBuilder	Source builder for constructing RedisStreamSource instances

Enums

RedisStreamGroupStartingId	Enum for defining where group consumers should start reading messages from.
RedisStreamPendingAction	This enum provides an action for how to deal with pending messages.
RedisStreamPrime	Enum for holding messages for RedisStreamSource testing See RedisStreamSourceBuilder#prime for more details.