blockworks-foundation
/
solana-accountsdb-connector
mirror of https://github.com/blockworks-foundation/solana-accountsdb-connector.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Rename count metrics

This commit is contained in:
Riordan Panayides 2022-10-06 01:33:07 +01:00
parent 484e853924
commit 1d1f462cf6
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
lib/src/grpc_plugin_source.rs
View File

@ -290,7 +290,7 @@ pub async fn process_events(
tokio::spawn(async move {
let mut metric_retries = metrics_sender.register_u64(format!(
"grpc_source_{}_connection_retries",
"grpc_source_{}_connection_retries_count",
grpc_source.name
));
let metric_status =
@ -335,13 +335,13 @@ pub async fn process_events(
// Number of slots to retain in latest_write
let latest_write_retention = 50;
let mut metric_account_writes = metrics_sender.register_u64("grpc_account_writes".into());
let mut metric_account_writes = metrics_sender.register_u64("grpc_account_writes_count".into());
let mut metric_account_queue = metrics_sender.register_u64("account_write_queue".into());
let mut metric_slot_queue = metrics_sender.register_u64("slot_update_queue".into());
let mut metric_slot_updates = metrics_sender.register_u64("grpc_slot_updates".into());
let mut metric_snapshots = metrics_sender.register_u64("grpc_snapshots".into());
let mut metric_slot_updates = metrics_sender.register_u64("grpc_slot_updates_count".into());
let mut metric_snapshots = metrics_sender.register_u64("grpc_snapshots_count".into());
let mut metric_snapshot_account_writes =
metrics_sender.register_u64("grpc_snapshot_account_writes".into());
metrics_sender.register_u64("grpc_snapshot_account_writes_count".into());
loop {
let msg = msg_receiver.recv().await.expect("sender must not close");

4
service-mango-fills/src/main.rs
View File

@ -136,10 +136,10 @@ async fn main() -> anyhow::Result<()> {
});
let metrics_opened_connections =
metrics_tx.register_u64("fills_feed_opened_connections".into());
metrics_tx.register_u64("fills_feed_opened_connections_count".into());
let metrics_closed_connections =
metrics_tx.register_u64("fills_feed_closed_connections".into());
metrics_tx.register_u64("fills_feed_closed_connections_count".into());
let (account_write_queue_sender, slot_queue_sender, fill_receiver) =
fill_event_filter::init(config.markets.clone(), metrics_tx.clone()).await?;