enh: refactor sync flow to channel-based pipeline - #584

Merged

lioraron merged 7 commits into

evacchi:refactor-async-pipeline-direct

Jul 17, 2026

Commits on Jul 17, 2026

add sync dispatchers: Direct, AIMD, and MetricsGate
evacchi
committed
736eff3
double counting in direct dispatcher
evacchi
committed
746b1cd
semaphore err handling
evacchi
committed
d52d3eb
add comment on Drain behavior
evacchi
committed
32a48c9
add comment on Produce + skip I/O on error
evacchi
committed
636ff69
fix: minimal item has empty CustomID, which causes Resolve() to silently drop it
evacchi
committed
4733f8b
delete original executeJob() codepath
evacchi
committed
132d104