caqti-async 1.7.0 · OCaml Package

val driver_info : Caqti_driver_info.t

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

package caqti-async