Repository navigation

feat(qwp)!: stop flushing pooled senders on close, add a commit window and a lease-scoped reset - #108

Open

jovfer wants to merge 57 commits into

mainfrom

sm_pool_flush_on_close

Open

feat(qwp)!: stop flushing pooled senders on close, add a commit window and a lease-scoped reset#108
jovfer wants to merge 57 commits into
mainfrom
sm_pool_flush_on_close

Commits on Oct 15, 2026
- feat(qwp): add checkError, hasRowInProgress and pendingRowCount probes to Sender
  
  jovfer
  and
  claude
  committed
  a8358f9
- feat(pool)!: pooled close() releases the slot without flushing; flush_on_close restores the old path
  
  jovfer
  and
  claude
  committed
  0f9155e
- test(pool): opt the flush-failure discard test into flush_on_close
  
  jovfer
  and
  claude
  committed
  030c53a
- test(pool): alphabetical test order, no reflection in the cancel-failure test, stronger assertions
  
  jovfer
  and
  claude
  committed
  5c9f15c
- feat(pool): settleIdle ships rows left in idle slots through an internal lease
  
  jovfer
  and
  claude
  committed
  e15d20a
- fix(pool): deterministic settle tests, retire on Error, log retired settle slots
  
  jovfer
  and
  claude
  committed
  52cc2b1
- feat(pool): housekeeper settles idle slots on its own cadence
  
  jovfer
  and
  claude
  committed
  ddaaa46
- feat(pool): flush_on_close key and builder option; settle cadence follows auto_flush_interval
  
  jovfer
  and
  claude
  committed
  81cba03
- fix(pool): parse auto_flush_interval for the settle cadence with the connect-string number syntax
  
  jovfer
  and
  claude
  committed
  f99cd3c
- test(pool): end-to-end close/flush/settle behaviour on the wire
  
  jovfer
  and
  claude
  committed
  8a22d6a
- fix(pool): drop the unreachable auto_flush_interval=off branch from the settle cadence
  
  jovfer
  and
  claude
  committed
  5f5f51a
- docs(pool): close releases, flush ships, drain waits; adjust tests that relied on close flushing
  
  jovfer
  and
  claude
  committed
  0b10240
- feat(qwp): rowsAppended, flushDeferred and hasDeferredFrames on Sender
  
  jovfer
  and
  claude
  committed
  74343ba
- fix(qwp): sort rowsAppended, pin no-commit-message on the wire, document the defaults
  
  jovfer
  and
  claude
  committed
  9884f80
- feat(pool): commit window: deferred frames per close, one commit per window, settle commits idle groups
  
  jovfer
  and
  claude
  committed
  d252415
- fix(pool): reject negative commit windows, pin the settle reset, tighten close() docs
  
  jovfer
  and
  claude
  committed
  a3a333a
- feat(pool): commit_rows and commit_interval_ms keys; window requires flush_on_close=on
  
  jovfer
  and
  claude
  committed
  4a15032
- fix(pool): keep build() idempotent for the commit window; range-check string window keys
  
  jovfer
  and
  claude
  committed
  27b7082
- test(pool): commit window on the wire: flags, age, settle commit, terminal and retriable rejections
  
  jovfer
  and
  claude
  committed
  6803675
- fix(pool): pooled close() wraps the delegate's error so try-with-resources keeps the primary exception
  
  jovfer
  and
  claude
  committed
  2ce9706
- fix(pool): keep retryable on the close() wrapper; order handler members; tolerate a late-latched terminal in the test
  
  jovfer
  and
  claude
  committed
  e2cae49
- docs(pool): commit window keys; add the borrow-per-row benchmark
  
  jovfer
  and
  claude
  committed
  9ffb041
- test(pool): restore @Ignore on the benchmark
  
  jovfer
  and
  claude
  committed
  58e7102
- fix(pool): surface shutdown and settle ship failures, keep the window mark on drain, typed close errors
  
  jovfer
  and
  claude
  committed
  21bfb59
- test(pool): make the window-reset tests fail when drain() or flush() skips the mark
  
  jovfer
  and
  claude
  committed
  0b2d5ba
- feat(qwp): bound the byte trigger by the server's batch cap when auto_flush_bytes is unset
  
  jovfer
  and
  claude
  committed
  b97e99c
- feat(qwp): table buffer savepoint: mark a row boundary and roll back to it
  
  jovfer
  and
  claude
  committed
  3cc1507
- fix(qwp): retainInProgressRow moves the table buffer savepoint like reset does
  
  jovfer
  and
  claude
  committed
  90d2654
- fix(qwp): savepoint rollback keeps a retained column's geohash precision; tests for the retain and never-marked cases
  
  jovfer
  and
  claude
  committed
  4f8fa65
- feat(qwp): markSavepoint and resetToSavepoint on Sender; checkError reports a retained over-cap batch
  
  jovfer
  and
  claude
  committed
  557152d
- fix(qwp): resetToSavepoint restores the symbol watermark and drops unsent column definitions
  
  jovfer
  and
  claude
  committed
  142dc25
- fix(qwp): resetToSavepoint reclaims the symbol ids the dropped rows registered
  
  jovfer
  and
  claude
  committed
  e43a6d8
- fix(pool): reset() on a lease discards only that lease's rows
  
  jovfer
  and
  claude
  committed
  23f4f0b
- fix(pool): retire a slot whose batch the server cap rejects
  
  jovfer
  and
  claude
  committed
  13838bf
- fix(pool): place pendingRowsOf after hasUnshippedWork; say unshipped, not dropped, in the close wrapper
  
  jovfer
  and
  claude
  committed
  66b8739
- fix(pool): retry failed startup recovery once a second, saturate housekeeper deadlines
  
  jovfer
  and
  claude
  committed
  41ab789
- fix(pool): place deadline() and the recovery constant at their alphabetical positions
  
  jovfer
  and
  claude
  committed
  0915532
- test(pool): pin the window age restart, flushAndGetSequence's mark, the retryable wrapper and the settle Error path
  
  jovfer
  and
  claude
  committed
  287f29d
- docs(pool): state frame-level fate sharing instead of promising replay; fix the examples; license headers
  
  jovfer
  and
  claude
  committed
  c42d7a5
- docs(pool): remove the last example comment that says close() flushes; wrap two long lines
  
  jovfer
  and
  claude
  committed
  f586ac5
- fix(pool): a lease whose row crosses the cap margin no longer takes earlier leases' rows down with it
  
  jovfer
  and
  claude
  committed
  219144b
- fix(pool): pool messages drop the standalone remedy, client-side drops log at ERROR, savepoint Javadoc for pooled senders
  
  jovfer
  and
  claude
  committed
  0b23f31
Commits on Oct 16, 2026
- fix(pool): mark the borrow savepoint after releasing the pool lock
  
  jovfer
  and
  claude
  committed
  89ee6d9
- fix(pool): a release ships rows older than auto_flush_interval
  
  jovfer
  and
  claude
  committed
  24be1a0
- feat(qwp): a table buffer can hold back its last committed row
  
  jovfer
  and
  claude
  committed
  f26fa8d
- fix(qwp): a row that pushes the batch over the cap ships the rows before it
  
  jovfer
  and
  claude
  committed
  7747319
- fix(qwp): a held row alone in its table keeps the savepoint columns
  
  jovfer
  and
  claude
  committed
  c9259f8
- fix(qwp): a held row over the byte budget flushes on its own at once
  
  jovfer
  and
  claude
  committed
  d2bba3b
- fix(pool): housekeeper deadlines follow a monotonic clock
  
  jovfer
  and
  claude
  committed
  49bf8ae
- fix(pool): settle takes one idle slot at a time
  
  jovfer
  and
  claude
  committed
  95d540f
- fix(qwp): appendBlocking parks instead of spinning when interrupted
  
  jovfer
  and
  claude
  committed
  4255613
- test(qwp): drop debug print from appendBlocking interrupt test
  
  jovfer
  and
  claude
  committed
  8b29691
- fix(qwp): an empty savepoint stores symbol watermark -1
  
  jovfer
  and
  claude
  committed
  df6b841
- docs(pool): scope rejection isolation to no commit window; state the byte-trigger default
  
  jovfer
  and
  claude
  committed
  b5d5fb4
- fix(qwp): final review round-2 fix-ups
  
  jovfer
  and
  claude
  committed
  b2de8e4
Commits on Oct 17, 2026
- fix(qwp): keep released rows visible at pool close and reap
  
  jovfer
  and
  claude
  committed
  d8ab9be
- docs(pool): describe what a release ships accurately
  
  jovfer
  and
  claude
  committed
  47603c7

Commits

Commits on Oct 15, 2026

Commits on Oct 16, 2026

Commits on Oct 17, 2026