feat integration/logs: update paths

This commit is contained in:
Simon Cruanes 2025-12-03 13:29:12 -05:00
parent 8692976f3e
commit d5436d953f
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4

View file

@ -11,13 +11,13 @@ module Otel = Opentelemetry
(* Levels *) (* Levels *)
(*****************************************************************************) (*****************************************************************************)
(* Convert log level to Otel severity *) (* Convert log level to Otel severity *)
let log_level_to_severity (level : Logs.level) : Otel.Logs.severity = let log_level_to_severity (level : Logs.level) : Otel.Log_record.severity =
match level with match level with
| Logs.App -> Otel.Logs.Severity_number_info (* like info, but less severe *) | Logs.App -> Severity_number_info (* like info, but less severe *)
| Logs.Info -> Otel.Logs.Severity_number_info2 | Logs.Info -> Severity_number_info2
| Logs.Error -> Otel.Logs.Severity_number_error | Logs.Error -> Severity_number_error
| Logs.Warning -> Otel.Logs.Severity_number_warn | Logs.Warning -> Severity_number_warn
| Logs.Debug -> Otel.Logs.Severity_number_debug | Logs.Debug -> Severity_number_debug
(*****************************************************************************) (*****************************************************************************)
(* Logs Util *) (* Logs Util *)
@ -44,9 +44,12 @@ let log ?service_name ?(attrs = []) ?(scope = Otel.Scope.get_ambient_scope ())
Option.map (fun (scope : Otel.Scope.t) -> scope.trace_id) scope Option.map (fun (scope : Otel.Scope.t) -> scope.trace_id) scope
in in
let severity = log_level_to_severity level in let severity = log_level_to_severity level in
let log = Otel.Logs.make_str ~severity ~log_level ?trace_id ?span_id msg in let log =
Otel.Log_record.make_str ~severity ~log_level ?trace_id ?span_id msg
in
(* Noop if no backend is set *) (* Noop if no backend is set *)
Otel.Logs.emit ?service_name ~attrs [ log ] (* TODO: be more explicit *)
Otel.Logger.emit ?service_name ~attrs [ log ]
let otel_reporter ?service_name ?(attributes = []) () : Logs.reporter = let otel_reporter ?service_name ?(attributes = []) () : Logs.reporter =
let report src level ~over k msgf = let report src level ~over k msgf =