shove 0.11.5

Async tasks via pubsub on steroids. Comes with built-in support for complex queue configurations, audit logs, autoscaling consumer groups and more.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

//! Internal Redis Streams backend implementation.
//! Public surface lives in [`crate::redis`].

#![allow(unused_imports)] // Re-exports are consumed by tasks added in subsequent PRs.

mod autoscaler;
mod backend;
pub(super) mod client;
pub(super) mod constants;
mod consumer;
mod consumer_group;
mod maintenance;
mod publisher;
mod reaper;
mod requeue;
mod stream_id;
mod topology;

pub use autoscaler::{
    RedisAutoscalerBackend, RedisQueueStats, RedisQueueStatsProvider, XlenStatsProvider,
};
pub use client::{RedisClient, RedisConfig, RedisMode};
pub use consumer::RedisConsumer;
pub use consumer_group::{
    RedisConsumerGroup, RedisConsumerGroupConfig, RedisConsumerGroupRegistry,
};
pub use publisher::{RedisPublisher, shard_for_key};
#[doc(hidden)]
pub use reaper::{spawn_maintenance, spawn_reaper};
pub(crate) use requeue::{HoldEntry, enqueue_hold, spawn_requeuer};
pub use topology::RedisTopologyDeclarer;