Skip to content

Commit

Permalink
Remove plurals
Browse files Browse the repository at this point in the history
  • Loading branch information
paulhauner committed Jul 18, 2023
1 parent 8fb6bc3 commit 232e47d
Show file tree
Hide file tree
Showing 3 changed files with 22 additions and 22 deletions.
28 changes: 14 additions & 14 deletions beacon_node/beacon_processor/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1225,72 +1225,72 @@ impl<E: EthSpec> BeaconProcessor<E> {
self.current_workers as i64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[GOSSIP_ATTESTATION],
attestation_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[GOSSIP_AGGREGATE],
aggregate_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[GOSSIP_SYNC_SIGNATURE],
sync_message_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[GOSSIP_SYNC_CONTRIBUTION],
sync_contribution_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[GOSSIP_BLOCK],
gossip_block_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[RPC_BLOCK],
rpc_block_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[CHAIN_SEGMENT],
chain_segment_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[CHAIN_SEGMENT_BACKFILL],
backfill_chain_segment.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[GOSSIP_VOLUNTARY_EXIT],
gossip_voluntary_exit_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[GOSSIP_PROPOSER_SLASHING],
gossip_proposer_slashing_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[GOSSIP_ATTESTER_SLASHING],
gossip_attester_slashing_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[GOSSIP_BLS_TO_EXECUTION_CHANGE],
gossip_bls_to_execution_change_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[API_REQUEST_P0],
api_request_p0_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_QUEUE_LENGTH,
&[API_REQUEST_P1],
api_request_p1_queue.len() as f64,
);
Expand Down
8 changes: 4 additions & 4 deletions beacon_node/beacon_processor/src/metrics.rs
Original file line number Diff line number Diff line change
Expand Up @@ -47,8 +47,8 @@ lazy_static::lazy_static! {
"beacon_processor_event_handling_seconds",
"Time spent handling a new message and allocating it to a queue or worker."
);
pub static ref BEACON_PROCESSOR_QUEUE_LENGTHS: Result<HistogramVec> = try_create_histogram_vec_with_buckets(
"beacon_processor_queue_lengths",
pub static ref BEACON_PROCESSOR_QUEUE_LENGTH: Result<HistogramVec> = try_create_histogram_vec_with_buckets(
"beacon_processor_queue_length",
"The lengths of each beacon processor event queue.",
Ok(queue_length_buckets()),
&["type"]
Expand All @@ -57,8 +57,8 @@ lazy_static::lazy_static! {
/*
* Attestation reprocessing queue metrics.
*/
pub static ref BEACON_PROCESSOR_REPROCESSING_QUEUE_LENGTHS: Result<HistogramVec> = try_create_histogram_vec_with_buckets(
"beacon_processor_reprocessing_queue_lengths",
pub static ref BEACON_PROCESSOR_REPROCESSING_QUEUE_LENGTH: Result<HistogramVec> = try_create_histogram_vec_with_buckets(
"beacon_processor_reprocessing_queue_length",
"The lengths of each beacon processor reprocessing queue.",
Ok(queue_length_buckets()),
&["type"]
Expand Down
8 changes: 4 additions & 4 deletions beacon_node/beacon_processor/src/work_reprocessing_queue.rs
Original file line number Diff line number Diff line change
Expand Up @@ -888,22 +888,22 @@ impl<S: SlotClock> ReprocessQueue<S> {
}

metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_REPROCESSING_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_REPROCESSING_QUEUE_LENGTH,
&[GOSSIP_BLOCKS],
self.gossip_block_delay_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_REPROCESSING_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_REPROCESSING_QUEUE_LENGTH,
&[RPC_BLOCKS],
self.rpc_block_delay_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_REPROCESSING_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_REPROCESSING_QUEUE_LENGTH,
&[ATTESTATIONS],
self.attestations_delay_queue.len() as f64,
);
metrics::observe_histogram_vec(
&metrics::BEACON_PROCESSOR_REPROCESSING_QUEUE_LENGTHS,
&metrics::BEACON_PROCESSOR_REPROCESSING_QUEUE_LENGTH,
&[LIGHT_CLIENT_UPDATES],
self.lc_updates_delay_queue.len() as f64,
);
Expand Down

0 comments on commit 232e47d

Please sign in to comment.