1
88%
main: 88%

Ran 04 Dec 2025 11:11AM UTC

Files 229

Run time 8s

Badge

Embed ▾

Committed 04 Dec 2025 10:58AM UTC coverage: 92.651% (+0.2%) from 92.439%

Job # 19926825449.1

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

14132 of 15253 relevant lines covered (92.65%)

151865.78 hits per line

databendlabs / openraft / 19926825449 / 1
88%
main: 88%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 19926825449.1

databendlabs / openraft / 19926825449 / 1 88% main: 88%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 19926825449.1

databendlabs / openraft / 19926825449 / 1
88%
main: 88%

README BADGES
x