shibuya-kiroku-adapter: Kiroku event store adapter for the Shibuya queue processing framework
A Shibuya adapter that integrates with Kiroku, a PostgreSQL event store.
Wraps Kiroku's push-based subscriptions into Shibuya's pull-based Adapter
interface, enabling supervised multi-subscription processing with failure
isolation, per-subscription metrics, and coordinated graceful shutdown.
.
Events flow through kiroku-store's ack-coupled subscriptionAckStream
bridge and are lifted into Shibuya's effect stack via Stream.morphInner.
Each finalized Shibuya AckDecision drives Kiroku checkpointing, retry,
dead-lettering, or halt before the worker moves to the next event.
Downloads
- shibuya-kiroku-adapter-0.4.0.0.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] | 0.1.0.0, 0.2.0.0, 0.4.0.0 |
|---|---|
| Change log | CHANGELOG.md |
| Dependencies | aeson (>=2.1 && <2.3), base (>=4.18 && <5), effectful-core (>=2.5 && <2.7), hs-opentelemetry-api (>=1.0 && <1.1), hs-opentelemetry-semantic-conventions (>=1.40 && <1.41), kiroku-store (>=0.3 && <0.4), shibuya-core (>=0.8 && <0.9), stm (>=2.5 && <2.6), streamly-core (>=0.3 && <0.4), text (>=2.0 && <2.2), unordered-containers (>=0.2 && <0.3), uuid (>=1.3 && <1.4) [details] |
| License | BSD-3-Clause |
| Author | Nadeem Bitar |
| Maintainer | nadeem@gmail.com |
| Uploaded | by shinzui at 2026-07-11T15:23:26Z |
| Category | Concurrency, Database, Eventing |
| Home page | https://github.com/shinzui/kiroku |
| Bug tracker | https://github.com/shinzui/kiroku/issues |
| Source repo | head: git clone https://github.com/shinzui/kiroku.git |
| Distributions | |
| Reverse Dependencies | 1 direct, 1 indirect [details] |
| Downloads | 19 total (10 in the last 30 days) |
| Rating | (no votes yet) [estimated by Bayesian average] |
| Your Rating | |
| Status | Docs uploaded by user Build status unknown [no reports yet] |