This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch eventmesh-server-go
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from 700ddf6ea Merge pull request #2223 from
walleliu1016/eventmesh-server-go
new 9c5d6f3e8 add grpc sub and un sub test case
new e2e27ca32 add rocketmq config, init rocket connector instance on
plugin start
new d24b2d59b add grpc stream subscribe testcase
new fc62b46a2 update substream producer nil
new cd06ec164 update config yaml
new 598c210b6 Merge branch 'eventmesh-server-go' into eventmesh-server-go
new 5704dc8bc Merge pull request #2497 from
walleliu1016/eventmesh-server-go
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-server-go/config/config.go | 2 +-
eventmesh-server-go/configs/eventmesh-server.yaml | 17 ++-
eventmesh-server-go/go.mod | 13 +-
eventmesh-server-go/go.sum | 8 --
.../plugin/connector/rocketmq/factory.go | 42 +++---
.../plugin/connector/standalone/consumer.go | 5 +-
.../plugin/connector/standalone/producer.go | 4 +-
.../runtime/core/protocol/grpc/consumer_manager.go | 2 +-
.../runtime/core/protocol/grpc/consumer_service.go | 39 +++---
.../core/protocol/grpc/consumer_service_test.go | 154 +++++++++++++++++++++
.../runtime/core/protocol/grpc/fake_client.go | 113 +++++++++++++++
.../runtime/core/protocol/grpc/processor.go | 2 +-
eventmesh-server-go/runtime/emserver/grpc_test.go | 68 +++++++++
eventmesh-server-go/tests/grpc.md | 83 +++++++++++
14 files changed, 494 insertions(+), 58 deletions(-)
create mode 100644
eventmesh-server-go/runtime/core/protocol/grpc/consumer_service_test.go
create mode 100644
eventmesh-server-go/runtime/core/protocol/grpc/fake_client.go
create mode 100644 eventmesh-server-go/runtime/emserver/grpc_test.go
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
