auths-telemetry 0.1.3

Telemetry and metrics for Auths components.
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

//! Telemetry sink port definition.

/// Synchronous, fire-and-forget sink for structured telemetry payloads.
///
/// Implementations are responsible for persistence, buffering, and flushing.
/// `emit()` must never block the caller; defer I/O to a background thread or
/// accumulate in memory. `flush()` blocks until all previously-emitted payloads
/// have been persisted.
///
/// Usage:
/// ```ignore
/// use auths_telemetry::ports::EventSink;
///
/// struct NullSink;
/// impl EventSink for NullSink {
///     fn emit(&self, _payload: &str) {}
///     fn flush(&self) {}
/// }
/// ```
pub trait EventSink: Send + Sync + 'static {
    /// Emit a JSON-serialized event payload. Must not block.
    fn emit(&self, payload: &str);

    /// Block until all previously-emitted payloads have been written.
    fn flush(&self);
}