Struct TraceContext 

pub struct TraceContext {
    pub trace_id: String,
    pub span_id: String,
    pub trace_flags: String,
    pub trace_state: Option<String>,
}

W3C Trace Context for distributed tracing

Compatible with OpenTelemetry, Jaeger, Zipkin, and other distributed tracing systems. See: https://www.w3.org/TR/trace-context/

Example

use celers_broker_sql::{MysqlBroker, TraceContext};
use celers_core::{Broker, SerializedTask};

// Create a trace context
let trace_ctx = TraceContext::new(
    "4bf92f3577b34da6a3ce929d0e0e4736",
    "00f067aa0ba902b7"
);

// Enqueue task with trace context
let task = SerializedTask::new("my_task".to_string(), vec![]);
broker.enqueue_with_trace_context(task, trace_ctx).await?;

// Extract trace context when processing
if let Some(msg) = broker.dequeue().await? {
    if let Some(ctx) = broker.extract_trace_context(&msg.task.metadata.id).await? {
        println!("Processing task with trace_id: {}", ctx.trace_id);
    }
}

Fields

trace_id: String

W3C Trace ID (32 hex characters, 16 bytes)

span_id: String

W3C Span ID (16 hex characters, 8 bytes)

trace_flags: String

Trace flags (8-bit field, typically “01” for sampled)

trace_state: Option<String>

Optional trace state for vendor-specific data

Implementations

impl TraceContext

pub fn new(trace_id: impl Into<String>, span_id: impl Into<String>) -> Self

Create a new trace context with trace_id and span_id

Arguments

• trace_id - 32 hex character trace ID (W3C format)
• span_id - 16 hex character span ID (W3C format)

Example

use celers_broker_sql::TraceContext;

let ctx = TraceContext::new(
    "4bf92f3577b34da6a3ce929d0e0e4736",
    "00f067aa0ba902b7"
);
assert_eq!(ctx.trace_flags, "01"); // Sampled by default

pub fn from_traceparent(traceparent: &str) -> Result<Self>

Create trace context from W3C traceparent header value

Format: “00-{trace_id}-{span_id}-{flags}”

Example

use celers_broker_sql::TraceContext;

let ctx = TraceContext::from_traceparent(
    "00-4bf92f3577b34da6a3ce929d0e0e4736-00f067aa0ba902b7-01"
).unwrap();
assert_eq!(ctx.trace_id, "4bf92f3577b34da6a3ce929d0e0e4736");
assert_eq!(ctx.span_id, "00f067aa0ba902b7");

pub fn to_traceparent(&self) -> String

Convert to W3C traceparent header value

Example

use celers_broker_sql::TraceContext;

let ctx = TraceContext::new(
    "4bf92f3577b34da6a3ce929d0e0e4736",
    "00f067aa0ba902b7"
);
assert_eq!(
    ctx.to_traceparent(),
    "00-4bf92f3577b34da6a3ce929d0e0e4736-00f067aa0ba902b7-01"
);

pub fn is_sampled(&self) -> bool

Check if trace is sampled (should be recorded)

pub fn create_child_span(&self) -> Self

Generate a new child span ID for this trace

Example

use celers_broker_sql::TraceContext;

let parent_ctx = TraceContext::new(
    "4bf92f3577b34da6a3ce929d0e0e4736",
    "00f067aa0ba902b7"
);
let child_ctx = parent_ctx.create_child_span();

// Same trace ID, different span ID
assert_eq!(child_ctx.trace_id, parent_ctx.trace_id);
assert_ne!(child_ctx.span_id, parent_ctx.span_id);

Trait Implementations

impl Clone for TraceContext

fn clone(&self) -> TraceContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TraceContext

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TraceContext

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for TraceContext

fn eq(&self, other: &TraceContext) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for TraceContext

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for TraceContext

impl StructuralPartialEq for TraceContext