This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch eventmesh-function
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from c673a1946 fix conflicts with master
add a224b5178 fix missing apache header
No new revisions were added by this update.
Summary of changes:
.../com/apache/eventmesh/admin/server/Admin.java | 21 ++++++++++
.../apache/eventmesh/admin/server/AdminServer.java | 22 +++++++++-
.../admin/server/AdminServerProperties.java | 19 +++++++++
.../admin/server/AdminServerRuntimeException.java | 19 +++++++++
.../eventmesh/admin/server/ComponentLifeCycle.java | 19 +++++++++
.../eventmesh/admin/server/ExampleAdminServer.java | 20 +++++++++
.../admin/server/web/AdminGrpcServer.java | 33 ++++++++++++---
.../eventmesh/admin/server/web/BaseServer.java | 17 ++++++++
.../eventmesh/admin/server/web/GrpcServer.java | 17 ++++++++
.../eventmesh/admin/server/web/HttpServer.java | 17 ++++++++
.../apache/eventmesh/admin/server/web/Request.java | 17 ++++++++
.../eventmesh/admin/server/web/Response.java | 18 +++++++++
.../admin/server/web/ServerController.java | 18 +++++++++
.../admin/server/web/db/DBThreadPool.java | 30 ++++++++++++--
.../server/web/db/entity/EventMeshDataSource.java | 21 +++++++++-
.../server/web/db/entity/EventMeshJobDetail.java | 19 +++++++++
.../server/web/db/entity/EventMeshJobInfo.java | 21 +++++++++-
.../web/db/entity/EventMeshMysqlPosition.java | 21 +++++++++-
.../entity/EventMeshPositionReporterHistory.java | 21 +++++++++-
.../web/db/entity/EventMeshRuntimeHeartbeat.java | 21 +++++++++-
.../web/db/entity/EventMeshRuntimeHistory.java | 21 +++++++++-
.../web/db/mapper/EventMeshDataSourceMapper.java | 28 ++++++++++---
.../web/db/mapper/EventMeshJobInfoMapper.java | 28 ++++++++++---
.../db/mapper/EventMeshMysqlPositionMapper.java | 28 ++++++++++---
.../EventMeshPositionReporterHistoryMapper.java | 28 ++++++++++---
.../db/mapper/EventMeshRuntimeHeartbeatMapper.java | 28 ++++++++++---
.../db/mapper/EventMeshRuntimeHistoryMapper.java | 28 ++++++++++---
.../web/db/service/EventMeshDataSourceService.java | 17 ++++++++
.../web/db/service/EventMeshJobInfoService.java | 17 ++++++++
.../db/service/EventMeshMysqlPositionService.java | 17 ++++++++
.../EventMeshPositionReporterHistoryService.java | 17 ++++++++
.../service/EventMeshRuntimeHeartbeatService.java | 26 ++++++++++--
.../db/service/EventMeshRuntimeHistoryService.java | 25 ++++++++++--
.../impl/EventMeshDataSourceServiceImpl.java | 28 ++++++++++---
.../service/impl/EventMeshJobInfoServiceImpl.java | 30 +++++++++++---
.../impl/EventMeshMysqlPositionServiceImpl.java | 30 +++++++++++---
...ventMeshPositionReporterHistoryServiceImpl.java | 28 ++++++++++---
.../impl/EventMeshRuntimeHeartbeatServiceImpl.java | 30 +++++++++++---
.../impl/EventMeshRuntimeHistoryServiceImpl.java | 28 ++++++++++---
.../server/web/handler/BaseRequestHandler.java | 18 +++++++++
.../server/web/handler/RequestHandlerFactory.java | 22 +++++++++-
.../web/handler/impl/FetchJobRequestHandler.java | 23 ++++++++++-
.../web/handler/impl/FetchPositionHandler.java | 21 ++++++++++
.../web/handler/impl/ReportHeartBeatHandler.java | 21 ++++++++++
.../web/handler/impl/ReportPositionHandler.java | 34 +++++++++++++---
.../EventMeshRuntimeHeartbeatBizService.java | 39 +++++++++++++-----
.../service/job/EventMeshJobInfoBizService.java | 47 ++++++++++++++++------
.../position/EventMeshPositionBizService.java | 23 ++++++++++-
.../service/position/IFetchPositionHandler.java | 18 +++++++++
.../service/position/IReportPositionHandler.java | 18 +++++++++
.../web/service/position/PositionHandler.java | 20 ++++++++-
.../service/position/PositionHandlerFactory.java | 27 +++++++++++--
.../position/impl/MysqlPositionHandler.java | 37 +++++++++++++----
.../src/main/resources/META-INF/spring.factories | 17 ++++++++
.../src/main/resources/application.yaml | 17 ++++++++
.../src/main/resources/eventmesh-admin.properties | 17 ++++++++
56 files changed, 1184 insertions(+), 128 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
