mirror of
https://github.com/ocaml-tracing/ocaml-opentelemetry.git
synced 2026-03-08 20:07:55 -04:00
44 lines
1.4 KiB
OCaml
44 lines
1.4 KiB
OCaml
module Trace_service = Opentelemetry.Proto.Trace_service
|
|
module Metrics_service = Opentelemetry.Proto.Metrics_service
|
|
module Logs_service = Opentelemetry.Proto.Logs_service
|
|
module Span = Opentelemetry.Span
|
|
|
|
let ( let@ ) = ( @@ )
|
|
|
|
module Converter = struct
|
|
let resource_to_string ~encoder ~ctor ~enc resource =
|
|
let encoder =
|
|
match encoder with
|
|
| Some e ->
|
|
Pbrt.Encoder.reset e;
|
|
e
|
|
| None -> Pbrt.Encoder.create ()
|
|
in
|
|
let x = ctor resource in
|
|
let@ _sc = Self_trace.with_ ~kind:Span.Span_kind_internal "encode-proto" in
|
|
enc x encoder;
|
|
Pbrt.Encoder.to_string encoder
|
|
|
|
let logs ?encoder resource_logs =
|
|
resource_logs
|
|
|> resource_to_string ~encoder
|
|
~ctor:(fun r ->
|
|
Logs_service.default_export_logs_service_request ~resource_logs:r ())
|
|
~enc:Logs_service.encode_pb_export_logs_service_request
|
|
|
|
let metrics ?encoder resource_metrics =
|
|
resource_metrics
|
|
|> resource_to_string ~encoder
|
|
~ctor:(fun r ->
|
|
Metrics_service.default_export_metrics_service_request
|
|
~resource_metrics:r ())
|
|
~enc:Metrics_service.encode_pb_export_metrics_service_request
|
|
|
|
let traces ?encoder resource_spans =
|
|
resource_spans
|
|
|> resource_to_string ~encoder
|
|
~ctor:(fun r ->
|
|
Trace_service.default_export_trace_service_request ~resource_spans:r
|
|
())
|
|
~enc:Trace_service.encode_pb_export_trace_service_request
|
|
end
|