#agent-telemetry

#Design Layers

• Thin wrapper (lib.mbt): provider initialization, tracer cache, span lifecycle helpers such as start_span / end_span.
• Semantic wrapper (genai.mbt, tool.mbt, agent.mbt): sets attributes according to the OpenTelemetry GenAI semantic conventions, covering chat, tool execution, and agent turn spans.

#Quick Start

moon add cybershang/agent-telemetry

// Option 1: one-line initialization from environment variables.
// Reads OTEL_SERVICE_NAME, OTEL_STDOUT, and OTEL_EXPORTER_OTLP_ENDPOINT.
// Use ProcessUniqueRandom to avoid duplicate trace/span IDs across restarts.
let provider = @telemetry.init_from_env(
  id_generator=@telemetry.ProcessUniqueRandom,
)

// Option 2: manually select an exporter.
let config = @telemetry.TelemetryConfig::new(service_name="my-agent")
let provider = @telemetry.init_telemetry(
  config,
  @telemetry.Otlp("http://localhost:4318"),
  id_generator=@telemetry.ProcessUniqueRandom,
)

// Create a GenAI chat span.
let tracer = @telemetry.tracer("my-agent/llm")
let span = @telemetry.start_chat_span(
  tracer,
  provider_name="stepfun",
  model="step-3.7-flash",
  max_tokens=1024,
)
// ... send the request and obtain response_json ...
@telemetry.record_chat_response(span, response_json)
@telemetry.end_span_ok(span)

#Main API

#Environment Variables

#Flushing and Shutting Down

fn format_error(err : @error.OTelSdkError) -> String {
  match err {
    AlreadyShutdown => "AlreadyShutdown"
    Timeout(ms) => "Timeout(\{ms}ms)"
    InvalidArgument(msg) => "InvalidArgument(\{msg})"
    InternalFailure(msg) => "InternalFailure(\{msg})"
    ExportFailure(name, msg) => "ExportFailure(\{name}, \{msg})"
  }
}

match provider.force_flush() {
  Ok(_) => ()
  Err(err) => @stdio.stdout.write("Telemetry flush failed: " + format_error(err) + "\n")
}

match provider.shutdown() {
  Ok(_) => ()
  Err(err) => @stdio.stdout.write("Telemetry shutdown failed: " + format_error(err) + "\n")
}

#ID Generator Option

#Target Backend

#Example Project

#Testing

moon test -p cybershang/agent-telemetry --target native

#License