diff options
| author | tv <tv@krebsco.de> | 2026-11-03 00:26:42 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-03 00:26:42 +0100 |
| commit | c070bef0c1005366104176c1fc5af8b8f63cf01f (patch) | |
| tree | eab3e6da7d2b0b4f2648a452a23b5f592091301a /src/node.rs | |
| parent | 5e62e09d6fe2a03c7fdcda63c879d8fdd1dfb7b1 (diff) | |
add stream heartbeat
Diffstat (limited to 'src/node.rs')
| -rw-r--r-- | src/node.rs | 3 |
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(), |
