feat!: async microsvc transports + persistence matrix + async-only consolidation - #47

Merged

patrickleet merged 39 commits into

mainfrom

feat/bus-transports

May 30, 2026

Commits on May 28, 2026

refactor: remove old pattern
patrickleet
committed
3186c2b

Commits on May 29, 2026

feat(transport): async transport foundation in microsvc::transport

patrickleet
and
claude
committed
9f0dfc1
test(transport): reusable conformance harness + in-memory reference run

patrickleet
and
claude
committed
bb10271
feat(transport): Postgres durable receive via OutboxSource

patrickleet
and
claude
committed
70298e1
feat(transport): NATS JetStream adapter + integration tests + CI

patrickleet
and
claude
committed
b7ca692
feat(transport): RabbitMQ (AMQP) adapter + integration tests + CI

patrickleet
and
claude
committed
a5b9a8b
feat(transport): Knative CloudEvents HTTP ingress

patrickleet
and
claude
committed
512b688
feat(transport): Kafka adapter + integration tests + CI

patrickleet
and
claude
committed
8a78405
ci: extract integration tests to reusable workflows; run on push-to-main

patrickleet
and
claude
committed
2b1b372
docs(transport): add async transports guide

patrickleet
and
claude
committed
efbf5bc
feat(transport): add Bus/BusConsumer facade + InMemoryBus

patrickleet
and
claude
committed
5bab4ec
feat(transport): add NatsBus (send/listen + publish/subscribe)

patrickleet
and
claude
committed
d59ec24
feat(transport): add PostgresBus (work queue + log/offset fan-out)

patrickleet
and
claude
committed
5e80467
feat(transport): add RabbitBus (send/listen + publish/subscribe)

patrickleet
and
claude
committed
0121e45
feat(transport): add KafkaBus (send/listen + publish/subscribe)

patrickleet
and
claude
committed
14de16a
feat(transport): add KnativeBus (Bus produce + manifest generation)

patrickleet
and
claude
committed
9cc8b40
docs(transport): document the bus facade + transport-swap example

patrickleet
and
claude
committed
e19fb3a
ci: install libcurl dev headers for the rdkafka build

patrickleet
and
claude
committed
f528994
docs(read-model): clarify ReadModelCommitOutcome is an intentional stub

patrickleet
and
claude
committed
f91c9fc
fix(transport): address CodeRabbit review on PR #47

patrickleet
and
claude
committed
4ef3a6c
feat(inbox): add InboxReceipt/InboxOutcome + CommitBatch participant field

patrickleet
and
claude
committed
6213cc8
feat(inbox): persist consumer_inbox receipts across all backends

patrickleet
and
claude
committed
266e7ee
test+fix(inbox): empty-receipt parity + shared conformance scenario

patrickleet
and
claude
committed
bb2209e

Commits on May 30, 2026

test(matrix): generic transport×persistence harness + in-memory cell

patrickleet
and
claude
committed
94f69f7
test(matrix): full transport×persistence matrix over the bus facade

patrickleet
and
claude
committed
bb6230f
test(matrix): complete transport×persistence grid + refactor gold-standard test onto the async bus

patrickleet
and
claude
committed
b35f771
test(cutover): migrate transport_subscribe onto the async InMemoryBus

patrickleet
and
claude
committed
6eb448f
feat(read-model): async ReadModelWorkspace (load_async/commit_async parity)

patrickleet
and
claude
committed
1cfaef4
feat(queued-repo): async QueuedRepository — per-aggregate serialization over the async surface

patrickleet
and
claude
committed
b0b0e79
test(cutover): migrate transport_listen onto the async InMemoryBus

patrickleet
and
claude
committed
f9d175f
test(cutover): migrate microsvc_saga distributed test onto the async InMemoryBus

patrickleet
and
claude
committed
a87edcf
test(cutover): remove superseded raw-legacy-bus saga tests (distributed.rs)

patrickleet
and
claude
committed
cf18eda
test(cutover): decouple projection handlers from bus::Event; migrate board onto InMemoryBus

patrickleet
and
claude
committed
c0bd6a5
refactor!: remove the legacy sync bus

patrickleet
and
claude
committed
a64f92c
feat(microsvc)!: async handler model (core) — handlers become async fn

patrickleet
and
claude
committed
27f58ea
test(microsvc)!: migrate all integration test crates to async handlers

patrickleet
and
claude
committed
5e70ac1
refactor!: remove the sync repository API — the crate is now async-only

patrickleet
and
claude
committed
5a67159
test: gate matrix table_schema_registry helper to postgres/sqlite

patrickleet
and
claude
committed
e2da936
test: address CodeRabbit review (block_on, handler panic, weak assertion)

patrickleet
and
claude
committed
47466ea