Skip to content

Commit

Permalink
chore: refactor XRead (#3775)
Browse files Browse the repository at this point in the history 
Previously XREAD:
- Fetched group consumer info (with a hop)
- Looked up last stream ids (with a hop)
- Determined if there are entries to read (on coordinator)
- Dispatched a hop to read entries or retired to blocking mode

Instead we can merge steps (1), (2) and (3) into a single step, optionally with step (4) for single shard operations that can avoid concluding (we had this optimization before)
  • Loading branch information
@dranikpg
dranikpg authored Sep 27, 2024
1 parent 895567f commit 55699a9
Show file tree
Hide file tree
Showing 2 changed files with 146 additions and 282 deletions.
Loading

0 comments on commit 55699a9

Please sign in to comment.