Update Besu dependencies

CHANGELOG.md

@@ -2,21 +2,14 @@
 
 ## Upcoming Breaking Changes
 
-- Next release will introduce a breaking change to Teku's metrics. This is due to some metrics changing names after a library upgrade.
-We recommend all users of the `Teku - Detailed` dashboard to upgrade to version [Revision 12](https://grafana.com/api/dashboards/16737/revisions/12/download)  
-as soon as possible. Documentation with all metrics that have been renamed will be provided.
-- Next release will require Java 21. The current release is compatible, please consider upgrading before the next release.
-- From the next release, you will need to explicitly set `--data-storage-mode=(prune|archive)` unless you're using minimal data-storage-mode (which is the default behaviour).
-
 ## Current Releases
 
-For information on changes in released versions of Teku, see
-the [releases page](https://github.com/Consensys/teku/releases).
-
 ## Unreleased Changes
 
 ### Breaking Changes
 
+- Updated counter metrics to incorporate the suffix `_total`. If you are using a custom dashboard to monitor Teku metrics, you might need to update the metrics manually when breaking changes are introduced. For more information, see [Update metrics](../../how-to/monitor/update-metrics.md).
+
 ### Additions and Improvements
 
 ### Bug Fixes

ethereum/executionlayer/src/main/java/tech/pegasys/teku/ethereum/executionlayer/ExecutionLayerManagerImpl.java

@@ -85,7 +85,7 @@ public static ExecutionLayerManagerImpl create(
     final LabelledMetric<Counter> executionPayloadSourceCounter =
         metricsSystem.createLabelledCounter(
             TekuMetricCategory.BEACON,
-            "execution_payload_source",
+            "execution_payload_source_total",
             "Counter recording the source of the execution payload during block production",
             "source",
             "fallback_reason");

ethereum/executionlayer/src/test/java/tech/pegasys/teku/ethereum/executionlayer/ExecutionLayerBlockProductionManagerImplTest.java

@@ -569,7 +569,7 @@ private void verifyEngineCalled(
   private void verifySourceCounter(final Source source, final FallbackReason reason) {
     final long actualCount =
         stubMetricsSystem
-            .getCounter(TekuMetricCategory.BEACON, "execution_payload_source")
+            .getCounter(TekuMetricCategory.BEACON, "execution_payload_source_total")
             .getValue(source.toString(), reason.toString());
     assertThat(actualCount).isOne();
   }

ethereum/executionlayer/src/test/java/tech/pegasys/teku/ethereum/executionlayer/ExecutionLayerManagerImplTest.java

@@ -858,7 +858,7 @@ private void verifyEngineCalled(
   private void verifySourceCounter(final Source source, final FallbackReason reason) {
     final long actualCount =
         stubMetricsSystem
-            .getCounter(TekuMetricCategory.BEACON, "execution_payload_source")
+            .getCounter(TekuMetricCategory.BEACON, "execution_payload_source_total")
             .getValue(source.toString(), reason.toString());
     assertThat(actualCount).isOne();
   }

ethereum/spec/src/testFixtures/java/tech/pegasys/teku/spec/datastructures/interop/MergedGenesisTestBuilder.java

@@ -17,9 +17,11 @@
 import org.hyperledger.besu.config.GenesisConfigFile;
 import org.hyperledger.besu.config.GenesisConfigOptions;
 import org.hyperledger.besu.datatypes.Wei;
+import org.hyperledger.besu.ethereum.chain.BadBlockManager;
 import org.hyperledger.besu.ethereum.chain.GenesisState;
 import org.hyperledger.besu.ethereum.core.Block;
 import org.hyperledger.besu.ethereum.core.BlockHeader;
+import org.hyperledger.besu.ethereum.core.MiningParameters;
 import org.hyperledger.besu.ethereum.mainnet.MainnetProtocolSchedule;
 import org.hyperledger.besu.ethereum.mainnet.ProtocolSchedule;
 import tech.pegasys.teku.infrastructure.bytes.Bytes20;
@@ -35,8 +37,10 @@ public static ExecutionPayloadHeader createPayloadForBesuGenesis(
     final GenesisConfigFile configFile = GenesisConfigFile.fromConfig(genesisConfigFile);
     final GenesisConfigOptions genesisConfigOptions =
         configFile.getConfigOptions(Collections.emptyMap());
+    final BadBlockManager badBlockManager = new BadBlockManager();
     final ProtocolSchedule protocolSchedule =
-        MainnetProtocolSchedule.fromConfig(genesisConfigOptions);
+        MainnetProtocolSchedule.fromConfig(
+            genesisConfigOptions, MiningParameters.MINING_DISABLED, badBlockManager);
     final GenesisState genesisState = GenesisState.fromConfig(configFile, protocolSchedule);
     final Block genesisBlock = genesisState.getBlock();
     final BlockHeader header = genesisBlock.getHeader();

ethereum/statetransition/src/main/java/tech/pegasys/teku/statetransition/MappedOperationPool.java

@@ -98,7 +98,7 @@ public MappedOperationPool(
     validationReasonCounter =
         metricsSystem.createLabelledCounter(
             TekuMetricCategory.BEACON,
-            OPERATION_POOL_SIZE_VALIDATION_REASON + metricType,
+            OPERATION_POOL_SIZE_VALIDATION_REASON + metricType + "_total",
             "Total number of attempts to add an operation to the pool, broken down by validation result",
             "result");
 

ethereum/statetransition/src/main/java/tech/pegasys/teku/statetransition/SimpleOperationPool.java

@@ -113,7 +113,7 @@ private SimpleOperationPool(
     validationReasonCounter =
         metricsSystem.createLabelledCounter(
             TekuMetricCategory.BEACON,
-            OPERATION_POOL_SIZE_VALIDATION_REASON + metricType,
+            OPERATION_POOL_SIZE_VALIDATION_REASON + metricType + "_total",
             "Total number of attempts to add an operation to the pool, broken down by validation result",
             "result");
   }

ethereum/statetransition/src/main/java/tech/pegasys/teku/statetransition/util/PoolFactory.java

@@ -63,7 +63,7 @@ public PoolFactory(final MetricsSystem metricsSystem) {
     this.blockBlobSidecarsTrackersPoolStats =
         metricsSystem.createLabelledCounter(
             TekuMetricCategory.BEACON,
-            "block_blobs_trackers_pool_stats",
+            "block_blobs_trackers_pool_stats_total",
             "Block-blobs trackers pool statistics",
             "type",
             "subtype");

ethereum/statetransition/src/main/java/tech/pegasys/teku/statetransition/validation/signatures/AggregatingSignatureVerificationService.java

@@ -81,12 +81,12 @@ public class AggregatingSignatureVerificationService extends SignatureVerificati
     batchCounter =
         metricsSystem.createCounter(
             TekuMetricCategory.EXECUTOR,
-            "signature_verifications_batch_count",
+            "signature_verifications_batch_count_total",
             "Reports the number of verification batches processed");
     taskCounter =
         metricsSystem.createCounter(
             TekuMetricCategory.EXECUTOR,
-            "signature_verifications_task_count",
+            "signature_verifications_task_count_total",
             "Reports the number of individual verification tasks processed");
     batchSizeHistogram =
         MetricsHistogram.create(

ethereum/statetransition/src/test/java/tech/pegasys/teku/statetransition/util/BlockBlobSidecarsTrackersPoolImplTest.java

@@ -1066,7 +1066,8 @@ private static BlobIdentifier blobIdentifierFromBlobSidecar(final BlobSidecar bl
   }
 
   private void assertStats(final String type, final String subType, final double count) {
-    assertThat(getMetricsValues("block_blobs_trackers_pool_stats").get(List.of(type, subType)))
+    assertThat(
+            getMetricsValues("block_blobs_trackers_pool_stats_total").get(List.of(type, subType)))
         .isEqualTo(count);
   }
 

gradle/versions.gradle

@@ -137,14 +137,14 @@ dependencyManagement {
 
     dependency 'org.xerial.snappy:snappy-java:1.1.10.5'
 
-    dependency 'io.prometheus:simpleclient:0.9.0'
+    dependency 'io.prometheus:simpleclient:0.16.0'
 
-    dependencySet(group: 'org.hyperledger.besu.internal', version: '24.1.2') {
+    dependencySet(group: 'org.hyperledger.besu.internal', version: '24.5.2') {
       entry('metrics-core')
       entry('core')
       entry('config')
     }
-    dependencySet(group: 'org.hyperledger.besu', version: '24.1.2') {
+    dependencySet(group: 'org.hyperledger.besu', version: '24.5.2') {
       entry('besu-datatypes')
       entry('evm')
       entry('plugin-api')

infrastructure/events/src/main/java/tech/pegasys/teku/infrastructure/events/DirectEventDeliverer.java

@@ -35,14 +35,14 @@ class DirectEventDeliverer<T> extends EventDeliverer<T> {
     consumedEventCounter =
         metricsSystem.createLabelledCounter(
             EVENTBUS,
-            "event_consumed_count",
+            "event_consumed_count_total",
             "Total number of events consumed",
             "channel",
             "subscriber");
     failedEventCounter =
         metricsSystem.createLabelledCounter(
             EVENTBUS,
-            "event_failed_count",
+            "event_failed_count_total",
             "Number of events which failed to be processed",
             "channel",
             "subscriber");

infrastructure/events/src/main/java/tech/pegasys/teku/infrastructure/events/EventDeliverer.java

@@ -32,7 +32,7 @@ protected EventDeliverer(final MetricsSystem metricsSystem) {
     publishedEventCounter =
         metricsSystem.createLabelledCounter(
             TekuMetricCategory.EVENTBUS,
-            "event_published_count",
+            "event_published_count_total",
             "Total number of events published",
             "channel");
   }

infrastructure/metrics/src/test/java/tech/pegasys/teku/infrastructure/metrics/MetricsCountersByIntervalsTest.java

@@ -73,6 +73,7 @@ void shouldCountWithDefault() {
         metricsSystem
             .streamObservations(CATEGORY)
             .filter(ob -> ob.getMetricName().equals(COUNTER_NAME))
+            .filter(ob -> !ob.getLabels().contains("created"))
             .collect(Collectors.toMap(Observation::getLabels, Observation::getValue));
 
     assertThat(values)
@@ -117,6 +118,7 @@ void shouldNotCountNonMatching() {
         metricsSystem
             .streamObservations(CATEGORY)
             .filter(ob -> ob.getMetricName().equals(COUNTER_NAME))
+            .filter(ob -> !ob.getLabels().contains("created"))
             .collect(Collectors.toMap(Observation::getLabels, Observation::getValue));
 
     assertThat(values).containsOnly(entry(List.of("label1Val1", "label2UnknownVal", "[0,∞)"), 1d));
@@ -141,6 +143,7 @@ void shouldInitCounters() {
         metricsSystem
             .streamObservations(CATEGORY)
             .filter(ob -> ob.getMetricName().equals(COUNTER_NAME))
+            .filter(ob -> !ob.getLabels().contains("created"))
             .collect(Collectors.toMap(Observation::getLabels, Observation::getValue));
 
     assertThat(values).containsOnly(entry(List.of("a", "b", "[0,∞)"), 0d));

networking/eth2/src/main/java/tech/pegasys/teku/networking/eth2/peers/PeerChainValidator.java

@@ -59,7 +59,7 @@ private PeerChainValidator(
     final LabelledMetric<Counter> validationCounter =
         metricsSystem.createLabelledCounter(
             TekuMetricCategory.NETWORK,
-            "peer_chain_validation_attempts",
+            "peer_chain_validation_attempts_total",
             "Number of peers chain verification has been performed on",
             "status");
     validationStartedCounter = validationCounter.labels("started");

networking/p2p/src/main/java/tech/pegasys/teku/networking/p2p/connection/ConnectionManager.java

@@ -78,7 +78,7 @@ public ConnectionManager(
     final LabelledMetric<Counter> connectionAttemptCounter =
         metricsSystem.createLabelledCounter(
             TekuMetricCategory.NETWORK,
-            "peer_connection_attempt_count",
+            "peer_connection_attempt_count_total",
             "Total number of outbound connection attempts made",
             "status");
     attemptedConnectionCounter = connectionAttemptCounter.labels("attempted");

services/beaconchain/src/main/java/tech/pegasys/teku/services/beaconchain/BeaconChainMetrics.java

@@ -197,7 +197,7 @@ public BeaconChainMetrics(
     final LabelledMetric<Counter> versionCounter =
         metricsSystem.createLabelledCounter(
             TekuMetricCategory.BEACON,
-            VersionProvider.CLIENT_IDENTITY + "_version",
+            VersionProvider.CLIENT_IDENTITY + "_version_total",
             "Teku version in use",
             "version");
     versionCounter.labels(version).inc();

storage/src/main/java/tech/pegasys/teku/storage/server/kvstore/dataaccess/V4FinalizedStateTreeStorageLogic.java

@@ -49,18 +49,18 @@ public V4FinalizedStateTreeStorageLogic(
     this.branchNodeStoredCounter =
         metricsSystem.createLabelledCounter(
             TekuMetricCategory.STORAGE_FINALIZED_DB,
-            "state_branch_nodes",
+            "state_branch_nodes_total",
             "Number of finalized state tree branch nodes stored vs skipped",
             "type");
     this.leafNodeStoredCounter =
         metricsSystem.createCounter(
             TekuMetricCategory.STORAGE_FINALIZED_DB,
-            "state_leaf_nodes",
+            "state_leaf_nodes_total",
             "Number of finalized state tree leaf nodes stored");
     statesStoredCounter =
         metricsSystem.createCounter(
             TekuMetricCategory.STORAGE_FINALIZED_DB,
-            "states_stored",
+            "states_stored_total",
             "Number of finalized states stored");
   }
 

validator/client/src/integration-test/java/tech/pegasys/teku/validator/client/signer/ExternalSignerTestUtil.java

@@ -59,7 +59,7 @@ static void validateMetrics(
       final long failCount,
       final long timeoutCount) {
     final StubCounter labelledCounter =
-        metricsSystem.getCounter(TekuMetricCategory.VALIDATOR, "external_signer_requests");
+        metricsSystem.getCounter(TekuMetricCategory.VALIDATOR, "external_signer_requests_total");
     assertThat(labelledCounter.getValue("success")).isEqualTo(successCount);
     assertThat(labelledCounter.getValue("failed")).isEqualTo(failCount);
     assertThat(labelledCounter.getValue("timeout")).isEqualTo(timeoutCount);

validator/client/src/main/java/tech/pegasys/teku/validator/client/PendingDuties.java

@@ -54,7 +54,7 @@ private PendingDuties(
     dutiesPerformedCounter =
         metricsSystem.createLabelledCounter(
             TekuMetricCategory.VALIDATOR,
-            "duties_performed",
+            "duties_performed_total",
             "Count of the failed duties, by duty type",
             "type",
             "result");

validator/client/src/main/java/tech/pegasys/teku/validator/client/signer/ExternalSigner.java

@@ -93,7 +93,7 @@ public ExternalSigner(
     final LabelledMetric<Counter> labelledCounter =
         metricsSystem.createLabelledCounter(
             TekuMetricCategory.VALIDATOR,
-            "external_signer_requests",
+            "external_signer_requests_total",
             "Completed external signer counts",
             "result");
     successCounter = labelledCounter.labels("success");

validator/client/src/test/java/tech/pegasys/teku/validator/client/PendingDutiesTest.java

@@ -245,7 +245,7 @@ void shouldReportTotalNumberOfSuccessesAndFailuresToMetrics() {
 
   private void validateMetrics(final String duty, final long successCount, final long failCount) {
     final StubCounter labelledCounter =
-        metricsSystem.getCounter(TekuMetricCategory.VALIDATOR, "duties_performed");
+        metricsSystem.getCounter(TekuMetricCategory.VALIDATOR, "duties_performed_total");
     assertThat(labelledCounter.getValue(duty, "success")).isEqualTo(successCount);
     assertThat(labelledCounter.getValue(duty, "failed")).isEqualTo(failCount);
   }