package sihl

  1. Overview
  2. Docs

Module Sihl.DatabaseSource

include module type of struct include Sihl_persistence.Database end
Sourceval log_src : Logs.src
Sourceval pool_ref : (Caqti_lwt.connection, Caqti_error.t) Caqti_lwt.Pool.t option ref
Sourceval prepare_requests : string -> string -> string -> 'a Caqti_type.t -> (int, 'a, [ `Many | `One | `Zero ]) Caqti_request.t * (int, 'a, [ `Many | `One | `Zero ]) Caqti_request.t * (string * int, 'a, [ `Many | `One | `Zero ]) Caqti_request.t * (string * int, 'a, [ `Many | `One | `Zero ]) Caqti_request.t
Sourceval run_request : (module Caqti_lwt.CONNECTION) -> (('a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t * ('a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t * ('c * 'a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t * ('c * 'a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t) -> [< `Asc | `Desc ] -> 'c option -> 'a -> 'b list Lwt.t
Sourcetype config = Sihl_persistence.Database.config = {
  1. url : string;
  2. pool_size : int option;
}
Sourceval config : string -> int option -> config
Sourceval schema : (string, string -> int option -> config, config) Conformist.t
Sourceval raise_error : ('a, [< Caqti_error.t ]) result -> 'a
Sourceval print_pool_usage : ('a, 'b) Caqti_lwt.Pool.t -> unit
Sourceval fetch_pool : unit -> (Caqti_lwt.connection, Caqti_error.t) Caqti_lwt.Pool.t
Sourceval transaction : (Caqti_lwt.connection -> 'a Lwt.t) -> 'a Lwt.t
Sourceval query : (Caqti_lwt.connection -> 'a Lwt.t) -> 'a Lwt.t
Sourceval used_database : unit -> Sihl_contract.Database.database_type option
Sourceval start : unit -> unit Lwt.t
Sourceval stop : unit -> unit Lwt.t
Sourceval register : unit -> Core.Container.Service.t
Sourcemodule Setup : sig ... end