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

simplify

Browse source
This commit is contained in:
Simon Cruanes 2024-10-16 13:29:39 -04:00
parent 276ba2efd1
commit 020de6887a
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
2 changed files with 2 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -569,11 +569,7 @@ let setup_ ?stop ?config () =
let backend = create_backend ?stop ?config () in let backend = create_backend ?stop ?config () in
let (module B : OT.Collector.BACKEND) = backend in let (module B : OT.Collector.BACKEND) = backend in
OT.Collector.set_backend backend; OT.Collector.set_backend backend;
let cleanup () = OT.Collector.remove_backend
B.tick ();
B.cleanup ()
in
cleanup
let setup ?stop ?config ?(enable = true) () = let setup ?stop ?config ?(enable = true) () =
if enable then ( if enable then (

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

@ -508,12 +508,7 @@ let setup_ ?(stop = Atomic.make false) ?(config : Config.t = Config.make ()) ()
let sleep_ms = min 60_000 (max 2 config.ticker_interval_ms) in let sleep_ms = min 60_000 (max 2 config.ticker_interval_ms) in
ignore (setup_ticker_thread ~stop ~sleep_ms backend () : Thread.t) ignore (setup_ticker_thread ~stop ~sleep_ms backend () : Thread.t)
); );
OT.Collector.remove_backend
let cleanup () =
B.tick ();
B.cleanup ()
in
cleanup
let setup ?stop ?config ?(enable = true) () = let setup ?stop ?config ?(enable = true) () =
if enable then ( if enable then (