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 a325394 [INLONG-2703][Common] Add common reporter to report stream
config log and stream metric(#2704)
add 924538a [INLONG-2682][Manager] Add stream metric and stream config
log related interface (#2683)
No new revisions were added by this update.
Summary of changes:
.../pojo/stream/InlongStreamConfigLogRequest.java | 29 +--
.../pojo/stream/InlongStreamMetricRequest.java | 33 ++--
.../manager/dao/entity/StreamConfigLogEntity.java | 209 ++++++++++++++++++++
.../manager/dao/entity/StreamMetricEntity.java | 197 +++++++++++++++++++
...apper.java => StreamConfigLogEntityMapper.java} | 23 ++-
...tyMapper.java => StreamMetricEntityMapper.java} | 25 ++-
.../src/main/resources/generatorConfig.xml | 24 ++-
.../mappers/StreamConfigLogEntityMapper.xml | 215 +++++++++++++++++++++
.../resources/mappers/StreamMetricEntityMapper.xml | 204 +++++++++++++++++++
...eatService.java => StreamConfigLogService.java} | 9 +-
...rtbeatService.java => StreamMetricService.java} | 9 +-
.../manager/service/core/impl/AbstractService.java | 112 +++++++++++
.../core/impl/StreamConfigLogServiceImpl.java | 67 +++++++
.../service/core/impl/StreamMetricServiceImpl.java | 67 +++++++
.../manager-web/sql/apache_inlong_manager.sql | 46 ++++-
.../StreamConfigLogController.java} | 33 ++--
.../StreamMetricController.java} | 32 ++-
17 files changed, 1229 insertions(+), 105 deletions(-)
copy
inlong-common/src/main/java/org/apache/inlong/common/reporpter/dto/StreamConfigLogInfo.java
=>
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/stream/InlongStreamConfigLogRequest.java
(60%)
copy
inlong-common/src/main/java/org/apache/inlong/common/reporpter/dto/StreamMetricInfo.java
=>
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/stream/InlongStreamMetricRequest.java
(59%)
create mode 100644
inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/StreamConfigLogEntity.java
create mode 100644
inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/StreamMetricEntity.java
copy
inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/{SortTaskIdParamEntityMapper.java
=> StreamConfigLogEntityMapper.java} (63%)
copy
inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/{OperationLogEntityMapper.java
=> StreamMetricEntityMapper.java} (64%)
create mode 100644
inlong-manager/manager-dao/src/main/resources/mappers/StreamConfigLogEntityMapper.xml
create mode 100644
inlong-manager/manager-dao/src/main/resources/mappers/StreamMetricEntityMapper.xml
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/{AgentHeartbeatService.java
=> StreamConfigLogService.java} (80%)
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/{AgentHeartbeatService.java
=> StreamMetricService.java} (80%)
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AbstractService.java
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/StreamConfigLogServiceImpl.java
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/StreamMetricServiceImpl.java
copy
inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/{BasicInfoController.java
=> openapi/StreamConfigLogController.java} (59%)
copy
inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/{BasicInfoController.java
=> openapi/StreamMetricController.java} (59%)
