Opt-in batched terminal flush#131

Merged

lesnik512 merged 10 commits into

mainfrom

batched-terminal-flush

Jul 15, 2026

Commits on Jul 15, 2026

docs(planning): design for opt-in batched terminal flush
lesnik512
committed
feat: add delete_batch_with_lease client method with real-vs-fake parity
lesnik512
committed
feat: add terminal_flush_batch_size subscriber knob (default 1, validated)

lesnik512
and
claude
committed
feat: per-worker batched terminal flush behind terminal_flush_batch_size

lesnik512
and
claude
committed
test(subscriber): cover the batched-flush size trigger and DLQ inline path
lesnik512
committed
test+bench: drain-safety proof and gated batched-flush before/after

lesnik512
and
claude
committed
fix(subscriber): bound worker exit-flush with a timeout

lesnik512
and
claude
committed
fix(subscriber): task_done buffered rows on exit-flush cancellation
lesnik512
committed
docs(subscriber): sharpen benchmark determinism note, lease-bound formula, exit-flush comment
lesnik512
committed
test(subscriber): run exit-flush-timeout tests via create_task for 3.11 coverage
lesnik512
committed