simon/ocaml-opentelemetry
1
0
Fork 0
mirror of https://github.com/ocaml-tracing/ocaml-opentelemetry.git synced 2026-03-08 20:07:55 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

use Extensions module in opentelemetry.trace

Browse source
This commit is contained in:
Simon Cruanes 2026-02-23 13:35:03 -05:00
parent 3608c218bf
commit e33a792f46
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
2 changed files with 42 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
src/trace/opentelemetry_trace.ml
View file

@ -6,19 +6,30 @@ module Well_known = struct end
let on_internal_error = let on_internal_error =
ref (fun msg -> Printf.eprintf "error in Opentelemetry_trace: %s\n%!" msg) ref (fun msg -> Printf.eprintf "error in Opentelemetry_trace: %s\n%!" msg)
type span_info = { module Extensions = struct
type span_info = {
start_time: int64; start_time: int64;
name: string; name: string;
scope: Otel.Scope.t; scope: Otel.Scope.t;
parent: Otel.Span_ctx.t option; parent: Otel.Span_ctx.t option;
} }
type Trace.span += Span_otel of span_info let scope_of_span_info s = s.scope
type Trace.extension_event += type Trace.span += Span_otel of span_info
type Trace.extension_event +=
| Ev_link_span of Trace.span * Trace.span | Ev_link_span of Trace.span * Trace.span
| Ev_set_span_kind of Trace.span * Otel.Span_kind.t
| Ev_record_exn of Trace.span * exn * Printexc.raw_backtrace | Ev_record_exn of Trace.span * exn * Printexc.raw_backtrace
| Ev_set_span_kind of Trace.span * Otel.Span_kind.t
type Trace.metric +=
| Metric_hist of Opentelemetry_proto.Metrics.histogram_data_point
| Metric_sum_int of int
| Metric_sum_float of float
end
open Extensions
module Internal = struct module Internal = struct
let enter_span' ?(parent_span : Trace.span option) ~__FUNCTION__ ~__FILE__ let enter_span' ?(parent_span : Trace.span option) ~__FUNCTION__ ~__FILE__

20
src/trace/opentelemetry_trace.mli
View file

@ -19,13 +19,27 @@
module Otel := Opentelemetry module Otel := Opentelemetry
module Otrace := Trace_core module Otrace := Trace_core
type Otrace.extension_event += module Extensions : sig
type span_info
val scope_of_span_info : span_info -> Otel.Scope.t
type Otrace.span += Span_otel of span_info
type Otrace.extension_event +=
| Ev_link_span of Otrace.span * Otrace.span | Ev_link_span of Otrace.span * Otrace.span
(** Link the two spans together. Both must be currently active spans. *) (** Link the two spans together. Both must be currently active spans.
| Ev_set_span_kind of Otrace.span * Otel.Span_kind.t *)
| Ev_record_exn of Otrace.span * exn * Printexc.raw_backtrace | Ev_record_exn of Otrace.span * exn * Printexc.raw_backtrace
| Ev_set_span_kind of Otrace.span * Otel.Span_kind.t
(** Record exception and potentially turn span to an error *) (** Record exception and potentially turn span to an error *)
type Otrace.metric +=
| Metric_hist of Opentelemetry_proto.Metrics.histogram_data_point
| Metric_sum_int of int
| Metric_sum_float of float
end
val on_internal_error : (string -> unit) ref val on_internal_error : (string -> unit) ref
(** Callback to print errors in the library itself (ie bugs) *) (** Callback to print errors in the library itself (ie bugs) *)