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.