jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 02:49:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: Add metrics for file read triggered

Browse Source 
Usually, "Loading block data from ..." shouldn't be shown in logs at all. Add metrics to detect the file read.
This commit is contained in:
sprites0
2025-10-05 11:27:23 +00:00
parent 12f366573e
commit 4d83b687d4
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/pseudo_peer/sources/hl_node/mod.rs
View File

@ -52,6 +52,8 @@ pub struct HlNodeBlockSourceMetrics {
pub fetched_from_hl_node: Counter, pub fetched_from_hl_node: Counter,
/// How many times the HL node block source is fetched from the fallback /// How many times the HL node block source is fetched from the fallback
pub fetched_from_fallback: Counter, pub fetched_from_fallback: Counter,
/// How many times `try_collect_local_block` was faster than ingest loop
pub file_read_triggered: Counter,
} }
impl BlockSource for HlNodeBlockSource { impl BlockSource for HlNodeBlockSource {
@ -64,7 +66,9 @@ impl BlockSource for HlNodeBlockSource {
Box::pin(async move { Box::pin(async move {
let now = OffsetDateTime::now_utc(); let now = OffsetDateTime::now_utc();
if let Some(block) = Self::try_collect_local_block(local_blocks_cache, height).await { if let Some(block) =
Self::try_collect_local_block(&metrics, local_blocks_cache, height).await
{
Self::update_last_fetch(last_local_fetch, height, now).await; Self::update_last_fetch(last_local_fetch, height, now).await;
metrics.fetched_from_hl_node.increment(1); metrics.fetched_from_hl_node.increment(1);
return Ok(block); return Ok(block);
@ -155,6 +159,7 @@ impl HlNodeBlockSource {
} }
async fn try_collect_local_block( async fn try_collect_local_block(
metrics: &HlNodeBlockSourceMetrics,
local_blocks_cache: Arc<Mutex<LocalBlocksCache>>, local_blocks_cache: Arc<Mutex<LocalBlocksCache>>,
height: u64, height: u64,
) -> Option<BlockAndReceipts> { ) -> Option<BlockAndReceipts> {
@ -164,6 +169,7 @@ impl HlNodeBlockSource {
} }
let path = u_cache.get_path_for_height(height)?; let path = u_cache.get_path_for_height(height)?;
info!("Loading block data from {:?}", path); info!("Loading block data from {:?}", path);
metrics.file_read_triggered.increment(1);
let mut line_stream = LineStream::from_path(&path).ok()?; let mut line_stream = LineStream::from_path(&path).ok()?;
let scan_result = Scanner::scan_hour_file( let scan_result = Scanner::scan_hour_file(
&mut line_stream, &mut line_stream,