Source file `telemetry_.ml`

1
2
3
4
5
6
7
8
9
10
11
12
open Riot

type Telemetry.event +=
  | Accepted_connection of { client_addr : Net.Addr.stream_addr }
  | Connection_started
  | Listening of { socket : Net.Socket.listen_socket }

let accepted_connection client_addr =
  Telemetry.emit (Accepted_connection { client_addr })

let connection_started () = Telemetry.emit Connection_started
let listening socket = Telemetry.emit (Listening { socket })