From 46ff8d51dcd38f8660a39a54d9ad9832a1e00b81 Mon Sep 17 00:00:00 2001 From: Jon Chambers Date: Wed, 12 Mar 2025 15:09:39 -0400 Subject: [PATCH] Switch to remote aggregation for persister distribution summaries --- .../textsecuregcm/storage/MessagePersister.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java index 6d15fefb8..73cc0ea96 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java @@ -51,15 +51,15 @@ public class MessagePersister implements Managed { Metrics.counter(name(MessagePersister.class, "persistQueueException")); private static final Counter TRIMMED_MESSAGE_COUNTER = Metrics.counter(name(MessagePersister.class, "trimmedMessage")); private static final Counter TRIMMED_MESSAGE_BYTES_COUNTER = Metrics.counter(name(MessagePersister.class, "trimmedMessageBytes")); + private static final DistributionSummary QUEUE_COUNT_DISTRIBUTION_SUMMARY = DistributionSummary.builder( name(MessagePersister.class, "queueCount")) - .publishPercentiles(0.5, 0.75, 0.95, 0.99, 0.999) - .distributionStatisticExpiry(Duration.ofMinutes(10)) + .publishPercentileHistogram(true) .register(Metrics.globalRegistry); + private static final DistributionSummary QUEUE_SIZE_DISTRIBUTION_SUMMARY = DistributionSummary.builder( name(MessagePersister.class, "queueSize")) - .publishPercentiles(0.5, 0.75, 0.95, 0.99, 0.999) - .distributionStatisticExpiry(Duration.ofMinutes(10)) + .publishPercentileHistogram(true) .register(Metrics.globalRegistry); static final int QUEUE_BATCH_LIMIT = 100;