Skip to content

Commit 8ec5b90

Browse files
committed
Add mlis for observer_helpers and observer_skeleton
Signed-off-by: Steven Woods <[email protected]>
1 parent 80bd494 commit 8ec5b90

File tree

3 files changed

+238
-1
lines changed

3 files changed

+238
-1
lines changed
Lines changed: 194 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,194 @@
1+
val queue_name : string
2+
3+
val default_path : string
4+
5+
module Errors : sig
6+
type error =
7+
| Internal_error of string
8+
| Unimplemented of string
9+
| Unknown_error
10+
11+
val typ_of_error : error Rpc.Types.typ
12+
13+
val error : error Rpc.Types.def
14+
end
15+
16+
exception Observer_error of Errors.error
17+
18+
type debug_info = string
19+
20+
module ObserverAPI : functor (R : Idl.RPC) -> sig
21+
val description : Idl.Interface.description
22+
23+
val implementation : R.implementation
24+
25+
val create :
26+
( debug_info
27+
-> string
28+
-> string
29+
-> (string * string) list
30+
-> string list
31+
-> bool
32+
-> (unit, Errors.error) R.comp
33+
)
34+
R.res
35+
36+
val destroy : (debug_info -> string -> (unit, Errors.error) R.comp) R.res
37+
38+
val set_enabled :
39+
(debug_info -> string -> bool -> (unit, Errors.error) R.comp) R.res
40+
41+
val set_attributes :
42+
( debug_info
43+
-> string
44+
-> (string * string) list
45+
-> (unit, Errors.error) R.comp
46+
)
47+
R.res
48+
49+
val set_endpoints :
50+
(debug_info -> string -> string list -> (unit, Errors.error) R.comp) R.res
51+
52+
val init : (debug_info -> (unit, Errors.error) R.comp) R.res
53+
54+
val set_trace_log_dir :
55+
(debug_info -> string -> (unit, Errors.error) R.comp) R.res
56+
57+
val set_export_interval :
58+
(debug_info -> float -> (unit, Errors.error) R.comp) R.res
59+
60+
val set_max_spans : (debug_info -> int -> (unit, Errors.error) R.comp) R.res
61+
62+
val set_max_traces : (debug_info -> int -> (unit, Errors.error) R.comp) R.res
63+
64+
val set_max_file_size :
65+
(debug_info -> int -> (unit, Errors.error) R.comp) R.res
66+
67+
val set_host_id : (debug_info -> string -> (unit, Errors.error) R.comp) R.res
68+
69+
val set_compress_tracing_files :
70+
(debug_info -> bool -> (unit, Errors.error) R.comp) R.res
71+
end
72+
73+
module type Server_impl = sig
74+
type context = unit
75+
76+
val create :
77+
context
78+
-> dbg:debug_info
79+
-> uuid:string
80+
-> name_label:string
81+
-> attributes:(string * string) list
82+
-> endpoints:string list
83+
-> enabled:bool
84+
-> unit
85+
86+
val destroy : context -> dbg:debug_info -> uuid:string -> unit
87+
88+
val set_enabled :
89+
context -> dbg:debug_info -> uuid:string -> enabled:bool -> unit
90+
91+
val set_attributes :
92+
context
93+
-> dbg:debug_info
94+
-> uuid:string
95+
-> attributes:(string * string) list
96+
-> unit
97+
98+
val set_endpoints :
99+
context -> dbg:debug_info -> uuid:string -> endpoints:string list -> unit
100+
101+
val init : context -> dbg:debug_info -> unit
102+
103+
val set_trace_log_dir : context -> dbg:debug_info -> dir:string -> unit
104+
105+
val set_export_interval : context -> dbg:debug_info -> interval:float -> unit
106+
107+
val set_max_spans : context -> dbg:debug_info -> spans:int -> unit
108+
109+
val set_max_traces : context -> dbg:debug_info -> traces:int -> unit
110+
111+
val set_max_file_size : context -> dbg:debug_info -> file_size:int -> unit
112+
113+
val set_host_id : context -> dbg:debug_info -> host_id:string -> unit
114+
115+
val set_compress_tracing_files :
116+
context -> dbg:debug_info -> enabled:bool -> unit
117+
end
118+
119+
module Server : functor (_ : Server_impl) () -> sig
120+
module S : sig
121+
val create :
122+
( debug_info
123+
-> string
124+
-> string
125+
-> (string * string) list
126+
-> string list
127+
-> bool
128+
-> unit
129+
)
130+
-> unit
131+
132+
val destroy : (debug_info -> string -> unit) -> unit
133+
134+
val set_enabled : (debug_info -> string -> bool -> unit) -> unit
135+
136+
val set_attributes :
137+
(debug_info -> string -> (string * string) list -> unit) -> unit
138+
139+
val set_endpoints : (debug_info -> string -> string list -> unit) -> unit
140+
141+
val init : (debug_info -> unit) -> unit
142+
143+
val set_trace_log_dir : (debug_info -> string -> unit) -> unit
144+
145+
val set_export_interval : (debug_info -> float -> unit) -> unit
146+
147+
val set_max_spans : (debug_info -> int -> unit) -> unit
148+
149+
val set_max_traces : (debug_info -> int -> unit) -> unit
150+
151+
val set_max_file_size : (debug_info -> int -> unit) -> unit
152+
153+
val set_host_id : (debug_info -> string -> unit) -> unit
154+
155+
val set_compress_tracing_files : (debug_info -> bool -> unit) -> unit
156+
end
157+
158+
val process : Rpc.call -> Rpc.response
159+
end
160+
161+
module Client : sig
162+
val create :
163+
debug_info
164+
-> string
165+
-> string
166+
-> (string * string) list
167+
-> string list
168+
-> bool
169+
-> unit
170+
171+
val destroy : debug_info -> string -> unit
172+
173+
val set_enabled : debug_info -> string -> bool -> unit
174+
175+
val set_attributes : debug_info -> string -> (string * string) list -> unit
176+
177+
val set_endpoints : debug_info -> string -> string list -> unit
178+
179+
val init : debug_info -> unit
180+
181+
val set_trace_log_dir : debug_info -> string -> unit
182+
183+
val set_export_interval : debug_info -> float -> unit
184+
185+
val set_max_spans : debug_info -> int -> unit
186+
187+
val set_max_traces : debug_info -> int -> unit
188+
189+
val set_max_file_size : debug_info -> int -> unit
190+
191+
val set_host_id : debug_info -> string -> unit
192+
193+
val set_compress_tracing_files : debug_info -> bool -> unit
194+
end
Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,43 @@
1+
module Observer : sig
2+
type context = unit
3+
4+
val create :
5+
context
6+
-> dbg:string
7+
-> uuid:string
8+
-> name_label:string
9+
-> attributes:(string * string) list
10+
-> endpoints:string list
11+
-> enabled:bool
12+
-> unit
13+
14+
val destroy : context -> dbg:string -> uuid:string -> unit
15+
16+
val set_enabled : context -> dbg:string -> uuid:string -> enabled:bool -> unit
17+
18+
val set_attributes :
19+
context
20+
-> dbg:string
21+
-> uuid:string
22+
-> attributes:(string * string) list
23+
-> unit
24+
25+
val set_endpoints :
26+
context -> dbg:string -> uuid:string -> endpoints:string list -> unit
27+
28+
val init : context -> dbg:string -> unit
29+
30+
val set_trace_log_dir : context -> dbg:string -> dir:string -> unit
31+
32+
val set_export_interval : context -> dbg:string -> interval:float -> unit
33+
34+
val set_max_spans : context -> dbg:string -> spans:int -> unit
35+
36+
val set_max_traces : context -> dbg:string -> traces:int -> unit
37+
38+
val set_max_file_size : context -> dbg:string -> file_size:int -> unit
39+
40+
val set_host_id : context -> dbg:string -> host_id:string -> unit
41+
42+
val set_compress_tracing_files : context -> dbg:string -> enabled:bool -> unit
43+
end

quality-gate.sh

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ verify-cert () {
2525
}
2626

2727
mli-files () {
28-
N=469
28+
N=467
2929
X="ocaml/tests"
3030
X+="|ocaml/quicktest"
3131
X+="|ocaml/message-switch/core_test"

0 commit comments

Comments
 (0)