databendlabs / openraft / 15236981491

88%

main: 88%

Build Type

push

github

Committed by drmingdrmer

Commit Message

feat: add `Raft::get_read_linearizer()`

Add new API `Raft::get_read_linearizer()` to implement linearizable
reads. It provides a clearer API and gives users intuitive guidance
on how to perform local linearizable reads or follower reads, i.e.,
get `read_log_id` from a remote leader but read the local state machine.

`Raft::get_read_linearizer()` ensures leadership and returns a
`Linearizer` instance containing `read_log_id` and the last `applied`
log ID in the state machine. The caller, either on the local node or on
a remote follower, calls `Linearizer::await_applied()` to block until
the state machine applies up to `read_log_id` to assert linearizability.

A typical usage of follower read:

```rust,ignore
// Application defined RPC to get the `read_log_id` from the remote leader
let leader_id = my_raft.current_leader().await?.unwrap();
let linearizer = my_app_rpc.get_read_linearizer(leader_id, ReadPolicy::ReadIndex).await?;

// Block waiting local state machine to apply up to the `read_log_id`
let _ = linearizer.await_applied(&my_raft, None).await?.unwrap();

// Following read from state machine is linearized across the cluster
let val = my_raft.with_state_machine(|sm| { sm.read("foo") }).await?;
```

Run Details

63 of 79 new or added lines in 7 files covered. (79.75%)

1 existing line in 1 file now uncovered.

9840 of 10890 relevant lines covered (90.36%)

97687.84 hits per line