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/10/25 02:11:43 UTC
[incubator-eventmesh] branch eventmesh-server-go updated (9f7b7315 -> cff5ead8)
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 9f7b7315 Merge pull request #1815 from walleliu1016/eventmesh-server-go
new fe8c3a20 add grpc logic
new 35eeae43 add status code
new 91d4cb71 fix compile err
new cff5ead8 Merge pull request #1817 from walleliu1016/eventmesh-server-go
The 1358 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/go.mod | 7 +-
eventmesh-server-go/go.sum | 13 +-
.../pkg/common/protocol/grpc/keys.go | 23 +-
.../pkg/common/protocol/grpc/message.go | 13 +-
.../pkg/common/protocol/grpc/status_code.go | 68 +++
eventmesh-server-go/pkg/common/protocol/tcp/pck.go | 97 ++++
.../runtime/consts/{state.go => constant.go} | 12 +-
eventmesh-server-go/runtime/consts/env.go | 2 +
.../protocol/grpc/{config => }/consumer_group.go | 2 +-
.../group_client.go => consumer_group_client.go} | 8 +-
.../group_option.go => consumer_group_option.go} | 19 +-
.../{consumer/manager.go => consumer_manager.go} | 43 +-
.../{consumer/consumer.go => consumer_mesh.go} | 14 +-
.../runtime/core/protocol/grpc/consumer_service.go | 157 +++++++
.../runtime/core/protocol/grpc/context.go | 101 ++++
.../{wrapper/base.go => protocol/grpc/emitter.go} | 32 +-
.../grpc/{push/handler.go => message_handler.go} | 2 +-
.../runtime/core/protocol/grpc/processor.go | 521 +++++++++++++++++++++
.../runtime/core/protocol/grpc/producer/context.go | 31 --
.../protocol/grpc/{config => }/producer_group.go | 2 +-
.../{producer/manager.go => producer_manager.go} | 21 +-
.../{producer/producer.go => producer_mesh.go} | 7 +-
.../runtime/core/protocol/grpc/producer_service.go | 122 +++++
.../runtime/core/protocol/grpc/push/context.go | 34 --
.../core/protocol/grpc/{push => }/request.go | 5 +-
.../protocol/grpc/{retry/context.go => retry.go} | 2 +-
.../runtime/core/protocol/grpc/validator.go | 125 +++++
.../runtime/core/wrapper/consumer.go | 4 +-
.../runtime/core/wrapper/consumer_test.go | 8 +-
.../runtime/core/wrapper/producer.go | 4 +-
.../runtime/core/wrapper/producer_test.go | 4 +-
eventmesh-server-go/runtime/emserver/grpc.go | 24 +
32 files changed, 1333 insertions(+), 194 deletions(-)
copy eventmesh-sdk-go/grpc/protocol_type.go => eventmesh-server-go/pkg/common/protocol/grpc/keys.go (61%)
copy eventmesh-sdk-go/grpc/consts.go => eventmesh-server-go/pkg/common/protocol/grpc/message.go (75%)
create mode 100644 eventmesh-server-go/pkg/common/protocol/grpc/status_code.go
create mode 100644 eventmesh-server-go/pkg/common/protocol/tcp/pck.go
copy eventmesh-server-go/runtime/consts/{state.go => constant.go} (82%)
rename eventmesh-server-go/runtime/core/protocol/grpc/{config => }/consumer_group.go (99%)
rename eventmesh-server-go/runtime/core/protocol/grpc/{consumer/group_client.go => consumer_group_client.go} (88%)
rename eventmesh-server-go/runtime/core/protocol/grpc/{consumer/group_option.go => consumer_group_option.go} (89%)
rename eventmesh-server-go/runtime/core/protocol/grpc/{consumer/manager.go => consumer_manager.go} (83%)
rename eventmesh-server-go/runtime/core/protocol/grpc/{consumer/consumer.go => consumer_mesh.go} (96%)
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/consumer_service.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/context.go
copy eventmesh-server-go/runtime/core/{wrapper/base.go => protocol/grpc/emitter.go} (65%)
rename eventmesh-server-go/runtime/core/protocol/grpc/{push/handler.go => message_handler.go} (99%)
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/processor.go
delete mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/producer/context.go
rename eventmesh-server-go/runtime/core/protocol/grpc/{config => }/producer_group.go (98%)
rename eventmesh-server-go/runtime/core/protocol/grpc/{producer/manager.go => producer_manager.go} (77%)
rename eventmesh-server-go/runtime/core/protocol/grpc/{producer/producer.go => producer_mesh.go} (92%)
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/producer_service.go
delete mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/push/context.go
rename eventmesh-server-go/runtime/core/protocol/grpc/{push => }/request.go (97%)
rename eventmesh-server-go/runtime/core/protocol/grpc/{retry/context.go => retry.go} (98%)
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/validator.go
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org