[inlong] branch master updated: [INLONG-6708][DataProxy] Add more metrics of DataProxy (#6714)

[dockerzhang]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 0fadf6abe [INLONG-6708][DataProxy] Add more metrics of DataProxy 
(#6714)
0fadf6abe is described below

commit 0fadf6abe2f2bbf1288dc1d97cd38482f98e38e0
Author: vernedeng <deng...@pku.edu.cn>
AuthorDate: Sun Dec 4 16:51:53 2022 +0800

    [INLONG-6708][DataProxy] Add more metrics of DataProxy (#6714)
---
 .../dataproxy/metrics/DataProxyMetricItem.java     | 24 ++++++++++++++++------
 1 file changed, 18 insertions(+), 6 deletions(-)

diff --git 
a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/metrics/DataProxyMetricItem.java
 
b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/metrics/DataProxyMetricItem.java
index 91884e52a..6dfc40d3e 100644
--- 
a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/metrics/DataProxyMetricItem.java
+++ 
b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/metrics/DataProxyMetricItem.java
@@ -31,7 +31,6 @@ import org.apache.inlong.dataproxy.metrics.audit.AuditUtils;
 import org.apache.inlong.dataproxy.utils.Constants;
 
 /**
- * 
  * DataProxyMetricItem
  */
 @MetricDomain(name = "DataProxy")
@@ -45,7 +44,7 @@ public class DataProxyMetricItem extends MetricItem {
     public static final String KEY_SINK_ID = "sinkId";
     public static final String KEY_SINK_DATA_ID = "sinkDataId";
     public static final String KEY_MESSAGE_TIME = "msgTime";
-    //
+
     public static final String M_READ_SUCCESS_COUNT = "readSuccessCount";
     public static final String M_READ_SUCCESS_SIZE = "readSuccessSize";
     public static final String M_READ_FAIL_COUNT = "readFailCount";
@@ -56,11 +55,16 @@ public class DataProxyMetricItem extends MetricItem {
     public static final String M_SEND_SUCCESS_SIZE = "sendSuccessSize";
     public static final String M_SEND_FAIL_COUNT = "sendFailCount";
     public static final String M_SEND_FAIL_SIZE = "sendFailSize";
-    //
+
     public static final String M_SINK_DURATION = "sinkDuration";
     public static final String M_NODE_DURATION = "nodeDuration";
     public static final String M_WHOLE_DURATION = "wholeDuration";
 
+    public static final String M_READ_PACK_COUNT = "readPackCount";
+    public static final String M_READ_PACK_SIZE = "readPackSize";
+    public static final String M_SEND_PACK_COUNT = "sendPackCount";
+    public static final String M_SEND_PACK_SIZE = "sendPackSize";
+
     @Dimension
     public String clusterId;
     @Dimension
@@ -106,6 +110,14 @@ public class DataProxyMetricItem extends MetricItem {
     @CountMetric
     // sinkCallbackTime - eventCreateTime(milliseconds)
     public AtomicLong wholeDuration = new AtomicLong(0);
+    @CountMetric
+    public AtomicLong readPackCount = new AtomicLong(0);
+    @CountMetric
+    public AtomicLong readPackSize = new AtomicLong(0);
+    @CountMetric
+    public AtomicLong sendPackCount = new AtomicLong(0);
+    @CountMetric
+    public AtomicLong sendPackSize = new AtomicLong(0);
 
     /**
      * fillInlongId
@@ -126,7 +138,7 @@ public class DataProxyMetricItem extends MetricItem {
 
     /**
      * fillAuditFormatTime
-     * 
+     *
      * @param event
      * @param dimensions
      */
@@ -138,7 +150,7 @@ public class DataProxyMetricItem extends MetricItem {
 
     /**
      * getInlongGroupId
-     * 
+     *
      * @param  headers
      * @return
      */
@@ -152,7 +164,7 @@ public class DataProxyMetricItem extends MetricItem {
 
     /**
      * getInlongStreamId
-     * 
+     *
      * @param  headers
      * @return
      */