[incubator-eventmesh] branch master updated (ce514fd8 -> da9e120b)

[ch...@apache.org]

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 ce514fd8 Merge pull request #1198 from horoc/fix-filewebHookconfig-insert-error
     new 1bbfb5da Set theme jekyll-theme-cayman
     new 053ff4ee Add files via upload
     new 53219e3a Add files via upload
     new 19d8c323 [Issue #533] Adding design doc for EventMesh Workflow
     new ebe57dbb Add remote processors
     new da896bcc Uploaded implementation of Knative producer.
     new 261e8b8e Uploaded implementation of Knative producer.
     new 720ca94a Amended Knative producer implementation according to comments.
     new 0f05d107 Amended Knative producer implementation according to comments.
     new 1269da7d Amended Knative producer implementation according to comments.
     new 6a0588f9 Fixed checkstyle and license check issues.
     new 7090c9fe Amended according to discussion.
     new 2832d5e7 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 139ea9ed Passed producer test for the whole pub/sub procedure.
     new 4781b7e0 Minor fixed for checkstyle issue.
     new fe755b73 Added start and shutdown methods.
     new 434096c6 Added license in KnativeConnectorTest.
     new 2c33ff53 Uploaded implementation of Knative consumer.
     new 40905c8c Fixed missing license header problem.
     new 44a484a8 Fixed CI problems.
     new da9e120b Merge pull request #1214 from pchengma/master

The 1388 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-knative}/build.gradle      |  18 ++-
 .../gradle.properties                              |   4 +-
 .../knative/cloudevent/KnativeMessageFactory.java  |  23 ++-
 .../impl/KnativeBinaryMessageReader.java}          |  32 ++--
 .../knative/cloudevent/impl/KnativeHeaders.java    |  14 +-
 .../cloudevent/impl/KnativeMessageWriter.java      |  73 +++++++++
 .../knative}/common/EventMeshConstants.java        |   6 +-
 .../knative}/config/ClientConfiguration.java       |  14 +-
 .../knative}/config/ConfigurationWrapper.java      |   6 +-
 .../ConnectorResourceServiceKnativeImpl.java}      |   4 +-
 .../knative/consumer/DefaultConsumer.java          |  69 +++++++++
 .../knative/consumer/KnativeConsumerImpl.java}     |  59 ++++----
 .../knative/consumer/PullConsumerImpl.java         | 168 +++++++++++++++++++++
 .../connector/knative/domain/NonStandardKeys.java} |  11 +-
 .../patch/EventMeshConsumeConcurrentlyContext.java |  16 +-
 .../patch/EventMeshConsumeConcurrentlyStatus.java  |   4 +-
 .../EventMeshMessageListenerConcurrently.java}     |  12 +-
 .../knative}/producer/AbstractProducer.java        |  22 ++-
 .../knative/producer/KnativeProducerImpl.java}     |  16 +-
 .../connector/knative/producer/ProducerImpl.java   | 127 ++++++++++++++++
 .../connector/knative}/utils/CloudEventUtils.java  |   6 +-
 ...ventmesh.api.connector.ConnectorResourceService |   2 +-
 .../org.apache.eventmesh.api.consumer.Consumer     |   2 +-
 .../org.apache.eventmesh.api.producer.Producer}    |   4 +-
 .../src/main/resources/knative-client.properties}  |   4 +-
 .../knative/connector/KnativeConnectorTest.java    | 118 +++++++++++++++
 .../knative/consumer/KnativeConsumerImplTest.java  |  21 ++-
 .../knative/producer/KnativeProducerImplTest.java  |  58 +++++++
 28 files changed, 778 insertions(+), 135 deletions(-)
 copy {eventmesh-protocol-plugin/eventmesh-protocol-api => eventmesh-connector-plugin/eventmesh-connector-knative}/build.gradle (66%)
 copy eventmesh-connector-plugin/{eventmesh-connector-pulsar => eventmesh-connector-knative}/gradle.properties (95%)
 copy eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/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-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/Constants.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeHeaders.java (73%)
 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-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative}/common/EventMeshConstants.java (85%)
 copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative}/config/ClientConfiguration.java (78%)
 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/consumer/DefaultConsumer.java
 copy eventmesh-connector-plugin/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumerAdaptor.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImpl.java} (57%)
 create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/PullConsumerImpl.java
 copy eventmesh-connector-plugin/{eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/domain/NonStandardKeys.java} (82%)
 copy eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/exception/AclException.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyContext.java (73%)
 copy {eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime => eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative}/patch/EventMeshConsumeConcurrentlyStatus.java (93%)
 copy eventmesh-connector-plugin/{eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshMessageListenerConcurrently.java} (76%)
 copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative}/producer/AbstractProducer.java (79%)
 copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/PulsarProducerImpl.java => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImpl.java} (83%)
 create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/ProducerImpl.java
 copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar => eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative}/utils/CloudEventUtils.java (84%)
 copy eventmesh-connector-plugin/{eventmesh-connector-pulsar => eventmesh-connector-knative}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService (89%)
 copy eventmesh-connector-plugin/{eventmesh-connector-pulsar => eventmesh-connector-knative}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer (91%)
 copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/gradle.properties => eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer} (91%)
 copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/src/main/resources/pulsar-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
 copy eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeaderTest.java => eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImplTest.java (60%)
 create mode 100644 eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImplTest.java


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org