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

no pipe needed

Browse Source
This commit is contained in:
Bryan Stitt 2022-10-07 02:21:24 +00:00
parent c8fbf46885
commit 44adffcd32
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
web3_proxy/src/stats.rs
View File

@ -17,9 +17,9 @@ pub enum ProxyResponseType {
impl Display for ProxyResponseType { impl Display for ProxyResponseType {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
match self { match self {
ProxyResponseType::CacheHit => f.write_str("cache_hit"), ProxyResponseType::CacheHit => f.write_str("ch"),
ProxyResponseType::CacheMiss => f.write_str("cache_miss"), ProxyResponseType::CacheMiss => f.write_str("cm"),
ProxyResponseType::Error => f.write_str("error"), ProxyResponseType::Error => f.write_str("err"),
} }
} }
} }
@ -72,9 +72,7 @@ impl StatEmitter {
// TODO: this is too loud. just doing it for dev // TODO: this is too loud. just doing it for dev
debug!(?x, "emitting stat"); debug!(?x, "emitting stat");
// TODO: do this without the pipe? if let Err(err) = redis::Cmd::incr(&x, 1)
if let Err(err) = redis::pipe()
.incr(&x, 1)
.query_async::<_, ()>(&mut redis_conn) .query_async::<_, ()>(&mut redis_conn)
.await .await
.context("incrementing stat") .context("incrementing stat")