Crate redis_streams

redis-streams-rs exposes the Redis Stream functionality as a Trait on top of redis-rs.

The crate is called redis_streams.

In order to you use this crate, you’ll first want to add it as a github dependency (until I have a chance to publish on crates.io).

[dependencies.redis_streams]
git = "https://github.com/grippy/redis-streams-rs.git"

From here, just unlock the streaming commands prior to instantiating client connections.

use redis_streams::{client_open,Connection,StreamCommands};
let client = client_open("redis://127.0.0.1/0").unwrap();
let mut con = client.get_connection().unwrap();

This crate also exposes all top-level redis-rs types. To pick up all redis-rs Commands, just use the Commands trait.

use redis_streams::{Commands};

Structs

StreamClaimOptions

Builder options for xclaim_options command.

StreamClaimReply

Reply type used with xclaim command.

StreamId

Represents a stream id and its field/values as a HashMap

StreamInfoConsumer

A consumer parsed from xinfo_consumers command.

StreamInfoConsumersReply

Reply type used with xinfo_consumer command.

StreamInfoGroup

A group parsed from xinfo_groups command.

StreamInfoGroupsReply

Reply type used with xinfo_groups command.

StreamInfoStreamReply

Reply type used with xinfo_stream command.

StreamKey

Represents a stream key and its id’s parsed from xread methods.

StreamPendingCountReply

Reply type used with xpending_count and xpending_consumer_count commands.

StreamPendingData

Inner reply type when an [xpending] command has data.

StreamPendingId

Represents a pending message parsed from xpending methods.

StreamRangeReply

Reply type used with xrange, xrange_count, xrange_all, xrevrange, xrevrange_count, xrevrange_all commands.

StreamReadOptions

Builder options for xread_options command.

StreamReadReply

Reply type used with xread or xread_options commands.

Enums

StreamMaxlen

Utility enum for passing MAXLEN [= or ~] [COUNT] arguments into StreamCommands. The enum value represents the count.

StreamPendingReply

Reply type used with xpending command.

Traits

StreamCommands

Implementation of all redis stream commands.

Functions

client_open

Curry redis::Client::open calls.