happy-eyeballs 0.0.5 · OCaml Package

type t

The internal state of happy eyeballs.

type action =

| Resolve_a of [ `host ] Domain_name.t
| Resolve_aaaa of [ `host ] Domain_name.t
| Connect of [ `host ] Domain_name.t * int * Ipaddr.t * int
| Connect_failed of [ `host ] Domain_name.t * int

The variant of actions to be performed by the effectful layer.

val pp_action : action Fmt.t

pp_action ppf a pretty-prints the action a on ppf.

type event =

| Resolved_a of [ `host ] Domain_name.t * Ipaddr.V4.Set.t
| Resolved_aaaa of [ `host ] Domain_name.t * Ipaddr.V6.Set.t
| Resolved_a_failed of [ `host ] Domain_name.t
| Resolved_aaaa_failed of [ `host ] Domain_name.t
| Connection_failed of [ `host ] Domain_name.t * int * Ipaddr.t * int
| Connected of [ `host ] Domain_name.t * int * Ipaddr.t * int

The variant of events.

val pp_event : event Fmt.t

pp_event ppf e pretty-prints event e on ppf.

val create : int64 -> t

create ts creates the internal state, initialized with the timestamp ts (an arbitrary number that must be monotonically increasing).

val timer : t -> int64 -> t * action list

timer t ts is a timer function that results in an updated t and a list of actions that need to be performed (connection to be retried, connection failures to be repored, ...)

val connect : 
  t ->
  int64 ->
  id:int ->
  [ `host ] Domain_name.t ->
  int list ->
  t * action list

connect t ts ~id host ports attempts a connection to host, where the ports are attempted in sequence. It results in an updated t and a list of actions to be performed.

raises Failure
if ports is the empty list.

val connect_ip : 
  ?shuffle:bool ->
  t ->
  int64 ->
  id:int ->
  Ipaddr.t list ->
  int list ->
  t * action list

connect_ip ~shuffle t ts ~id ips ports attempts a connection to ips, ports. If shuffle is provided and true (default: false), the list of ips will be mixed before attempting connections. By default, the list will be tried in sequence. The ports will be tried in sequence. The result is an updated t and a list of actions to be performed.

raises Failure
if ports is the empty list or ips the empty list.

val event : t -> int64 -> event -> t * action list

event t ts ev results in an updated t and a list of actions to be performed.

raises Failure
if ev contains an empty set of IP addresses.

module Waiter_map : sig ... end

A map for waiters and internal id.

package happy-eyeballs