[incubator-eventmesh] branch master updated (703ff366 -> c48b692e)

[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 703ff366 Merge pull request #1215 from horoc/fix-webhook-request-type-convert-error
     new 96220299 init
     new e44f4ccf init
     new e1b7a5d8 add config with test
     new 85a007da add exception class
     new c0085d16 edit gitignore
     new c1a3cabb [bug] grpc version conflict
     new d6a73b98 producer
     new f8dfd89b Merge remote-tracking branch 'upstream/master' into pravega_connector
     new c3d6946b Merge remote-tracking branch 'upstream/master' into pravega_connector
     new 0293f4a4 update scope name
     new b2f6b331 add config item
     new 25051aec update PravegaClient
     new aea53e1a SubscribeTask
     new 1ae4d668 fix PravegaClient bug
     new 079df0b7 update config and format code
     new ab8181c6 add test
     new cc5a235e add UT
     new 9e31517e Merge remote-tracking branch 'upstream/master' into pravega_connector
     new 27c4dabf reuse writer
     new b92b7b65 remove .gitignore duplicate items
     new aed744a8 move SubscribeTask.java
     new 92de6434 fix pub/sub bug
     new b9709086 format
     new e04f3ffc Merge remote-tracking branch 'upstream/master' into pravega_connector
     new d0df831e Merge remote-tracking branch 'upstream/master' into pravega_connector
     new 898537fd add license
     new d0aad1bd add test properties
     new 11e52b6f ignore docker test, add known-dependencies.txt
     new c48b692e Merge pull request #1203 from LIU-WEI-git/pravega_connector

The 1440 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:
 .gitignore                                         |   1 -
 .../build.gradle                                   |  23 ++-
 .../gradle.properties                              |   4 +-
 .../PravegaConnectorResourceServiceImpl.java}      |  12 +-
 .../connector/pravega/PravegaConsumerImpl.java}    |  52 ++---
 .../connector/pravega/PravegaProducerImpl.java}    |  67 ++++---
 .../eventmesh/connector/pravega/SubscribeTask.java |  70 +++++++
 .../connector/pravega/client/PravegaClient.java    | 214 +++++++++++++++++++++
 .../pravega/client/PravegaCloudEventWriter.java}   |  49 +++--
 .../connector/pravega/client/PravegaEvent.java     |  74 +++++++
 .../pravega/config/PravegaConnectorConfig.java     | 113 +++++++++++
 .../config/PravegaConnectorConfigWrapper.java}     |  18 +-
 .../exception/PravegaConnectorException.java}      |  13 +-
 ...entmesh.api.connector.ConnectorResourceService} |   2 +-
 .../org.apache.eventmesh.api.consumer.Consumer}    |   4 +-
 .../org.apache.eventmesh.api.producer.Producer}    |   4 +-
 .../main/resources/pravega-connector.properties}   |  12 +-
 .../pravega/client/PravegaClientTest.java          | 183 ++++++++++++++++++
 .../pravega/config/PravegaConnectorConfigTest.java |  81 ++++++++
 .../test/resources/pravega-connector.properties}   |  12 +-
 settings.gradle                                    |   1 +
 tools/dependency-check/known-dependencies.txt      |  22 +++
 22 files changed, 909 insertions(+), 122 deletions(-)
 copy eventmesh-connector-plugin/{eventmesh-connector-knative => eventmesh-connector-pravega}/build.gradle (71%)
 copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq => eventmesh-connector-pravega}/gradle.properties (95%)
 copy eventmesh-connector-plugin/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java => eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConnectorResourceServiceImpl.java} (76%)
 copy eventmesh-connector-plugin/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumerAdaptor.java => eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConsumerImpl.java} (57%)
 copy eventmesh-connector-plugin/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImpl.java => eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaProducerImpl.java} (52%)
 create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/SubscribeTask.java
 create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaClient.java
 copy eventmesh-connector-plugin/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeMessageWriter.java => eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaCloudEventWriter.java} (50%)
 create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaEvent.java
 create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfig.java
 copy eventmesh-connector-plugin/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/ConfigurationWrapper.java => eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfigWrapper.java} (77%)
 copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQTimeoutException.java => eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/exception/PravegaConnectorException.java} (73%)
 copy eventmesh-connector-plugin/{eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer => eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService} (90%)
 copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/gradle.properties => eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer} (92%)
 copy eventmesh-connector-plugin/{eventmesh-connector-pulsar/gradle.properties => eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer} (92%)
 copy eventmesh-connector-plugin/{eventmesh-connector-knative/src/main/resources/knative-client.properties => eventmesh-connector-pravega/src/main/resources/pravega-connector.properties} (64%)
 create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/client/PravegaClientTest.java
 create mode 100644 eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfigTest.java
 copy eventmesh-connector-plugin/{eventmesh-connector-knative/src/main/resources/knative-client.properties => eventmesh-connector-pravega/src/test/resources/pravega-connector.properties} (64%)


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