MirrorMirror
/
Signal-Server
mirror of https://github.com/signalapp/Signal-Server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update MicrometerAwsSdkMetricPublisher maxConcurrency metric name

This commit is contained in:
Chris Eager 2024-11-19 17:30:11 -06:00 committed by Chris Eager
parent ea75c39b58
commit 4e8a48ab3d
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
service/src/main/java/org/whispersystems/textsecuregcm/metrics/MicrometerAwsSdkMetricPublisher.java
View File

@ -4,16 +4,15 @@ import io.micrometer.core.instrument.DistributionSummary;
import io.micrometer.core.instrument.Metrics; import io.micrometer.core.instrument.Metrics;
import io.micrometer.core.instrument.Tags; import io.micrometer.core.instrument.Tags;
import io.micrometer.core.instrument.Timer; import io.micrometer.core.instrument.Timer;
import software.amazon.awssdk.metrics.MetricCollection;
import software.amazon.awssdk.metrics.MetricPublisher;
import software.amazon.awssdk.metrics.MetricRecord;
import java.time.Duration; import java.time.Duration;
import java.util.Map; import java.util.Map;
import java.util.Optional; import java.util.Optional;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import software.amazon.awssdk.metrics.MetricCollection;
import software.amazon.awssdk.metrics.MetricPublisher;
import software.amazon.awssdk.metrics.MetricRecord;
/** /**
* A Micrometer AWS SDK metric publisher consumes {@link MetricCollection} instances provided by the AWS SDK when it * A Micrometer AWS SDK metric publisher consumes {@link MetricCollection} instances provided by the AWS SDK when it
@ -80,6 +79,9 @@ public class MicrometerAwsSdkMetricPublisher implements MetricPublisher {
private static final String CONCURRENT_REQUESTS_DISTRIBUTION_NAME = private static final String CONCURRENT_REQUESTS_DISTRIBUTION_NAME =
MetricsUtil.name(MicrometerAwsSdkMetricPublisher.class, "concurrentRequests"); MetricsUtil.name(MicrometerAwsSdkMetricPublisher.class, "concurrentRequests");
private static final String MAX_CONCURRENCY_GAUGE_NAME =
MetricsUtil.name(MicrometerAwsSdkMetricPublisher.class, "maxConcurrency");
private static final String CLIENT_NAME_TAG = "clientName"; private static final String CLIENT_NAME_TAG = "clientName";
/** /**
@ -93,7 +95,7 @@ public class MicrometerAwsSdkMetricPublisher implements MetricPublisher {
this.recordMetricsExecutorService = recordMetricsExecutorService; this.recordMetricsExecutorService = recordMetricsExecutorService;
this.awsClientName = awsClientName; this.awsClientName = awsClientName;
mostRecentMaxConcurrency = Metrics.gauge("maxConcurrency", mostRecentMaxConcurrency = Metrics.gauge(MAX_CONCURRENCY_GAUGE_NAME,
Tags.of(CLIENT_NAME_TAG, awsClientName), Tags.of(CLIENT_NAME_TAG, awsClientName),
new AtomicInteger(0)); new AtomicInteger(0));
} }