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 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

Maintainer's Corner

Package maintainers

For package maintainers and hackage trustees

Candidates

  • No Candidates
Versions [RSS] 0.1.0.0
Change log CHANGELOG.md
Dependencies aeson (>=2.1 && <2.3), base (>=4.18 && <5), effectful-core (>=2.4 && <2.7), kiroku-store (>=0.1 && <0.2), shibuya-core (>=0.5 && <0.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-05-23T21:17:03Z
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 1 total (1 in the last 30 days)
Rating (no votes yet) [estimated by Bayesian average]
Your Rating
  • λ
  • λ
  • λ
Status Docs uploaded by user [build log]
All reported builds failed as of 2026-05-23 [all 1 reports]