package caqti-async

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
val driver_info : Caqti_driver_info.t
val driver_connection : Caqti_connection_sig.driver_connection option
module Response : sig ... end
val call : f: (('b, [< `Many | `One | `Zero ] as 'd) Response.t -> ('c, [> Caqti_error.call ] as 'e) Stdlib.result Async_kernel.Deferred.t) -> ('a, 'b, 'd) Caqti_request.t -> 'a -> ('c, 'e) Stdlib.result Async_kernel.Deferred.t
val set_statement_timeout : float option -> (unit, [> Caqti_error.call ]) Stdlib.result Async_kernel.Deferred.t
val start : unit -> (unit, [> Caqti_error.transact ]) Stdlib.result Async_kernel.Deferred.t
val commit : unit -> (unit, [> Caqti_error.transact ]) Stdlib.result Async_kernel.Deferred.t
val rollback : unit -> (unit, [> Caqti_error.transact ]) Stdlib.result Async_kernel.Deferred.t
val deallocate : ('a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t -> (unit, [> Caqti_error.call ]) Stdlib.result Async_kernel.Deferred.t
val disconnect : unit -> unit Async_kernel.Deferred.t
val validate : unit -> bool Async_kernel.Deferred.t
val check : (bool -> unit) -> unit
val exec : ('a, unit, [< `Zero ]) Caqti_request.t -> 'a -> (unit, [> Caqti_error.call_or_retrieve ]) Stdlib.result Async_kernel.Deferred.t
val exec_with_affected_count : ('a, unit, [< `Zero ]) Caqti_request.t -> 'a -> (int, [> Caqti_error.call_or_retrieve ]) Stdlib.result Async_kernel.Deferred.t
val find : ('a, 'b, [< `One ]) Caqti_request.t -> 'a -> ('b, [> Caqti_error.call_or_retrieve ]) Stdlib.result Async_kernel.Deferred.t
val find_opt : ('a, 'b, [< `One | `Zero ]) Caqti_request.t -> 'a -> ('b option, [> Caqti_error.call_or_retrieve ]) Stdlib.result Async_kernel.Deferred.t
val fold : ('a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t -> ('b -> 'c -> 'c) -> 'a -> 'c -> ('c, [> Caqti_error.call_or_retrieve ]) Stdlib.result Async_kernel.Deferred.t
val fold_s : ('a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t -> ('b -> 'c -> ('c, [> Caqti_error.call_or_retrieve ] as 'd) Stdlib.result Async_kernel.Deferred.t) -> 'a -> 'c -> ('c, 'd) Stdlib.result Async_kernel.Deferred.t
val iter_s : ('a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t -> ('b -> (unit, [> Caqti_error.call_or_retrieve ] as 'c) Stdlib.result Async_kernel.Deferred.t) -> 'a -> (unit, 'c) Stdlib.result Async_kernel.Deferred.t
val collect_list : ('a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t -> 'a -> ('b list, [> Caqti_error.call_or_retrieve ]) Stdlib.result Async_kernel.Deferred.t
val rev_collect_list : ('a, 'b, [< `Many | `One | `Zero ]) Caqti_request.t -> 'a -> ('b list, [> Caqti_error.call_or_retrieve ]) Stdlib.result Async_kernel.Deferred.t
val with_transaction : (unit -> ('a, [> Caqti_error.transact ] as 'b) Stdlib.result Async_kernel.Deferred.t) -> ('a, 'b) Stdlib.result Async_kernel.Deferred.t
val populate : table:string -> columns:string list -> 'a Caqti_type.t -> ('a, 'err) Stream.t -> (unit, [> `Congested of 'err | `Decode_rejected of Caqti_error.coding_error | `Encode_failed of Caqti_error.coding_error | `Encode_rejected of Caqti_error.coding_error | `Request_failed of Caqti_error.query_error | `Request_rejected of Caqti_error.query_error | `Response_failed of Caqti_error.query_error | `Response_rejected of Caqti_error.query_error ]) Stdlib.result Async_kernel.Deferred.t
OCaml

Innovation. Community. Security.