Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[Issue #417] Grpc Publisher and Consumer API work #660

Merged
merged 111 commits into from
Dec 24, 2021
Merged

[Issue #417] Grpc Publisher and Consumer API work #660

merged 111 commits into from
Dec 24, 2021

Conversation

jinrongluo
Copy link
Contributor

@jinrongluo jinrongluo commented Dec 17, 2021 •
edited
Loading

Fixes ISSUE#417.

Grpc Publisher API work, including the followings:

  • runtime grpc server
  • runtime grpc publisher API and processor
  • runtime grpc consumer API and processor
  • grpc java-sdk-client
  • grpc java client test in eventmesh-example module

xwm1992 and others added 30 commits October 29, 2021 18:13
@xwm1992
readme.md
6f57a90
@xwm1992
Merge branch 'develop' of https://github.com/apache/incubator-eventmesh…
88f8ffc 
… into develop

� Conflicts:
�	README.md
@wangshaojie4039
[ISSUE apache#563] SDK SUPPORT CLOUD EVENT (apache#575)
1feaaa7 
* 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]>
@xwm1992
[Feature apache#562] support cloudevents api in eventmesh-connector-a…
deee538 
…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
@wangshaojie4039
connector support cloud event (apache#586)
3ae9234 
Co-authored-by: wangshaojie <[email protected]>
@xwm1992
[Feature apache#562] Support CloudEvents for pub/sub in EventMesh run…
fcde151 
…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
@xwm1992 @qqeasonchen
@ruanwenjun @nichozhan @hagsyn
[Feature apache#562] Implement CloudEvents protocol adaptor (apache#595)
6828f57 
* [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]>
@xwm1992 @qqeasonchen
@ruanwenjun @nichozhan @hagsyn
[Feature apache#562] Implement EventMeshMessage protocol adaptor (apa…
0096cee 
…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]>
@ruanwenjun
Remove some unused code (apache#591)
db02781 
* Remove some unused code in sdk module

* Remove some unused code in sdk module
@sarihuangshanrong
fixed a wrong url in cn-doc (apache#585)
f8ffb44 
close apache#596
@hagsyn
resolve_exception->Consumer subscription topic is invalid apache#590 (a…
0acafcc 
…pache#598)

close apache#590
@xwm1992 @qqeasonchen
@ruanwenjun @nichozhan @hagsyn
update Eventmeshmessage plugin (apache#599)
fcd1218 
* [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]>
@qqeasonchen
Update eventmesh-store-quickstart.md
e53acaf
@qqeasonchen
Update README.md
4f04d9d
@ruanwenjun
Add slack icon (apache#601)
71bcb09
@ruanwenjun
Add protocol producer in java sdk (apache#600)
ac8db5a 
* Add protocol producer in sdk

* Refactor callback handler

* Add tcp protocol client
@ruanwenjun
Change Tcp interface (apache#603)
bcc1503
@xwm1992
update http push request and adaptor (apache#606)
0082f3d 
1.update http push request
2.update http in protocol adaptor
@xwm1992
update java sdk (apache#607)
c66c8f7
@ruanwenjun
Fix standalone connector interface, fix example (apache#608)
5f61c24
@xwm1992
fix compile error (apache#609)
a0204ae 
* update java sdk

* fix compile error
@xwm1992
Java sdk update (apache#610)
0268792 
* update java sdk

* fix compile error

* fix sdk error
@ruanwenjun
Add EventMeshTCPClient, this client wrap the sub/sub client (apache#611)
1c34373
@xwm1992
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
@xwm1992
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
@yzhao244
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
@ruanwenjun
Fix some small issue (apache#616)
d1064cb
@xwm1992
eventmeshmessage protocol adaptor for tcp (apache#618)
351f3ba 
1.fix the standalone connector
2.fix eventmeshmessage protocol adaptor for tcp
@yzhao244
remove openschema implementation from em project
e337b79
@xwm1992
eventmesh message protocol for http pub/sub with standalone connector (…
b46026d 
…apache#619)

1.fix eventmeshmessage protocol adaptor for http with standalone connector
jinrongluo and others added 27 commits December 14, 2021 10:06
@jinrongluo
Merge remote-tracking branch 'origin/develop' into grpc2
6718b0b
@jinrongluo
[Issue apache#417] grpc publish API
c24e083
@ruanwenjun
[MINOR] Add third-part dependencies licenses (apache#650)
a54d1f5
@xwm1992
[MINOR] supply the license and update the third party license file na…
05f8a3c 
…me (apache#653)

 [MINOR] supply the license and update the third party license file name
@Roc-00
[ISSUE apache#340]Add http trace http point (apache#527)
a9fe559 
* tracing in AbstractHTTPServer

* add licence

* the span exporter

* design docs

* fix the error on text

* delete the useless dependence

* remove the unused code

* fix the different spanExporter

* change the class name

* fix gradle -build problem

* design docs improve

* fix the gradle.build error problem

* fixed

* unsure fix

* fix the path name

* fix check error

* format code

* add javadoc

* checkstyle fix

* unversioned files

* put context into channel in advance
@ruanwenjun
Update quick start docs (apache#656)
e32c9f5
@ruanwenjun
[MINOR] Upgrade log4j version to 2.16.0 (apache#654)
f7c2694 
* Update log4j version
@xwm1992
[MINOR] update the license and add the third party license files (apa…
f30588e 
…che#657)

* [MINOR] update the license and add the third party license files
@lrhkobe
[ISSUE apache#604]Improve the rebalance algorithm (apache#605)
1c7429b 
* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

* modify:remove unneccessary interface in eventmesh-connector-api

* modify:fix conflict

* modify:add license in EventMeshAction

* modify:fix ack problem

* modify:fix exception handle when exception occured in EventMeshTcpMessageDispatcher

* modify:fix log print

* modify: fix issue#496,ClassCastException

* modify: improve rebalance algorithm

close apache#604
@xwm1992
[Feature apache#547] Create and upload 1.3.0-snapshot docker image (a…
b77646c 
…pache#659)

* [Feature apache#547] Create and upload 1.3.0-snapshot docker image
@jinrongluo
grpc consumer work
9507956
@ruanwenjun @jinrongluo
[MINOR] Add third-part dependencies licenses (apache#650)
2968f49
@xwm1992 @jinrongluo
[MINOR] supply the license and update the third party license file na…
b35e39a 
…me (apache#653)

 [MINOR] supply the license and update the third party license file name
@Roc-00 @jinrongluo
[ISSUE apache#340]Add http trace http point (apache#527)
2323237 
* tracing in AbstractHTTPServer

* add licence

* the span exporter

* design docs

* fix the error on text

* delete the useless dependence

* remove the unused code

* fix the different spanExporter

* change the class name

* fix gradle -build problem

* design docs improve

* fix the gradle.build error problem

* fixed

* unsure fix

* fix the path name

* fix check error

* format code

* add javadoc

* checkstyle fix

* unversioned files

* put context into channel in advance
@ruanwenjun @jinrongluo
Update quick start docs (apache#656)
c393c8b
@ruanwenjun @jinrongluo
[MINOR] Upgrade log4j version to 2.16.0 (apache#654)
6adc45e 
* Update log4j version
@xwm1992 @jinrongluo
[MINOR] update the license and add the third party license files (apa…
a71524f 
…che#657)

* [MINOR] update the license and add the third party license files
@lrhkobe @jinrongluo
[ISSUE apache#604]Improve the rebalance algorithm (apache#605)
683f02b 
* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

* modify:remove unneccessary interface in eventmesh-connector-api

* modify:fix conflict

* modify:add license in EventMeshAction

* modify:fix ack problem

* modify:fix exception handle when exception occured in EventMeshTcpMessageDispatcher

* modify:fix log print

* modify: fix issue#496,ClassCastException

* modify: improve rebalance algorithm

close apache#604
@xwm1992 @jinrongluo
[Feature apache#547] Create and upload 1.3.0-snapshot docker image (a…
66568fd 
…pache#659)

* [Feature apache#547] Create and upload 1.3.0-snapshot docker image
@jinrongluo
merge from develop
fbaf7cc
@jinrongluo
GRPC producer publish API
b07fef5
@jinrongluo
grpc publish with cloudevents
3c6e877
@jinrongluo
Merge remote-tracking branch 'origin/develop' into grpc-dev
c3a1b00
@jinrongluo
Adding grpc publish and subscribe API examples
11c5772
@jinrongluo
grpc consumer api testing and bug fixing
9460f75
@jinrongluo
minor enhancement to grpc consumer
8805fb3
@jinrongluo
Merge branch 'grpc-dev' into grpc2
be25dc8
@jinrongluo jinrongluo changed the title [Issue #417] Grpc Publisher API work [Issue #417] Grpc Publisher and Consumer API work Dec 17, 2021
@xwm1992 xwm1992 merged commit 87a1116 into apache:grpc Dec 24, 2021
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers

@xwm1992 xwm1992 xwm1992 approved these changes

Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.