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

add queue lengths to status page

Browse Source
This commit is contained in:
Bryan Stitt 2023-06-07 13:05:15 -07:00
parent b50579ea3a
commit 91d288315f
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
web3_proxy/src/rpcs/many.rs
View File

@ -1202,7 +1202,7 @@ impl Serialize for Web3Rpcs {
where where
S: Serializer, S: Serializer,
{ {
let mut state = serializer.serialize_struct("Web3Rpcs", 4)?; let mut state = serializer.serialize_struct("Web3Rpcs", 8)?;
{ {
let by_name = self.by_name.load(); let by_name = self.by_name.load();
@ -1224,6 +1224,20 @@ impl Serialize for Web3Rpcs {
state.serialize_field("blocks_by_hash", &self.blocks_by_hash)?; state.serialize_field("blocks_by_hash", &self.blocks_by_hash)?;
state.serialize_field("blocks_by_number", &self.blocks_by_number)?; state.serialize_field("blocks_by_number", &self.blocks_by_number)?;
state.serialize_field("pending_transaction_cache", &self.pending_transaction_cache)?;
state.serialize_field("block_sender_len", &self.block_sender.len())?;
state.serialize_field(
"watch_consensus_rpcs_receivers",
&self.watch_consensus_rpcs_sender.receiver_count(),
)?;
if let Some(ref x) = self.watch_consensus_head_sender {
state.serialize_field("watch_consensus_head_receivers", &x.receiver_count())?;
} else {
state.serialize_field("watch_consensus_head_receivers", &None::<()>)?;
}
state.end() state.end()
} }