Example gaming leaderboard application covering streaming ingestion, CDC enrichment, processing and visualisation including demo of advance real-time analytics concepts like late data arrival, exactly-once, dynamic config, archival and on-demand replay
A full agent framework on the Vercel AI SDK, durable from the core: exactly-once tool calls, deterministic replay, time-travel.
Streaming data pipeline in TypeScript: segmented append-only log with CRC and crash recovery, credit-based backpressure (429 Retry-After instead of an unbounded buffer), idempotent producers, exactly-once materialisation into a time-series store.
A task queue that makes sure each job, like a payment, happens exactly once, even when something crashes.
Deduplicate keyed agent steps and HTTP retries with cached results, a local proxy and optional JSON-file persistence.
Paced outbound messaging with anti-ban rails and exactly-once delivery across concurrent workers. Transport-agnostic, TypeScript.
Idempotent healthcare EDI processing: make at-least-once delivery safe with the inbox + outbox pattern — dedup by ISA13, effectively-once processing, exactly-once effects. TypeScript, with tests and a live playground.
Exactly-once job processing for BullMQ: key-based deduplication, claim TTLs with heartbeats, retry with backoff, and a dead-letter queue.
Exactly-once processing for webhooks, events, and jobs. Dedupe, crash recovery, and dead-letter handling in one call.
Real-time event analytics dashboard with an exactness harness: every accepted event counted once, under redelivery and mid-batch failure.
Is that UPI payment real? Checks the buyer's screenshot against the bank's DKIM-signed credit alert. Each credit pays for one order only, enforced by Aurora DSQL. Lambda, Textract, KMS, CDK.
Run a side effect at most once per key — crash-safe idempotency for at-least-once schedulers (cron double-fires, queue redelivery, lambda retries).
Lets long-running AI workflows pause for approval and resume exactly once after disconnects or restarts, without binding to one agent protocol.
Generic idempotency for Node.js — execute any operation exactly once per key, with pluggable storage, explicit concurrency semantics, and first-class observability.
Distributed delayed notification queue on PostgreSQL (FOR UPDATE SKIP LOCKED) with NestJS
Agent-safe payouts: a typed toolbox and MCP server that lets Claude work payment incidents on the Airwallex sandbox without ever paying a supplier twice.
Idempotency keys for Solana. Retry without executing twice. At-most-once successful execution of a guarded logical intent within a configurable retention window.
Idempotency kernel for TypeScript. 1,000 racing callers, exactly one execution — proven under forced races, zero dependencies.
Idempotent webhook to BullMQ worker pipeline.
To associate your repository with the exactly-once topic, visit your repo's landing page and select "manage topics."