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

drop in flight. throughput is enough

This commit is contained in:
Bryan Stitt 2022-09-14 07:08:48 +00:00
parent 731a255d2f
commit 31227d8c0c
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
web3_proxy/src/app.rs
View File

@ -21,7 +21,7 @@ use futures::stream::FuturesUnordered;
use futures::stream::StreamExt; use futures::stream::StreamExt;
use futures::Future; use futures::Future;
use hashbrown::HashMap; use hashbrown::HashMap;
use metered::{metered, ErrorCount, HitCount, InFlight, ResponseTime, Throughput}; use metered::{metered, ErrorCount, HitCount, ResponseTime, Throughput};
use migration::{Migrator, MigratorTrait}; use migration::{Migrator, MigratorTrait};
use moka::future::Cache; use moka::future::Cache;
use redis_rate_limit::{Config as RedisConfig, Pool as RedisPool, RedisRateLimit, Runtime}; use redis_rate_limit::{Config as RedisConfig, Pool as RedisPool, RedisRateLimit, Runtime};
@ -364,7 +364,7 @@ impl Web3ProxyApp {
} }
#[instrument(skip_all)] #[instrument(skip_all)]
#[measure([ErrorCount, HitCount, InFlight, ResponseTime, Throughput])] #[measure([ErrorCount, HitCount, ResponseTime, Throughput])]
pub async fn eth_subscribe<'a>( pub async fn eth_subscribe<'a>(
self: &'a Arc<Self>, self: &'a Arc<Self>,
payload: JsonRpcRequest, payload: JsonRpcRequest,
@ -621,7 +621,7 @@ impl Web3ProxyApp {
} }
} }
#[measure([ErrorCount, HitCount, InFlight, ResponseTime, Throughput])] #[measure([ErrorCount, HitCount, ResponseTime, Throughput])]
#[instrument(skip_all)] #[instrument(skip_all)]
async fn proxy_web3_rpc_request( async fn proxy_web3_rpc_request(
self: &Arc<Self>, self: &Arc<Self>,

3
web3_proxy/src/rpcs/request.rs
View File

@ -3,7 +3,6 @@ use super::provider::Web3Provider;
use metered::metered; use metered::metered;
use metered::ErrorCount; use metered::ErrorCount;
use metered::HitCount; use metered::HitCount;
use metered::InFlight;
use metered::ResponseTime; use metered::ResponseTime;
use metered::Throughput; use metered::Throughput;
use std::fmt; use std::fmt;
@ -66,7 +65,7 @@ impl OpenRequestHandle {
/// TODO: we no longer take self because metered doesn't like that /// TODO: we no longer take self because metered doesn't like that
/// TODO: ErrorCount includes too many types of errors, such as transaction reverts /// TODO: ErrorCount includes too many types of errors, such as transaction reverts
#[instrument(skip_all)] #[instrument(skip_all)]
#[measure([ErrorCount, HitCount, InFlight, ResponseTime, Throughput])] #[measure([ErrorCount, HitCount, ResponseTime, Throughput])]
pub async fn request<T, R>( pub async fn request<T, R>(
&self, &self,
method: &str, method: &str,