blockworks-foundation
/
pyth-crosschain
mirror of https://github.com/blockworks-foundation/pyth-crosschain.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

wormhole-attester: Add a histogram metric for tx processing duration (#434) 

This adds buckets between 16ms and 65.536 seconds. In tilt, most
attestation txs fall between 256 and 1024 milliseconds.
This commit is contained in:
Stanisław Drozd 2022-12-20 11:53:51 +01:00 committed by GitHub
parent 54846061dd
commit afd4a8be91
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
solana/pyth2wormhole/client/src/main.rs
View File

@ -21,8 +21,10 @@ use {
},
p2w_sdk::P2WEmitter,
prometheus::{
register_histogram,
register_int_counter,
register_int_gauge,
Histogram,
IntCounter,
IntGauge,
},
@ -99,6 +101,13 @@ lazy_static! {
"Latest sequence number produced by this attester"
)
.expect("FATAL: Could not instantiate LAST_SEQNO_GAUGE");
static ref SOL_RPC_TX_PROCESSING_HIST: Histogram = register_histogram!(
"sol_rpc_tx_processing",
"How long in milliseconds it takes to send a transaction to the Solana RPC",
prometheus::exponential_buckets(0.016, 2.0, 13) // 0.016s, 0.032s, 0.064s, [...], 65.536s
.expect("FATAL: Could not instantiate buckets for SOL_RPC_TX_PROCESSING_HIST")
)
.expect("FATAL: Could not instantiate SOL_RPC_TX_PROCESSING_HIST");
}
#[tokio::main(flavor = "multi_thread")]
@ -813,6 +822,9 @@ async fn attestation_job(args: AttestationJobArgs) -> Result<(), ErrBoxSend> {
symbols.as_slice(),
latest_blockhash,
);
let tx_processing_start_time = Instant::now();
let sig = rpc
.send_and_confirm_transaction(&tx_res?)
.map_err(|e| -> ErrBoxSend { e.into() })
@ -827,6 +839,15 @@ async fn attestation_job(args: AttestationJobArgs) -> Result<(), ErrBoxSend> {
},
)
.await?;
let tx_processing_duration = tx_processing_start_time.elapsed();
// Manually insert the value into histogram. NOTE: We're not
// using the start_timer() method because it would record
// durations even for early returns in error conditions which
// would look weird in monitoring.
SOL_RPC_TX_PROCESSING_HIST.observe(tx_processing_duration.as_secs_f64());
let seqno = tx_data
.transaction
.meta