package opentelemetry

  1. Overview
  2. Docs
package opentelemetry
Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Source file trace_service_pb.ml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
[@@@ocaml.warning "-27-30-39"]

type export_trace_service_request_mutable = {
  mutable resource_spans : Trace_types.resource_spans list;
}

let default_export_trace_service_request_mutable () : export_trace_service_request_mutable = {
  resource_spans = [];
}

type export_trace_partial_success_mutable = {
  mutable rejected_spans : int64;
  mutable error_message : string;
}

let default_export_trace_partial_success_mutable () : export_trace_partial_success_mutable = {
  rejected_spans = 0L;
  error_message = "";
}

type export_trace_service_response_mutable = {
  mutable partial_success : Trace_service_types.export_trace_partial_success option;
}

let default_export_trace_service_response_mutable () : export_trace_service_response_mutable = {
  partial_success = None;
}


let rec decode_export_trace_service_request d =
  let v = default_export_trace_service_request_mutable () in
  let continue__= ref true in
  while !continue__ do
    match Pbrt.Decoder.key d with
    | None -> (
      v.resource_spans <- List.rev v.resource_spans;
    ); continue__ := false
    | Some (1, Pbrt.Bytes) -> begin
      v.resource_spans <- (Trace_pb.decode_resource_spans (Pbrt.Decoder.nested d)) :: v.resource_spans;
    end
    | Some (1, pk) -> 
      Pbrt.Decoder.unexpected_payload "Message(export_trace_service_request), field(1)" pk
    | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind
  done;
  ({
    Trace_service_types.resource_spans = v.resource_spans;
  } : Trace_service_types.export_trace_service_request)

let rec decode_export_trace_partial_success d =
  let v = default_export_trace_partial_success_mutable () in
  let continue__= ref true in
  while !continue__ do
    match Pbrt.Decoder.key d with
    | None -> (
    ); continue__ := false
    | Some (1, Pbrt.Varint) -> begin
      v.rejected_spans <- Pbrt.Decoder.int64_as_varint d;
    end
    | Some (1, pk) -> 
      Pbrt.Decoder.unexpected_payload "Message(export_trace_partial_success), field(1)" pk
    | Some (2, Pbrt.Bytes) -> begin
      v.error_message <- Pbrt.Decoder.string d;
    end
    | Some (2, pk) -> 
      Pbrt.Decoder.unexpected_payload "Message(export_trace_partial_success), field(2)" pk
    | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind
  done;
  ({
    Trace_service_types.rejected_spans = v.rejected_spans;
    Trace_service_types.error_message = v.error_message;
  } : Trace_service_types.export_trace_partial_success)

let rec decode_export_trace_service_response d =
  let v = default_export_trace_service_response_mutable () in
  let continue__= ref true in
  while !continue__ do
    match Pbrt.Decoder.key d with
    | None -> (
    ); continue__ := false
    | Some (1, Pbrt.Bytes) -> begin
      v.partial_success <- Some (decode_export_trace_partial_success (Pbrt.Decoder.nested d));
    end
    | Some (1, pk) -> 
      Pbrt.Decoder.unexpected_payload "Message(export_trace_service_response), field(1)" pk
    | Some (_, payload_kind) -> Pbrt.Decoder.skip d payload_kind
  done;
  ({
    Trace_service_types.partial_success = v.partial_success;
  } : Trace_service_types.export_trace_service_response)

let rec encode_export_trace_service_request (v:Trace_service_types.export_trace_service_request) encoder = 
  List.iter (fun x -> 
    Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; 
    Pbrt.Encoder.nested (Trace_pb.encode_resource_spans x) encoder;
  ) v.Trace_service_types.resource_spans;
  ()

let rec encode_export_trace_partial_success (v:Trace_service_types.export_trace_partial_success) encoder = 
  Pbrt.Encoder.key (1, Pbrt.Varint) encoder; 
  Pbrt.Encoder.int64_as_varint v.Trace_service_types.rejected_spans encoder;
  Pbrt.Encoder.key (2, Pbrt.Bytes) encoder; 
  Pbrt.Encoder.string v.Trace_service_types.error_message encoder;
  ()

let rec encode_export_trace_service_response (v:Trace_service_types.export_trace_service_response) encoder = 
  begin match v.Trace_service_types.partial_success with
  | Some x -> 
    Pbrt.Encoder.key (1, Pbrt.Bytes) encoder; 
    Pbrt.Encoder.nested (encode_export_trace_partial_success x) encoder;
  | None -> ();
  end;
  ()