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 6fd7644 Use errs
new 0d4ed41 [INLONG-624]Go SDK consumer interface
new 845de0b Add license and comments
new a2af6f0 Implement offerEventResult
new d5ea125 Add trim and use slice
new a6fc39d Add comment.
new 2d64bb5 Address review comments
new 67400c7 Add license
new 07e73ae init the channel
new 65cfc8f [INLONG-624]Go SDK Consumer Start API
The 9 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/client/consumer.go | 40 +--
.../tubemq-client-go/client/consumer_impl.go | 374 +++++++++++++++++++++
.../tubemq-client-go/client/heartbeat.go | 236 +++++++++++++
.../tubemq-client-go/client/remote.go | 79 -----
.../tubemq-client-go/client/version.go | 7 +-
.../tubemq-client-go/config/config.go | 18 +-
.../tubemq-client-go/config/config_test.go | 10 +-
tubemq-client-twins/tubemq-client-go/errs/errs.go | 12 +-
.../tubemq-client-go/metadata/consumer_event.go | 15 +
.../tubemq-client-go/metadata/metadata.go | 20 ++
.../tubemq-client-go/metadata/node.go | 54 +++
.../tubemq-client-go/metadata/partition.go | 45 ++-
.../tubemq-client-go/metadata/subcribe_info.go | 54 ++-
.../tubemq-client-go/remote/remote.go | 346 +++++++++++++++++++
tubemq-client-twins/tubemq-client-go/rpc/broker.go | 32 +-
tubemq-client-twins/tubemq-client-go/rpc/client.go | 23 +-
tubemq-client-twins/tubemq-client-go/rpc/master.go | 19 +-
.../tubemq-client-go/{client => sub}/info.go | 77 ++++-
.../tubemq-client-go/transport/client.go | 8 +-
tubemq-client-twins/tubemq-client-go/util/util.go | 74 ++++
20 files changed, 1372 insertions(+), 171 deletions(-)
copy
tubemq-server/src/main/java/org/apache/tubemq/server/common/offsetstorage/zookeeper/Abortable.java
=> tubemq-client-twins/tubemq-client-go/client/consumer.go (54%)
create mode 100644 tubemq-client-twins/tubemq-client-go/client/consumer_impl.go
create mode 100644 tubemq-client-twins/tubemq-client-go/client/heartbeat.go
delete mode 100644 tubemq-client-twins/tubemq-client-go/client/remote.go
copy tubemq-core/src/main/java/org/apache/tubemq/corerpc/codec/Protocol.txt =>
tubemq-client-twins/tubemq-client-go/client/version.go (92%)
create mode 100644 tubemq-client-twins/tubemq-client-go/remote/remote.go
rename tubemq-client-twins/tubemq-client-go/{client => sub}/info.go (62%)
create mode 100644 tubemq-client-twins/tubemq-client-go/util/util.go
