WIP webhooks#3

Open

solsson wants to merge 34 commits into

mainfrom

Commits on Jun 5, 2026

test: sink-trait matrix + loop_invariants against real FilesystemSink

Yolean macbot01
and
claude
committed
test: discoverable ignored-tests for documented coverage gaps

Yolean macbot01
and
claude
committed
test: palette of testability enablers for TDD-style spec authoring

Yolean macbot01
and
claude
committed
proposes a webhook feature to close the KKV gap
solsson
committed
notify: phase 1 — config types + validation for the `notify` block

Yolean macbot01
and
claude
committed
notify: phase 2 — Notifier trait + NoOpNotifier wired into run loop

Yolean macbot01
and
claude
committed
notify: phase 3a+3b — kkv-v1 dispatcher with outcome-driven retry

Yolean macbot01
and
claude
committed
notify: phase 3c — source-consume debounce buffer

Yolean macbot01
and
claude
committed
notify: phase 5 — wire KkvV1Notifier into mirror-bin

Yolean macbot01
and
claude
committed
notify: phase 3d — DNS-A fan-out for K8s headless services

Yolean macbot01
and
claude
committed
notify: phase 4a — FlushObserver trait + FS/S3/Tee wiring

Yolean macbot01
and
claude
committed
notify: phase 4b — FlushDispatcher for trigger.on: destination-flush

Yolean macbot01
and
claude
committed
notify: phase 6 — e2e tests for source-consume + destination-flush

Yolean macbot01
and
claude
committed

Commits on Jun 6, 2026

cache: serve /q/health/ready alias for kkv-client onReady compat

solsson
and
claude
committed
ci: single-arch image build on PRs

Yolean macbot01
and
claude
committed
style: drop mdash and phase references per CLAUDE.md

Yolean macbot01
and
claude
committed
notify-kkv: include the `v: 1` protocol-version field in the body

solsson
and
claude
committed
notify-kkv: suppress until per-mirror bootstrap_hwm

solsson
and
claude
committed
cache-v1: per-mirror paths + cache-v1-main singleton alias

solsson
and
claude
committed

Commits on Jun 7, 2026

e2e: catch the harness up to the cache-v1 + suppression API changes

Yolean macbot01
and
claude
committed
core: add Source::commit_through + Source::fetch_committed_offset

Yolean macbot01
and
claude
committed
kafka: implement Source::commit_through + fetch_committed_offset

Yolean macbot01
and
claude
committed
core: add WriteObserver + AckSink + KafkaSink/MockSink wiring

Yolean macbot01
and
claude
committed
notify-kkv: wire AckSink into KkvV1Notifier + FlushDispatcher

Yolean macbot01
and
claude
committed
mirror-bin: per-mirror AckTracker + periodic source-commit task

Yolean macbot01
and
claude
committed
core: per-mirror suppression_threshold from committed offset

Yolean macbot01
and
claude
committed
core: MirrorStatus enum replaces caught_up: AtomicBool

Yolean macbot01
and
claude
committed
mirror-bin: per-mirror readiness poller (lag + assignment)

Yolean macbot01
and
claude
committed
config: per-destination affects-readiness field (default true)

Yolean macbot01
and
claude
committed
cache: structured /q/health/ready JSON + 503 body on per-mirror routes

Yolean macbot01
and
claude
committed
e2e: dev2 reproducer for between-pods notify gap

Yolean macbot01
and
claude
committed
docs: deployment-strategy requirement + structured readiness

Yolean macbot01
and
claude
committed
mirror-bin: register every enabled mirror, not just slot-needing ones

solsson
and
claude
committed

Commits on Jun 8, 2026

e2e: cache_v1 spec assertion follows the per-mirror path rename

solsson
and
claude
committed