improvements in clients

after all the refactoring
This commit is contained in:
Simon Cruanes 2025-12-17 14:00:22 -05:00
parent 3c08842e2d
commit dc99897e87
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
5 changed files with 13 additions and 7 deletions

View file

@ -6,12 +6,15 @@
(pps lwt_ppx)) (pps lwt_ppx))
(libraries (libraries
(re_export opentelemetry) (re_export opentelemetry)
(re_export opentelemetry-lwt)
(re_export opentelemetry-client) (re_export opentelemetry-client)
opentelemetry-client.lwt (re_export opentelemetry-client.lwt)
(re_export lwt) (re_export lwt)
(re_export lwt.unix)
(re_export cohttp-lwt) (re_export cohttp-lwt)
(re_export cohttp-lwt-unix) (re_export cohttp-lwt-unix)
(re_export cohttp) (re_export cohttp)
(re_export unix)
uri uri
threads threads
pbrt pbrt

View file

@ -120,8 +120,8 @@ let create_exporter ?(config = Config.make ()) () =
let create_backend = create_exporter let create_backend = create_exporter
let setup_ ?config () : unit = let setup_ ?config () : unit =
let backend = create_backend ?config () in let exp = create_exporter ?config () in
Main_exporter.set backend; Main_exporter.set exp;
() ()
let setup ?config ?(enable = true) () = if enable then setup_ ?config () let setup ?config ?(enable = true) () = if enable then setup_ ?config ()

View file

@ -91,7 +91,7 @@ let create_exporter ?(config = Config.make ()) () =
let create_backend = create_exporter let create_backend = create_exporter
let setup_ ?config () : Exporter.t = let setup_ ?config () : Exporter.t =
let exp = create_backend ?config () in let exp = create_exporter ?config () in
Main_exporter.set exp; Main_exporter.set exp;
exp exp
@ -114,11 +114,11 @@ let with_setup ?(after_shutdown = ignore) ?(config = Config.make ())
Lwt.catch Lwt.catch
(fun () -> (fun () ->
let* res = f () in let* res = f () in
let+ () = remove_backend () in let+ () = remove_exporter () in
after_shutdown exp; after_shutdown exp;
res) res)
(fun exn -> (fun exn ->
let* () = remove_backend () in let* () = remove_exporter () in
after_shutdown exp; after_shutdown exp;
Lwt.reraise exn) Lwt.reraise exn)
else else

View file

@ -6,6 +6,7 @@
opentelemetry.atomic opentelemetry.atomic
(re_export opentelemetry-client) (re_export opentelemetry-client)
(re_export curl) (re_export curl)
unix
pbrt pbrt
threads threads
mtime mtime

View file

@ -4,4 +4,6 @@
(synopsis "Lwt frontend for opentelemetry") (synopsis "Lwt frontend for opentelemetry")
(preprocess (preprocess
(pps lwt_ppx)) (pps lwt_ppx))
(libraries lwt opentelemetry)) (libraries
(re_export lwt)
(re_export opentelemetry)))