You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by he...@apache.org on 2022/02/11 09:45:33 UTC

[incubator-inlong] branch master updated (9ac6e53 -> ebb1fca)

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

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


    from 9ac6e53  [INLONG-2464] remove the useless aviator dependency (#2466)
     add ebb1fca  [INLONG-2474][TubeMQ] Adjust the statistics of Broker's message service part (#2475)

No new revisions were added by this update.

Summary of changes:
 .../tubemq/corebase/metric/impl/ESTHistogram.java  |  12 +-
 .../tubemq/corebase/metric/impl/SinceTime.java     |   5 +
 .../tubemq/corebase/metric/HistogramTest.java      |  18 +-
 .../tubemq/server/broker/BrokerServiceServer.java  |  10 +-
 .../inlong/tubemq/server/broker/TubeBroker.java    |   8 +-
 .../server/broker/msgstore/disk/FileSegment.java   |  10 +-
 .../server/broker/msgstore/disk/MsgFileStore.java  |   8 +-
 .../server/broker/msgstore/mem/MsgMemStore.java    |   4 +-
 .../server/broker/offset/DefaultOffsetManager.java |   4 +-
 .../server/broker/stats/ServiceStatsHolder.java    | 247 +++++++++++++++++++++
 .../common/offsetstorage/ZkOffsetStorage.java      |  11 +-
 .../broker/stats/ServiceStatsHolderTest.java       | 104 +++++++++
 12 files changed, 401 insertions(+), 40 deletions(-)
 create mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/stats/ServiceStatsHolder.java
 create mode 100644 inlong-tubemq/tubemq-server/src/test/java/org/apache/inlong/tubemq/server/broker/stats/ServiceStatsHolderTest.java