Repodb.Pool.Make.Multi

type t = D.connection multi_t

val create : 
  servers:string list ->
  ?validate:(D.connection -> bool) ->
  unit ->
  D.connection multi_t

val create_sized : 
  servers:string list ->
  max_size_per_server:int ->
  ?validate:(D.connection -> bool) ->
  unit ->
  D.connection multi_t

val acquire : 'a multi_t -> ('a, pool_error) result

val acquire_blocking : ?timeoutf:float -> 'a multi_t -> ('a, pool_error) result

val release : 'a multi_t -> 'a -> unit

val with_connection : 'a multi_t -> ('a -> 'b) -> ('b, pool_error) result

val with_connection_blocking : 
  ?timeoutf:float ->
  'a multi_t ->
  ('a -> 'b) ->
  ('b, pool_error) result

val drain : 'a multi_t -> unit

val shutdown : 'a multi_t -> unit

val stats : 'a multi_t -> multi_stats

val size : 'a multi_t -> int

val available : 'a multi_t -> int

val in_use : 'a multi_t -> int

val is_closed : 'a multi_t -> bool

val server_count : 'a multi_t -> int

val is_healthy : 'a multi_t -> int -> bool

val mark_healthy : 'a multi_t -> int -> unit

val mark_unhealthy : 'a multi_t -> int -> unit