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/08/26 10:20:01 UTC
[incubator-eventmesh] branch knative-connector updated (72a7b33b -> be661a3c)
This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a change to branch knative-connector
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from 72a7b33b Merge pull request #966 from walterlife/walterlife/add-unit-test-for-runtime
new 6e8c485f Uploaded implementation of Knative producer.
new 6cd8f02a Uploaded implementation of Knative producer.
new 93c9a38e Amended Knative producer implementation according to comments.
new d6a939ab Amended Knative producer implementation according to comments.
new a854445a Amended Knative producer implementation according to comments.
new a7e1e49b Fixed checkstyle and license check issues.
new 49d09e4d Amended according to discussion.
new 01c21123 Fixed issues in PR check. 1. Fixed issue in Continuous Integration / Build (ubuntu-latest, 8) (pull_request). 2. Fixed issue in Continuous Integration / Build (ubuntu-latest, 11) (pull_request). 3. Fixed issue in Continuous Integration / Build (macOS-latest, 8) (pull_request). 4. Fixed issue in Continuous Integration / Build (macOS-latest, 11) (pull_request). 5. Fixed issue in Continuous Integration / License Check (pull_request).
new 079e246b Passed producer test for the whole pub/sub procedure.
new 7d7234ac Minor fixed for checkstyle issue.
new ba9cd068 Added start and shutdown methods.
new f1e92454 Added license in KnativeConnectorTest.
new be661a3c Merge pull request #1027 from pchengma/knative-connector
The 1125 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 | 3 +-
.../eventmesh-connector-knative}/build.gradle | 15 ++-
.../gradle.properties | 4 +-
.../knative/cloudevent/KnativeMessageFactory.java | 23 +++-
.../impl/KnativeBinaryMessageReader.java} | 32 ++----
.../knative/cloudevent/impl/KnativeHeaders.java | 17 ++-
.../cloudevent/impl/KnativeMessageWriter.java | 73 ++++++++++++
.../knative/common/EventMeshConstants.java} | 7 +-
.../knative/config/ClientConfiguration.java | 36 +++---
.../knative}/config/ConfigurationWrapper.java | 6 +-
.../ConnectorResourceServiceKnativeImpl.java} | 4 +-
.../knative/producer/AbstractProducer.java | 64 +++++++++++
.../knative/producer/KnativeProducerImpl.java} | 51 +++++----
.../connector/knative/producer/ProducerImpl.java | 127 +++++++++++++++++++++
.../connector/knative/utils/CloudEventUtils.java | 16 ++-
...entmesh.api.connector.ConnectorResourceService} | 6 +-
.../org.apache.eventmesh.api.producer.Producer} | 6 +-
.../src/main/resources/knative-client.properties} | 4 +-
.../knative/connector/KnativeConnectorTest.java | 90 +++++++++++++++
.../knative/producer/KnativeProducerImplTest.java | 58 ++++++++++
eventmesh-runtime/conf/eventmesh.properties | 2 +-
settings.gradle | 1 +
tools/dependency-check/known-dependencies.txt | 5 +
tools/third-party-licenses/LICENSE | 1 +
...t => LICENSE-async-http-client-netty-utils.txt} | 0
...ertj-core.txt => LICENSE-async-http-client.txt} | 0
...tation-api.txt => LICENSE-javax.activation.txt} | 0
...-api.txt => LICENSE-netty-reactive-streams.txt} | 0
...tation-api.txt => LICENSE-reactive-streams.txt} | 0
29 files changed, 532 insertions(+), 119 deletions(-)
copy {eventmesh-protocol-plugin/eventmesh-protocol-api => eventmesh-connector-plugin/eventmesh-connector-knative}/build.gradle (71%)
copy eventmesh-connector-plugin/{eventmesh-connector-standalone => eventmesh-connector-knative}/gradle.properties (95%)
copy eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/http/SendMessageBatchProtocolResolver.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/KnativeMessageFactory.java (57%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeBinaryMessageReader.java} (52%)
copy eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatRequestHeaderTest.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeHeaders.java (68%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeMessageWriter.java
copy eventmesh-connector-plugin/{eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/common/EventMeshConstants.java} (82%)
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/BaseResponseHeader.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/ClientConfiguration.java (51%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative}/config/ConfigurationWrapper.java (92%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/connector/ConnectorResourceServiceRocketmqImpl.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java} (87%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/AbstractProducer.java
copy eventmesh-connector-plugin/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducerAdaptor.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImpl.java} (58%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/ProducerImpl.java
copy eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/http/SendMessageBatchProtocolResolver.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/utils/CloudEventUtils.java (63%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/gradle.properties => eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService} (89%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/gradle.properties => eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer} (91%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/test/resources/rocketmq-client.properties => eventmesh-connector-knative/src/main/resources/knative-client.properties} (84%)
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/connector/KnativeConnectorTest.java
create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImplTest.java
copy tools/third-party-licenses/licenses/java/{LICENSE-assertj-core.txt => LICENSE-async-http-client-netty-utils.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-assertj-core.txt => LICENSE-async-http-client.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-javax.annotation-api.txt => LICENSE-javax.activation.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-javax.annotation-api.txt => LICENSE-netty-reactive-streams.txt} (100%)
copy tools/third-party-licenses/licenses/java/{LICENSE-javax.annotation-api.txt => LICENSE-reactive-streams.txt} (100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org