You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by ch...@apache.org on 2022/12/07 10:26:15 UTC
[incubator-eventmesh] branch master updated (53d23b203 -> c29247b72)
This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from 53d23b203 fix issue2461 (#2462)
new fc19d63ea add eventmesh server go
new f68d4bab5 add license
new 56152da39 Merge pull request #1122 from walleliu1016/eventmesh-server-go
new dba21c258 feat(makefile): support build/test/coverage sub-cmd
new ae4a2b930 docs(makefile):License Header
new 230d5f400 add plugin/config/log/server module
new 06131b64d fix cr comment problems
new f11a42294 remove factory file
new 9cfb573a5 Merge pull request #1140 from walterlife/walterlife/addplugin
new 0514d2d39 modify eventmesh-server-go mod namespace
new 0945ab92d add license header
new 3496bdda3 fix invalid license header
new 22ecc08c5 Merge pull request #1145 from walterlife/walterlife/modify_mod_namespace
new 3a65790c4 fix conflicts
new 31fe65b39 Merge pull request #1141 from baiyutang/feature/ci-makefile
new db4e1b18e go server: add standalone connector
new 439cbafe9 Merge pull request #1169 from horoc/go-standalone-connector
new 889468082 add http server
new 3b16e8979 add grpc tcp http server
new 3f0d41a36 add standalone
new 3b03f6492 fix compile err
new 50b063ea3 add broker
new cd499a8cc add until
new 64a87aa63 add standalone consumer
new 1e8ddc166 add publish
new 6507be75b add until in message queue
new 42d889c3d Merge branch 'eventmesh-server-go' into eventmesh-server-go
new 64d85d27f Merge pull request #1 from apache/eventmesh-server-go
new b47f03a7f merge
new cc707c200 adapter the new connector plugin
new 8f62d8ac1 Merge pull request #1173 from walleliu1016/eventmesh-server-go
new f1a8fecf4 update dependecies
new 69bd52e6b Merge pull request #1269 from horoc/update-dependencies
new 56ba18cc5 add rocketmq message convert
new e5c57fa60 Merge pull request #1267 from horoc/go-server-rocketmq-message-convert
new 6a3b4b732 add go server rocketmq consumer
new 9b027fe16 fix int str convert
new c062edbcd Merge pull request #1289 from horoc/go-server-add-rocketmq-consumer
new 8868cac2a add runtime consumer wrapper
new 579081ba3 add runtime consumer wrapper test
new 2ca2b745e add runtime consumer wrapper test
new 3f53c003b Merge pull request #1309 from walleliu1016/eventmesh-server-go-runtime
new 194ba8e6e add consumer implement
new 5283d837e Merge pull request #1336 from walleliu1016/eventmesh-server-go-runtime
new cd733a72b add protocol plugin api
new e9894dd94 Merge pull request #1338 from walleliu1016/eventmesh-server-go-runtime
new 0392be85d add runtime producer
new 41f9139f8 Merge pull request #1339 from walleliu1016/eventmesh-server-go-runtime
new 7608164a5 combine connector api
new 510a6ed22 Merge pull request #1352 from horoc/combine-connector-api
new 6a538a8f7 add rocketmq mock and unit test
new 7b2fad5c7 Merge branch 'eventmesh-server-go' into go-server-add-rocketmq-connector
new 4d039ff16 Merge pull request #1312 from horoc/go-server-add-rocketmq-connector
new ad8e49e77 add go server metrics
new e30072af9 Merge pull request #1524 from horoc/add-go-server-metrics
new 6c480b08f go server standalond connector optimization
new f94c6e742 Merge pull request #1652 from horoc/eventmesh-server-go
new 71795d765 add prototol plugin
new 5e45fd694 Merge pull request #1813 from walleliu1016/eventmesh-server-go
new 9c49dc73d add hearbeat service
new 9f7b7315b Merge pull request #1815 from walleliu1016/eventmesh-server-go
new fe8c3a200 add grpc logic
new 35eeae430 add status code
new 91d4cb71b fix compile err
new eb461a9f1 add batch message validator
new ae65b67e0 fix compile err
new f2f05ff0f registry compile err
new ef5cd5f74 repair compile err
new 7b00648a3 add plugin loader
new 458156f18 fix boot err
new 02cd6a089 add cachedir for nacos, grpc runtime boot ok
new d9172855b add grpcurl to debug
new 9e85b42a3 add active plugin in config, fix consumer group topic register err
new 12ce40083 add publish test, fix cloudevent contenttype
new 30d75c841 subscribe webhook ok, publish ok
new cb14cbd63 update webhook demo
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 7474a2b89 remove docs
new cff5ead87 Merge pull request #1817 from walleliu1016/eventmesh-server-go
new ece9d9ada Merge pull request #1979 from walleliu1016/eventmesh-server-go
new 88b66299d remove unused go library
new dc14ee0b6 Merge pull request #2096 from walterlife/modify-go-mod
new 4be3c6085 add ci for server-go
new e130ab098 move ci yml to root folder
new 25093f2c2 run go mod tidy before go build
new 1fd133e87 fix ci: specify go version 1.18
new 4f243dc97 fix ci: try to trigger the server go ci
new 54f206638 fix ci: fix go build error
new 330cf31e4 Merge pull request #2161 from HoffmanZheng/issue-1131
new 700ddf6ea Merge pull request #2223 from walleliu1016/eventmesh-server-go
new 598c210b6 Merge branch 'eventmesh-server-go' into eventmesh-server-go
new 5704dc8bc Merge pull request #2497 from walleliu1016/eventmesh-server-go
new cb130dc16 Merge branch 'eventmesh-server-go' of https://github.com/walleliu1016/incubator-eventmesh into eventmesh-server-go
new fe1fa94cd remove java licience
new c29247b72 Merge pull request #2499 from walleliu1016/eventmesh-server-go
The 2684 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:
.github/workflows/eventmesh-server-go.yml | 52 +
eventmesh-server-go/.gitignore | 33 +
.../.golangci.yml | 0
LICENSE => eventmesh-server-go/LICENSE | 0
eventmesh-server-go/Makefile | 27 +
.../api/openapi-spec/swagger.json | 0
.../api/protobuf-spec/eventmesh.proto | 0
eventmesh-server-go/assets/REAEMD.md | 1 +
eventmesh-server-go/config/config.go | 90 ++
eventmesh-server-go/config/grpc.go | 68 +
eventmesh-server-go/config/http.go | 30 +
eventmesh-server-go/config/plugin.go | 28 +
eventmesh-server-go/config/pprof.go | 22 +
eventmesh-server-go/config/tcp.go | 34 +
eventmesh-server-go/config/tls.go | 34 +
eventmesh-server-go/configs/eventmesh-server.yaml | 70 +
eventmesh-server-go/deployments/README.md | 1 +
.../deployments/docker-compose/eventmesh.yml | 15 +
eventmesh-server-go/deployments/helms/REAME.md | 1 +
eventmesh-server-go/eventmesh.go | 60 +
eventmesh-server-go/examples/README.md | 1 +
eventmesh-server-go/examples/webhook/main.go | 79 ++
eventmesh-server-go/go.mod | 82 ++
eventmesh-server-go/go.sum | 684 +++++++++
eventmesh-server-go/log/config.go | 186 +++
eventmesh-server-go/log/log.go | 113 ++
eventmesh-server-go/log/logger.go | 120 ++
eventmesh-server-go/log/logger_factory.go | 155 ++
.../log/rollwriter/async_roll_writer.go | 133 ++
.../log/rollwriter/async_roll_writer_options.go | 62 +
eventmesh-server-go/log/rollwriter/roll_writer.go | 446 ++++++
.../log/rollwriter/roll_writer_options.go | 72 +
eventmesh-server-go/log/writer_factory.go | 116 ++
eventmesh-server-go/log/zaplogger.go | 502 +++++++
eventmesh-server-go/pkg/README.md | 1 +
.../pkg/common/protocol/grpc/keys.go | 65 +
.../pkg/common/protocol/grpc/message.go | 26 +
.../pkg/common/protocol/grpc/status_code.go | 68 +
eventmesh-server-go/pkg/common/protocol/tcp/pck.go | 97 ++
.../pkg/naming/registry/instance.go | 34 +
.../pkg/naming/registry/registry.go | 72 +
.../pkg/naming/selector/selector.go | 43 +
eventmesh-server-go/pkg/util/id.go | 39 +
eventmesh-server-go/pkg/util/id_test.go | 94 ++
eventmesh-server-go/pkg/util/ip.go | 43 +
eventmesh-server-go/pkg/util/pid.go | 32 +
eventmesh-server-go/pkg/util/pid_test.go | 37 +
eventmesh-server-go/pkg/version/version.go | 20 +
eventmesh-server-go/plugin/connector/connector.go | 122 ++
.../connector/rocketmq/client/rocketmq_consumer.go | 159 +++
.../connector/rocketmq/client/rocketmq_producer.go | 168 +++
.../connector/rocketmq/config/client_config.go | 41 +
.../rocketmq/constants/message_constants.go | 25 +
.../constants/rocketmq_message_properties.go | 61 +
.../plugin/connector/rocketmq/consumer.go | 221 +++
.../plugin/connector/rocketmq/consumer_test.go | 130 ++
.../rocketmq/convert/message_ext_convert.go | 33 +
.../rocketmq/convert/rocketmq_message_reader.go | 110 ++
.../convert/rocketmq_message_reader_test.go | 47 +
.../rocketmq/convert/rocketmq_message_writer.go | 86 ++
.../convert/rocketmq_message_writer_test.go | 44 +
.../plugin/connector/rocketmq/factory.go | 84 ++
.../rocketmq/mock/mock_rocketmq_consumer.go | 145 ++
.../rocketmq/mock/mock_rocketmq_producer.go | 167 +++
.../plugin/connector/rocketmq/producer.go | 236 ++++
.../plugin/connector/rocketmq/producer_test.go | 214 +++
.../plugin/connector/rocketmq/resource.go | 29 +
.../plugin/connector/rocketmq/utils/oms_util.go | 27 +
.../plugin/connector/standalone/broker.go | 259 ++++
.../plugin/connector/standalone/consumer.go | 200 +++
.../plugin/connector/standalone/factory.go | 70 +
.../plugin/connector/standalone/message.go | 47 +
.../plugin/connector/standalone/producer.go | 116 ++
.../plugin/connector/standalone/resource.go | 29 +
.../standalone/standalone_connector_test.go | 223 +++
eventmesh-server-go/plugin/database/mysql/mysql.go | 68 +
eventmesh-server-go/plugin/metrics/metrics.go | 36 +
.../plugin/metrics/prometheus/config.go | 26 +
.../plugin/metrics/prometheus/metrics.go | 153 ++
.../plugin/metrics/prometheus/metrics_test.go | 30 +
.../plugin/naming/nacos/registry/config.go | 32 +
.../plugin/naming/nacos/registry/registry.go | 170 +++
.../plugin/naming/nacos/selector/config.go | 30 +
.../plugin/naming/nacos/selector/selector.go | 120 ++
eventmesh-server-go/plugin/plugin.go | 66 +
.../plugin/protocol/cloudevents/Readme.md | 1 +
.../plugin/protocol/cloudevents/cloudevents.go | 215 +++
eventmesh-server-go/plugin/protocol/protocol.go | 40 +
eventmesh-server-go/plugin/setup.go | 153 ++
eventmesh-server-go/plugin/types.go | 37 +
eventmesh-server-go/runtime/consts/constant.go | 24 +
eventmesh-server-go/runtime/consts/env.go | 32 +
eventmesh-server-go/runtime/consts/state.go | 25 +
.../runtime/core/protocol/grpc/consumer_group.go | 80 ++
.../core/protocol/grpc/consumer_group_client.go | 39 +
.../core/protocol/grpc/consumer_group_option.go | 279 ++++
.../runtime/core/protocol/grpc/consumer_manager.go | 201 +++
.../runtime/core/protocol/grpc/consumer_mesh.go | 236 ++++
.../runtime/core/protocol/grpc/consumer_service.go | 158 +++
.../core/protocol/grpc/consumer_service_test.go | 154 ++
.../runtime/core/protocol/grpc/context.go | 101 ++
.../runtime/core/protocol/grpc/emitter.go | 32 +
.../runtime/core/protocol/grpc/fake_client.go | 113 ++
.../core/protocol/grpc/heartbeat_service.go | 67 +
.../runtime/core/protocol/grpc/message_handler.go | 103 ++
.../runtime/core/protocol/grpc/processor.go | 521 +++++++
.../runtime/core/protocol/grpc/producer_group.go | 20 +
.../runtime/core/protocol/grpc/producer_manager.go | 77 +
.../runtime/core/protocol/grpc/producer_mesh.go | 100 ++
.../runtime/core/protocol/grpc/producer_service.go | 122 ++
.../core/protocol/grpc/producer_service_test.go | 86 ++
.../runtime/core/protocol/grpc/request.go | 239 ++++
.../runtime/core/protocol/grpc/retry.go | 33 +
.../runtime/core/protocol/grpc/validator.go | 152 ++
eventmesh-server-go/runtime/core/wrapper/base.go | 44 +
.../runtime/core/wrapper/consumer.go | 85 ++
.../runtime/core/wrapper/consumer_test.go | 108 ++
.../runtime/core/wrapper/producer.go | 79 ++
.../runtime/core/wrapper/producer_test.go | 79 ++
eventmesh-server-go/runtime/emserver/graceful.go | 37 +
eventmesh-server-go/runtime/emserver/grpc.go | 99 ++
eventmesh-server-go/runtime/emserver/grpc_test.go | 68 +
eventmesh-server-go/runtime/emserver/http.go | 86 ++
eventmesh-server-go/runtime/emserver/tcp.go | 38 +
.../runtime/proto/pb}/README.md | 0
.../runtime/proto/pb/eventmesh-client.pb.go | 1485 ++++++++++++++++++++
.../runtime/proto/pb}/eventmesh-client.proto | 0
.../runtime/proto/pb/eventmesh-client_grpc.pb.go | 479 +++++++
eventmesh-server-go/runtime/server.go | 96 ++
eventmesh-server-go/scripts/REAEMD.md | 1 +
.../style}/checkStyle.xml | 0
eventmesh-server-go/tests/grpc.md | 199 +++
132 files changed, 14235 insertions(+)
create mode 100644 .github/workflows/eventmesh-server-go.yml
create mode 100644 eventmesh-server-go/.gitignore
copy {eventmesh-catalog-go => eventmesh-server-go}/.golangci.yml (100%)
copy LICENSE => eventmesh-server-go/LICENSE (100%)
create mode 100644 eventmesh-server-go/Makefile
copy eventmesh-connector-plugin/build.gradle => eventmesh-server-go/api/openapi-spec/swagger.json (100%)
copy eventmesh-connector-plugin/build.gradle => eventmesh-server-go/api/protobuf-spec/eventmesh.proto (100%)
create mode 100644 eventmesh-server-go/assets/REAEMD.md
create mode 100644 eventmesh-server-go/config/config.go
create mode 100644 eventmesh-server-go/config/grpc.go
create mode 100644 eventmesh-server-go/config/http.go
create mode 100644 eventmesh-server-go/config/plugin.go
create mode 100644 eventmesh-server-go/config/pprof.go
create mode 100644 eventmesh-server-go/config/tcp.go
create mode 100644 eventmesh-server-go/config/tls.go
create mode 100644 eventmesh-server-go/configs/eventmesh-server.yaml
create mode 100644 eventmesh-server-go/deployments/README.md
create mode 100644 eventmesh-server-go/deployments/docker-compose/eventmesh.yml
create mode 100644 eventmesh-server-go/deployments/helms/REAME.md
create mode 100644 eventmesh-server-go/eventmesh.go
create mode 100644 eventmesh-server-go/examples/README.md
create mode 100644 eventmesh-server-go/examples/webhook/main.go
create mode 100644 eventmesh-server-go/go.mod
create mode 100644 eventmesh-server-go/go.sum
create mode 100644 eventmesh-server-go/log/config.go
create mode 100644 eventmesh-server-go/log/log.go
create mode 100644 eventmesh-server-go/log/logger.go
create mode 100644 eventmesh-server-go/log/logger_factory.go
create mode 100644 eventmesh-server-go/log/rollwriter/async_roll_writer.go
create mode 100644 eventmesh-server-go/log/rollwriter/async_roll_writer_options.go
create mode 100644 eventmesh-server-go/log/rollwriter/roll_writer.go
create mode 100644 eventmesh-server-go/log/rollwriter/roll_writer_options.go
create mode 100644 eventmesh-server-go/log/writer_factory.go
create mode 100644 eventmesh-server-go/log/zaplogger.go
create mode 100644 eventmesh-server-go/pkg/README.md
create mode 100644 eventmesh-server-go/pkg/common/protocol/grpc/keys.go
create mode 100644 eventmesh-server-go/pkg/common/protocol/grpc/message.go
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
create mode 100644 eventmesh-server-go/pkg/naming/registry/instance.go
create mode 100644 eventmesh-server-go/pkg/naming/registry/registry.go
create mode 100644 eventmesh-server-go/pkg/naming/selector/selector.go
create mode 100644 eventmesh-server-go/pkg/util/id.go
create mode 100644 eventmesh-server-go/pkg/util/id_test.go
create mode 100644 eventmesh-server-go/pkg/util/ip.go
create mode 100644 eventmesh-server-go/pkg/util/pid.go
create mode 100644 eventmesh-server-go/pkg/util/pid_test.go
create mode 100644 eventmesh-server-go/pkg/version/version.go
create mode 100644 eventmesh-server-go/plugin/connector/connector.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/client/rocketmq_consumer.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/client/rocketmq_producer.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/config/client_config.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/constants/message_constants.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/constants/rocketmq_message_properties.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/consumer.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/consumer_test.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/convert/message_ext_convert.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/convert/rocketmq_message_reader.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/convert/rocketmq_message_reader_test.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/convert/rocketmq_message_writer.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/convert/rocketmq_message_writer_test.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/factory.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/mock/mock_rocketmq_consumer.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/mock/mock_rocketmq_producer.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/producer.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/producer_test.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/resource.go
create mode 100644 eventmesh-server-go/plugin/connector/rocketmq/utils/oms_util.go
create mode 100644 eventmesh-server-go/plugin/connector/standalone/broker.go
create mode 100644 eventmesh-server-go/plugin/connector/standalone/consumer.go
create mode 100644 eventmesh-server-go/plugin/connector/standalone/factory.go
create mode 100644 eventmesh-server-go/plugin/connector/standalone/message.go
create mode 100644 eventmesh-server-go/plugin/connector/standalone/producer.go
create mode 100644 eventmesh-server-go/plugin/connector/standalone/resource.go
create mode 100644 eventmesh-server-go/plugin/connector/standalone/standalone_connector_test.go
create mode 100644 eventmesh-server-go/plugin/database/mysql/mysql.go
create mode 100644 eventmesh-server-go/plugin/metrics/metrics.go
create mode 100644 eventmesh-server-go/plugin/metrics/prometheus/config.go
create mode 100644 eventmesh-server-go/plugin/metrics/prometheus/metrics.go
create mode 100644 eventmesh-server-go/plugin/metrics/prometheus/metrics_test.go
create mode 100644 eventmesh-server-go/plugin/naming/nacos/registry/config.go
create mode 100644 eventmesh-server-go/plugin/naming/nacos/registry/registry.go
create mode 100644 eventmesh-server-go/plugin/naming/nacos/selector/config.go
create mode 100644 eventmesh-server-go/plugin/naming/nacos/selector/selector.go
create mode 100644 eventmesh-server-go/plugin/plugin.go
create mode 100644 eventmesh-server-go/plugin/protocol/cloudevents/Readme.md
create mode 100644 eventmesh-server-go/plugin/protocol/cloudevents/cloudevents.go
create mode 100644 eventmesh-server-go/plugin/protocol/protocol.go
create mode 100644 eventmesh-server-go/plugin/setup.go
create mode 100644 eventmesh-server-go/plugin/types.go
create mode 100644 eventmesh-server-go/runtime/consts/constant.go
create mode 100644 eventmesh-server-go/runtime/consts/env.go
create mode 100644 eventmesh-server-go/runtime/consts/state.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/consumer_group.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/consumer_group_client.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/consumer_group_option.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/consumer_manager.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/consumer_mesh.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/consumer_service.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/consumer_service_test.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/context.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/emitter.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/fake_client.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/heartbeat_service.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/message_handler.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/processor.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/producer_group.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/producer_manager.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/producer_mesh.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/producer_service.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/producer_service_test.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/request.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/retry.go
create mode 100644 eventmesh-server-go/runtime/core/protocol/grpc/validator.go
create mode 100644 eventmesh-server-go/runtime/core/wrapper/base.go
create mode 100644 eventmesh-server-go/runtime/core/wrapper/consumer.go
create mode 100644 eventmesh-server-go/runtime/core/wrapper/consumer_test.go
create mode 100644 eventmesh-server-go/runtime/core/wrapper/producer.go
create mode 100644 eventmesh-server-go/runtime/core/wrapper/producer_test.go
create mode 100644 eventmesh-server-go/runtime/emserver/graceful.go
create mode 100644 eventmesh-server-go/runtime/emserver/grpc.go
create mode 100644 eventmesh-server-go/runtime/emserver/grpc_test.go
create mode 100644 eventmesh-server-go/runtime/emserver/http.go
create mode 100644 eventmesh-server-go/runtime/emserver/tcp.go
copy {eventmesh-sdk-go/grpc/proto => eventmesh-server-go/runtime/proto/pb}/README.md (100%)
create mode 100644 eventmesh-server-go/runtime/proto/pb/eventmesh-client.pb.go
copy {eventmesh-sdk-go/grpc/proto => eventmesh-server-go/runtime/proto/pb}/eventmesh-client.proto (100%)
create mode 100644 eventmesh-server-go/runtime/proto/pb/eventmesh-client_grpc.pb.go
create mode 100644 eventmesh-server-go/runtime/server.go
create mode 100644 eventmesh-server-go/scripts/REAEMD.md
copy {style => eventmesh-server-go/style}/checkStyle.xml (100%)
create mode 100644 eventmesh-server-go/tests/grpc.md
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org