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