rlg 0.0.9

A near-lock-free structured logging library for Rust. Sub-microsecond ingestion via a 65k-slot ring buffer (LMAX Disruptor pattern), deferred formatting, and native OS sinks (`os_log` on macOS via `syslog(3)`, `journald` on Linux). 14 output formats including JSON, MCP, OTLP, ECS, GELF, CEF, and Logfmt.
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
50
51
52
53
54
55
56
57
58
59
60
61

// macros.rs
// Copyright © 2024-2026 RustLogs (RLG). All rights reserved.
// SPDX-License-Identifier: Apache-2.0
// SPDX-License-Identifier: MIT

//! Convenience macros for span tracking, latency profiling, and MCP notifications.
//!
//! All macros dispatch through the lock-free [`ENGINE`](crate::engine::ENGINE).

/// Execute a block within an OTLP-tagged span.
///
/// Emits an OTLP log with a generated `span_id`, increments the active
/// span counter, runs `$block`, then decrements. Returns the block's value.
#[macro_export]
macro_rules! rlg_span {
    ($name:expr, $block:block) => {{
        let span_id = $crate::utils::generate_span_id();
        $crate::engine::ENGINE.inc_spans();
        $crate::log::Log::info($name)
            .with("span_id", &span_id)
            .format($crate::log_format::LogFormat::OTLP)
            .fire();
        let result = $block;
        $crate::engine::ENGINE.dec_spans();
        result
    }};
}

/// Measure wall-clock latency of a block and emit a Logfmt metric.
///
/// Captures `Instant::now()` before the block, computes elapsed
/// microseconds after, and fires a Logfmt log with `latency_us`.
#[macro_export]
macro_rules! rlg_time_it {
    ($action:expr, $block:block) => {{
        let start = std::time::Instant::now();
        let result = $block;
        let elapsed = start.elapsed().as_micros();

        $crate::log::Log::info(&format!("{} completed", $action))
            .with("latency_us", elapsed as u64)
            .format($crate::log_format::LogFormat::Logfmt)
            .fire();

        result
    }};
}

/// Emit an MCP-formatted state transition notification.
///
/// Use for AI agent orchestration where state changes must be
/// machine-readable via JSON-RPC 2.0 notification semantics.
#[macro_export]
macro_rules! rlg_mcp_notify {
    ($state_key:expr, $state_val:expr) => {
        $crate::log::Log::info("State transition")
            .with($state_key, $state_val)
            .format($crate::log_format::LogFormat::MCP)
            .fire();
    };
}