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

clients: setup self-debug as well

Browse source
This commit is contained in:
Simon Cruanes 2026-03-03 17:16:04 -05:00
parent f1f379d2e1
commit d86b883c70
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
4 changed files with 35 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/client-cohttp-eio/opentelemetry_client_cohttp_eio.ml
View file

@ -178,10 +178,14 @@ let create_backend = create_exporter
let setup_ ~sw ~config env : unit = let setup_ ~sw ~config env : unit =
Opentelemetry_ambient_context.set_current_storage Ambient_context_eio.storage; Opentelemetry_ambient_context.set_current_storage Ambient_context_eio.storage;
let exp = create_exporter ~config ~sw ~env () in let exp = create_exporter ~config ~sw ~env () in
Sdk.set ?batch_traces:config.batch_traces ?batch_metrics:config.batch_metrics Sdk.set ~traces:config.traces ~metrics:config.metrics ~logs:config.logs exp;
?batch_logs:config.batch_logs
~batch_timeout:Mtime.Span.(config.batch_timeout_ms * ms) Option.iter
exp (fun min_level -> Opentelemetry.Self_debug.to_stderr ~min_level ())
config.log_level;
Opentelemetry.Self_debug.log Opentelemetry.Self_debug.Info (fun () ->
"opentelemetry: cohttp-eio exporter installed")
let setup ?(config = Config.make ()) ?(enable = true) ~sw env = let setup ?(config = Config.make ()) ?(enable = true) ~sw env =
if enable && not config.sdk_disabled then setup_ ~sw ~config env if enable && not config.sdk_disabled then setup_ ~sw ~config env

13
src/client-cohttp-lwt/opentelemetry_client_cohttp_lwt.ml
View file

@ -111,10 +111,15 @@ let create_backend = create_exporter
let setup_ ~config () : unit = let setup_ ~config () : unit =
Opentelemetry_client_lwt.Util_ambient_context.setup_ambient_context (); Opentelemetry_client_lwt.Util_ambient_context.setup_ambient_context ();
let exp = create_exporter ~config () in let exp = create_exporter ~config () in
Sdk.set ?batch_traces:config.batch_traces ?batch_metrics:config.batch_metrics Sdk.set ~traces:config.traces ~metrics:config.metrics ~logs:config.logs exp;
?batch_logs:config.batch_logs
~batch_timeout:Mtime.Span.(config.batch_timeout_ms * ms) Option.iter
exp; (fun min_level -> Opentelemetry.Self_debug.to_stderr ~min_level ())
config.log_level;
Opentelemetry.Self_debug.log Opentelemetry.Self_debug.Info (fun () ->
"opentelemetry: cohttp-lwt exporter installed");
() ()
let setup ?(config = Config.make ()) ?(enable = true) () = let setup ?(config = Config.make ()) ?(enable = true) () =

13
src/client-ocurl-lwt/opentelemetry_client_ocurl_lwt.ml
View file

@ -86,10 +86,15 @@ let create_backend = create_exporter
let setup_ ~config () : Exporter.t = let setup_ ~config () : Exporter.t =
Opentelemetry_client_lwt.Util_ambient_context.setup_ambient_context (); Opentelemetry_client_lwt.Util_ambient_context.setup_ambient_context ();
let exp = create_exporter ~config () in let exp = create_exporter ~config () in
Sdk.set ?batch_traces:config.batch_traces ?batch_metrics:config.batch_metrics Sdk.set ~traces:config.traces ~metrics:config.metrics ~logs:config.logs exp;
?batch_logs:config.batch_logs
~batch_timeout:Mtime.Span.(config.batch_timeout_ms * ms) Option.iter
exp; (fun min_level -> Opentelemetry.Self_debug.to_stderr ~min_level ())
config.log_level;
Opentelemetry.Self_debug.log Opentelemetry.Self_debug.Info (fun () ->
"opentelemetry: ocurl-lwt exporter installed");
exp exp
let setup ?(config = Config.make ()) ?(enable = true) () = let setup ?(config = Config.make ()) ?(enable = true) () =

14
src/client-ocurl/opentelemetry_client_ocurl.ml
View file

@ -89,11 +89,15 @@ let create_backend = create_exporter
let setup_ ~config () : OTEL.Exporter.t = let setup_ ~config () : OTEL.Exporter.t =
let exporter = create_exporter ~config () in let exporter = create_exporter ~config () in
OTEL.Sdk.set ?batch_traces:config.common.batch_traces OTEL.Sdk.set ~traces:config.common.traces ~metrics:config.common.metrics
?batch_metrics:config.common.batch_metrics ~logs:config.common.logs exporter;
?batch_logs:config.common.batch_logs
~batch_timeout:Mtime.Span.(config.common.batch_timeout_ms * ms) Option.iter
exporter; (fun min_level -> OTEL.Self_debug.to_stderr ~min_level ())
config.common.log_level;
OTEL.Self_debug.log OTEL.Self_debug.Info (fun () ->
"opentelemetry: ocurl exporter installed");
OTELC.Self_trace.set_enabled config.common.self_trace; OTELC.Self_trace.set_enabled config.common.self_trace;
exporter exporter