shibuya-kiroku-adapter: Kiroku event store adapter for the Shibuya queue processing framework

[ bsd3, concurrency, database, eventing, library ] [ Propose Tags ] [ Report a vulnerability ]

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.

Flags

Manual Flags

NameDescriptionDefault
lifecycle-live

Build the repository-only lifecycle release fixture

Disabled

Use -f <flag> to enable a flag, or -f -<flag> to disable that flag. More info

Downloads

Maintainer's Corner

Package maintainers

For package maintainers and hackage trustees

Candidates

  • No Candidates
Versions [RSS] 0.1.0.0, 0.2.0.0, 0.4.0.0, 0.4.0.1, 0.5.0.0, 0.5.0.1, 0.5.0.2, 0.5.1.0, 0.5.1.1, 0.5.1.2, 0.5.1.3, 0.5.1.4, 0.5.1.5
Change log CHANGELOG.md
Dependencies aeson (>=2.1 && <2.3), async (>=2.2 && <2.3), base (>=4.18 && <5), bytestring (>=0.11 && <0.13), containers (>=0.6 && <0.8), effectful-core (>=2.6.1 && <2.7 || >=2.7.1.1 && <2.8), ephemeral-pg (>=0.3.1 && <0.4), hs-opentelemetry-api (>=1.0 && <1.1), hs-opentelemetry-semantic-conventions (>=1.40 && <1.41), kiroku-store (>=0.8 && <0.9), kiroku-test-support (>=0.1.0.0 && <0.2), shibuya-core (>=0.10 && <0.11), shibuya-kiroku-adapter, stm (>=2.5 && <2.6), streamly-core (>=0.3 && <0.4), text (>=2.0 && <2.2), time (>=1.12 && <1.15), unordered-containers (>=0.2 && <0.3), uuid (>=1.3 && <1.4), vector (>=0.13 && <0.14) [details]
License BSD-3-Clause
Author Nadeem Bitar
Maintainer nadeem@gmail.com
Uploaded by shinzui at 2026-09-22T13:42:15Z
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]
Executables lifecycle-live
Downloads 94 total (32 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]