This is an automated email from the ASF dual-hosted git repository.
wqliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from fe3000c62 [ISSUE 4360] Fix unSubscribeUrl cannot be null (#4361)
new 475cb2c4b feat: refactor with mongodb plugin.
new c271cee56 feat: refactor with mongodb plugin.
new 8d627ec62 feat: refactor with mongodb plugin.
new f1a01a2ef Merge branch 'apache:master' into mongodb_plugin
new 3bbffb3bd feat: refactor with mongodb plugin.
new d96804a1e feat: refactor with mongodb plugin.
new 324045c82 Merge pull request #4367 from fabian4/mongodb_plugin
The 4404 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:
.../eventmesh-connector-mongodb}/build.gradle | 10 +-
.../gradle.properties | 2 +-
.../mongodb/config/MongodbServerConfig.java} | 7 +-
.../mongodb/constant/MongodbConstants.java | 5 +-
.../mongodb/server/MongodbConnectServer.java} | 24 ++---
.../sink/client/Impl/MongodbSinkClient.java | 15 ++-
.../sink/client/MongodbReplicaSetSinkClient.java | 75 ++++++++++++++
.../sink/client/MongodbStandaloneSinkClient.java | 98 +++++++++++++++++++
.../mongodb/sink/config/MongodbSinkConfig.java} | 5 +-
.../mongodb}/sink/config/SinkConnectorConfig.java | 10 +-
.../sink/connector/MongodbSinkConnector.java} | 55 ++++++-----
.../source/client/Impl/MongodbSourceClient.java | 15 ++-
.../client/MongodbReplicaSetSourceClient.java | 101 +++++++++++++++++++
.../client/MongodbStandaloneSourceClient.java | 108 +++++++--------------
.../source/config/MongodbSourceConfig.java} | 5 +-
.../source/config/SourceConnectorConfig.java | 10 +-
.../source/connector/MongodbSourceConnector.java} | 51 +++++-----
.../mongodb/utils/MongodbCloudEventUtil.java | 10 +-
.../src/main/resources/server-config.yml | 0
.../src/main/resources/sink-config.yml | 15 +--
.../src/main/resources/source-config.yml | 25 ++---
settings.gradle | 1 +
22 files changed, 444 insertions(+), 203 deletions(-)
copy
{eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-nacos
=> eventmesh-connectors/eventmesh-connector-mongodb}/build.gradle (85%)
copy eventmesh-connectors/{eventmesh-connector-redis =>
eventmesh-connector-mongodb}/gradle.properties (97%)
copy
eventmesh-connectors/{eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/config/KafkaServerConfig.java
=>
eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/config/MongodbServerConfig.java}
(84%)
copy
{eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector}/mongodb/constant/MongodbConstants.java
(96%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/server/PulsarConnectServer.java
=>
eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/server/MongodbConnectServer.java}
(61%)
copy
eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java
=>
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/client/Impl/MongodbSinkClient.java
(79%)
create mode 100644
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/client/MongodbReplicaSetSinkClient.java
create mode 100644
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/client/MongodbStandaloneSinkClient.java
copy
eventmesh-connectors/{eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/sink/config/RedisSinkConfig.java
=>
eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/config/MongodbSinkConfig.java}
(89%)
copy
eventmesh-connectors/{eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction
=>
eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb}/sink/config/SinkConnectorConfig.java
(83%)
copy
eventmesh-connectors/{eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/sink/connector/RedisSinkConnector.java
=>
eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/connector/MongodbSinkConnector.java}
(66%)
copy
eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/ConnectorWorker.java
=>
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/source/client/Impl/MongodbSourceClient.java
(81%)
create mode 100644
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/source/client/MongodbReplicaSetSourceClient.java
copy
eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/consumer/MongodbStandaloneConsumer.java
=>
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/source/client/MongodbStandaloneSourceClient.java
(53%)
copy
eventmesh-connectors/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/source/config/PulsarSourceConfig.java
=>
eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/source/config/MongodbSourceConfig.java}
(88%)
copy
eventmesh-connectors/{eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis
=>
eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb}/source/config/SourceConnectorConfig.java
(83%)
copy
eventmesh-connectors/{eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/source/connector/RedisSourceConnector.java
=>
eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/source/connector/MongodbSourceConnector.java}
(70%)
copy
{eventmesh-storage-plugin/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector}/mongodb/utils/MongodbCloudEventUtil.java
(91%)
copy eventmesh-connectors/{eventmesh-connector-pulsar =>
eventmesh-connector-mongodb}/src/main/resources/server-config.yml (100%)
copy eventmesh-connectors/{eventmesh-connector-redis =>
eventmesh-connector-mongodb}/src/main/resources/sink-config.yml (77%)
copy eventmesh-connectors/{eventmesh-connector-rocketmq =>
eventmesh-connector-mongodb}/src/main/resources/source-config.yml (71%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
