Liking cljdoc? Tell your friends :D

pg.pool

A simple connection pool. Runs open connections in two data structures: a queue of free connections and a map of busy connections. The connections are taken from a tail of the queue and put back into the head.

Every time the connection is borrowed, it's check for expiration. An expired connection gets closed, and the one is produced.

Should all free connections are in use at the moment and the client is going to borrow another one, an exception is triggered.

When a connection is put back, it's checked for expiration and for the transaction status. Connections that are in the error state are closed; Connections that are in a transaction are rolled back.

A simple connection pool. Runs open connections in two
data structures: a queue of free connections and a map
of busy connections. The connections are taken from a tail
of the queue and put back into the head.

Every time the connection is borrowed, it's check for expiration.
An expired connection gets closed, and the one is produced.

Should all free connections are in use at the moment and the client
is going to borrow another one, an exception is triggered.

When a connection is put back, it's checked for expiration and for
the transaction status. Connections that are in the error state
are closed; Connections that are in a transaction are rolled back.
raw docstring

borrow-connectionclj

(borrow-connection pool)

Borrow a connection from a pool.

Borrow a connection from a pool.
sourceraw docstring

closeclj

(close pool)

Close the pool by terminating all the connections, both free and used.

Close the pool by terminating all the connections,
both free and used.
sourceraw docstring

closed?clj

(closed? pool)

True if the pool has been closed before.

True if the pool has been closed before.
sourceraw docstring

free-countclj

(free-count pool)

Return the current number of free connections.

Return the current number of free connections.
sourceraw docstring

idclj

(id pool)

Get a unique ID of the pool.

Get a unique ID of the pool.
sourceraw docstring

poolclj

(pool opt)
(pool host port user password database)

Run a new Pool from a config map.

Run a new Pool from a config map.
sourceraw docstring

pool?clj

(pool? x)

True if a value is a Pool instance.

True if a value is a Pool instance.
sourceraw docstring

replenish-connectionsclj

(replenish-connections pool)

Forcibly run a task that determines how many new free connections should be created, and creates them. The number is calculated as follows:

gap = min-size - size(free-conns) - size(used-conns)

When gap is > 0, the corresponding number of free connections is created.

Blocks the pool.

Forcibly run a task that determines how many new
free connections should be created, and creates them.
The number is calculated as follows:

gap = min-size - size(free-conns) - size(used-conns)

When gap is > 0, the corresponding number of free connections
is created.

Blocks the pool.
sourceraw docstring

statsclj

(stats pool)

Return both free and used connection amount as a map.

Return both free and used connection amount as a map.
sourceraw docstring

used-countclj

(used-count pool)

Return the current number of busy connections.

Return the current number of busy connections.
sourceraw docstring

with-conncljmacro

(with-conn [bind pool] & body)

Just a shorter version of with-connection.

Just a shorter version of `with-connection`.
sourceraw docstring

with-connectioncljmacro

(with-connection [bind pool] & body)

Execute the body while the bind symbol is bound to a borrowed Connection instance. The connection is marked is busy and won't be available for other consumers. Return the connection to the pool when exiting the macro.

When no connections available, throw an exception.

Execute the body while the `bind` symbol is bound
to a borrowed Connection instance. The connection
is marked is busy and won't be available for other
consumers. Return the connection to the pool when
exiting the macro.

When no connections available, throw an exception.
sourceraw docstring

with-poolcljmacro

(with-pool [bind config] & body)

Execute the body while the bind symbol is bound to a new Pool instance. Close the pool afterwards.

Execute the body while the `bind` symbol is bound
to a new Pool instance. Close the pool afterwards.
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close