hasql-queue: A PostgreSQL backed queue
Modules
- Hasql
- Queue
- Hasql.Queue.IO
- Hasql.Queue.Internal
- Hasql.Queue.Migrate
- Hasql.Queue.Session
- Queue
Downloads
- hasql-queue-1.0.1.1.tar.gz [browse] (Cabal source package)
- Package description (as included in the package)
Maintainer's Corner
For package maintainers and hackage trustees
Candidates
- No Candidates
| Versions [RSS] | 1.0.1, 1.0.1.1, 1.2.0.0, 1.2.0.1, 1.2.0.2 |
|---|---|
| Change log | CHANGELOG.md |
| Dependencies | aeson, async, base (>=4.7 && <5), base64-bytestring, bytestring, cryptohash-sha1, exceptions, hasql, hasql-queue, here, monad-control, postgresql-libpq, postgresql-libpq-notify (>=0.2.0.0), random, resource-pool, stm, text, time, tmp-postgres, transformers [details] |
| License | BSD-3-Clause |
| Copyright | 2020 Jonathan Fischoff |
| Author | Jonathan Fischoff |
| Maintainer | jonathangfischoff@gmail.com |
| Category | Web |
| Home page | https://github.com/jfischoff/hasql-queue#readme |
| Bug tracker | https://github.com/jfischoff/hasql-queue/issues |
| Source repo | head: git clone https://github.com/jfischoff/hasql-queue |
| Uploaded | by JonathanFischoff at 2020-06-14T06:17:44Z |
| Distributions | |
| Executables | benchmark |
| Downloads | 1081 total (20 in the last 30 days) |
| Rating | (no votes yet) [estimated by Bayesian average] |
| Your Rating | |
| Status | Docs not available [build log] All reported builds failed as of 2020-06-14 [all 3 reports] |
Readme for hasql-queue-1.0.1.1
[back to package description]
hasql-queue
This module utilizes PostgreSQL to implement a durable queue for efficently processing payloads.
Typically a producer would enqueue a new payload as part of larger database transaction
createAccount userRecord = transaction Serializable Write $ do
createUser userRecord
enqueueNotification "queue_channel" emailEncoder [makeVerificationEmail userRecord]
In another thread or process the consumer would drain the queue.
-- Wait for a single new record and try to send the email 5 times for giving
-- up and marking the payload as failed.
forever $ withDequeue "queue_channel" conn emailDecoder 5 1 $
mapM_ sendEmail
In the example above we used the Session API for enqueuing and the IO for
dequeuing.
The Session API is useful for composing larger transactions and the IO utilizes PostgreSQL notifications to avoid polling.
Installation
stack install hasql-queue