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/08/22 11:03:37 UTC
[incubator-eventmesh] 10/10: Merge branch 'eventmesh-server-go' into eventmesh-server-go
This is an automated email from the ASF dual-hosted git repository.
walleliu pushed a commit to branch eventmesh-server-go
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
commit 42d889c3dcb87060ed659b8e8f79792a70b67414
Merge: 439cbafe 6507be75
Author: walleliu <li...@163.com>
AuthorDate: Mon Aug 22 19:03:21 2022 +0800
Merge branch 'eventmesh-server-go' into eventmesh-server-go
eventmesh-server-go/config/config.go | 24 +-
.../{pkg/runtime/client.go => config/grpc.go} | 15 +-
.../{pkg/util/ip_util.go => config/http.go} | 30 +-
.../{pkg/runtime/client.go => config/pprof.go} | 8 +-
eventmesh-server-go/{main.go => config/tcp.go} | 30 +-
eventmesh-server-go/{main.go => config/tls.go} | 30 +-
eventmesh-server-go/{server.go => eventmesh.go} | 59 +-
eventmesh-server-go/go.mod | 2 +-
eventmesh-server-go/go.sum | 97 +-
eventmesh-server-go/pkg/connector/action.go | 9 +
.../{main.go => pkg/connector/consumer.go} | 29 +-
.../{runtime/client.go => connector/lifecycle.go} | 10 +-
.../{runtime/client.go => connector/listener.go} | 14 +-
.../{runtime/client.go => connector/properties.go} | 8 +-
eventmesh-server-go/pkg/connector/publisher.go | 66 +
.../pkg/connector/standalone/broker.go | 173 +++
.../pkg/connector/standalone/consumer.go | 104 ++
.../standalone/message_entity.go} | 28 +-
.../pkg/connector/standalone/message_queue.go | 184 +++
.../pkg/connector/standalone/producer.go | 97 ++
.../pkg/connector/standalone/subscribe.go | 103 ++
.../pkg/runtime/emserver/graceful.go | 37 +
eventmesh-server-go/pkg/runtime/emserver/grpc.go | 72 +
eventmesh-server-go/pkg/runtime/emserver/http.go | 87 ++
.../pkg/runtime/{client.go => emserver/tcp.go} | 24 +-
eventmesh-server-go/pkg/runtime/proto/pb/README.md | 20 +
.../pkg/runtime/proto/pb/eventmesh-client.pb.go | 1485 ++++++++++++++++++++
.../pkg/runtime/proto/pb/eventmesh-client.proto | 165 +++
.../runtime/proto/pb/eventmesh-client_grpc.pb.go | 479 +++++++
eventmesh-server-go/pkg/runtime/server.go | 96 ++
eventmesh-server-go/pkg/util/{ip_util.go => ip.go} | 0
.../pkg/util/{ip_util.go => until.go} | 45 +-
32 files changed, 3465 insertions(+), 165 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org