Durable execution for Rust on object storage, with transactional coordination and no database, broker or control plane to operate.
-
Updated
Oct 5, 2026 - Rust
#
at-least-once
Here are 43 public repositories matching this topic...
A set of C# libraries for streamlined microservice development: audit, caching, outbox, CAP, MassTransit (events & config), idempotency, specifications, security, and other useful utilities. Packages: https://www.nuget.org/profiles/dex
distributed-systems audit cap cache-control distributed-tracing masstransit security-tools security-token-service at-least-once outbox-pattern config-encryption
-
Updated
Oct 9, 2026 - C#
Qrono time-ordered queue server
-
Updated
Apr 9, 2023 - Rust
Transactional Outbox Pattern for Java: reliable, ordered event delivery from PostgreSQL to Kafka, with Spring Boot autoconfiguration. No CDC, no Kafka Connect.
java cli distributed-systems microservices kafka spring spring-boot postgresql event-driven apache-kafka observability event-driven-architecture cloudevents at-least-once outbox opentelemetry transactional-outbox outbox-pattern message-ordering transactional-outbox-pattern
-
Updated
Oct 12, 2026 - Java
Fire the same request or event N times concurrently and verify real database state to catch idempotency violations — across HTTP, Kafka, SQS, and RabbitMQ.
testing cli http distributed-systems kafka rabbitmq reliability concurrency sqs consumer api-testing duplicate idempotent idempotency at-least-once race-condition
-
Updated
Sep 14, 2026 - TypeScript
Go implementation of the Message Queue based on Redis Streams.
go redis streams message-queue retry delay-queue ratelimit at-least-once redis-streams opentelemetry
-
Updated
May 25, 2026 - Go
Transactional outbox event processor for Postgres and MongoDB — at-least-once delivery, near-realtime wakeup signals, graceful shutdown, and horizontal scalability.
events microservices typescript ddd background-jobs message-queue event-driven graceful-shutdown horizontal-scalable pg-notify at-least-once transactional-outbox outbox-pattern transactional-inbox osbytes
-
Updated
Oct 2, 2026 - TypeScript
Asynchronous event-driven job processing queue in Go with durable SQLite persistence, at-least-once execution, visibility timeouts, retries/DLQ, and crash recovery.
go golang backend sqlite job-scheduler concurrency background-jobs event-driven sqlite3 dispatcher job-queue producer-consumer graceful-shutdown goroutine-pool worker-pool system-design idempotency at-least-once visibility-timeout crash-recovery
-
Updated
Mar 29, 2026 - Go
Interactive browser simulator that visualizes delivery guarantees, idempotency, DLQ, Outbox and Inbox patterns across Azure Service Bus, Event Hubs, Event Grid, Kafka, RabbitMQ and more. Built for teaching Event-Driven Architecture.
redis azure eda event-driven pub-sub exactly-once event-driven-architecture dlq at-least-once delivery-guarantees outbox-pattern inbox-pattern at-most-once
-
Updated
May 29, 2026 - Vue
Transactional Outbox Pattern for Node.js + PostgreSQL — reliable at-least-once event delivery
nodejs redis microservices typescript postgresql event-driven at-least-once transactional-outbox outbox-pattern
-
Updated
Jul 8, 2026 - TypeScript
A durable at-least-once mpsc queue.
-
Updated
Oct 11, 2026 - Rust
SC4051 Distributed Systems Project. Bank System w/ different invocation semantics
-
Updated
Apr 7, 2026 - Java
When delayed-delivery: practical landing — packaging, Windows HA smoke, deployment/ops notes. Independent fork of oryx-labs/when; not an official upstream release.
java redis distributed-systems kafka grpc etcd high-availability observability at-least-once timing-wheel message-scheduling delayed-delivery
-
Updated
Sep 14, 2026 - Java
Kafka → TigerBeetle: a sink for applying financial commands from a stream, with poison/reject/infrastructure handling and DLQ — plus CDC back out.
golang kafka accounting ledger fintech event-driven kafka-connector cdc change-data-capture double-entry-accounting at-least-once financial-transactions franz-go tigerbeetle
-
Updated
Aug 25, 2026 - Go
A persistent message broker in Go — single-node or a replicated raft cluster. Append-only WAL with CRC framing, per-message fsync, at-least-once delivery, partitions, crash recovery, and leader-elected replication. A learning project.
golang distributed-systems replication raft consensus pubsub prometheus message-queue wal observability message-broker learning-project write-ahead-log at-least-once opentelemetry
-
Updated
Sep 19, 2026 - Go
Persistent cross-restart scheduler core: SQLite archive + lease-claim dispatch + full clock discipline. Zero framework dependencies. Every claim carries an experiment number.
-
Updated
Aug 26, 2026 - TypeScript
A transactional outbox for Postgres and Go: write events in the same transaction as your data
golang postgres messaging postgresql prometheus event-driven pgx at-least-once outbox transactional-outbox listen-notify outbox-pattern
-
Updated
Oct 1, 2026 - Go
Streaming fraud scoring end-to-end — durable event log with consumer groups + at-least-once delivery (crash recovery proven: 0/800 lost), online windowed features, ~10k events/s, precision 82%/recall 92%, PSI drift alerting
python machine-learning streaming real-time fraud-detection mlops at-least-once drift-detection consumer-groups online-features
-
Updated
Jul 25, 2026 - Python
Distributed SMS notification platform in Go on AWS — SQS, RDS Postgres behind RDS Proxy, KEDA autoscaling on k3s, Terraform. Load runs are gated on SQL invariants, and the campaign evidence is reconciled against CloudWatch.
go kubernetes golang aws distributed-systems terraform sms postgresql sqs load-testing prometheus idempotency at-least-once keda
-
Updated
Oct 5, 2026 - Go
A Postgres-backed job queue in Go with lease-based semantics, at-least-once delivery, and crash recovery — every tradeoff documented.
-
Updated
Aug 23, 2026 - Go
Add this topic to your repo
To associate your repository with the at-least-once topic, visit your repo's landing page and select "manage topics."