You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/06/27 08:18:21 UTC

[rocketmq-clients] branch master updated: CPP: amend the bucket for histogram (#21)

This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new c7b05ca  CPP: amend the bucket for histogram (#21)
c7b05ca is described below

commit c7b05ca4e3c922bec627ba5c2e62edbae24e043a
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Mon Jun 27 16:18:16 2022 +0800

    CPP: amend the bucket for histogram (#21)
---
 cpp/src/main/cpp/stats/ConsumeStats.cpp | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/cpp/src/main/cpp/stats/ConsumeStats.cpp b/cpp/src/main/cpp/stats/ConsumeStats.cpp
index e563c8c..c95ad2e 100644
--- a/cpp/src/main/cpp/stats/ConsumeStats.cpp
+++ b/cpp/src/main/cpp/stats/ConsumeStats.cpp
@@ -119,7 +119,7 @@ ConsumeStats::ConsumeStats()
       .set_description("Message delivery latency")
       .set_measure("delivery_latency")
       .set_aggregation(opencensus::stats::Aggregation::Distribution(
-          opencensus::stats::BucketBoundaries::Explicit({5, 10, 20, 50, 500})))
+          opencensus::stats::BucketBoundaries::Explicit({1.0, 5.0, 10.0, 20.0, 50.0, 200.0, 500.0})))
       .add_column(Tag::topicTag())
       .add_column(Tag::clientIdTag())
       .RegisterForExport();
@@ -129,7 +129,7 @@ ConsumeStats::ConsumeStats()
       .set_description("Message await time")
       .set_measure("await_time")
       .set_aggregation(opencensus::stats::Aggregation::Distribution(
-          opencensus::stats::BucketBoundaries::Explicit({1, 1000, 60000, 900000})))
+          opencensus::stats::BucketBoundaries::Explicit({1.0, 5.0, 20.0, 100.0, 1000.0, 5000.0, 10000.0})))
       .add_column(Tag::topicTag())
       .add_column(Tag::clientIdTag())
       .RegisterForExport();
@@ -139,7 +139,7 @@ ConsumeStats::ConsumeStats()
       .set_description("Process time")
       .set_measure("process_time")
       .set_aggregation(opencensus::stats::Aggregation::Distribution(
-          opencensus::stats::BucketBoundaries::Explicit({100, 1000, 60000, 900000})))
+          opencensus::stats::BucketBoundaries::Explicit({1.0, 5.0, 10.0, 100.0, 10000.0, 60000.0})))
       .add_column(Tag::topicTag())
       .add_column(Tag::clientIdTag())
       .RegisterForExport();