[Feature]DataProxy support monitor indicator with JMX.

[luchunliang]

Description

[Feature]DataProxy provide monitor indicator based on JMX, user can implement the code that read the metrics and report to user-defined monitor system.

DataProxy provide monitor indicator based on JMX, user can implement the code that read the metrics and report to user-defined monitor system.
Source-module and Sink-module can add monitor metric class that is the subclass of org.apache.inlong.commons.config.metrics.MetricItemSet, and register it to MBeanServer.
User-defined plugin can get module metric with JMX, and report metric data to different monitor system.

User can describe the configuration in the file "common.properties ".
For example:
metricDomains=DataProxy metricDomains.DataProxy.domainListeners=com.tencent.pcg.atta.dataproxy.metrics.m007.M007MetricListener org.apache.inlong.dataproxy.metrics.prometheus.PrometheusMetricListener metricDomains.DataProxy.snapshotInterval=60000

The JMX domain name of DataProxy is "DataProxy".
It is defined by the parameter "metricDomains".
The listeners of JMX domain is defined by the parameter "metricDomains.$domainName.domainListeners".
The class names of the listeners is separated by the space char.
The listener class need to implement the interface "org.apache.inlong.dataproxy.metrics.MetricListener".
The snapshot interval of the listeners is defined by the parameter "metricDomains.$domainName.snapshotInterval", the parameter unit is "millisecond".

The method proto of org.apache.inlong.dataproxy.metrics.MetricListener is:
public void snapshot(String domain, List itemValues);

The field of MetricItemValue.dimensions has these key(The fields of DataProxyMetricItem defined by the Annotation "@Dimension"):

• public String clusterId;
• public String sourceId;
• public String sourceDataId;
• public String inlongGroupId;
• public String inlongStreamId;
• public String sinkId;
• public String sinkDataId;

The field of MetricItemValue.metrics has these key(The fields of DataProxyMetricItem defined by the Annotation "@CountMetric"):

• readSuccessCount
• readSuccessSize
• readSuccessCount
• readSuccessSize
• readFailCount
• readFailSize
• sendCount
• sendSize
• sendSuccessCount
• sendSuccessSize
• sendFailCount
• sendFailSize
• sinkDuration, the unit is millisecond, the duration is between current timepoint and the timepoint in sending to sink destination.
• nodeDuration, the unit is millisecond, the duration is between current timepoint and the timepoint in getting event from source.
• wholeDuration, the unit is millisecond, the duration is between current timepoint and the timepoint in generating event.

Use case

No response

Are you willing to submit PR?

• Yes, I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct