Skip to content

Commit c28586e

Browse files
committed
Separate TX_ACK metrics by OK and error codes.
1 parent 00dbd77 commit c28586e

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

src/forwarder.rs

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -522,8 +522,13 @@ fn handle_pull_resp(state: &Arc<State>, data: &[u8]) -> Result<(), String> {
522522
error!("UDP send error: {}, server: {}", e, state.server);
523523
};
524524

525-
metrics::incr_udp_sent_count(&state.server, "TX_ACK");
526-
metrics::incr_udp_sent_bytes(&state.server, "TX_ACK", bytes.len());
525+
let metrics_key: String = match tx_ack_udp.payload.txpk_ack.error.as_str() {
526+
"" => "TX_ACK_OK".to_string(),
527+
_ => "TX_ACK_ERROR_".to_owned() + &tx_ack_udp.payload.txpk_ack.error,
528+
};
529+
530+
metrics::incr_udp_sent_count(&state.server, &metrics_key);
531+
metrics::incr_udp_sent_bytes(&state.server, &metrics_key, bytes.len());
527532

528533
Ok(())
529534
}

0 commit comments

Comments
 (0)