Companion PR for removing Prometheus metrics prefix (#3623)

* Companion PR for removing Prometheus metrics prefix

* Was missing some metrics

* Fix missing renames

* Fix test

* Fixes

* Update test

* Update Substrate

* Second time

* remove prefix from intergration test for zombienet

* update zombienet image

* Update Substrate

Co-authored-by: Bastian Köcher <info@kchr.de>
Co-authored-by: Javier Viola <pepoviola@gmail.com>
This commit is contained in:
Pierre Krieger
2021-12-10 15:24:54 +01:00
committed by GitHub
parent e910a3f80f
commit 77d70ac0d3
26 changed files with 283 additions and 294 deletions
+1 -1
View File
@@ -27,7 +27,7 @@ variables:
CI_IMAGE: "paritytech/ci-linux:production"
DOCKER_OS: "debian:stretch"
ARCH: "x86_64"
ZOMBIENET_IMAGE: "docker.io/paritypr/zombienet"
ZOMBIENET_IMAGE: "docker.io/paritytech/zombienet"
VAULT_SERVER_URL: "https://vault.parity-mgmt-vault.parity.io"
VAULT_AUTH_PATH: "gitlab-parity-io-jwt"
VAULT_AUTH_ROLE: "cicd_gitlab_parity_${CI_PROJECT_NAME}"
+163 -163
View File
File diff suppressed because it is too large Load Diff
@@ -474,7 +474,7 @@ impl metrics::Metrics for Metrics {
let metrics = MetricsInner {
collations_generated_total: prometheus::register(
prometheus::Counter::new(
"parachain_collations_generated_total",
"polkadot_parachain_collations_generated_total",
"Number of collations generated."
)?,
registry,
@@ -482,7 +482,7 @@ impl metrics::Metrics for Metrics {
new_activations_overall: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"parachain_collation_generation_new_activations",
"polkadot_parachain_collation_generation_new_activations",
"Time spent within fn handle_new_activations",
)
)?,
@@ -491,7 +491,7 @@ impl metrics::Metrics for Metrics {
new_activations_per_relay_parent: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"parachain_collation_generation_per_relay_parent",
"polkadot_parachain_collation_generation_per_relay_parent",
"Time spent handling a particular relay parent within fn handle_new_activations"
)
)?,
@@ -500,7 +500,7 @@ impl metrics::Metrics for Metrics {
new_activations_per_availability_core: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"parachain_collation_generation_per_availability_core",
"polkadot_parachain_collation_generation_per_availability_core",
"Time spent handling a particular availability core for a relay parent in fn handle_new_activations",
)
)?,
@@ -240,7 +240,7 @@ impl metrics::Metrics for Metrics {
let metrics = MetricsInner {
imported_candidates_total: prometheus::register(
prometheus::Counter::new(
"parachain_imported_candidates_total",
"polkadot_parachain_imported_candidates_total",
"Number of candidates imported by the approval voting subsystem",
)?,
registry,
@@ -248,7 +248,7 @@ impl metrics::Metrics for Metrics {
assignments_produced: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"parachain_assignments_produced",
"polkadot_parachain_assignments_produced",
"Assignments and tranches produced by the approval voting subsystem",
).buckets(vec![0.0, 1.0, 2.0, 3.0, 4.0, 5.0, 10.0, 15.0, 25.0, 40.0, 70.0]),
)?,
@@ -257,7 +257,7 @@ impl metrics::Metrics for Metrics {
approvals_produced_total: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_approvals_produced_total",
"polkadot_parachain_approvals_produced_total",
"Number of approvals produced by the approval voting subsystem",
),
&["status"]
@@ -266,14 +266,14 @@ impl metrics::Metrics for Metrics {
)?,
no_shows_total: prometheus::register(
prometheus::Counter::new(
"parachain_approvals_no_shows_total",
"polkadot_parachain_approvals_no_shows_total",
"Number of assignments which became no-shows in the approval voting subsystem",
)?,
registry,
)?,
wakeups_triggered_total: prometheus::register(
prometheus::Counter::new(
"parachain_approvals_wakeups_total",
"polkadot_parachain_approvals_wakeups_total",
"Number of times we woke up to process a candidate in the approval voting subsystem",
)?,
registry,
@@ -281,7 +281,7 @@ impl metrics::Metrics for Metrics {
candidate_approval_time_ticks: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"parachain_approvals_candidate_approval_time_ticks",
"polkadot_parachain_approvals_candidate_approval_time_ticks",
"Number of ticks (500ms) to approve candidates.",
).buckets(vec![6.0, 12.0, 18.0, 24.0, 30.0, 36.0, 72.0, 100.0, 144.0]),
)?,
@@ -290,7 +290,7 @@ impl metrics::Metrics for Metrics {
block_approval_time_ticks: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"parachain_approvals_blockapproval_time_ticks",
"polkadot_parachain_approvals_blockapproval_time_ticks",
"Number of ticks (500ms) to approve blocks.",
).buckets(vec![6.0, 12.0, 18.0, 24.0, 30.0, 36.0, 72.0, 100.0, 144.0]),
)?,
@@ -299,7 +299,7 @@ impl metrics::Metrics for Metrics {
time_db_transaction: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"parachain_time_approval_db_transaction",
"polkadot_parachain_time_approval_db_transaction",
"Time spent writing an approval db transaction.",
)
)?,
@@ -308,7 +308,7 @@ impl metrics::Metrics for Metrics {
time_recover_and_approve: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"parachain_time_recover_and_approve",
"polkadot_parachain_time_recover_and_approve",
"Time spent recovering and approving data in approval voting",
)
)?,
+8 -8
View File
@@ -93,56 +93,56 @@ impl metrics::Metrics for Metrics {
let metrics = MetricsInner {
received_availability_chunks_total: prometheus::register(
prometheus::Counter::new(
"parachain_received_availability_chunks_total",
"polkadot_parachain_received_availability_chunks_total",
"Number of availability chunks received.",
)?,
registry,
)?,
pruning: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_av_store_pruning",
"polkadot_parachain_av_store_pruning",
"Time spent within `av_store::prune_all`",
))?,
registry,
)?,
process_block_finalized: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_av_store_process_block_finalized",
"polkadot_parachain_av_store_process_block_finalized",
"Time spent within `av_store::process_block_finalized`",
))?,
registry,
)?,
block_activated: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_av_store_block_activated",
"polkadot_parachain_av_store_block_activated",
"Time spent within `av_store::process_block_activated`",
))?,
registry,
)?,
process_message: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_av_store_process_message",
"polkadot_parachain_av_store_process_message",
"Time spent within `av_store::process_message`",
))?,
registry,
)?,
store_available_data: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_av_store_store_available_data",
"polkadot_parachain_av_store_store_available_data",
"Time spent within `av_store::store_available_data`",
))?,
registry,
)?,
store_chunk: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_av_store_store_chunk",
"polkadot_parachain_av_store_store_chunk",
"Time spent within `av_store::store_chunk`",
))?,
registry,
)?,
get_chunk: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_av_store_get_chunk",
"polkadot_parachain_av_store_get_chunk",
"Time spent fetching requested chunks.`",
))?,
registry,
+5 -5
View File
@@ -1364,35 +1364,35 @@ impl metrics::Metrics for Metrics {
let metrics = MetricsInner {
signed_statements_total: prometheus::register(
prometheus::Counter::new(
"parachain_candidate_backing_signed_statements_total",
"polkadot_parachain_candidate_backing_signed_statements_total",
"Number of statements signed.",
)?,
registry,
)?,
candidates_seconded_total: prometheus::register(
prometheus::Counter::new(
"parachain_candidate_backing_candidates_seconded_total",
"polkadot_parachain_candidate_backing_candidates_seconded_total",
"Number of candidates seconded.",
)?,
registry,
)?,
process_second: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_candidate_backing_process_second",
"polkadot_parachain_candidate_backing_process_second",
"Time spent within `candidate_backing::process_second`",
))?,
registry,
)?,
process_statement: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_candidate_backing_process_statement",
"polkadot_parachain_candidate_backing_process_statement",
"Time spent within `candidate_backing::process_statement`",
))?,
registry,
)?,
get_backed_candidates: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_candidate_backing_get_backed_candidates",
"polkadot_parachain_candidate_backing_get_backed_candidates",
"Time spent within `candidate_backing::get_backed_candidates`",
))?,
registry,
@@ -210,14 +210,14 @@ impl metrics::Metrics for Metrics {
let metrics = MetricsInner {
bitfields_signed_total: prometheus::register(
prometheus::Counter::new(
"parachain_bitfields_signed_total",
"polkadot_parachain_bitfields_signed_total",
"Number of bitfields signed.",
)?,
registry,
)?,
run: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_bitfield_signing_run",
"polkadot_parachain_bitfield_signing_run",
"Time spent within `bitfield_signing::run`",
))?,
registry,
@@ -716,7 +716,7 @@ impl metrics::Metrics for Metrics {
validation_requests: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_validation_requests_total",
"polkadot_parachain_validation_requests_total",
"Number of validation requests served.",
),
&["validity"],
@@ -725,21 +725,21 @@ impl metrics::Metrics for Metrics {
)?,
validate_from_chain_state: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_candidate_validation_validate_from_chain_state",
"polkadot_parachain_candidate_validation_validate_from_chain_state",
"Time spent within `candidate_validation::validate_from_chain_state`",
))?,
registry,
)?,
validate_from_exhaustive: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_candidate_validation_validate_from_exhaustive",
"polkadot_parachain_candidate_validation_validate_from_exhaustive",
"Time spent within `candidate_validation::validate_from_exhaustive`",
))?,
registry,
)?,
validate_candidate_exhaustive: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_candidate_validation_validate_candidate_exhaustive",
"polkadot_parachain_candidate_validation_validate_candidate_exhaustive",
"Time spent within `candidate_validation::validate_candidate_exhaustive`",
))?,
registry,
+7 -7
View File
@@ -229,7 +229,7 @@ impl metrics::Metrics for Metrics {
chain_api_requests: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_chain_api_requests_total",
"polkadot_parachain_chain_api_requests_total",
"Number of Chain API requests served.",
),
&["success"],
@@ -238,42 +238,42 @@ impl metrics::Metrics for Metrics {
)?,
block_number: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_chain_api_block_number",
"polkadot_parachain_chain_api_block_number",
"Time spent within `chain_api::block_number`",
))?,
registry,
)?,
block_header: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_chain_api_block_headers",
"polkadot_parachain_chain_api_block_headers",
"Time spent within `chain_api::block_headers`",
))?,
registry,
)?,
block_weight: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_chain_api_block_weight",
"polkadot_parachain_chain_api_block_weight",
"Time spent within `chain_api::block_weight`",
))?,
registry,
)?,
finalized_block_hash: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_chain_api_finalized_block_hash",
"polkadot_parachain_chain_api_finalized_block_hash",
"Time spent within `chain_api::finalized_block_hash`",
))?,
registry,
)?,
finalized_block_number: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_chain_api_finalized_block_number",
"polkadot_parachain_chain_api_finalized_block_number",
"Time spent within `chain_api::finalized_block_number`",
))?,
registry,
)?,
ancestors: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_chain_api_ancestors",
"polkadot_parachain_chain_api_ancestors",
"Time spent within `chain_api::ancestors`",
))?,
registry,
@@ -82,7 +82,7 @@ impl metrics::Metrics for Metrics {
let metrics = MetricsInner {
open: prometheus::register(
prometheus::Counter::with_opts(prometheus::Opts::new(
"parachain_candidate_disputes_total",
"polkadot_parachain_candidate_disputes_total",
"Total number of raised disputes.",
))?,
registry,
@@ -90,7 +90,7 @@ impl metrics::Metrics for Metrics {
concluded: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_candidate_dispute_concluded",
"polkadot_parachain_candidate_dispute_concluded",
"Concluded dispute votes, sorted by candidate is `valid` and `invalid`.",
),
&["validity"],
@@ -100,7 +100,7 @@ impl metrics::Metrics for Metrics {
votes: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_candidate_dispute_votes",
"polkadot_parachain_candidate_dispute_votes",
"Accumulated dispute votes, sorted by candidate is `valid` and `invalid`.",
),
&["validity"],
@@ -110,7 +110,7 @@ impl metrics::Metrics for Metrics {
queued_participations: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_dispute_participations",
"polkadot_parachain_dispute_participations",
"Total number of queued participations, grouped by priority and best-effort. (Not every queueing will necessarily lead to an actual participation because of duplicates.)",
),
&["priority"],
@@ -91,7 +91,7 @@ impl metrics::Metrics for Metrics {
inherent_data_requests: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_inherent_data_requests_total",
"polkadot_parachain_inherent_data_requests_total",
"Number of InherentData requests served by provisioner.",
),
&["success"],
@@ -100,14 +100,14 @@ impl metrics::Metrics for Metrics {
)?,
request_inherent_data: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_provisioner_request_inherent_data_time",
"polkadot_parachain_provisioner_request_inherent_data_time",
"Time spent within `provisioner::request_inherent_data`",
))?,
registry,
)?,
provisionable_data: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_provisioner_provisionable_data_time",
"polkadot_parachain_provisioner_provisionable_data_time",
"Time spent within `provisioner::provisionable_data`",
))?,
registry,
@@ -115,7 +115,7 @@ impl metrics::Metrics for Metrics {
inherent_data_dispute_statements: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_inherent_data_dispute_statements",
"polkadot_parachain_inherent_data_dispute_statements",
"Number of dispute statements passed to `create_inherent()`.",
),
&["validity"],
@@ -124,7 +124,7 @@ impl metrics::Metrics for Metrics {
)?,
inherent_data_dispute_statement_sets: prometheus::register(
prometheus::Counter::new(
"parachain_inherent_data_dispute_statement_sets",
"polkadot_parachain_inherent_data_dispute_statement_sets",
"Number of dispute statements sets passed to `create_inherent()`.",
)?,
registry,
+9 -9
View File
@@ -93,7 +93,7 @@ impl metrics::Metrics for Metrics {
worker_spawning: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"pvf_worker_spawning",
"polkadot_pvf_worker_spawning",
"The total number of workers began to spawn",
),
&["flavor"],
@@ -103,7 +103,7 @@ impl metrics::Metrics for Metrics {
worker_spawned: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"pvf_worker_spawned",
"polkadot_pvf_worker_spawned",
"The total number of workers spawned successfully",
),
&["flavor"],
@@ -113,7 +113,7 @@ impl metrics::Metrics for Metrics {
worker_retired: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"pvf_worker_retired",
"polkadot_pvf_worker_retired",
"The total number of workers retired, either killed by the host or died on duty",
),
&["flavor"],
@@ -122,28 +122,28 @@ impl metrics::Metrics for Metrics {
)?,
prepare_enqueued: prometheus::register(
prometheus::Counter::new(
"pvf_prepare_enqueued",
"polkadot_pvf_prepare_enqueued",
"The total number of jobs enqueued into the preparation pipeline"
)?,
registry,
)?,
prepare_concluded: prometheus::register(
prometheus::Counter::new(
"pvf_prepare_concluded",
"polkadot_pvf_prepare_concluded",
"The total number of jobs concluded in the preparation pipeline"
)?,
registry,
)?,
execute_enqueued: prometheus::register(
prometheus::Counter::new(
"pvf_execute_enqueued",
"polkadot_pvf_execute_enqueued",
"The total number of jobs enqueued into the execution pipeline"
)?,
registry,
)?,
execute_finished: prometheus::register(
prometheus::Counter::new(
"pvf_execute_finished",
"polkadot_pvf_execute_finished",
"The total number of jobs done in the execution pipeline"
)?,
registry,
@@ -151,7 +151,7 @@ impl metrics::Metrics for Metrics {
preparation_time: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"pvf_preparation_time",
"polkadot_pvf_preparation_time",
"Time spent in preparing PVF artifacts in seconds",
)
.buckets(vec![
@@ -173,7 +173,7 @@ impl metrics::Metrics for Metrics {
execution_time: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"pvf_execution_time",
"polkadot_pvf_execution_time",
"Time spent in executing PVFs",
)
)?,
+2 -2
View File
@@ -423,7 +423,7 @@ impl metrics::Metrics for Metrics {
chain_api_requests: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_runtime_api_requests_total",
"polkadot_parachain_runtime_api_requests_total",
"Number of Runtime API requests served.",
),
&["success"],
@@ -432,7 +432,7 @@ impl metrics::Metrics for Metrics {
)?,
make_runtime_api_request: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_runtime_api_make_runtime_api_request",
"polkadot_parachain_runtime_api_make_runtime_api_request",
"Time spent within `runtime_api::make_runtime_api_request`",
))?,
registry,
@@ -1303,42 +1303,42 @@ impl metrics::Metrics for Metrics {
let metrics = MetricsInner {
assignments_imported_total: prometheus::register(
prometheus::Counter::new(
"parachain_assignments_imported_total",
"polkadot_parachain_assignments_imported_total",
"Number of valid assignments imported locally or from other peers.",
)?,
registry,
)?,
approvals_imported_total: prometheus::register(
prometheus::Counter::new(
"parachain_approvals_imported_total",
"polkadot_parachain_approvals_imported_total",
"Number of valid approvals imported locally or from other peers.",
)?,
registry,
)?,
unified_with_peer_total: prometheus::register(
prometheus::Counter::new(
"parachain_unified_with_peer_total",
"polkadot_parachain_unified_with_peer_total",
"Number of times `unify_with_peer` is called.",
)?,
registry,
)?,
time_unify_with_peer: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_time_unify_with_peer",
"polkadot_parachain_time_unify_with_peer",
"Time spent within fn `unify_with_peer`.",
))?,
registry,
)?,
time_import_pending_now_known: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_time_import_pending_now_known",
"polkadot_parachain_time_import_pending_now_known",
"Time spent on importing pending assignments and approvals.",
))?,
registry,
)?,
time_awaiting_approval_voting: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_time_awaiting_approval_voting",
"polkadot_parachain_time_awaiting_approval_voting",
"Time spent awaiting a reply from the Approval Voting Subsystem.",
))?,
registry,
@@ -102,7 +102,7 @@ impl metrics::Metrics for Metrics {
fetched_chunks: prometheus::register(
CounterVec::new(
Opts::new(
"parachain_fetched_chunks_total",
"polkadot_parachain_fetched_chunks_total",
"Total number of fetched chunks.",
),
&["success"]
@@ -112,7 +112,7 @@ impl metrics::Metrics for Metrics {
served_chunks: prometheus::register(
CounterVec::new(
Opts::new(
"parachain_served_chunks_total",
"polkadot_parachain_served_chunks_total",
"Total number of chunks served by this backer.",
),
&["success"]
@@ -122,7 +122,7 @@ impl metrics::Metrics for Metrics {
served_povs: prometheus::register(
CounterVec::new(
Opts::new(
"parachain_served_povs_total",
"polkadot_parachain_served_povs_total",
"Total number of povs served by this backer.",
),
&["success"]
@@ -131,7 +131,7 @@ impl metrics::Metrics for Metrics {
)?,
retries: prometheus::register(
Counter::new(
"parachain_fetch_retries_total",
"polkadot_parachain_fetch_retries_total",
"Number of times we did not succeed in fetching a chunk and needed to try more backers.",
)?,
registry,
@@ -104,7 +104,7 @@ impl metrics::Metrics for Metrics {
let metrics = MetricsInner {
chunk_requests_issued: prometheus::register(
Counter::new(
"parachain_availability_recovery_chunk_requests_issued",
"polkadot_parachain_availability_recovery_chunk_requests_issued",
"Total number of issued chunk requests.",
)?,
registry,
@@ -112,7 +112,7 @@ impl metrics::Metrics for Metrics {
chunk_requests_finished: prometheus::register(
CounterVec::new(
Opts::new(
"parachain_availability_recovery_chunk_requests_finished",
"polkadot_parachain_availability_recovery_chunk_requests_finished",
"Total number of chunk requests finished.",
),
&["result"],
@@ -121,7 +121,7 @@ impl metrics::Metrics for Metrics {
)?,
time_chunk_request: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_availability_recovery_time_chunk_request",
"polkadot_parachain_availability_recovery_time_chunk_request",
"Time spent waiting for a response to a chunk request",
))?,
registry,
@@ -756,35 +756,35 @@ impl metrics::Metrics for Metrics {
let metrics = MetricsInner {
gossipped_own_availability_bitfields: prometheus::register(
prometheus::Counter::new(
"parachain_gossipped_own_availabilty_bitfields_total",
"polkadot_parachain_gossipped_own_availabilty_bitfields_total",
"Number of own availability bitfields sent to other peers.",
)?,
registry,
)?,
received_availability_bitfields: prometheus::register(
prometheus::Counter::new(
"parachain_received_availabilty_bitfields_total",
"polkadot_parachain_received_availabilty_bitfields_total",
"Number of valid availability bitfields received from other peers.",
)?,
registry,
)?,
active_leaves_update: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_bitfield_distribution_active_leaves_update",
"polkadot_parachain_bitfield_distribution_active_leaves_update",
"Time spent within `bitfield_distribution::active_leaves_update`",
))?,
registry,
)?,
handle_bitfield_distribution: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_bitfield_distribution_handle_bitfield_distribution",
"polkadot_parachain_bitfield_distribution_handle_bitfield_distribution",
"Time spent within `bitfield_distribution::handle_bitfield_distribution`",
))?,
registry,
)?,
handle_network_msg: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_bitfield_distribution_handle_network_msg",
"polkadot_parachain_bitfield_distribution_handle_network_msg",
"Time spent within `bitfield_distribution::handle_network_msg`",
))?,
registry,
+8 -8
View File
@@ -167,7 +167,7 @@ impl metrics::Metrics for Metrics {
peer_count: prometheus::register(
prometheus::GaugeVec::new(
prometheus::Opts::new(
"parachain_peer_count",
"polkadot_parachain_peer_count",
"The number of peers on a parachain-related peer-set",
),
&["protocol"]
@@ -177,7 +177,7 @@ impl metrics::Metrics for Metrics {
connected_events: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_peer_connect_events_total",
"polkadot_parachain_peer_connect_events_total",
"The number of peer connect events on a parachain notifications protocol",
),
&["protocol"]
@@ -187,7 +187,7 @@ impl metrics::Metrics for Metrics {
disconnected_events: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_peer_disconnect_events_total",
"polkadot_parachain_peer_disconnect_events_total",
"The number of peer disconnect events on a parachain notifications protocol",
),
&["protocol"]
@@ -197,7 +197,7 @@ impl metrics::Metrics for Metrics {
desired_peer_count: prometheus::register(
prometheus::GaugeVec::new(
prometheus::Opts::new(
"parachain_desired_peer_count",
"polkadot_parachain_desired_peer_count",
"The number of peers that the local node is expected to connect to on a parachain-related peer-set (either including or not including unresolvable authorities, depending on whether `ConnectToValidators` or `ConnectToValidatorsResolved` was used.)",
),
&["protocol"]
@@ -207,7 +207,7 @@ impl metrics::Metrics for Metrics {
notifications_received: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_notifications_received_total",
"polkadot_parachain_notifications_received_total",
"The number of notifications received on a parachain protocol",
),
&["protocol"]
@@ -217,7 +217,7 @@ impl metrics::Metrics for Metrics {
notifications_sent: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_notifications_sent_total",
"polkadot_parachain_notifications_sent_total",
"The number of notifications sent on a parachain protocol",
),
&["protocol"]
@@ -227,7 +227,7 @@ impl metrics::Metrics for Metrics {
bytes_received: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_notification_bytes_received_total",
"polkadot_parachain_notification_bytes_received_total",
"The number of bytes received on a parachain notification protocol",
),
&["protocol"]
@@ -237,7 +237,7 @@ impl metrics::Metrics for Metrics {
bytes_sent: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_notification_bytes_sent_total",
"polkadot_parachain_notification_bytes_sent_total",
"The number of bytes sent on a parachain notification protocol",
),
&["protocol"]
@@ -116,28 +116,28 @@ impl metrics::Metrics for Metrics {
let metrics = MetricsInner {
advertisements_made: prometheus::register(
prometheus::Counter::new(
"parachain_collation_advertisements_made_total",
"polkadot_parachain_collation_advertisements_made_total",
"A number of collation advertisements sent to validators.",
)?,
registry,
)?,
collations_send_requested: prometheus::register(
prometheus::Counter::new(
"parachain_collations_sent_requested_total",
"polkadot_parachain_collations_sent_requested_total",
"A number of collations requested to be sent to validators.",
)?,
registry,
)?,
collations_sent: prometheus::register(
prometheus::Counter::new(
"parachain_collations_sent_total",
"polkadot_parachain_collations_sent_total",
"A number of collations sent to validators.",
)?,
registry,
)?,
process_msg: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_collator_protocol_collator_process_msg",
"polkadot_parachain_collator_protocol_collator_process_msg",
"Time spent within `collator_protocol_collator::process_msg`",
))?,
registry,
@@ -150,7 +150,7 @@ impl metrics::Metrics for Metrics {
collation_requests: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_collation_requests_total",
"polkadot_parachain_collation_requests_total",
"Number of collations requested from Collators.",
),
&["success"],
@@ -160,7 +160,7 @@ impl metrics::Metrics for Metrics {
process_msg: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"parachain_collator_protocol_validator_process_msg",
"polkadot_parachain_collator_protocol_validator_process_msg",
"Time spent within `collator_protocol_validator::process_msg`",
)
)?,
@@ -169,7 +169,7 @@ impl metrics::Metrics for Metrics {
handle_collation_request_result: prometheus::register(
prometheus::Histogram::with_opts(
prometheus::HistogramOpts::new(
"parachain_collator_protocol_validator_handle_collation_request_result",
"polkadot_parachain_collator_protocol_validator_handle_collation_request_result",
"Time spent within `collator_protocol_validator::handle_collation_request_result`",
)
)?,
@@ -177,7 +177,7 @@ impl metrics::Metrics for Metrics {
)?,
collator_peer_count: prometheus::register(
prometheus::Gauge::new(
"parachain_collator_peer_count",
"polkadot_parachain_collator_peer_count",
"Amount of collator peers connected",
)?,
registry,
@@ -90,7 +90,7 @@ impl metrics::Metrics for Metrics {
sent_requests: prometheus::register(
CounterVec::new(
Opts::new(
"parachain_dispute_distribution_sent_requests",
"polkadot_parachain_dispute_distribution_sent_requests",
"Total number of sent requests.",
),
&["success"],
@@ -99,7 +99,7 @@ impl metrics::Metrics for Metrics {
)?,
received_requests: prometheus::register(
Counter::new(
"parachain_dispute_distribution_received_requests",
"polkadot_parachain_dispute_distribution_received_requests",
"Total number of received dispute requests.",
)?,
registry,
@@ -107,7 +107,7 @@ impl metrics::Metrics for Metrics {
imported_requests: prometheus::register(
CounterVec::new(
Opts::new(
"parachain_dispute_distribution_imported_requests",
"polkadot_parachain_dispute_distribution_imported_requests",
"Total number of imported requests.",
),
&["success"],
@@ -116,7 +116,7 @@ impl metrics::Metrics for Metrics {
)?,
time_dispute_request: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_dispute_distribution_time_dispute_request",
"polkadot_parachain_dispute_distribution_time_dispute_request",
"Time needed for dispute votes to get confirmed/fail getting transmitted.",
))?,
registry,
@@ -1970,14 +1970,14 @@ impl metrics::Metrics for Metrics {
let metrics = MetricsInner {
statements_distributed: prometheus::register(
prometheus::Counter::new(
"parachain_statements_distributed_total",
"polkadot_parachain_statements_distributed_total",
"Number of candidate validity statements distributed to other peers.",
)?,
registry,
)?,
sent_requests: prometheus::register(
prometheus::Counter::new(
"parachain_statement_distribution_sent_requests_total",
"polkadot_parachain_statement_distribution_sent_requests_total",
"Number of large statement fetching requests sent.",
)?,
registry,
@@ -1985,7 +1985,7 @@ impl metrics::Metrics for Metrics {
received_responses: prometheus::register(
prometheus::CounterVec::new(
prometheus::Opts::new(
"parachain_statement_distribution_received_responses_total",
"polkadot_parachain_statement_distribution_received_responses_total",
"Number of received responses for large statement data.",
),
&["success"],
@@ -1994,21 +1994,21 @@ impl metrics::Metrics for Metrics {
)?,
active_leaves_update: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_statement_distribution_active_leaves_update",
"polkadot_parachain_statement_distribution_active_leaves_update",
"Time spent within `statement_distribution::active_leaves_update`",
))?,
registry,
)?,
share: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_statement_distribution_share",
"polkadot_parachain_statement_distribution_share",
"Time spent within `statement_distribution::share`",
))?,
registry,
)?,
network_bridge_update_v1: prometheus::register(
prometheus::Histogram::with_opts(prometheus::HistogramOpts::new(
"parachain_statement_distribution_network_bridge_update_v1",
"polkadot_parachain_statement_distribution_network_bridge_update_v1",
"Time spent within `statement_distribution::network_bridge_update_v1`",
))?,
registry,
+11 -11
View File
@@ -115,21 +115,21 @@ impl MetricsTrait for Metrics {
let metrics = MetricsInner {
activated_heads_total: prometheus::register(
prometheus::Counter::new(
"parachain_activated_heads_total",
"polkadot_parachain_activated_heads_total",
"Number of activated heads.",
)?,
registry,
)?,
deactivated_heads_total: prometheus::register(
prometheus::Counter::new(
"parachain_deactivated_heads_total",
"polkadot_parachain_deactivated_heads_total",
"Number of deactivated heads.",
)?,
registry,
)?,
messages_relayed_total: prometheus::register(
prometheus::Counter::new(
"parachain_messages_relayed_total",
"polkadot_parachain_messages_relayed_total",
"Number of messages relayed by Overseer.",
)?,
registry,
@@ -137,7 +137,7 @@ impl MetricsTrait for Metrics {
to_subsystem_bounded_sent: prometheus::register(
prometheus::GaugeVec::<prometheus::U64>::new(
prometheus::Opts::new(
"parachain_subsystem_bounded_sent",
"polkadot_parachain_subsystem_bounded_sent",
"Number of elements sent to subsystems' bounded queues",
),
&["subsystem_name"],
@@ -147,7 +147,7 @@ impl MetricsTrait for Metrics {
to_subsystem_bounded_received: prometheus::register(
prometheus::GaugeVec::<prometheus::U64>::new(
prometheus::Opts::new(
"parachain_subsystem_bounded_received",
"polkadot_parachain_subsystem_bounded_received",
"Number of elements received by subsystems' bounded queues",
),
&["subsystem_name"],
@@ -157,7 +157,7 @@ impl MetricsTrait for Metrics {
to_subsystem_unbounded_sent: prometheus::register(
prometheus::GaugeVec::<prometheus::U64>::new(
prometheus::Opts::new(
"parachain_subsystem_unbounded_sent",
"polkadot_parachain_subsystem_unbounded_sent",
"Number of elements sent to subsystems' unbounded queues",
),
&["subsystem_name"],
@@ -167,7 +167,7 @@ impl MetricsTrait for Metrics {
to_subsystem_unbounded_received: prometheus::register(
prometheus::GaugeVec::<prometheus::U64>::new(
prometheus::Opts::new(
"parachain_subsystem_unbounded_received",
"polkadot_parachain_subsystem_unbounded_received",
"Number of elements received by subsystems' unbounded queues",
),
&["subsystem_name"],
@@ -177,7 +177,7 @@ impl MetricsTrait for Metrics {
signals_sent: prometheus::register(
prometheus::GaugeVec::<prometheus::U64>::new(
prometheus::Opts::new(
"parachain_overseer_signals_sent",
"polkadot_parachain_overseer_signals_sent",
"Number of signals sent by overseer to subsystems",
),
&["subsystem_name"],
@@ -187,7 +187,7 @@ impl MetricsTrait for Metrics {
signals_received: prometheus::register(
prometheus::GaugeVec::<prometheus::U64>::new(
prometheus::Opts::new(
"parachain_overseer_signals_received",
"polkadot_parachain_overseer_signals_received",
"Number of signals received by subsystems from overseer",
),
&["subsystem_name"],
@@ -197,14 +197,14 @@ impl MetricsTrait for Metrics {
memory_stats_allocated: prometheus::register(
prometheus::Gauge::<prometheus::U64>::new(
"memory_allocated",
"polkadot_memory_allocated",
"Total bytes allocated by the node",
)?,
registry,
)?,
memory_stats_resident: prometheus::register(
prometheus::Gauge::<prometheus::U64>::new(
"memory_resident",
"polkadot_memory_resident",
"Bytes allocated by the node, and held in RAM",
)?,
registry,
+3 -3
View File
@@ -280,9 +280,9 @@ fn extract_metrics(registry: &prometheus::Registry) -> HashMap<&'static str, u64
.get_value() as u64
};
let activated = extract("parachain_activated_heads_total");
let deactivated = extract("parachain_deactivated_heads_total");
let relayed = extract("parachain_messages_relayed_total");
let activated = extract("polkadot_parachain_activated_heads_total");
let deactivated = extract("polkadot_parachain_deactivated_heads_total");
let relayed = extract("polkadot_parachain_messages_relayed_total");
let mut result = HashMap::new();
result.insert("activated", activated);
result.insert("deactivated", deactivated);
-11
View File
@@ -272,15 +272,6 @@ impl IdentifyVariant for Box<dyn ChainSpec> {
}
}
// If we're using prometheus, use a registry with a prefix of `polkadot`.
fn set_prometheus_registry(config: &mut Configuration) -> Result<(), Error> {
if let Some(PrometheusConfig { registry, .. }) = config.prometheus_config.as_mut() {
*registry = Registry::new_custom(Some("polkadot".into()), None)?;
}
Ok(())
}
/// Initialize the `Jeager` collector. The destination must listen
/// on the given address and port for `UDP` packets.
#[cfg(any(test, feature = "full-node"))]
@@ -344,8 +335,6 @@ where
RuntimeApiCollection<StateBackend = sc_client_api::StateBackendFor<FullBackend, Block>>,
ExecutorDispatch: NativeExecutionDispatch + 'static,
{
set_prometheus_registry(config)?;
let telemetry = config
.telemetry_endpoints
.clone()
@@ -73,7 +73,7 @@ impl metrics::Metrics for Metrics {
approval_checking_finality_lag: prometheus::register(
prometheus::Gauge::with_opts(
prometheus::Opts::new(
"parachain_approval_checking_finality_lag",
"polkadot_parachain_approval_checking_finality_lag",
"How far behind the head of the chain the Approval Checking protocol wants to vote",
)
)?,
@@ -82,7 +82,7 @@ impl metrics::Metrics for Metrics {
disputes_finality_lag: prometheus::register(
prometheus::Gauge::with_opts(
prometheus::Opts::new(
"parachain_disputes_finality_lag",
"polkadot_parachain_disputes_finality_lag",
"How far behind the head of the chain the Disputes protocol wants to vote",
)
)?,