Arbiter.Hasql.MonadArbiter

hasql primitives for writing a custom MonadArbiter instance.

Handlers receive a Hasql.Connection.Connection for running typed hasql queries inside the worker transaction:

import Arbiter.Core qualified as Arb
import Arbiter.Hasql qualified as ArbH
import Hasql.Connection qualified as Hasql

instance Arb.MonadArbiter MyApp where
  type RegistryOf MyApp = MyRegistry
  type Handler MyApp job result = Hasql.Connection -> job -> MyApp result
  getSchema                = asks appSchema
  executeQuery             = ArbH.hasqlExecuteQuery
  executeQueryPrepared     = ArbH.hasqlExecuteQueryPrepared True
  executeStatement         = ArbH.hasqlExecuteStatement
  withDbTransaction        = ArbH.hasqlWithDbTransaction
  runHandlerWithConnection = ArbH.hasqlRunHandlerWithConnection
  getListener              = asks appListener

The primitives also need a HasPoolState Hasql.Connection MyApp instance. See HasPoolState.

Write a handler's own signature as JobHandler MyApp MyPayload MyResult, which is Handler at that queue's job and declared result types.