databendlabs / openraft / 19736997724

88%

Build Type

push

github

Committed by drmingdrmer

Commit Message

feat: add stream-oriented AppendEntries API for pipelined replication

Add `Raft::stream_append()` method that allows processing multiple AppendEntries
requests through a pipelined stream interface. This enables efficient batched
log replication with backpressure support via a bounded channel.

Example usage:

```rust
use std::pin::pin;
use futures::StreamExt;

let input = futures::stream::iter(vec![request1, request2, request3]);
let mut output = pin!(raft.stream_append(input));

while let Some(result) = output.next().await {
    match result {
        Ok(log_id) => println!("Flushed: {:?}", log_id),
        Err(err) => {
            println!("Error: {}", err);
            break;
        }
    }
}
```

Changes:
- Add `Raft::stream_append()` for stream-based AppendEntries processing
- Add `StreamAppendError` with `Conflict` and `HigherVote` variants
- Add `StreamAppendResult` type alias for stream item results
- Add `AppendEntriesResponse::into_stream_result()` conversion method
- Add `ProtocolApi::stream_append()` internal implementation
- Add integration tests for success, conflict, and higher vote scenarios

Run Details

64 of 74 new or added lines in 5 files covered. (86.49%)

13 existing lines in 3 files now uncovered.

13819 of 14946 relevant lines covered (92.46%)

154277.96 hits per line