You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by ch...@apache.org on 2022/09/02 11:27:14 UTC
[incubator-eventmesh] branch master updated (358711ea -> 2ecc73cb)
This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from 358711ea Merge pull request #1217 from apache/qqeasonchen-patch-4
add 6db4722a When trace enable, then get trace plugin.
add 9896e9d1 Implement the redis connector plugin.
add eb77f3a7 Remove invalid import.
add 2d5701ed Introduce redis-mock tool and test case optimization.
add fc74b31f Check style problem fix.
add 9a86f291 Check style problem fix & License Check problem fix
add dbfad847 Add known dependencies & Add LICENSE
add a7012829 Add known dependencies problem fix
add 28befe6e Code optimize.
add dcb28417 Build (macOS-latest, 8) testSendOneway FAILED fix.
add a8be7978 Partial modification recovery and code optimization.
add a560e612 Review suggestion: remove the unified configuration function.
add 4f2c1376 Merge pull request #990 from mytang0/feature/redis-connector
add 29a40af8 Merge remote-tracking branch 'apache/master' into redis-connector
new 2ecc73cb Merge pull request #1219 from apache/redis-connector
The 1 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:
.../org/apache/eventmesh/common/Constants.java | 38 ++++++
.../eventmesh/common/utils/PropertiesUtils.java | 64 +++++++++
.../common/utils/PropertiesUtilsTest.java | 43 ++++++
.../build.gradle | 31 +++--
.../gradle.properties | 2 +-
.../connector/redis/client/RedissonClient.java | 148 +++++++++++++++++++++
.../redis/cloudevent/CloudEventCodec.java | 60 +++++++++
.../connector/redis/config/ConfigOptions.java | 51 +++++++
.../redis}/config/ConfigurationWrapper.java | 48 +++----
.../connector/redis/config/RedisProperties.java | 94 +++++++++++++
.../connector/RedisConnectorResourceService.java} | 15 ++-
.../connector/redis/consumer/RedisConsumer.java | 131 ++++++++++++++++++
.../connector/redis/producer/RedisProducer.java | 139 +++++++++++++++++++
...ventmesh.api.connector.ConnectorResourceService | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer} | 6 +-
.../org.apache.eventmesh.api.producer.Producer} | 6 +-
.../src/main/resources/redis-client.properties | 1 +
.../connector/redis/AbstractRedisServer.java | 41 ++++++
.../redis/client/RedissonClientTest.java} | 28 ++--
.../connector/redis/connector/UnitTest.java | 109 +++++++++++++++
.../redis/consumer/RedisConsumerTest.java | 90 +++++++++++++
.../redis/producer/RedisProducerTest.java | 109 +++++++++++++++
.../src/test/resources/redis-client.properties | 3 +-
settings.gradle | 1 +
tools/dependency-check/check-dependencies.sh | 2 +-
tools/dependency-check/known-dependencies.txt | 13 +-
.../licenses/java/LICENSE-redisson.txt | 13 ++
27 files changed, 1212 insertions(+), 76 deletions(-)
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/PropertiesUtils.java
create mode 100644 eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/PropertiesUtilsTest.java
copy eventmesh-connector-plugin/{eventmesh-connector-pravega => eventmesh-connector-redis}/build.gradle (54%)
copy eventmesh-connector-plugin/{eventmesh-connector-pulsar => eventmesh-connector-redis}/gradle.properties (97%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/client/RedissonClient.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/cloudevent/CloudEventCodec.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/ConfigOptions.java
copy eventmesh-connector-plugin/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative => eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis}/config/ConfigurationWrapper.java (55%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/RedisProperties.java
copy eventmesh-connector-plugin/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java => eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/connector/RedisConnectorResourceService.java} (59%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumer.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/producer/RedisProducer.java
copy eventmesh-connector-plugin/{eventmesh-connector-pravega => eventmesh-connector-redis}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService (90%)
copy eventmesh-connector-plugin/{eventmesh-connector-pravega/gradle.properties => eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer} (92%)
copy eventmesh-connector-plugin/{eventmesh-connector-pravega/gradle.properties => eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer} (92%)
copy eventmesh-examples/gradle.properties => eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/redis-client.properties (99%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/AbstractRedisServer.java
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQHeaders.java => eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/client/RedissonClientTest.java} (56%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/connector/UnitTest.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumerTest.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/producer/RedisProducerTest.java
copy eventmesh-registry-plugin/eventmesh-registry-consul/gradle.properties => eventmesh-connector-plugin/eventmesh-connector-redis/src/test/resources/redis-client.properties (93%)
create mode 100644 tools/third-party-licenses/licenses/java/LICENSE-redisson.txt
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org
[incubator-eventmesh] 01/01: Merge pull request #1219 from apache/redis-connector
Posted by ch...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
commit 2ecc73cb8ca4992a23ac8a3d0d4ddc14053989b2
Merge: 358711ea 29a40af8
Author: Eason Chen <qq...@gmail.com>
AuthorDate: Fri Sep 2 19:27:08 2022 +0800
Merge pull request #1219 from apache/redis-connector
[ISSUE #389] Redis connector
.../org/apache/eventmesh/common/Constants.java | 38 ++++++
.../eventmesh/common/utils/PropertiesUtils.java | 64 +++++++++
.../common/utils/PropertiesUtilsTest.java | 43 ++++++
.../eventmesh-connector-redis/build.gradle | 46 +++++++
.../eventmesh-connector-redis/gradle.properties | 18 +++
.../connector/redis/client/RedissonClient.java | 148 +++++++++++++++++++++
.../redis/cloudevent/CloudEventCodec.java | 60 +++++++++
.../connector/redis/config/ConfigOptions.java | 51 +++++++
.../redis/config/ConfigurationWrapper.java | 73 ++++++++++
.../connector/redis/config/RedisProperties.java | 94 +++++++++++++
.../connector/RedisConnectorResourceService.java | 33 +++++
.../connector/redis/consumer/RedisConsumer.java | 131 ++++++++++++++++++
.../connector/redis/producer/RedisProducer.java | 139 +++++++++++++++++++
...ventmesh.api.connector.ConnectorResourceService | 16 +++
.../org.apache.eventmesh.api.consumer.Consumer | 16 +++
.../org.apache.eventmesh.api.producer.Producer | 16 +++
.../src/main/resources/redis-client.properties | 17 +++
.../connector/redis/AbstractRedisServer.java | 41 ++++++
.../connector/redis/client/RedissonClientTest.java | 31 +++++
.../connector/redis/connector/UnitTest.java | 109 +++++++++++++++
.../redis/consumer/RedisConsumerTest.java | 90 +++++++++++++
.../redis/producer/RedisProducerTest.java | 109 +++++++++++++++
.../src/test/resources/redis-client.properties | 18 +++
settings.gradle | 1 +
tools/dependency-check/check-dependencies.sh | 2 +-
tools/dependency-check/known-dependencies.txt | 13 +-
.../licenses/java/LICENSE-redisson.txt | 13 ++
27 files changed, 1428 insertions(+), 2 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org