bedrock-kv / bedrock / 365331e9902e8e857be4c7ae5c2ed2a469d4c715-PR-65

66%

develop: 65%

Build Type

Pull #65

github

Committed by jallum

Commit Message

Add Demux service for per-shard transaction distribution

Implements the Demux system that receives committed transactions from Log,
slices mutations by shard using SHARD_INDEX, and routes to per-shard
ShardServers for buffering and ObjectStorage persistence.

Key components:
- MutationSlicer: Extracts per-shard slices from transactions
- Durability: Tracks min durable version across shards using gb_sets
- ShardServer: Per-shard GenServer with buffer, flush, and long-pull API
- Server: Coordinator that routes transactions and tracks durability
- Supervisor: one_for_all supervision for consistency on crash

Also extends WaitingList with remove_all_less_than/2 for range-match
semantics needed by ShardServer long-pull notifications.

Pull Request Pull Request #65: Feature/bedrock as6j

Run Details

818 of 982 new or added lines in 44 files covered. (83.3%)

7 existing lines in 3 files now uncovered.

4986 of 7386 relevant lines covered (67.51%)

1960.9 hits per line