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 a bounded TBQueue bridge (provided by
kiroku-store's subscriptionStream) and are lifted into Shibuya's
effect stack via Stream.morphInner. Checkpoint management is handled
internally by Kiroku's subscription worker — the adapter's ack semantics
are no-op for AckOk/AckRetry/AckDeadLetter and trigger subscription
cancellation for AckHalt.
Downloads
- shibuya-kiroku-adapter-0.2.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 |
|---|---|
| Change log | CHANGELOG.md |
| Dependencies | aeson (>=2.1 && <2.3), base (>=4.18 && <5), effectful-core (>=2.4 && <2.7), hs-opentelemetry-api (>=1.0 && <1.1), hs-opentelemetry-semantic-conventions (>=1.40 && <1.41), kiroku-store (>=0.2 && <0.3), shibuya-core (>=0.6 && <0.7), 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-06-01T00:17:45Z |
| 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 | |
| Downloads | 4 total (4 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] |