light-telemetry 0.1.2

LightTelemetry ingest daemon
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

//! Canonical telemetry event type shared by ingest, bus, storage, and APIs.

use serde::{Deserialize, Serialize};
use serde_json::Value;
use std::time::{SystemTime, UNIX_EPOCH};

/// One telemetry event on the wire and inside the daemon.
///
/// `ts` is the client-side creation timestamp. `ingress_ts` is stamped by the
/// server at reception and is the only timestamp used for wait matching.
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct TelemetryEvent {
    /// Logical event channel (e.g. `logger`, `db.query`).
    pub topic: String,
    /// Unique source/instance identifier.
    pub id: String,
    /// Source classifier or entity group (e.g. `backend`, `kernel`).
    pub class: String,
    /// Client-side creation timestamp, microseconds since UNIX epoch.
    pub ts: u64,
    /// Structured attributes carried by the event.
    #[serde(default)]
    pub payload: Value,
    /// Server-side reception timestamp, microseconds since UNIX epoch.
    #[serde(skip_deserializing)]
    pub ingress_ts: u64,
}

/// Current UNIX epoch time in microseconds.
pub fn now_micros() -> u64 {
    SystemTime::now()
        .duration_since(UNIX_EPOCH)
        .unwrap_or_default()
        .as_micros() as u64
}