You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by wa...@apache.org on 2022/09/18 12:25:46 UTC
[incubator-eventmesh] branch eventmesh-server-go updated (c062edbc -> 3f53c003)
This is an automated email from the ASF dual-hosted git repository.
walleliu pushed a change to branch eventmesh-server-go
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from c062edbc Merge pull request #1289 from horoc/go-server-add-rocketmq-consumer
new 8868cac2 add runtime consumer wrapper
new 579081ba add runtime consumer wrapper test
new 2ca2b745 add runtime consumer wrapper test
new 3f53c003 Merge pull request #1309 from walleliu1016/eventmesh-server-go-runtime
The 1335 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-server-go/config/{pprof.go => plugin.go} | 16 ++-
.../runtime/consts/env.go | 19 ++--
.../runtime/consts/state.go | 17 ++--
eventmesh-server-go/runtime/core/grpc/Readme.md | 1 -
eventmesh-server-go/runtime/core/http/Readme.md | 1 -
.../runtime/core/wrapper/base.go | 36 +++----
.../runtime/core/wrapper/consumer.go | 94 ++++++++++++++++++
.../runtime/core/wrapper/consumer_test.go | 108 +++++++++++++++++++++
8 files changed, 252 insertions(+), 40 deletions(-)
copy eventmesh-server-go/config/{pprof.go => plugin.go} (73%)
copy eventmesh-sdk-go/grpc/protocol_type.go => eventmesh-server-go/runtime/consts/env.go (74%)
copy eventmesh-sdk-go/common/protocol/subscription_type.go => eventmesh-server-go/runtime/consts/state.go (81%)
delete mode 100644 eventmesh-server-go/runtime/core/grpc/Readme.md
delete mode 100644 eventmesh-server-go/runtime/core/http/Readme.md
copy eventmesh-sdk-go/common/seq/num.go => eventmesh-server-go/runtime/core/wrapper/base.go (62%)
create mode 100644 eventmesh-server-go/runtime/core/wrapper/consumer.go
create mode 100644 eventmesh-server-go/runtime/core/wrapper/consumer_test.go
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org