Module Pools.MakeSource

Parameters

module Config : ConfigSig

Signature

include Sig
Sourceval initialize : ?additional_pools:(string * string) list -> unit -> unit
Sourceval fetch_pool : ?ctx:(string * string) list -> ?retries:int -> unit -> (Caqti_lwt.connection, Caqti_error.t) Caqti_lwt_unix.Pool.t Lwt.t
Sourceval add_pool : ?required:bool -> string -> string -> unit
Sourceval drop_pool : string -> unit Lwt.t
Sourceval connect : string -> (unit, string) result
Sourceval disconnect : ?error:Caqti_error.t -> string -> unit Lwt.t
Sourceval find : ?ctx:(string * string) list -> ('a, 'b, [< `One ]) Caqti_request.t -> 'a -> 'b Lwt.t
Sourceval find_opt : ?ctx:(string * string) list -> ('a, 'b, [< `One | `Zero ]) Caqti_request.t -> 'a -> 'b option Lwt.t
Sourceval collect : ?ctx:(string * string) list -> ('a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t -> 'a -> 'b list Lwt.t
Sourceval exec : ?ctx:(string * string) list -> ('a, unit, [< `Zero ]) Caqti_request.t -> 'a -> unit Lwt.t
Sourceval populate : ?ctx:(string * string) list -> string -> string list -> 'a Caqti_type.t -> 'a list -> unit Lwt.t
Sourceval 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
Sourceval transaction_iter : ?ctx:(string * string) list -> (Caqti_lwt.connection -> (unit, Caqti_error.t) result Lwt.t) list -> unit Lwt.t
Sourceval query : ?ctx:(string * string) list -> (Caqti_lwt.connection -> ('a, Caqti_error.t) result Lwt.t) -> 'a Lwt.t