prisma-risk / tsoracle / 26427776142

95%

Build Type

push

github

Committed by web-flow

Commit Message

feat(openraft-toolkit): add ActiveWriteVersion cell and version constants (#460)

Replace the single `SCHEMA_VERSION` constant with three concepts and a
process-shared, runtime-mutable active write version, preparing the openraft
toolkit and driver for rolling on-disk / wire format evolution. Behavior is
preserved: every framed record still leads with byte 4 and no production code
path moves the cell.

The new public surface in `tsoracle-openraft-toolkit`:

- `MIN_READABLE_VERSION = 4` / `MAX_READABLE_VERSION = 4` — inclusive readable
  range. Disk reads (and, later, peer RPC reads) accept any version in this
  range; the toolkit's record helpers now validate against the range rather
  than equality with a single constant.
- `BASELINE_WRITE_VERSION = 4` — the default version a fresh node emits.
- `ActiveWriteVersion(Arc<AtomicU8>)` — the single source of truth for the
  version this node currently stamps. `Clone` is a refcount bump, so every
  writer that holds a clone observes a `set()` immediately.
- `recover_active_write_version(snapshot_leading_byte, highest_log_record_byte)`
  computes `max(BASELINE, ...)` from fsync-durable evidence; bootstrap seeds
  the cell from this once.
- `RocksdbLogStore::with_active_write_version(cell)` /
  `active_write_version()` accessor / `highest_log_record_version()` raw
  reverse scan over the log CF.

`RocksdbLogStore`'s three encode helpers (`encode_entry_record`,
`encode_vote_record`, `encode_log_id_record`) now take a `version: u8`
parameter sourced from the cell at call time; `unframe_with_version` widens
to the readable range. The meta helpers (`put_vote`, `put_log_id`) thread the
same version through.

In `tsoracle-driver-openraft`: `HighWaterStateMachine` gains a cell field, a
`with_store_and_active_version` constructor, and an `active_write_version()`
accessor; snapshot build/install encode at the cell's current version and
decode over `[MIN_READABLE_VERSION, MAX_READABLE_VERSION]`. The
`VersionedCodec` i... (continued)

Coverage Stats

241 of 258 new or added lines in 6 files covered. (93.41%)

1 existing line in 1 file now uncovered.

12184 of 12774 relevant lines covered (95.38%)

461115.65 hits per line