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

trace-collector: Match new Trace API

Browse source
This commit is contained in:
Elliott Cable 2023-08-03 20:29:35 +00:00
parent c82cd6d798
commit de35c80799
1 changed files with 25 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
src/trace/opentelemetry_trace.ml
View file

@ -36,23 +36,26 @@ let collector () : Trace.collector =
let end_time = Otel.Timestamp_ns.now_unix_ns () in let end_time = Otel.Timestamp_ns.now_unix_ns () in
let o_span : Otel.Span.t = let o_span : Otel.Span.t =
let last_dot = String.rindex __FUNCTION__ '.' in
let module_path = String.sub __FUNCTION__ 0 last_dot in
let function_name =
String.sub __FUNCTION__ (last_dot + 1)
(String.length __FUNCTION__ - last_dot - 1)
in
let attrs = let attrs =
[ match __FUNCTION__ with
"code.filepath", `String __FILE__; | None ->
"code.lineno", `Int __LINE__; [ "code.filepath", `String __FILE__; "code.lineno", `Int __LINE__ ]
"code.function", `String function_name; | Some __FUNCTION__ ->
"code.namespace", `String module_path; let last_dot = String.rindex __FUNCTION__ '.' in
] let module_path = String.sub __FUNCTION__ 0 last_dot in
@ data let function_name =
String.sub __FUNCTION__ (last_dot + 1)
(String.length __FUNCTION__ - last_dot - 1)
in
[
"code.filepath", `String __FILE__;
"code.lineno", `Int __LINE__;
"code.function", `String function_name;
"code.namespace", `String module_path;
]
in in
Otel.Span.create ~trace_id:new_scope.trace_id ~id:span_id ~start_time Otel.Span.create ~trace_id:new_scope.trace_id ~id:span_id ~start_time
~end_time ~attrs name ~end_time ~attrs:(attrs @ data) name
|> fst |> fst
in in
@ -60,11 +63,15 @@ let collector () : Trace.collector =
rv rv
let enter_explicit_span ~surrounding:_ ?__FUNCTION__:_ ~__FILE__:_ let enter_manual_span ~parent:_ ~__FUNCTION__:_ ~__FILE__:_ ~__LINE__:_
~__LINE__:_ ~data:_ _name : Trace.explicit_span = ~data:_ _name : Trace.explicit_span =
failwith "nyi" (* TODO: print debugging warning if OTEL_OCAML_DEBUG is enabled *)
Trace.Collector.dummy_explicit_span
let exit_explicit_span _sp = failwith "nyi" let exit_manual_span es =
(* TODO: print debugging warning if OTEL_OCAML_DEBUG is enabled *)
assert (es == Trace.Collector.dummy_explicit_span);
()
let message ?span ~data:_ msg : unit = let message ?span ~data:_ msg : unit =
(* gather information from context *) (* gather information from context *)