simon/tiny_httpd
1
0
Fork 0
mirror of https://github.com/c-cube/tiny_httpd.git synced 2025-12-06 19:25:32 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

compat old ocaml

Browse source
This commit is contained in:
Simon Cruanes 2024-01-18 21:36:20 -05:00
parent 66ddee3522
commit 2da3bd3fc7
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/prometheus/tiny_httpd_prometheus.ml
View file

@ -26,17 +26,21 @@ let emit_tags_ buf tags =
bpf buf "}" bpf buf "}"
) )
let opt_iter_ f = function
| None -> ()
| Some x -> f x
module Counter = struct module Counter = struct
type t = counter type t = counter
let create (reg : registry) ?(tags = []) ?descr name : t = let create (reg : registry) ?(tags = []) ?descr name : t =
let self : t = { name; descr; tags; c = A.make 0 } in let self : t = { name; descr; tags; c = A.make 0 } in
Option.iter (validate_descr_ "counter") descr; opt_iter_ (validate_descr_ "counter") descr;
reg.counters <- self :: reg.counters; reg.counters <- self :: reg.counters;
self self
let emit buf (self : t) = let emit buf (self : t) =
Option.iter (bpf buf "# HELP %s %s\n" self.name) self.descr; opt_iter_ (bpf buf "# HELP %s %s\n" self.name) self.descr;
bpf buf "# TYPE %s counter\n" self.name; bpf buf "# TYPE %s counter\n" self.name;
bpf buf "%s%a %d\n" self.name emit_tags_ self.tags (A.get self.c); bpf buf "%s%a %d\n" self.name emit_tags_ self.tags (A.get self.c);
() ()
@ -51,13 +55,13 @@ module Gauge = struct
type t = gauge type t = gauge
let create (reg : registry) ?(tags = []) ?descr name : t = let create (reg : registry) ?(tags = []) ?descr name : t =
Option.iter (validate_descr_ "gauge") descr; opt_iter_ (validate_descr_ "gauge") descr;
let self : t = { name; descr; tags; g = A.make 0 } in let self : t = { name; descr; tags; g = A.make 0 } in
reg.gauges <- self :: reg.gauges; reg.gauges <- self :: reg.gauges;
self self
let emit buf (self : t) = let emit buf (self : t) =
Option.iter (bpf buf "# HELP %s %s\n" self.name) self.descr; opt_iter_ (bpf buf "# HELP %s %s\n" self.name) self.descr;
bpf buf "# TYPE %s gauge\n" self.name; bpf buf "# TYPE %s gauge\n" self.name;
bpf buf "%s%a %d\n" self.name emit_tags_ self.tags (A.get self.g); bpf buf "%s%a %d\n" self.name emit_tags_ self.tags (A.get self.g);
() ()