Prefix beholder metrics

Author: DylanTinianov

metrics/logpoller.go

@@ -82,22 +82,22 @@ type logPollerMetrics struct {
 }
 
 func NewGenericLogPollerMetrics(chainID string, chainFamily string) (GenericLogPollerMetrics, error) {
-	queryDuration, err := beholder.GetMeter().Float64Histogram("log_poller_query_duration")
+	queryDuration, err := beholder.GetMeter().Float64Histogram("beholder_log_poller_query_duration")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register logpoller query duration metric: %w", err)
 	}
 
-	queryDatasetSize, err := beholder.GetMeter().Int64Gauge("log_poller_query_dataset_size")
+	queryDatasetSize, err := beholder.GetMeter().Int64Gauge("beholder_log_poller_query_dataset_size")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register query dataset size metric: %w", err)
 	}
 
-	logsInserted, err := beholder.GetMeter().Int64Counter("log_poller_logs_inserted")
+	logsInserted, err := beholder.GetMeter().Int64Counter("beholder_log_poller_logs_inserted")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register logs inserted metric: %w", err)
 	}
 
-	blocksInserted, err := beholder.GetMeter().Int64Counter("log_poller_blocks_inserted")
+	blocksInserted, err := beholder.GetMeter().Int64Counter("beholder_log_poller_blocks_inserted")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register blocks inserted metric: %w", err)
 	}

metrics/multinode.go

@@ -105,62 +105,62 @@ type multiNodeMetrics struct {
 }
 
 func NewGenericMultiNodeMetrics(network string, chainID string) (GenericMultiNodeMetrics, error) {
-	nodeStates, err := beholder.GetMeter().Int64Gauge("multi_node_states")
+	nodeStates, err := beholder.GetMeter().Int64Gauge("beholder_multi_node_states")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register multinode states metric: %w", err)
 	}
 
-	nodeVerifies, err := beholder.GetMeter().Int64Counter("pool_rpc_node_verifies")
+	nodeVerifies, err := beholder.GetMeter().Int64Counter("beholder_pool_rpc_node_verifies")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register node verifies metric: %w", err)
 	}
 
-	nodeVerifiesFailed, err := beholder.GetMeter().Int64Counter("pool_rpc_node_verifies_failed")
+	nodeVerifiesFailed, err := beholder.GetMeter().Int64Counter("beholder_pool_rpc_node_verifies_failed")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register node verifies failed metric: %w", err)
 	}
 
-	nodeVerifiesSuccess, err := beholder.GetMeter().Int64Counter("pool_rpc_node_verifies_success")
+	nodeVerifiesSuccess, err := beholder.GetMeter().Int64Counter("beholder_pool_rpc_node_verifies_success")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register node verifies success metric: %w", err)
 	}
 
-	nodeTransitionsToAlive, err := beholder.GetMeter().Int64Counter("pool_rpc_node_num_transitions_to_alive")
+	nodeTransitionsToAlive, err := beholder.GetMeter().Int64Counter("beholder_pool_rpc_node_num_transitions_to_alive")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register node transitions to alive metric: %w", err)
 	}
 
-	nodeTransitionsToInSync, err := beholder.GetMeter().Int64Counter("pool_rpc_node_num_transitions_to_in_sync")
+	nodeTransitionsToInSync, err := beholder.GetMeter().Int64Counter("beholder_pool_rpc_node_num_transitions_to_in_sync")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register node transitions to in sync metric: %w", err)
 	}
 
-	nodeTransitionsToOutOfSync, err := beholder.GetMeter().Int64Counter("pool_rpc_node_num_transitions_to_out_of_sync")
+	nodeTransitionsToOutOfSync, err := beholder.GetMeter().Int64Counter("beholder_pool_rpc_node_num_transitions_to_out_of_sync")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register node transitions to out of sync metric: %w", err)
 	}
 
-	nodeTransitionsToUnreachable, err := beholder.GetMeter().Int64Counter("pool_rpc_node_num_transitions_to_unreachable")
+	nodeTransitionsToUnreachable, err := beholder.GetMeter().Int64Counter("beholder_pool_rpc_node_num_transitions_to_unreachable")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register node transitions to unreachable metric: %w", err)
 	}
 
-	nodeTransitionsToInvalidChainID, err := beholder.GetMeter().Int64Counter("pool_rpc_node_num_transitions_to_invalid_chain_id")
+	nodeTransitionsToInvalidChainID, err := beholder.GetMeter().Int64Counter("beholder_pool_rpc_node_num_transitions_to_invalid_chain_id")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register node transitions to invalid chain id metric: %w", err)
 	}
 
-	nodeTransitionsToUnusable, err := beholder.GetMeter().Int64Counter("pool_rpc_node_num_transitions_to_unusable")
+	nodeTransitionsToUnusable, err := beholder.GetMeter().Int64Counter("beholder_pool_rpc_node_num_transitions_to_unusable")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register node transitions to unusable metric: %w", err)
 	}
 
-	nodeTransitionsToSyncing, err := beholder.GetMeter().Int64Counter("pool_rpc_node_num_transitions_to_syncing")
+	nodeTransitionsToSyncing, err := beholder.GetMeter().Int64Counter("beholder_pool_rpc_node_num_transitions_to_syncing")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register node transitions to syncing metric: %w", err)
 	}
 
-	invariantViolations, err := beholder.GetMeter().Int64Counter("multi_node_invariant_violations")
+	invariantViolations, err := beholder.GetMeter().Int64Counter("beholder_multi_node_invariant_violations")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register invariant violations metric: %w", err)
 	}

metrics/txm.go

@@ -95,37 +95,37 @@ type txmMetrics struct {
 }
 
 func NewGenericTxmMetrics(chainID string) (GenericTXMMetrics, error) {
-	numBroadcastedTxs, err := beholder.GetMeter().Int64Counter("tx_manager_num_broadcasted")
+	numBroadcastedTxs, err := beholder.GetMeter().Int64Counter("beholder_tx_manager_num_broadcasted")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register broadcasted txs number metric: %w", err)
 	}
 
-	timeUntilBroadcast, err := beholder.GetMeter().Float64Histogram("tx_manager_time_until_tx_broadcast")
+	timeUntilBroadcast, err := beholder.GetMeter().Float64Histogram("beholder_tx_manager_time_until_tx_broadcast")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register time until broadcast metric: %w", err)
 	}
 
-	numGasBumps, err := beholder.GetMeter().Int64Counter("tx_manager_num_gas_bumps")
+	numGasBumps, err := beholder.GetMeter().Int64Counter("beholder_tx_manager_num_gas_bumps")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register number of gas bumps metric: %w", err)
 	}
 
-	gasBumpExceedsLimit, err := beholder.GetMeter().Int64Counter("tx_manager_gas_bump_exceeds_limit")
+	gasBumpExceedsLimit, err := beholder.GetMeter().Int64Counter("beholder_tx_manager_gas_bump_exceeds_limit")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register gas bump exceeds limit metric: %w", err)
 	}
 
-	numConfirmedTxs, err := beholder.GetMeter().Int64Counter("tx_manager_num_confirmed_transactions")
+	numConfirmedTxs, err := beholder.GetMeter().Int64Counter("beholder_tx_manager_num_confirmed_transactions")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register confirmed txs number metric: %w", err)
 	}
 
-	timeUntilTxConfirmed, err := beholder.GetMeter().Float64Histogram("tx_manager_time_until_tx_confirmed")
+	timeUntilTxConfirmed, err := beholder.GetMeter().Float64Histogram("beholder_tx_manager_time_until_tx_confirmed")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register time until tx confirmed metric: %w", err)
 	}
 
-	blocksUntilTxConfirmed, err := beholder.GetMeter().Float64Histogram("tx_manager_blocks_until_tx_confirmed")
+	blocksUntilTxConfirmed, err := beholder.GetMeter().Float64Histogram("beholder_tx_manager_blocks_until_tx_confirmed")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register blocks until tx confirmed metric: %w", err)
 	}