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 a224b5178 fix missing apache header
add 864cda088 fix missing apache header
No new revisions were added by this update.
Summary of changes:
eventmesh-admin-server/build.gradle | 17 ++++++++++++
.../src/main/resources/eventmesh.sql | 17 ++++++++++++
.../resources/mapper/EventMeshDataSourceMapper.xml | 16 +++++++++++
.../resources/mapper/EventMeshJobInfoMapper.xml | 16 +++++++++++
.../mapper/EventMeshMysqlPositionMapper.xml | 16 +++++++++++
.../EventMeshPositionReporterHistoryMapper.xml | 16 +++++++++++
.../mapper/EventMeshRuntimeHeartbeatMapper.xml | 16 +++++++++++
.../mapper/EventMeshRuntimeHistoryMapper.xml | 16 +++++++++++
.../connector/rdb/canal/CanalSinkConfig.java | 17 ++++++++++++
.../connector/rdb/canal/CanalSourceConfig.java | 17 ++++++++++++
.../eventmesh/common/enums/ComponentType.java | 17 ++++++++++++
.../grpc/adminserver/AdminServiceGrpc.java | 17 ++++++++++++
.../grpc/adminserver/EventMeshAdminService.java | 17 ++++++++++++
.../common/protocol/grpc/adminserver/Metadata.java | 17 ++++++++++++
.../grpc/adminserver/MetadataOrBuilder.java | 17 ++++++++++++
.../common/protocol/grpc/adminserver/Payload.java | 17 ++++++++++++
.../grpc/adminserver/PayloadOrBuilder.java | 17 ++++++++++++
.../grpc/proto/event_mesh_admin_service.proto | 17 ++++++++++++
.../org/apache/eventmesh/common/remote/Job.java | 17 ++++++++++++
.../apache/eventmesh/common/remote/JobState.java | 17 ++++++++++++
.../apache/eventmesh/common/remote/JobType.java | 17 ++++++++++++
.../org/apache/eventmesh/common/remote/Task.java | 17 ++++++++++++
.../common/remote/exception/ErrorCode.java | 18 +++++++++++++
.../remote/exception/PayloadFormatException.java | 18 +++++++++++++
.../remote/exception/RemoteRuntimeException.java | 21 ++++++++++++++-
.../common/remote/job/DataSourceClassify.java | 17 ++++++++++++
.../common/remote/job/DataSourceDriverType.java | 17 ++++++++++++
.../common/remote/job/DataSourceType.java | 17 ++++++++++++
.../common/remote/job/JobTransportType.java | 26 +++++++++++++++---
.../common/remote/job/SyncConsistency.java | 31 +++++++++++++++++++---
.../eventmesh/common/remote/job/SyncMode.java | 17 ++++++++++++
.../eventmesh/common/remote/payload/IPayload.java | 18 +++++++++++++
.../common/remote/payload/PayloadFactory.java | 17 ++++++++++++
.../common/remote/payload/PayloadUtil.java | 17 ++++++++++++
.../common/remote/request/BaseRemoteRequest.java | 17 ++++++++++++
.../common/remote/request/FetchJobRequest.java | 17 ++++++++++++
.../remote/request/FetchPositionRequest.java | 17 ++++++++++++
.../remote/request/ReportHeartBeatRequest.java | 17 ++++++++++++
.../remote/request/ReportPositionRequest.java | 17 ++++++++++++
.../common/remote/response/BaseRemoteResponse.java | 17 ++++++++++++
.../common/remote/response/EmptyAckResponse.java | 17 ++++++++++++
.../common/remote/response/FailResponse.java | 17 ++++++++++++
.../common/remote/response/FetchJobResponse.java | 17 ++++++++++++
.../remote/response/FetchPositionResponse.java | 17 ++++++++++++
.../apache/eventmesh/common/utils/PagedList.java | 17 ++++++++++++
...apache.eventmesh.common.remote.payload.IPayload | 15 +++++++++++
.../connector/canal/ByteArrayConverter.java | 11 ++++----
.../connector/canal/DatabaseConnection.java | 17 ++++++++++++
.../connector/canal/SqlTimestampConverter.java | 11 ++++----
.../apache/eventmesh/connector/canal/SqlUtils.java | 11 ++++----
.../connector/canal/dialect/AbstractDbDialect.java | 11 ++++----
.../connector/canal/dialect/DbDialect.java | 11 ++++----
.../connector/canal/dialect/MysqlDialect.java | 11 ++++----
.../interceptor/SqlBuilderLoadInterceptor.java | 11 ++++----
.../connector/canal/model/EventColumn.java | 11 ++++----
.../canal/model/EventColumnIndexComparable.java | 11 ++++----
.../eventmesh/connector/canal/model/EventType.java | 11 ++++----
.../connector/canal/sink/DbLoadContext.java | 11 ++++----
.../eventmesh/connector/canal/sink/DbLoadData.java | 11 ++++----
.../connector/canal/sink/DbLoadMerger.java | 11 ++++----
.../connector/canal/source/EntryParser.java | 11 ++++----
.../canal/template/AbstractSqlTemplate.java | 11 ++++----
.../connector/canal/template/MysqlSqlTemplate.java | 11 ++++----
.../connector/canal/template/SqlTemplate.java | 11 ++++----
.../connector/jdbc/source/AbstractEngine.java | 4 +--
.../dialect/snapshot/AbstractSnapshotEngine.java | 2 +-
.../snapshot/mysql/MysqlSnapshotEngine.java | 4 +--
.../wecom/connector/MockRecordOffset.java | 17 ++++++++++++
.../wecom/connector/MockRecordPartition.java | 17 ++++++++++++
eventmesh-registry/build.gradle | 16 +++++++++++
.../eventmesh-registry-api/build.gradle | 17 ++++++++++++
.../org/apache/eventmesh/registry/NotifyEvent.java | 17 ++++++++++++
.../apache/eventmesh/registry/QueryInstances.java | 17 ++++++++++++
.../eventmesh/registry/RegisterServerInfo.java | 17 ++++++++++++
.../apache/eventmesh/registry/RegistryFactory.java | 17 ++++++++++++
.../eventmesh/registry/RegistryListener.java | 17 ++++++++++++
.../apache/eventmesh/registry/RegistryService.java | 17 ++++++++++++
.../registry/exception/RegistryException.java | 17 ++++++++++++
.../eventmesh-registry-nacos/build.gradle | 17 ++++++++++++
.../registry/nacos/NacosDiscoveryService.java | 17 ++++++++++++
eventmesh-runtime-v2/build.gradle | 17 ++++++++++++
.../java/org/apache/eventmesh/runtime/Runtime.java | 17 ++++++++++++
.../apache/eventmesh/runtime/RuntimeFactory.java | 17 ++++++++++++
.../eventmesh/runtime/RuntimeInstanceConfig.java | 17 ++++++++++++
.../eventmesh/runtime/boot/RuntimeInstance.java | 17 ++++++++++++
.../runtime/boot/RuntimeInstanceStarter.java | 17 ++++++++++++
.../runtime/connector/ConnectorRuntime.java | 17 ++++++++++++
.../runtime/connector/ConnectorRuntimeConfig.java | 17 ++++++++++++
.../runtime/connector/ConnectorRuntimeFactory.java | 17 ++++++++++++
.../runtime/function/FunctionRuntime.java | 17 ++++++++++++
.../runtime/function/FunctionRuntimeConfig.java | 17 ++++++++++++
.../runtime/function/FunctionRuntimeFactory.java | 17 ++++++++++++
.../runtime/manager/ConnectorManager.java | 17 ++++++++++++
.../eventmesh/runtime/manager/FunctionManager.java | 17 ++++++++++++
.../eventmesh/runtime/manager/MeshManager.java | 17 ++++++++++++
.../apache/eventmesh/runtime/mesh/MeshRuntime.java | 17 ++++++++++++
.../eventmesh/runtime/mesh/MeshRuntimeConfig.java | 17 ++++++++++++
.../eventmesh/runtime/mesh/MeshRuntimeFactory.java | 17 ++++++++++++
.../eventmesh/runtime/util/RuntimeUtils.java | 17 ++++++++++++
99 files changed, 1462 insertions(+), 99 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
