databendlabs / openraft / 19926825449

88%

Build Type

push

github

Committed by drmingdrmer

Commit Message

change: use `stream_append()` in `ReplicationCore` for log replication

Refactor `ReplicationCore` to call `RaftNetworkV2::stream_append()` instead of
`append_entries()` for log replication. This prepares the codebase for pipelined
replication, though the current implementation still uses request-response pattern.

Changes:
- Change `RaftNetworkV2::stream_append()` return type from `impl Stream` to
  `BoxFuture<BoxStream>` to avoid higher-ranked lifetime error
- Add `InflightAppend` and `InflightAppendQueue` for tracking in-flight requests
- Add `StreamState` and `StreamContext` for stream-based request generation
- Add `backoff_rank()` to `RPCError` for adaptive retry backoff
- Extract `ReplicationContext` with cancellation channel support

Upgrade tip:

If you implement `RaftNetworkV2::stream_append()`, update the return type from:
```rust
fn stream_append<'s, S>(...) -> impl Stream<...> + 's
where S: ... + 'static
```
to:
```rust
fn stream_append<'s, S>(...) -> BoxFuture<'s, Result<BoxStream<'s, ...>, RPCError<C>>>
where S: ... + 's
```

Run Details

339 of 363 new or added lines in 13 files covered. (93.39%)

13 existing lines in 4 files now uncovered.

14132 of 15253 relevant lines covered (92.65%)

151865.78 hits per line