Source file `data_db_core.ml`

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
open Base

exception Exception of string

type pool = (Caqti_lwt.connection, Caqti_error.t) Caqti_lwt.Pool.t

type connection = (module Caqti_lwt.CONNECTION)

let ctx_key_pool : pool Core.Ctx.key = Core.Ctx.create_key ()

let ctx_key_connection : connection Core.Ctx.key = Core.Ctx.create_key ()

let ctx_key_transaction : connection Core.Ctx.key = Core.Ctx.create_key ()

let find_pool ctx = Core.Ctx.find ctx_key_pool ctx

let add_pool pool ctx = Core.Ctx.add ctx_key_pool pool ctx

let remove_pool ctx = Core.Ctx.remove ctx_key_pool ctx

let find_connection ctx = Core.Ctx.find ctx_key_connection ctx

let add_connection connection ctx =
  Core.Ctx.add ctx_key_connection connection ctx

let remove_connection ctx = Core.Ctx.remove ctx_key_connection ctx

let find_transaction ctx = Core.Ctx.find ctx_key_transaction ctx

let add_transaction connection ctx =
  Core.Ctx.add ctx_key_transaction connection ctx

let remove_transaction ctx = Core.Ctx.remove ctx_key_transaction ctx

let pool_ref : pool option ref = ref None