blockworks-foundation
/
lite-rpc
mirror of https://github.com/blockworks-foundation/lite-rpc.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

rename metrics fields

This commit is contained in:
Aniket Prajapati 2023-01-08 22:32:30 +05:30
parent 35a9e2e193
commit 0f9d0bdfd3
No known key found for this signature in database
GPG Key ID: D4346D8C9C5398F2
2 changed files with 19 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/bridge.rs
View File

@ -98,18 +98,18 @@ impl LiteBridge {
loop {
one_second.tick().await;
let total_txs_sent = self.txs_sent.len();
let mut total_txs_confirmed: usize = 0;
let mut total_txs_finalized: usize = 0;
let txs_sent = self.txs_sent.len();
let mut txs_confirmed: usize = 0;
let mut txs_finalized: usize = 0;
for tx in self.txs_sent.iter() {
if let Some(tx) = tx.value() {
match tx.confirmation_status() {
TransactionConfirmationStatus::Confirmed => total_txs_confirmed += 1,
TransactionConfirmationStatus::Confirmed => txs_confirmed += 1,
TransactionConfirmationStatus::Finalized => {
total_txs_confirmed += 1;
total_txs_finalized += 1;
},
txs_confirmed += 1;
txs_finalized += 1;
}
_ => (),
}
}
@ -117,15 +117,13 @@ impl LiteBridge {
let mut metrics = self.metrics.write().await;
metrics.txs_sent_in_one_sec = total_txs_sent - metrics.total_txs_sent;
metrics.txs_confirmed_in_one_sec =
total_txs_confirmed - metrics.total_txs_confirmed;
metrics.txs_finalized_in_one_sec =
total_txs_finalized - metrics.total_txs_finalized;
metrics.txs_ps = txs_sent - metrics.txs_sent;
metrics.txs_confirmed_ps = txs_confirmed - metrics.txs_confirmed;
metrics.txs_finalized_ps = txs_finalized - metrics.txs_finalized;
metrics.total_txs_sent = total_txs_sent;
metrics.total_txs_confirmed = total_txs_confirmed;
metrics.total_txs_finalized = total_txs_finalized;
metrics.txs_sent = txs_sent;
metrics.txs_confirmed = txs_confirmed;
metrics.txs_finalized = txs_finalized;
log::info!("{metrics:?}");
}

13
src/metrics.rs
View File

@ -2,11 +2,10 @@ use serde::{Deserialize, Serialize};
#[derive(Clone, Default, Debug, Serialize, Deserialize)]
pub struct Metrics {
pub total_txs_sent: usize,
pub total_txs_confirmed: usize,
pub total_txs_finalized: usize,
pub txs_sent_in_one_sec: usize,
pub txs_confirmed_in_one_sec: usize,
pub txs_finalized_in_one_sec: usize
pub txs_sent: usize,
pub txs_confirmed: usize,
pub txs_finalized: usize,
pub txs_ps: usize,
pub txs_confirmed_ps: usize,
pub txs_finalized_ps: usize,
}