This is an automated email from the ASF dual-hosted git repository.
spetz pushed a change to branch go_sdk_vsr
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 6136cefab feat(go): migrate SDK to the VSR wire protocol
add 0e8267a31 fix
No new revisions were added by this update.
Summary of changes:
core/server-ng/src/dispatch.rs | 43 +--
.../binary_response_deserializer.go | 7 +-
.../vsr_response_deserializer_test.go | 5 +-
foreign/go/client/tcp/tcp_connect_test.go | 138 ++++++++-
.../go/client/tcp/tcp_consumer_group_management.go | 18 +-
.../tcp/tcp_consumer_group_management_test.go | 139 +++++++++
foreign/go/client/tcp/tcp_core.go | 51 +++-
foreign/go/client/tcp/tcp_core_test.go | 60 +++-
foreign/go/client/tcp/tcp_group_polling.go | 98 +++---
foreign/go/client/tcp/tcp_group_polling_test.go | 329 +++++++++++++++++++++
foreign/go/client/tcp/tcp_messaging.go | 5 +-
foreign/go/client/tcp/tcp_partition_management.go | 24 +-
foreign/go/client/tcp/tcp_stream_management.go | 6 +-
.../go/client/tcp/tcp_stream_management_test.go | 162 ++++++++++
foreign/go/client/tcp/tcp_topic_cache.go | 37 ++-
foreign/go/client/tcp/tcp_topic_cache_test.go | 92 ++++++
foreign/go/client/tcp/tcp_topic_management.go | 3 +-
foreign/go/client/tcp/tcp_topic_management_test.go | 133 +++++++++
foreign/go/contracts/client.go | 22 +-
foreign/go/errors/errors_test.go | 90 ++++++
foreign/go/internal/util/leader_aware_test.go | 104 +++++++
foreign/go/internal/vsr/reply.go | 9 +
22 files changed, 1453 insertions(+), 122 deletions(-)
create mode 100644 foreign/go/client/tcp/tcp_consumer_group_management_test.go
create mode 100644 foreign/go/client/tcp/tcp_group_polling_test.go
create mode 100644 foreign/go/client/tcp/tcp_stream_management_test.go
create mode 100644 foreign/go/client/tcp/tcp_topic_cache_test.go
create mode 100644 foreign/go/client/tcp/tcp_topic_management_test.go
