chasquimq 1.0.0

The fastest open-source message broker for Redis. Rust-native engine on Redis Streams + MessagePack, with Node.js and Python bindings.
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

pub mod ack;
pub mod config;
pub mod consumer;
pub mod error;
pub(crate) mod events;
pub mod job;
pub mod metrics;
pub mod producer;
pub mod promoter;
pub(crate) mod redis;
pub mod repeat;
pub mod scheduler;

pub use bytes::Bytes;
pub use config::{ConsumerConfig, ProducerConfig, PromoterConfig, RetryConfig, SchedulerConfig};
pub use consumer::Consumer;
pub use error::{Error, HandlerError, Result};
pub use job::{BackoffKind, BackoffSpec, Job, JobId, JobRetryOverride};
pub use metrics::{
    DlqReason, DlqRouted, JobOutcome, JobOutcomeKind, LockOutcome, MetricsSink, NoopSink,
    PromoterTick, ReaderBatch, RetryScheduled, noop_sink,
};
pub use producer::{DlqEntry, Producer};
pub use promoter::Promoter;
pub use repeat::{MissedFiresPolicy, RepeatPattern, RepeatableMeta, RepeatableSpec};
pub use scheduler::Scheduler;