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 9934aa1a0 fix admin server ci check error
add 715c595d8 fix ci checkStyle error
No new revisions were added by this update.
Summary of changes:
.../org/apache/eventmesh/admin/server/Admin.java | 3 +
.../apache/eventmesh/admin/server/AdminServer.java | 8 +-
.../admin/server/AdminServerProperties.java | 4 +-
.../eventmesh/admin/server/ComponentLifeCycle.java | 3 +
.../eventmesh/admin/server/ExampleAdminServer.java | 1 -
.../admin/server/web/AdminGrpcServer.java | 15 +-
.../eventmesh/admin/server/web/BaseServer.java | 6 +-
.../eventmesh/admin/server/web/GrpcServer.java | 12 +-
.../admin/server/web/db/DBThreadPool.java | 12 +-
.../server/web/db/entity/EventMeshDataSource.java | 6 +-
.../server/web/db/entity/EventMeshJobInfo.java | 6 +-
.../web/db/entity/EventMeshMysqlPosition.java | 6 +-
.../entity/EventMeshPositionReporterHistory.java | 6 +-
.../web/db/entity/EventMeshRuntimeHeartbeat.java | 6 +-
.../web/db/entity/EventMeshRuntimeHistory.java | 6 +-
.../web/db/mapper/EventMeshDataSourceMapper.java | 11 +-
.../web/db/mapper/EventMeshJobInfoMapper.java | 2 +-
.../db/mapper/EventMeshMysqlPositionMapper.java | 10 +-
.../EventMeshPositionReporterHistoryMapper.java | 11 +-
.../db/mapper/EventMeshRuntimeHeartbeatMapper.java | 2 +-
.../db/mapper/EventMeshRuntimeHistoryMapper.java | 11 +-
.../web/db/service/EventMeshDataSourceService.java | 4 +-
.../web/db/service/EventMeshJobInfoService.java | 5 +-
.../db/service/EventMeshMysqlPositionService.java | 5 +-
.../EventMeshPositionReporterHistoryService.java | 5 +-
.../service/EventMeshRuntimeHeartbeatService.java | 5 +-
.../db/service/EventMeshRuntimeHistoryService.java | 4 +-
.../impl/EventMeshDataSourceServiceImpl.java | 7 +-
.../service/impl/EventMeshJobInfoServiceImpl.java | 9 +-
.../impl/EventMeshMysqlPositionServiceImpl.java | 9 +-
...ventMeshPositionReporterHistoryServiceImpl.java | 7 +-
.../impl/EventMeshRuntimeHeartbeatServiceImpl.java | 9 +-
.../impl/EventMeshRuntimeHistoryServiceImpl.java | 7 +-
.../server/web/handler/RequestHandlerFactory.java | 8 +-
.../web/handler/impl/FetchJobRequestHandler.java | 9 +-
.../web/handler/impl/FetchPositionHandler.java | 9 +-
.../web/handler/impl/ReportHeartBeatHandler.java | 5 +-
.../web/handler/impl/ReportPositionHandler.java | 9 +-
.../EventMeshRuntimeHeartbeatBizService.java | 11 +-
.../service/job/EventMeshJobInfoBizService.java | 18 +-
.../position/EventMeshPositionBizService.java | 9 +-
.../service/position/IFetchPositionHandler.java | 3 +
.../service/position/IReportPositionHandler.java | 3 +
.../service/position/PositionHandlerFactory.java | 8 +-
.../position/impl/MysqlPositionHandler.java | 22 +-
.../grpc/adminserver/AdminServiceGrpc.java | 554 +++----
.../grpc/adminserver/EventMeshAdminService.java | 136 +-
.../common/protocol/grpc/adminserver/Metadata.java | 1548 +++++++++++---------
.../grpc/adminserver/MetadataOrBuilder.java | 92 +-
.../common/protocol/grpc/adminserver/Payload.java | 54 +-
.../grpc/adminserver/PayloadOrBuilder.java | 66 +-
.../common/remote/offset/RecordOffset.java | 2 +
.../common/remote/offset/RecordPosition.java | 48 +-
.../remote/offset/canal/CanalRecordOffset.java | 3 +-
.../remote/offset/canal/CanalRecordPartition.java | 5 +-
.../remote/offset/file/FileRecordPartition.java | 5 +-
.../remote/offset/kafka/KafkaRecordPartition.java | 5 +-
.../offset/pulsar/PulsarRecordPartition.java | 5 +-
58 files changed, 1514 insertions(+), 1346 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
