github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-26 15:48:13 -05:00
Code Issues Packages Projects Releases Wiki Activity

feat: add metrics for failed deliveries (#11456)

Browse Source
This commit is contained in:
Matthias Seitz
2024-10-03 15:44:41 +02:00
committed by GitHub
parent ac85fc0507
commit 91af1a75c2
2 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
crates/engine/tree/src/tree/metrics.rs
View File

@@ -34,6 +34,14 @@ pub(crate) struct EngineMetrics {
pub(crate) new_payload_messages: Counter,
/// Histogram of persistence operation durations (in seconds)
pub(crate) persistence_duration: Histogram,
/// Tracks the how often we failed to deliver a newPayload response.
///
/// This effectively tracks how often the message sender dropped the channel and indicates a CL
/// request timeout (e.g. it took more than 8s to send the response and the CL terminated the
/// request which resulted in a closed channel).
pub(crate) failed_new_payload_response_deliveries: Counter,
/// Tracks the how often we failed to deliver a forkchoice update response.
pub(crate) failed_forkchoice_updated_response_deliveries: Counter,
// TODO add latency metrics
}

8
crates/engine/tree/src/tree/mod.rs
View File

@@ -1219,6 +1219,10 @@ where
if let Err(err) =
tx.send(output.map(|o| o.outcome).map_err(Into::into))
{
self.metrics
.engine
.failed_forkchoice_updated_response_deliveries
.increment(1);
error!(target: "engine::tree", "Failed to send event: {err:?}");
}
}
@@ -1230,6 +1234,10 @@ where
)
})) {
error!(target: "engine::tree", "Failed to send event: {err:?}");
self.metrics
.engine
.failed_new_payload_response_deliveries
.increment(1);
}
}
BeaconEngineMessage::TransitionConfigurationExchanged => {