NimblePool-based connection pool for dllb TCP connections.
Workers are raw :gen_tcp sockets managed through Dllb.Connection.
Dead sockets are detected at checkout and transparently reconnected.
Summary
Functions
Executes multiple queries through a single pool checkout.
Returns a child spec for starting the pool under a supervisor.
Executes a query through the connection pool.
Functions
@spec batch([String.t()], Keyword.t()) :: [ok: Dllb.Result.t(), error: term()]
Executes multiple queries through a single pool checkout.
Checks out one socket, sends all queries sequentially, then checks the socket back in. This amortises the pool checkout cost across many queries (e.g. bulk AST ingestion).
Returns a list of {:ok, result} | {:error, reason} in the same
order as the input query strings.
@spec child_spec(Keyword.t()) :: Supervisor.child_spec()
Returns a child spec for starting the pool under a supervisor.
Options
:host- server hostname (default from app env or"127.0.0.1"):port- server port (default from app env or3009):pool_size- number of connections (default from app env or5):outcome- response format (default:json):timeout- connection/recv timeout in ms (default30_000)
@spec query(String.t(), Keyword.t()) :: {:ok, Dllb.Result.t()} | {:error, term()}
Executes a query through the connection pool.
Checks out a socket, runs the query via Dllb.Connection.query/3,
and checks the socket back in.
Options
:timeout- recv timeout in ms (default30_000)
Returns {:ok, result} or {:error, reason}.