feat(server): add deferred PollMessages wait timeout - #3605

Closed

arunsingh wants to merge 25 commits into

apache:masterfrom

arunsingh:feat/poll-messages-wait-timeout

Commits on Jul 31, 2026

test(binary-protocol): cover poll timeout wire format
arunsingh
committed
9b6a9ab
test(binary-protocol): tighten poll timeout byte assertion
arunsingh
committed
88d18ac
feat(common): add timeout-capable poll API
arunsingh
committed
fb6c72d
feat(common): send poll timeout over binary protocol
arunsingh
committed
db7f202
feat(sdk): expose poll timeout on Rust client
arunsingh
committed
ef597cd
feat(sdk): route poll timeout through client wrapper
arunsingh
committed
ba36db4
feat(server): pass poll timeout from binary handler
arunsingh
committed
7366b4e
feat(server): carry poll timeout in shard args
arunsingh
committed
fbeba7e
feat(server): add poll waiter registry
arunsingh
committed
b43b1ab
feat(server): store poll waiter registry per shard
arunsingh
committed
29adab3
fix(server): restore shard module with poll waiters
arunsingh
committed
43304d2
feat(server): initialize poll waiter registry
arunsingh
committed
cec70a5
feat(server): park empty timed binary polls
arunsingh
committed
e201bbe
feat(server): wake poll waiters on partition changes
arunsingh
committed
dbbb72a
Fix poll waiter registry cleanup borrows
arunsingh
committed
25db4ea
style: format poll waiter changes
arunsingh
committed
9274396
Add deferred PollMessages wait timeout
arunsingh
committed
91b30d1
bench: add poll wait timeout comparison runner
arunsingh
committed
24026c5
chore(bench): extend poll timeout comparison
arunsingh
committed
6213fea
fix(bench): map websocket transport for poll comparison
arunsingh
committed
33e2904
fix: address deferred polling review feedback
arunsingh
committed
459a4b7

Navigation Menu

Uh oh!

feat(server): add deferred PollMessages wait timeout - #3605

feat(server): add deferred PollMessages wait timeout#3605
arunsingh wants to merge 25 commits into
apache:masterfrom
arunsingh:feat/poll-messages-wait-timeout

Commits on Jul 31, 2026

test(binary-protocol): cover poll timeout wire format

test(binary-protocol): tighten poll timeout byte assertion

feat(common): add timeout-capable poll API

feat(common): send poll timeout over binary protocol

feat(sdk): expose poll timeout on Rust client

feat(sdk): route poll timeout through client wrapper

feat(server): pass poll timeout from binary handler

feat(server): carry poll timeout in shard args

feat(server): add poll waiter registry

feat(server): store poll waiter registry per shard

fix(server): restore shard module with poll waiters

feat(server): initialize poll waiter registry

feat(server): park empty timed binary polls

feat(server): wake poll waiters on partition changes

Fix poll waiter registry cleanup borrows

style: format poll waiter changes

Add deferred PollMessages wait timeout

bench: add poll wait timeout comparison runner

chore(bench): extend poll timeout comparison

fix(bench): map websocket transport for poll comparison

fix: address deferred polling review feedback

Commits on Aug 1, 2026

Merge branch 'master' into feat/poll-messages-wait-timeout

fix: update simulator poll request

fix: gate reconnect producer scenario for vsr

fix: share poll waiter live counter