package caqti-async

You can search for identifiers within the package.

in-package search v0.2.0

caqti-async
- Caqti_async
  - CONNECTION
    
    Response
  - Pool
  - Stream
- Caqti_async_sql_io

Legend:
Library
Module
Module type
Parameter
Class
Class type

Connector for Async.

include Caqti_connect_sig.S with type 'a future := 'a Async_kernel.Deferred.t

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

A pool implementation for the current concurrency library.

module Stream : 
  Caqti_stream.S with type 'a future := 'a Async_kernel.Deferred.t

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

The connection API specialized for the current concurrency library.

type connection = (module CONNECTION)

Shortcut for the connection API passed as a value.

val connect : 
  Uri.t ->
  (connection, [> Caqti_error.load_or_connect ]) result Async_kernel.Deferred.t

connect uri locates and loads a driver which can handle uri, passes uri to the driver, which establish a connection and returns a first-class module implementing Caqti_connection_sig.S.

val connect_pool : 
  ?max_size:int ->
  Uri.t ->
  ((connection, [> Caqti_error.connect ]) Pool.t, [> Caqti_error.load ]) result

connect_pool uri is a pool of database connections constructed by connect uri.