This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from be2b977 [INLONG-1938][DataProxy] add multi-pulsar cluster config demo
(#1940)
add d297738 [INLONG-1712][Feature][Agent] Add agent Prometheus metric
statistics (#1866)
No new revisions were added by this update.
Summary of changes:
inlong-agent/agent-common/pom.xml | 18 ++-
.../inlong/agent/constants/AgentConstants.java | 6 +
.../org/apache/inlong/agent/utils/ConfigUtil.java | 32 ++---
inlong-agent/agent-core/pom.xml | 13 ++
.../org/apache/inlong/agent/core/AgentMain.java | 31 ++++-
.../inlong/agent/core/job/JobJmxMetrics.java | 75 +++++++++++
.../apache/inlong/agent/core/job/JobManager.java | 16 ++-
.../apache/inlong/agent/core/job/JobMetrics.java | 68 ++++------
.../agent/core/job/JobPrometheusMetrics.java | 60 +++++++++
.../inlong/agent/core/task/TaskJmxMetrics.java | 90 +++++++++++++
.../apache/inlong/agent/core/task/TaskManager.java | 19 ++-
.../apache/inlong/agent/core/task/TaskMetrics.java | 79 +++++------
.../agent/core/task/TaskPrometheusMetrics.java | 76 +++++++++++
.../apache/inlong/agent/core/task/TaskWrapper.java | 2 +-
...estTaskMetrics.java => TestTaskJmxMetrics.java} | 10 +-
.../inlong/agent/plugin/channel/MemoryChannel.java | 39 ++++--
.../agent/plugin/metrics/PluginJmxMetric.java | 131 ++++++++++++++++++
.../inlong/agent/plugin/metrics/PluginMetric.java | 121 +++++++++++------
.../plugin/metrics/PluginPrometheusMetric.java | 146 +++++++++++++++++++++
.../inlong/agent/plugin/metrics/SinkJmxMetric.java | 71 ++++++++++
.../inlong/agent/plugin/metrics/SinkMetrics.java | 51 +++----
.../plugin/metrics/SinkPrometheusMetrics.java | 73 +++++++++++
.../agent/plugin/metrics/SourceJmxMetric.java | 71 ++++++++++
.../inlong/agent/plugin/metrics/SourceMetrics.java | 51 +++----
.../plugin/metrics/SourcePrometheusMetrics.java | 69 ++++++++++
.../inlong/agent/plugin/sinks/AbstractSink.java | 3 +-
.../inlong/agent/plugin/sinks/ConsoleSink.java | 21 +++
.../inlong/agent/plugin/sinks/ProxySink.java | 22 ++++
.../inlong/agent/plugin/sinks/PulsarSink.java | 34 ++++-
.../inlong/agent/plugin/sinks/SenderManager.java | 14 +-
.../agent/plugin/sources/DataBaseSource.java | 29 +++-
.../agent/plugin/sources/TextFileSource.java | 18 +++
.../agent/plugin/sources/reader/SqlReader.java | 16 +++
.../plugin/sources/reader/TextFileReader.java | 17 ++-
.../apache/inlong/agent/plugin/sinks/MockSink.java | 22 ++++
inlong-agent/conf/agent.properties | 9 ++
inlong-agent/pom.xml | 22 ++++
37 files changed, 1406 insertions(+), 239 deletions(-)
copy inlong-website/src/components/DashboardCard/CardList.tsx =>
inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/ConfigUtil.java
(62%)
create mode 100644
inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/job/JobJmxMetrics.java
create mode 100644
inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/job/JobPrometheusMetrics.java
create mode 100644
inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/TaskJmxMetrics.java
create mode 100644
inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/TaskPrometheusMetrics.java
rename
inlong-agent/agent-core/src/test/java/org/apache/inlong/agent/core/{TestTaskMetrics.java
=> TestTaskJmxMetrics.java} (80%)
create mode 100644
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/PluginJmxMetric.java
create mode 100644
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/PluginPrometheusMetric.java
create mode 100644
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SinkJmxMetric.java
copy inlong-website/src/components/DashboardCard/CardList.tsx =>
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SinkMetrics.java
(57%)
create mode 100644
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SinkPrometheusMetrics.java
create mode 100644
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SourceJmxMetric.java
copy inlong-website/src/components/DashboardCard/CardList.tsx =>
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SourceMetrics.java
(56%)
create mode 100644
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SourcePrometheusMetrics.java
