prisma-risk / tsoracle / 26429349642

95%

push

github

feat(driver-openraft): add format-activation gate and Capabilities RPC (#463)

Adds the self-contained capability-query mechanism and the leader-side
all-members activation gate so an operator can ask, before any format bump
is proposed, "can every current member (voters AND learners) read the
target write version?" — answered without any admin service or CLI, using
a new peer RPC on the existing `RaftPeerService` plus an interim library
trigger method on `StandaloneHost`. The gate is computed and returned; the
proposal itself is a later phase.

**Shared types (`tsoracle-driver-openraft::capabilities`).**

- `NodeCapabilities { min_readable_version, max_readable_version,
  active_write_version: u8 }` plus `::local(active)` that reads the
  compile-time `MIN_READABLE_VERSION` / `MAX_READABLE_VERSION` constants.
- `all_members_can_read(target, &reports) -> Option<BTreeSet<NodeId>>`:
  pure gate predicate, `Some` iff every gathered member's
  `max_readable_version >= target`.
- `FormatActivationError { NotLeader, MembersBelowTarget { target,
  incapable }, MemberUnreachable { node_id, detail } }` — fail-loud
  surface for the operator trigger.
- `CapabilitySource` async trait with an associated `Node` type and a
  `query(node_id, member) -> Result<NodeCapabilities, String>` method.
  Defined here so the gate is testable in the driver crate without
  depending on the transport crate (which would invert the dep edge).
- `gather_with`: a free helper, generic over `CapabilitySource`, that
  answers the local node from `local_capabilities` directly and dials
  every other member via the source. Fails closed
  (`MemberUnreachable`) the moment any remote query fails.

**`StandaloneHost` methods.** `local_capabilities()`,
`membership_snapshot()` (reads `raft.metrics().borrow_watched()` —
membership covers voters AND learners, matching the all-members rule),
`gather_member_capabilities()`, `run_activation_gate(target, source) ->
Result<BTreeSet<u64>, FormatActiva... (continued)

171 of 174 new or added lines in 2 files covered. (98.28%)

12463 of 13063 relevant lines covered (95.41%)

420665.49 hits per line