provider.h

Go to the documentation of this file.

// Copyright 2026 The A11 Authors.
 
#ifndef A11_OBS_PROVIDER_H_
#define A11_OBS_PROVIDER_H_
 
#include <string>
#include <utility>
#include <vector>
 
#include <absl/status/status.h>
 
#include "a11/obs/span.h"
 
namespace a11::obs {
 
enum class ExporterKind {
  kNone,      
  kInMemory,  
  kOstream,   
  kOtlpHttp,
};
 
struct ProviderOptions {
  std::string service_name = "a11";  
  std::vector<std::pair<std::string, std::string>> resource_attributes;
  ExporterKind exporter = ExporterKind::kNone;
  // Simple (synchronous) processing exports each span as it ends -- convenient
  // and deterministic for tests. Batch processing is used otherwise.
  bool use_simple_processor = false;  
 
  // OTLP/HTTP options (only used when exporter == kOtlpHttp).
  std::string otlp_endpoint;  
  std::vector<std::pair<std::string, std::string>> otlp_headers;
  int otlp_timeout_millis = 10000;  
 
  // Baggage keys promoted onto every span as attributes (of the same name).
  // This is how request-scoped values set upstream via the x-otel-baggage
  // header -- e.g. langfuse.session.id -- become span attributes that a
  // backend can read, while still propagating across nested/remote actions.
  std::vector<std::string> baggage_span_attributes;
};
 
absl::Status Configure(const ProviderOptions& options);
 
void Shutdown();
 
[[nodiscard]] bool IsConfigured();
 
// --- Introspection (meaningful only with ExporterKind::kInMemory) ---------
 
struct RecordedEvent {
  std::string name;  
  std::vector<std::pair<std::string, std::string>>
      attributes;  
};
 
struct RecordedSpan {
  std::string name;            
  std::string trace_id;        
  std::string span_id;         
  std::string parent_span_id;  
  SpanKind kind = SpanKind::kInternal;  
  int status_code = 0;             
  std::string status_description;  
  std::vector<std::pair<std::string, std::string>>
      attributes;                     
  std::vector<RecordedEvent> events;  
};
 
std::vector<RecordedSpan> GetRecordedSpans();
 
void ClearRecordedSpans();
 
}  // namespace a11::obs
 
#endif  // A11_OBS_PROVIDER_H_