aboutsummaryrefslogtreecommitdiffstats
path: root/src/node.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-03 00:26:42 +0100
committertv <tv@krebsco.de>2026-11-03 00:26:42 +0100
commitc070bef0c1005366104176c1fc5af8b8f63cf01f (patch)
treeeab3e6da7d2b0b4f2648a452a23b5f592091301a /src/node.rs
parent5e62e09d6fe2a03c7fdcda63c879d8fdd1dfb7b1 (diff)
add stream heartbeat
Diffstat (limited to 'src/node.rs')
-rw-r--r--src/node.rs3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/node.rs b/src/node.rs
index c1b0aea..8b18cd4 100644
--- a/src/node.rs
+++ b/src/node.rs
@@ -49,6 +49,8 @@ pub(crate) struct NodeConfig {
pub(crate) dashboard_url: Option<String>,
pub(crate) electorate_window: Duration,
pub(crate) clock_skew_warn: Duration,
+ /// `--stream-heartbeat`.
+ pub(crate) stream_heartbeat: Duration,
/// `--superseded-writes`.
pub(crate) superseded_writes: crate::remake::Superseded,
pub(crate) blob_chunk_bytes: u32,
@@ -121,6 +123,7 @@ impl Node {
dashboard_url: config.dashboard_url,
electorate_window: config.electorate_window,
clock_skew_warn: config.clock_skew_warn,
+ stream_heartbeat: config.stream_heartbeat,
superseded_writes: config.superseded_writes,
clock_ahead_ms: Default::default(),
clock_skew: Default::default(),