[−][src]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 |
StreamClaimReply | Reply type used with |
StreamId | Represents a stream |
StreamInfoConsumer | A consumer parsed from |
StreamInfoConsumersReply | Reply type used with |
StreamInfoGroup | A group parsed from |
StreamInfoGroupsReply | Reply type used with |
StreamInfoStreamReply | Reply type used with |
StreamKey | Represents a stream |
StreamPendingCountReply | Reply type used with |
StreamPendingData | Inner reply type when an [ |
StreamPendingId | Represents a pending message parsed from |
StreamRangeReply | Reply type used with |
StreamReadOptions | Builder options for |
StreamReadReply | Reply type used with |
Enums
StreamMaxlen | Utility enum for passing |
StreamPendingReply | Reply type used with |
Traits
StreamCommands | Implementation of all redis stream commands. |
Functions
client_open | Curry |