Test partitioned subscription ordering, concurrency, and shutdown
维护者通常 7 天内回复
还没有人认领这个 Issue。
评估
调研方向
Start with src/Eventuous.Subscriptions/Filters/PartitioningFilter.cs and the existing subscription tests to find how to configure a consume pipeline and observe partition metadata. Add coordinated tests for ordering, independent progress, key assignment, and graceful shutdown, using bounded waits and no external broker. Done means all acceptance criteria pass; run the focused subscription tests and collect coverage for this path.
由索引模型根据 Issue 内容生成。
描述
Problem
PartitioningFilter has no recorded line coverage in the October 5, 2026 .NET 10 coverage run. It selects a partition and routes each message through a serial handling worker, so failures here could reorder events, block unrelated work, or lose accepted messages during shutdown. You can view a test coverage report I generated here: index.html
Source: PartitioningFilter.cs.
Proposed tests
- Send multiple events for the same stream through a configured consume pipeline. Block the first handler and verify that later events in its partition cannot overtake it.
- Send events to distinct partitions and verify that an unblocked partition can progress while another handler is blocked.
- Verify default stream-based partitioning and a configured custom partition key through the partition metadata received by handlers.
- Exercise different keys that map to the same partition and verify serial processing within that partition.
- Begin shutdown while accepted work is queued. Verify that graceful shutdown waits for that work to finish and does not process messages twice.
Acceptance criteria
- Ordering and independent progress are asserted through actual message handling in a consume pipeline.
- Default and custom partition keys produce the expected handler-visible partition metadata.
- Graceful shutdown accounts for every accepted message before completing.
- Tests use explicit coordination signals and bounded waits instead of arbitrary sleeps to establish ordering.
- Tests do not call the hashing implementation or task extensions directly.
- No external broker or Docker container is required.
Validation
Run the focused subscription tests and collect coverage for the partitioning path. Use controlled keys or an injected hash where needed to make partition assignment deterministic, while retaining a test of the default configuration.
- 主要语言
- C#
- 星标
- 512
- 派生
- 99
- 平均合并
- 5 天 6 小时
- 30 天内合并 PR
- 5
环境准备
- 提供 Dockerfile 或 Docker Compose 文件
- 没有 Pull Request 模板
- 阅读贡献指南
从这里开始
- 先读完整个 Issue，再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库，在一个分支上完成修改。
- 提交 Pull Request，并在描述里引用这个 Issue 编号。
Eventuous/eventuous 的其他 Issue
-
MongoDB integration tests fail on newer GitHub Actions runner kernels可能已有人在做 @nmummau 于 2 天前认领。 未关闭
难度 2/5 1-3 小时 新手友好度 74/100
Eventuous/eventuous#626 · 2 条评论 ·
维护者通常 7 天内回复
-
`dotnet format style --verify-no-changes` fails with naming violations and unnecessary imports可能已有人在做 @nmummau 于 2 天前认领。 未关闭
难度 2/5 1-3 小时 新手友好度 80/100
Eventuous/eventuous#624 · 1 条评论 ·
维护者通常 7 天内回复
-
难度 5/5 一周以上 新手友好度 35/100
Eventuous/eventuous#627 · 1 条评论 ·
维护者通常 7 天内回复
-
SQL Server: `append_events` does not need the `@inserted` table variable可能已有人在做 @nmummau 于 8 天前认领。 未关闭
难度 3/5 1-2 天 新手友好度 20/100
Eventuous/eventuous#619 · 1 条评论 ·
维护者通常 7 天内回复
-
SQL Server: stream reads do one key lookup per event, and `IDX_EventsStream` duplicates `UQ_StreamIdAndStreamPosition`可能已有人在做 @nmummau 于 8 天前认领。 未关闭
难度 3/5 1-2 天 新手友好度 18/100
Eventuous/eventuous#618 · 1 条评论 ·
维护者通常 7 天内回复
查看 Eventuous/eventuous 的全部 Issue
相似的 Issue
-
Bug Platform: Android
难度 2/5 1-3 小时 新手友好度 78/100
getsentry/sentry-dotnet#5764 · 1 条评论 ·
维护者通常 1 天内回复
-
难度 2/5 1-3 小时 新手友好度 68/100
维护者通常 1 天内回复
-
难度 2/5 1-3 小时 新手友好度 78/100
microsoft/SimpleL7Proxy#287 ·
维护者通常 1 天内回复
-
bug priority: P2
难度 1/5 1 小时以内 新手友好度 78/100
维护者通常 1 天内回复
-
难度 2/5 1-3 小时 新手友好度 76/100
IridiumIO/CompactGUI#699 ·
维护者通常 3 天内回复