@hackage / shibuya-kiroku-adapter

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.