This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a change to branch INLONG-25
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from 3249de3 [TUBEMQ-594] Trpc-go tube sdk strongly rely on local
config(addendum)
new 108fd1f [INLONG-600]Multiplexed connection pool for Go sdk
new 0033c62 Add license and remove the chinese comment
new 058ad95 Address review comments
new 96b5728 nitpick
new c6d3f75 Rename and add some comments
new e0fd869 Remove go.sum from git index
new a1c86bc nitpick
new 459405a nitpick for codec and dialopts
new 6b64b52 Address review comments
new e00a5ba Add missing file
new a16216d Address review comments
new 2cd11c3 nitpick
The 12 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:
.../tubemq-client-go/codec/codec.go | 31 +-
.../tubemq-client-go/codec/tubemq_codec.go | 132 +++++++
.../tubemq-client-go/go.mod | 24 +-
.../tubemq-client-go/multiplexing/multiplexing.go | 419 +++++++++++++++++++++
.../multiplexing/multlplexing_test.go | 144 +++++++
5 files changed, 719 insertions(+), 31 deletions(-)
copy
tubemq-client/src/main/java/org/apache/tubemq/client/consumer/MessageListener.java
=> tubemq-client-twins/tubemq-client-go/codec/codec.go (56%)
create mode 100644 tubemq-client-twins/tubemq-client-go/codec/tubemq_codec.go
copy codestyle/suppressions.xml => tubemq-client-twins/tubemq-client-go/go.mod
(54%)
create mode 100644
tubemq-client-twins/tubemq-client-go/multiplexing/multiplexing.go
create mode 100644
tubemq-client-twins/tubemq-client-go/multiplexing/multlplexing_test.go
