sova-rabbit 0.1.1

RabbitMQ / AMQP broker plugin for Sova (raw publish/consume + fake)
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

//! DevTools tracing (`target: "sova.rabbit"`).

use crate::error::RabbitError;

pub(crate) fn emit_publish(
    exchange: &str,
    routing_key: &str,
    bytes: u64,
    duration_ms: f64,
    result: &Result<(), RabbitError>,
) {
    let (ok, error) = match result {
        Ok(()) => (true, None),
        Err(e) => (false, Some(e.to_string())),
    };
    tracing::debug!(
        target: "sova.rabbit",
        op = "publish",
        exchange = exchange,
        routing_key = routing_key,
        bytes = bytes,
        duration_ms = duration_ms,
        ok = ok,
        error = error.as_deref(),
    );
}

pub(crate) fn emit_consume(
    queue: &str,
    bytes: Option<u64>,
    duration_ms: f64,
    result: &Result<(), RabbitError>,
    empty: bool,
) {
    let (ok, error) = match result {
        Ok(()) => (true, None),
        Err(e) => (false, Some(e.to_string())),
    };
    tracing::debug!(
        target: "sova.rabbit",
        op = "consume",
        queue = queue,
        bytes = bytes,
        duration_ms = duration_ms,
        ok = ok,
        empty = empty,
        error = error.as_deref(),
    );
}