khorolets / near-lake-pulse

Simple NEAR Lake indexer node that implements Prometheus endpoint for alerting

near-lake-pulse

It is a simple NEAR Lake indexer that just prints the block heights and exposes some Prometheus-friendly metrics:

• latest indexed block height
• number of blocks indexed

It is supposed to be used for healthcheck and check that the data we've reindexed to the AWS S3 buckets is consistent and doesn't have any gaps.

And also it can send alert notifications via TelegramBot (optional) if blocks per second rate drop to zero.

Usage

Don't forget you need to have ~/.aws/credentials with your AWS credentials

Basic:

./target/release/near-lake-pulse <chain_id> --block-height <BLOCK_HEIGHT>

Mainnet:

./target/release/near-lake-pulse mainnet --block-height 61941713

Testnet

./target/release/near-lake-pulse mainnet --block-height 85635752

With alerts:

./target/release/near-lake-pulse --telegram-token 123456789:blablabla --chat-id 1234567 --http-port 3030 mainnet --block-height 85635752

near-lake-pulse's Issues

BPS reporting should never stuck

I have observed testnet pulse instance getting stuck updating bps metric once

It either got into a deadlock (not likely) or .unwrap() crashed the thread here:

near-lake-pulse/src/main.rs

Lines 164 to 206 in 0d030f6

	match prev_state {
	State::Alerting => {
	if block_processing_speed > 0.0 {
	prev_state = State::Operating;
	for chat_id in chat_ids.iter() {
	bot.send_message(
	chat_id.to_string(),
	format!(
	"<b>Resolved</b> {}\n BPS is {}",
	&config_string, block_processing_speed,
	),
	)
	// Optional parameters can be supplied by calling setters
	.parse_mode(ParseMode::Html)
	// To send request to telegram you need to call `.send()` and await the resulting future
	.send()
	.await
	.unwrap();
	}
	}
	}
	_ => {
	if block_processing_speed <= 0.0 {
	prev_state = State::Alerting;
	for chat_id in chat_ids.iter() {
	bot.send_message(
	chat_id.to_string(),
	format!(
	"<b>Alert!</b> BPS dropped to {}\n{}",
	block_processing_speed, &config_string,
	),
	)
	// Optional parameters can be supplied by calling setters
	.parse_mode(ParseMode::Html)
	// To send request to telegram you need to call `.send()` and await the resulting future
	.send()
	.await
	.unwrap();
	}
	}
	}
	};
	}