Legend:
Library
Module
Module type
Parameter
Class
Class type
Library
Module
Module type
Parameter
Class
Class type
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 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