shove 0.8.1

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

pub mod autoscaler;
pub mod backend;
pub mod client;
pub mod consumer;
pub mod consumer_group;
pub(crate) mod headers;
pub mod management;
pub mod publisher;
pub mod registry;
pub(crate) mod router;
pub mod topology;

use lapin::Error as LapinError;

use crate::error::ShoveError;

/// Maps a lapin error to the appropriate [`ShoveError`] variant using lapin's
/// own `can_be_recovered()` classification. Recoverable errors (IO, channel
/// state, heartbeat) become `Connection`; permanent errors (auth, protocol
/// version, parsing) become `Topology`.
pub(super) fn map_lapin_error(context: &str, e: LapinError) -> ShoveError {
    if e.can_be_recovered() {
        ShoveError::Connection(format!("{context}: {e}"))
    } else {
        ShoveError::Topology(format!("{context}: {e}"))
    }
}