This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a change to branch eventmesh-connector
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 7d3bbde05 Merge pull request #3758 from shaowenchen/fix_build_image
new d2d156020 Add eventmesh-connector-api
new 208260c53 fix the license header
new b18b83a12 remove the unused import
new f5ec01f49 fix checkStyle error
new 9f3f835e3 Merge pull request #3807 from xwm1992/eventmesh-connector-api
The 4083 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../build.gradle | 0
.../eventmesh-connector-api}/build.gradle | 0
.../eventmesh-connector-api}/gradle.properties | 0
.../eventmesh/connector/api/config/Config.java | 8 +-
.../eventmesh/connector/api/config/SinkConfig.java | 8 +-
.../connector/api/config/SourceConfig.java | 8 +-
.../connector/api/connector/Connector.java | 25 ++--
.../connector/api/connector/SinkConnector.java | 16 +--
.../connector/api/connector/SourceConnector.java | 16 +--
.../connector/api/data/ConnectRecord.java | 132 ++++++++++++++++++
.../connector/api/data/DefaultKeyValue.java | 152 +++++++++++++++++++++
.../eventmesh/connector/api/data/KeyValue.java | 66 +++++++++
.../eventmesh/connector/api/data/RecordOffset.java | 62 +++++++++
.../connector/api/data/RecordPartition.java | 64 +++++++++
.../connector/api/data/RecordPosition.java | 57 ++++++++
.../apache/eventmesh/connector/api/sink/Sink.java | 15 +-
.../eventmesh/connector/api/source/Source.java | 15 +-
.../gradle.properties | 0
settings.gradle | 1 +
19 files changed, 592 insertions(+), 53 deletions(-)
copy {eventmesh-metrics-plugin => eventmesh-connectors}/build.gradle (100%)
copy {eventmesh-admin =>
eventmesh-connectors/eventmesh-connector-api}/build.gradle (100%)
copy {eventmesh-admin =>
eventmesh-connectors/eventmesh-connector-api}/gradle.properties (100%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/config/Config.java
(80%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/config/SinkConfig.java
(80%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/config/SourceConfig.java
(80%)
copy
eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/storage/RabbitmqStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/connector/Connector.java
(64%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/connector/SinkConnector.java
(69%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/connector/SourceConnector.java
(68%)
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/ConnectRecord.java
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/DefaultKeyValue.java
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/KeyValue.java
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/RecordOffset.java
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/RecordPartition.java
create mode 100644
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/data/RecordPosition.java
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/sink/Sink.java
(72%)
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
=>
eventmesh-connectors/eventmesh-connector-api/src/main/java/org/apache/eventmesh/connector/api/source/Source.java
(73%)
copy {eventmesh-admin => eventmesh-connectors}/gradle.properties (100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
