package caqti-async

You can search for identifiers within the package.

in-package search v0.2.0

caqti-async
- Caqti_async

Legend:
Library
Module
Module type
Parameter
Class
Class type

Connector for Async.

module Stream : 
  Caqti_stream_sig.S with type 'a fiber := 'a Async_kernel.Deferred.t

module Pool : Caqti_pool_sig.S with type 'a fiber := 'a Async_kernel.Deferred.t

module type CONNECTION =
  Caqti_connection_sig.S
    with type 'a fiber := 'a Async_kernel.Deferred.t
     and type ('a, 'e) stream := ('a, 'e) Stream.t

include Caqti_connect_sig.S
  with type 'a fiber := 'a Async_kernel.Deferred.t
   and type 'a with_switch := 'a
   and type 'a with_stdenv := 'a
   and type ('a, 'e) stream := ('a, 'e) Stream.t
   and type ('a, 'e) pool := ('a, 'e) Pool.t
   and type connection = (module CONNECTION)

type connection = (module CONNECTION)

val connect : 
  ?env:(Caqti_driver_info.t -> string -> Caqti_query.t) ->
  ?tweaks_version:(int * int) ->
  Uri.t ->
  (connection, [> Caqti_error.load_or_connect ]) Stdlib.result
    Async_kernel.Deferred.t

val with_connection : 
  ?env:(Caqti_driver_info.t -> string -> Caqti_query.t) ->
  ?tweaks_version:(int * int) ->
  Uri.t ->
  (connection ->
    ('a, [> Caqti_error.load_or_connect ] as 'b) Stdlib.result
      Async_kernel.Deferred.t) ->
  ('a, 'b) Stdlib.result Async_kernel.Deferred.t

val connect_pool : 
  ?pool_config:Caqti_pool_config.t ->
  ?post_connect:
    (connection ->
      (unit, [> Caqti_error.connect ] as 'a) Stdlib.result
        Async_kernel.Deferred.t) ->
  ?env:(Caqti_driver_info.t -> string -> Caqti_query.t) ->
  ?tweaks_version:(int * int) ->
  Uri.t ->
  ((connection, 'a) Pool.t, [> Caqti_error.load ]) Stdlib.result