Module stream

Stream module that contains specific interfaces for work with Redis-Stream “https://redis.io/topics/streams-intro”.

Structs

AckOptions

Set of options that are required by RedisStream::ack_entry()

EntryId

PendingOptions

Set of options that are required by RedisStream::pending_entries()

RangeEntry

Structure that wraps an range entry received on XRANGE request.

RangeOptions

Set of options that are required by RedisStream::range()

ReadExplicitOptions

Set of options that are required by RedisStream::read_explicit()

RedisGroup

Pair of group name and consumer name

RedisStream

The structure represents a Redis connection that provides interface for working with Redis Stream “https://redis.io/topics/streams-intro”.

SendEntryOptions

Set of options that are required by RedisStream::send_entry()

StreamEntry

Structure that wraps a entry received on XREAD/XREADGROUP request.

Subscribe

The Stream<Item=Vec<StreamEntry>, Error=RedisError> wrapper

SubscribeOptions

Set of options that are required by RedisStream::subscribe()

TouchGroupOptions

Set of options that are required by RedisStream::touch_group()

Enums

AckResponse

Structure that wraps a response on XACK request.

RangeType