inferadb 0.1.5

Official Rust SDK for InferaDB
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

//! Tracing integration for observability.
//!
//! This module provides integration with the `tracing` ecosystem
//! for structured logging and distributed tracing.
//!
//! ## Features
//!
//! - Request/response logging
//! - Span propagation (W3C Trace Context)
//! - OpenTelemetry integration
//! - Metrics collection
//!
//! ## Example
//!
//! ```rust,ignore
//! use tracing_subscriber::prelude::*;
//! use inferadb::tracing_support::TraceContext;
//!
//! // Set up tracing subscriber
//! tracing_subscriber::registry()
//!     .with(tracing_subscriber::fmt::layer())
//!     .init();
//!
//! // Propagate trace context from incoming request
//! let trace_ctx = TraceContext::from_headers(&headers)?;
//!
//! // SDK automatically creates spans for operations
//! let allowed = vault.check("user:alice", "view", "doc:1")
//!     .with_trace_context(trace_ctx)
//!     .await?;
//! ```

// Allow dead code for tracing types not yet integrated
#![allow(dead_code)]

mod context;
mod metrics;
mod propagator;
mod span;

pub use context::{SpanId, TraceContext, TraceFlags, TraceId};
pub use metrics::{Counter, Gauge, Histogram, Metrics, MetricsConfig};
pub use propagator::{B3Propagator, HeaderExtractor, HeaderInjector, Propagator, W3CTraceContext};
pub use span::{InferaDbSpan, SpanKind, SpanStatus};

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_trace_context_roundtrip() {
        let ctx = TraceContext::new_root();
        let header = ctx.to_traceparent();
        let parsed = TraceContext::from_traceparent(&header).unwrap();
        assert_eq!(parsed.trace_id(), ctx.trace_id());
    }
}