gsm-telemetry 0.4.2

Tracing and OpenTelemetry configuration helpers for Greentic messaging services.
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

#[derive(Debug, Clone)]
pub struct TelemetryLabels {
    pub tenant: String,
    pub platform: Option<String>,
    pub chat_id: Option<String>,
    pub msg_id: Option<String>,
    pub extra: Vec<(String, String)>,
}

impl TelemetryLabels {
    pub fn new(tenant: impl Into<String>) -> Self {
        Self {
            tenant: tenant.into(),
            platform: None,
            chat_id: None,
            msg_id: None,
            extra: Vec::new(),
        }
    }

    pub fn tags(&self) -> Vec<(&str, String)> {
        let mut tags = Vec::with_capacity(4);
        tags.push(("tenant", self.tenant.clone()));
        if let Some(p) = &self.platform {
            tags.push(("platform", p.clone()));
        }
        if let Some(chat) = &self.chat_id {
            tags.push(("chat_id", chat.clone()));
        }
        if let Some(msg) = &self.msg_id {
            tags.push(("msg_id", msg.clone()));
        }
        for (key, value) in &self.extra {
            tags.push((key.as_str(), value.clone()));
        }
        tags
    }
}

#[derive(Debug, Clone)]
pub struct MessageContext {
    pub labels: TelemetryLabels,
}

impl MessageContext {
    pub fn new(labels: TelemetryLabels) -> Self {
        Self { labels }
    }
}