tornadocontrib/web3-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add to the running total everywhere

Browse Source
This commit is contained in:
Bryan Stitt 2023-07-21 16:38:02 -07:00
parent b08a279b60
commit 88b2618edf
2 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
web3_proxy/src/stats/mod.rs
View File

@ -45,7 +45,10 @@ pub type BackendRequests = Mutex<Vec<Arc<Web3Rpc>>>;
#[derive(Copy, Clone, Debug)]
pub struct FlushedStats {
pub relational: usize,
pub relational_frontend_requests: u64,
pub timeseries: usize,
/// the number of global frontend requests saved to influx
pub timeseries_frontend_requests: u64,
}
/// TODO: better name? RpcQueryStatBuilder?

14
web3_proxy/src/stats/stat_buffer.rs
View File

@ -160,6 +160,9 @@ impl StatBuffer {
Some(x) => {
let flushed_stats = self._flush(&mut stat_receiver).await?;
tsdb_frontend_requests += flushed_stats.timeseries_frontend_requests;
db_frontend_requests += flushed_stats.relational_frontend_requests;
if let Err(err) = x.send(flushed_stats) {
error!(?flushed_stats, ?err, "unable to notify about flushed stats");
}
@ -198,7 +201,10 @@ impl StatBuffer {
// sleep(Duration::from_millis(10)).await;
// }
self._flush(&mut stat_receiver).await?;
let flushed_stats = self._flush(&mut stat_receiver).await?;
tsdb_frontend_requests += flushed_stats.timeseries_frontend_requests;
db_frontend_requests += flushed_stats.relational_frontend_requests;
// TODO: if these totals don't match, something is wrong!
info!(%total_frontend_requests, %tsdb_frontend_requests, %db_frontend_requests, "accounting and stat save loop complete");
@ -341,13 +347,15 @@ impl StatBuffer {
// flush the buffers
// TODO: include frontend counts here
let (tsdb_count, _) = self.save_tsdb_stats().await;
let (relational_count, _) = self.save_relational_stats().await;
let (tsdb_count, tsdb_frontend_requests) = self.save_tsdb_stats().await;
let (relational_count, relational_frontend_requests) = self.save_relational_stats().await;
// notify
let flushed_stats = FlushedStats {
timeseries: tsdb_count,
timeseries_frontend_requests: tsdb_frontend_requests,
relational: relational_count,
relational_frontend_requests,
};
trace!(?flushed_stats);