redis_asio/stream/
mod.rs

1//! Stream module that contains specific interfaces
2//! for work with Redis-Stream "https://redis.io/topics/streams-intro".
3
4mod entry;
5mod stream;
6mod produce;
7mod consume;
8mod manage;
9
10pub use entry::{StreamEntry, EntryId, RangeEntry, RangeType};
11pub use stream::RedisStream;
12pub use produce::SendEntryOptions;
13pub use consume::{SubscribeOptions, ReadExplicitOptions, RangeOptions, RedisGroup, Subscribe};
14pub use manage::{AckOptions, PendingOptions, TouchGroupOptions, AckResponse};
15
16use entry::{parse_stream_entries, parse_range_entries};
17use produce::add_command;
18use consume::{subscribe, subscribe_cmd, read_explicit_cmd, range_cmd};
19use manage::{ack_entry_command, pending_list_command, touch_group_command};