This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 593b80e2b [INLONG-8127][Manager] Fix UT failed in
HeartbeatManagerTest.testReportHeartbeat (#8128)
add a858fd783 [INLONG-8122][TubeMQ] Implement "Heartbeat" method for GO
SDK (#8123)
No new revisions were added by this update.
Summary of changes:
.../tubemq-client-go/client/heartbeat.go | 84 +++++++++++++++++--
.../tubemq-client-go/client/producer.go | 96 +++++++++++++++++-----
.../example/{producer.go => producer_example.go} | 6 +-
.../{client/client.go => metadata/topic_info.go} | 35 +++++++-
.../tubemq-client-go/rpc/client.go | 3 +
.../tubemq-client-go/rpc/master.go | 39 +++++++++
6 files changed, 234 insertions(+), 29 deletions(-)
rename inlong-tubemq/tubemq-client-twins/tubemq-client-go/example/{producer.go
=> producer_example.go} (90%)
copy inlong-tubemq/tubemq-client-twins/tubemq-client-go/{client/client.go =>
metadata/topic_info.go} (57%)
