mirrors/buzzrelay
1
0
Fork 0
mirror of https://github.com/astro/buzzrelay.git synced 2024-11-22 12:11:00 +00:00
Code Issues Projects Releases Packages Wiki Activity

relay: add histogram "relay_post"

Browse source
This commit is contained in:
Astro 2022-12-20 03:59:32 +01:00
parent a3847e20b2
commit 959c5c41b2
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/relay.rs
View file

@ -1,5 +1,5 @@
use std::{sync::Arc, collections::HashSet}; use std::{sync::Arc, collections::HashSet, time::Instant};
use metrics::increment_counter; use metrics::{increment_counter, histogram};
use serde::Deserialize; use serde::Deserialize;
use serde_json::json; use serde_json::json;
use sigh::PrivateKey; use sigh::PrivateKey;
@ -71,7 +71,7 @@ pub fn spawn(
tokio::spawn(async move { tokio::spawn(async move {
while let Some(data) = stream_rx.recv().await { while let Some(data) = stream_rx.recv().await {
// dbg!(&data); let t1 = Instant::now();
let post: Post = match serde_json::from_str(&data) { let post: Post = match serde_json::from_str(&data) {
Ok(post) => post, Ok(post) => post,
Err(e) => { Err(e) => {
@ -80,7 +80,6 @@ pub fn spawn(
continue; continue;
} }
}; };
// tracing::trace!("post uri={:?} url={:?}", post.uri, post.url);
let post_url = match post.url { let post_url = match post.url {
Some(url) => url, Some(url) => url,
// skip reposts // skip reposts
@ -144,6 +143,8 @@ pub fn spawn(
} else { } else {
increment_counter!("post", "action" => "relay"); increment_counter!("post", "action" => "relay");
} }
let t2 = Instant::now();
histogram!("relay_post", t2 - t1);
} }
}); });
} }