Queue supersession (shipped) and debounce/burst coalescing (#38) are per runtime instance: the pending-waiter registry and burst windows live in process memory. When multiple runtime instances share a production State (Redis/Postgres/NATS), same-scope events delivered to different instances are not superseded across instances — each instance dispatches its own most-recent/final event, and the Thread Lock only serializes them. Per-instance behavior is documented on ConcurrencyQueue-adjacent GoDoc in #38, but the upstream semantic is global newest-wins.
ADR 0012 anticipated this cost: "queue/debounce/burst need wait/coalesce coordination" on the Runtime State contract — the coordination piece was deliberately not shipped with either the queue slice or #38. Doing it properly needs a distributed newest-wins registration (per-scope CAS or fenced write with TTL) as a new State capability (presumably optional, like LockForcer, with per-instance fallback), implemented across memory/redis/postgres/NATS plus the conformance suite.
Raised by the round-4 Codex review on #38 (thread: #38 (comment)).
Generated with mux • Model: anthropic:claude-fable-5 • Thinking: xhigh
Queue supersession (shipped) and debounce/burst coalescing (#38) are per runtime instance: the pending-waiter registry and burst windows live in process memory. When multiple runtime instances share a production State (Redis/Postgres/NATS), same-scope events delivered to different instances are not superseded across instances — each instance dispatches its own most-recent/final event, and the Thread Lock only serializes them. Per-instance behavior is documented on
ConcurrencyQueue-adjacent GoDoc in #38, but the upstream semantic is global newest-wins.ADR 0012 anticipated this cost: "queue/debounce/burst need wait/coalesce coordination" on the Runtime State contract — the coordination piece was deliberately not shipped with either the queue slice or #38. Doing it properly needs a distributed newest-wins registration (per-scope CAS or fenced write with TTL) as a new State capability (presumably optional, like
LockForcer, with per-instance fallback), implemented across memory/redis/postgres/NATS plus the conformance suite.Raised by the round-4 Codex review on #38 (thread: #38 (comment)).
Generated with
mux• Model:anthropic:claude-fable-5• Thinking:xhigh