• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

databendlabs / openraft / 19926825449
88%

Build:
DEFAULT BRANCH: main
Ran 04 Dec 2025 11:11AM UTC
Jobs 1
Files 229
Run time 2min
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst

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

push

github

drmingdrmer
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
```

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

New Missed Lines in Diff

Lines Coverage ∆ File
1
0.0
0.0% openraft/src/raft/message/stream_append_error.rs
2
44.88
1.55% openraft/src/error/mod.rs
6
96.89
4.41% openraft/src/replication/mod.rs
7
89.71
openraft/src/replication/stream_state.rs
8
0.0
openraft/src/replication/replication_context.rs

Uncovered Existing Lines

Lines Coverage ∆ File
1
91.44
1.13% openraft/src/core/raft_core.rs
2
92.0
-4.0% openraft/src/raft/message/append_entries_response.rs
2
93.88
-3.85% openraft/src/replication/request.rs
8
88.31
-10.39% openraft/src/core/heartbeat/worker.rs
Jobs
ID Job ID Ran Files Coverage
1 19926825449.1 04 Dec 2025 11:11AM UTC 229
92.65
GitHub Action Run
Source Files on build 19926825449
  • Tree
  • List 229
  • Changed 11
  • Source Changed 9
  • Coverage Changed 11
Coverage ∆ File Lines Relevant Covered Missed Hits/Line
  • Back to Repo
  • Github Actions Build #19926825449
  • db86423a on github
  • Prev Build on main (#19892261719)
  • Next Build on main (#19931711762)
  • Delete
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2026 Coveralls, Inc