You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/01/18 08:20:10 UTC
[incubator-inlong] branch master updated (c2439b5 -> e1235ad)

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

dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.


    from c2439b5  [INLONG-2051] audit query support mysql and elasticsearch (#2147)
     add e1235ad  [INLONG-2176] Add histogram metric and client-side metric output (#2177)

No new revisions were added by this update.

Summary of changes:
 .../inlong/tubemq/client/common/ClientMetrics.java | 308 ++++++++++++++++++
 .../tubemq/client/common/TClientConstants.java     |   9 +
 .../tubemq/client/config/TubeClientConfig.java     |  49 +++
 .../client/consumer/BaseMessageConsumer.java       |  39 ++-
 .../consumer/SimpleClientBalanceConsumer.java      |  54 +++-
 .../client/consumer/SimplePullMessageConsumer.java |   2 +
 .../client/consumer/SimplePushMessageConsumer.java |   2 +
 .../tubemq/client/producer/ProducerManager.java    |  51 ++-
 .../client/producer/SimpleMessageProducer.java     |  20 +-
 .../tubemq/corebase/metric/AbsMetricItem.java      |  10 +-
 .../tubemq/corebase/metric/CountMetricItem.java    |   4 +-
 .../tubemq/corebase/metric/GaugeMaxMetricItem.java |   4 +-
 .../tubemq/corebase/metric/GaugeMinMetricItem.java |   4 +-
 .../corebase/metric/GaugeNormMetricItem.java       |   2 +-
 .../tubemq/corebase/metric/TimeDltMetricItem.java  | 348 +++++++++++++++++++++
 .../{MetricType.java => ValueAdjustType.java}      |  20 +-
 .../inlong/tubemq/corebase/MessagesTest.java       |   8 +-
 .../tubemq/corebase/metric/MetricItemTest.java     |  71 ++++-
 .../corebase/utils/DateTimeConvertUtilsTest.java   |   4 +-
 .../server/broker/metrics/BrokerMetrics.java       |  91 +++---
 .../server/broker/metrics/BrokerMetricsHolder.java |   6 +-
 .../server/master/metrics/MasterMetrics.java       | 158 ++++------
 .../server/master/metrics/MasterMetricsHolder.java |   7 +-
 .../tubemq/server/broker/BrokerMetricsTest.java    | 116 +++----
 .../tubemq/server/master/MasterMetricsTest.java    | 140 ++++-----
 25 files changed, 1172 insertions(+), 355 deletions(-)
 create mode 100644 inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/common/ClientMetrics.java
 create mode 100644 inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/metric/TimeDltMetricItem.java
 copy inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/metric/{MetricType.java => ValueAdjustType.java} (71%)