[Issue #417] Grpc Transport Protocol support #701

jinrongluo · 2022-01-07T19:24:28Z

Fixes ISSUE #417

Motivation

Support GRPC transport protocol in Eventmensh Runtime and Java SDK.

Modifications

Adding the following GRPC API support:

GRPC Request and Reply
GRPC Batch Publish
GRPC Subscribe and Unsubscribe
GRPC heartbeat
GRPC CloudEvents support

Documentation

Does this pull request introduce a new feature? yes
If yes, how is the feature documented? docs / JavaDoc

… into develop � Conflicts: � README.md

* SDK SUPPORT CLOUD EVENT * SDK SUPPORT CLOUD EVENT * SDK SUPPORT CLOUD EVENT * SDK SUPPORT CLOUD EVENT * SDK SUPPORT CLOUD EVENT * SDK SUPPORT CLOUD EVENT * SDK SUPPORT CLOUD EVENT * SDK SUPPORT CLOUD EVENT * SDK SUPPORT CLOUD EVENT Co-authored-by: wangshaojie <[email protected]>

…pi module (apache#578) * [Feature apache#564] Support CloudEvents protocols for pub/sub in EventMesh-feature design * support cloudevents api in eventmesh-connector-api module * fix checkStyle * fix checkStyle * fix checkStyle * 1.support LifeCycle.java 2.update Consumer and Producer * fix remove the extra blank line

Co-authored-by: wangshaojie <[email protected]>

…time (apache#587) * [Feature apache#564] Support CloudEvents protocols for pub/sub in EventMesh-feature design * support cloudevents api in eventmesh-connector-api module * fix checkStyle * fix checkStyle * fix checkStyle * 1.support LifeCycle.java 2.update Consumer and Producer * fix remove the extra blank line * support cloudEvents * support cloudEvents * support cloudEvents * support cloudEvents * support cloudevents * support cloudEvents * support cloudEvents * support cloudEvents

* [Feature apache#564] Support CloudEvents protocols for pub/sub in EventMesh-feature design * support cloudevents api in eventmesh-connector-api module * fix checkStyle * fix checkStyle * fix checkStyle * 1.support LifeCycle.java 2.update Consumer and Producer * fix remove the extra blank line * support cloudEvents * Add files via upload * Update README.md * support cloudEvents * support cloudEvents * [ISSUE apache#580] Add checkstyle gradle plugin (apache#581) * Add checkstyle gradle plugin, change plugin package * skip check in ci * support cloudEvents * support cloudevents * update wechat-official qr code * update mesh-helper qr code * Add files via upload * update README.md * update README.md * Update .asf.yaml * support cloudEvents * support cloudEvents * [ISSUE apache#588] Fix typo in README.md (apache#589) close apache#588 * support cloudEvents * [Bug apache#590] Consumer subscription topic is invalid (apache#590) (apache#592) * [Bug apache#590] Consumer subscription topic is invalid (apache#590) * [Bug apache#590] Consumer subscription topic is invalid (apache#590) close apache#590 * support cloudEvents adaptor * [Feature apache#562] Implement CloudEvents adaptor Co-authored-by: Eason Chen <[email protected]> Co-authored-by: Wenjun Ruan <[email protected]> Co-authored-by: Nicholas Zhan <[email protected]> Co-authored-by: hagsyn <[email protected]>

…che#597) * [Feature apache#564] Support CloudEvents protocols for pub/sub in EventMesh-feature design * support cloudevents api in eventmesh-connector-api module * fix checkStyle * fix checkStyle * fix checkStyle * 1.support LifeCycle.java 2.update Consumer and Producer * fix remove the extra blank line * support cloudEvents * Add files via upload * Update README.md * support cloudEvents * support cloudEvents * [ISSUE apache#580] Add checkstyle gradle plugin (apache#581) * Add checkstyle gradle plugin, change plugin package * skip check in ci * support cloudEvents * support cloudevents * update wechat-official qr code * update mesh-helper qr code * Add files via upload * update README.md * update README.md * Update .asf.yaml * support cloudEvents * support cloudEvents * [ISSUE apache#588] Fix typo in README.md (apache#589) close apache#588 * support cloudEvents * [Bug apache#590] Consumer subscription topic is invalid (apache#590) (apache#592) * [Bug apache#590] Consumer subscription topic is invalid (apache#590) * [Bug apache#590] Consumer subscription topic is invalid (apache#590) close apache#590 * support cloudEvents adaptor * [Feature apache#562] Implement CloudEvents adaptor * [Feature apache#562] Implement EventMeshMessage protocol adaptor * supplement apache header Co-authored-by: Eason Chen <[email protected]> Co-authored-by: Wenjun Ruan <[email protected]> Co-authored-by: Nicholas Zhan <[email protected]> Co-authored-by: hagsyn <[email protected]>

* Remove some unused code in sdk module * Remove some unused code in sdk module

close apache#596

…pache#598) close apache#590

* [Feature apache#564] Support CloudEvents protocols for pub/sub in EventMesh-feature design * support cloudevents api in eventmesh-connector-api module * fix checkStyle * fix checkStyle * fix checkStyle * 1.support LifeCycle.java 2.update Consumer and Producer * fix remove the extra blank line * support cloudEvents * Add files via upload * Update README.md * support cloudEvents * support cloudEvents * [ISSUE apache#580] Add checkstyle gradle plugin (apache#581) * Add checkstyle gradle plugin, change plugin package * skip check in ci * support cloudEvents * support cloudevents * update wechat-official qr code * update mesh-helper qr code * Add files via upload * update README.md * update README.md * Update .asf.yaml * support cloudEvents * support cloudEvents * [ISSUE apache#588] Fix typo in README.md (apache#589) close apache#588 * support cloudEvents * [Bug apache#590] Consumer subscription topic is invalid (apache#590) (apache#592) * [Bug apache#590] Consumer subscription topic is invalid (apache#590) * [Bug apache#590] Consumer subscription topic is invalid (apache#590) close apache#590 * support cloudEvents adaptor * [Feature apache#562] Implement CloudEvents adaptor * [Feature apache#562] Implement EventMeshMessage protocol adaptor * supplement apache header * 1.update package name 2.support build.gradle and gradle.properties 3.support ProtocolTransportObject Co-authored-by: Eason Chen <[email protected]> Co-authored-by: Wenjun Ruan <[email protected]> Co-authored-by: Nicholas Zhan <[email protected]> Co-authored-by: hagsyn <[email protected]>

* Add protocol producer in sdk * Refactor callback handler * Add tcp protocol client

1.update http push request 2.update http in protocol adaptor

* update java sdk * fix compile error

* update java sdk * fix compile error * fix sdk error

* update java sdk * fix compile error * fix sdk error * 1.remove the openmessage from connector-api 2.fix the standalone connector

* update java sdk * fix compile error * fix sdk error 1.remove the openmessage from connector-api 2.fix the standalone connector * 1.fix the standalone connector 2.fix the sdk

* eventmesh-admin-rocketmq submodule and createTopic draft API * add license header * change to /topicmanage * fix build error * fix some code check style issues close apache#435 apache#346

1.fix the standalone connector 2.fix eventmeshmessage protocol adaptor for tcp

…apache#619) 1.fix eventmeshmessage protocol adaptor for http with standalone connector

* gradle * Anonymous new Runnable() can be replaced with lambda * Anonymous new Runnable() can be replaced with lambda * add logger print exception

) * gradle * ConfigurationWrapper class adds thread pool shutdown

…ache#678) * translate English to Chinese close apache#677

[Minor apache#405] update cloudevents examples

Bump gradle version to 7.3.3 to Support Java17 build

Close ISSUE apache#690.

…#695) * Change the default merge strategy to squash close apache#692

… en & cn (apache#698) * update eventmesh-runtime-quickstart-with-docker.md en & cn close apache#673

# Conflicts: # eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/SyncRequestInstance.java # eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/CloudEventsProtocolAdaptor.java

close apache#702

fixed apache#405

jinrongluo · 2022-01-10T19:27:56Z

Due to too many merge conflicts between grpc branch and Master branch. I am not able to merge my own grpc-dev directly.

I suggest abandon current grpc branch, recreate a new grpc branch from Master. Then my grpc-dev branch can merge in. Thanks.

xwm1992 · 2022-01-11T02:41:39Z

I will close this pull request now, and reopen it soon until a new grpc branch check out from the master.

qqeasonchen · 2022-01-11T02:46:42Z

Due to too many merge conflicts between grpc branch and Master branch. I am not able to merge my own grpc-dev directly.

I suggest abandon current grpc branch, recreate a new grpc branch from Master. Then my grpc-dev branch can merge in. Thanks.

It seems ok now.

xwm1992 and others added 30 commits October 29, 2021 18:13

readme.md

6f57a90

Merge branch 'develop' of https://github.com/apache/incubator-eventmesh…

88f8ffc

… into develop � Conflicts: � README.md

connector support cloud event (apache#586)

3ae9234

Co-authored-by: wangshaojie <[email protected]>

Remove some unused code (apache#591)

db02781

* Remove some unused code in sdk module * Remove some unused code in sdk module

fixed a wrong url in cn-doc (apache#585)

f8ffb44

close apache#596

resolve_exception->Consumer subscription topic is invalid apache#590 (a…

0acafcc

…pache#598) close apache#590

Update eventmesh-store-quickstart.md

e53acaf

Update README.md

4f04d9d

Add slack icon (apache#601)

71bcb09

Add protocol producer in java sdk (apache#600)

ac8db5a

* Add protocol producer in sdk * Refactor callback handler * Add tcp protocol client

Change Tcp interface (apache#603)

bcc1503

update http push request and adaptor (apache#606)

0082f3d

1.update http push request 2.update http in protocol adaptor

update java sdk (apache#607)

c66c8f7

Fix standalone connector interface, fix example (apache#608)

5f61c24

fix compile error (apache#609)

a0204ae

* update java sdk * fix compile error

Java sdk update (apache#610)

0268792

* update java sdk * fix compile error * fix sdk error

Add EventMeshTCPClient, this client wrap the sub/sub client (apache#611)

1c34373

runtime update (apache#612)

d8eb87f

* update java sdk * fix compile error * fix sdk error * 1.remove the openmessage from connector-api 2.fix the standalone connector

Java sdk update (apache#615)

f7d0fbb

* update java sdk * fix compile error * fix sdk error 1.remove the openmessage from connector-api 2.fix the standalone connector * 1.fix the standalone connector 2.fix the sdk

eventmesh-admin-rocketmq submodule and createTopic REST API (apache#530)

f3b9520

* eventmesh-admin-rocketmq submodule and createTopic draft API * add license header * change to /topicmanage * fix build error * fix some code check style issues close apache#435 apache#346

Fix some small issue (apache#616)

d1064cb

eventmeshmessage protocol adaptor for tcp (apache#618)

351f3ba

1.fix the standalone connector 2.fix eventmeshmessage protocol adaptor for tcp

remove openschema implementation from em project

e337b79

eventmesh message protocol for http pub/sub with standalone connector (…

b46026d

…apache#619) 1.fix eventmeshmessage protocol adaptor for http with standalone connector

li-xiao-shuang and others added 23 commits December 31, 2021 19:10

[MINOR] Fixed redundant boxing operations (apache#684)

5adc007

[MINOR] new Runnable() can be replaced with lambda (apache#685)

1654c47

* gradle * Anonymous new Runnable() can be replaced with lambda * Anonymous new Runnable() can be replaced with lambda * add logger print exception

[MINOR] ConfigurationWrapper class adds thread pool shutdown (apache#683

fd60ab9

) * gradle * ConfigurationWrapper class adds thread pool shutdown

GRPC RequestReply API

dc7810e

[ISSUE apache#677] Translate readme files from English to Chinese (ap…

852c22b

…ache#678) * translate English to Chinese close apache#677

[ISSUE apache#405]update cloudevents examples (apache#688)

2b3e861

[Minor apache#405] update cloudevents examples

grpc batchpublish API

7fdcd8d

Bump gradle version to 7.3.3 Support Java17 build

52d423f

Merge pull request apache#689 from Shoothzj/gradle-7-3

a1140ab

Bump gradle version to 7.3.3 to Support Java17 build

[ISSUE apache#690]Remove extra code style check job in CI (apache#691)

032bb0d

Close ISSUE apache#690.

Update intro.md (apache#693)

0cadf29

Add files via upload (apache#694)

9fca946

removing broadcast API

80c4bf8

[ISSUE apache#692]Change the default merge strategy to squash (apache…

5c0f8a9

…#695) * Change the default merge strategy to squash close apache#692

[ISSUE apache#673] update eventmesh-runtime-quickstart-with-docker.md…

8ac37a0

… en & cn (apache#698) * update eventmesh-runtime-quickstart-with-docker.md en & cn close apache#673

[MINOR] Change Tar and Zip name (apache#699)

a9d102c

[Issue apache#417] support cloudevents in GRPC

5c89a23

[Issue apache#702] Fix Slack Join link (apache#705)

70080e7

close apache#702

Updated Notice file to 2022 (apache#704)

80aa61a

add instruction docs of trace and metrics in eventmesh (apache#706)

5dc964b

[ISSUE apache#405]Fix args typo in examples (apache#707)

db6b34f

fixed apache#405

Merge remote-tracking branch 'origin/master' into grpc-dev

42ba9fa

xwm1992 closed this Jan 11, 2022

xwm1992 reopened this Jan 11, 2022

xwm1992 closed this Jan 12, 2022

jinrongluo deleted the grpc-dev branch February 3, 2022 21:27

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[Issue #417] Grpc Transport Protocol support #701

[Issue #417] Grpc Transport Protocol support #701

jinrongluo commented Jan 7, 2022

jinrongluo commented Jan 10, 2022

xwm1992 commented Jan 11, 2022

qqeasonchen commented Jan 11, 2022

[Issue #417] Grpc Transport Protocol support #701

[Issue #417] Grpc Transport Protocol support #701

Conversation

jinrongluo commented Jan 7, 2022

Motivation

Modifications

Documentation

jinrongluo commented Jan 10, 2022

xwm1992 commented Jan 11, 2022

qqeasonchen commented Jan 11, 2022