diff options
| author | tv <tv@krebsco.de> | 2026-10-20 06:10:48 +0200 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-20 06:10:48 +0200 |
| commit | e176d3f240498b28b2b3a1cff58e46ef2fc6fd6c (patch) | |
| tree | 7e2579b40ed09197d2623c4614f207e5ec3e95fe /src/compaction/mod.rs | |
| parent | f55a0d983790fb3ec3707c4be73d8a0d70231645 (diff) | |
serve stale reads during rejoin
Diffstat (limited to 'src/compaction/mod.rs')
| -rw-r--r-- | src/compaction/mod.rs | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/compaction/mod.rs b/src/compaction/mod.rs index f84d974..e44a840 100644 --- a/src/compaction/mod.rs +++ b/src/compaction/mod.rs @@ -69,6 +69,10 @@ pub(crate) trait Host: Clone + Send + Sync + 'static { /// Serves requests again after [`Host::suspend`]. fn resume(&self) -> impl Future<Output = ()> + Send; + /// Serves reads from this document (read-only, marked stale) while the node is not + /// ready; `None` ends it. + fn set_stale_view(&self, view: Option<(Epoch, AutoCommit)>); + /// Whether the document caught up with a peer since the last reset. fn initial_sync_done(&self) -> bool; |
