Database (p.guardian.0.4.0.doc.guardian.backend.Guardian

val initialize : ?additional_pools:(string * string) list -> unit -> unit

val fetch_pool : 
  ?ctx:(string * string) list ->
  ?retries:int ->
  unit ->
  (Caqti_lwt.connection, Caqti_error.t) Caqti_lwt_unix.Pool.t Lwt.t

val add_pool : ?required:bool -> string -> string -> unit

val drop_pool : string -> unit Lwt.t

val connect : string -> (unit, string) result

val disconnect : ?error:Caqti_error.t -> string -> unit Lwt.t

val find : 
  ?ctx:(string * string) list ->
  ('a, 'b, [< `One ]) Caqti_request.t ->
  'a ->
  'b Lwt.t

val find_opt : 
  ?ctx:(string * string) list ->
  ('a, 'b, [< `One | `Zero ]) Caqti_request.t ->
  'a ->
  'b option Lwt.t

val collect : 
  ?ctx:(string * string) list ->
  ('a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t ->
  'a ->
  'b list Lwt.t

val exec : 
  ?ctx:(string * string) list ->
  ('a, unit, [< `Zero ]) Caqti_request.t ->
  'a ->
  unit Lwt.t

val populate : 
  ?ctx:(string * string) list ->
  string ->
  string list ->
  'a Caqti_type.t ->
  'a list ->
  unit Lwt.t

val transaction : 
  ?ctx:(string * string) list ->
  ?setup:(Caqti_lwt.connection -> (unit, Caqti_error.t) Lwt_result.t) list ->
  ?cleanup:(Caqti_lwt.connection -> (unit, Caqti_error.t) Lwt_result.t) list ->
  (Caqti_lwt.connection -> ('a, Caqti_error.t) Lwt_result.t) ->
  'a Lwt.t

val transaction_iter : 
  ?ctx:(string * string) list ->
  (Caqti_lwt.connection -> (unit, Caqti_error.t) result Lwt.t) list ->
  unit Lwt.t