This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch stm-output
in repository https://gitbox.apache.org/repos/asf/iggy.git
from a939ab053 Merge branch 'master' into stm-output
add 8b96f6203 feat(go): implement Go leader redirection scenario (#2580)
add 50b5ff6cb Merge branch 'master' into stm-output
No new revisions were added by this update.
Summary of changes:
bdd/docker-compose.yml | 7 +-
bdd/go/go.mod | 1 +
bdd/go/go.sum | 6 +-
...{basic_messaging_test.go => basic_messaging.go} | 126 +++--
bdd/go/tests/leader_redirection.go | 530 +++++++++++++++++++++
.../{tcp_test/tcp_suite_test.go => suite_test.go} | 31 +-
bdd/go/tests/tcp_test/consumers_steps.go | 13 +-
bdd/go/tests/tcp_test/messages_steps.go | 3 +-
bdd/go/tests/tcp_test/partitions_steps.go | 3 +-
bdd/go/tests/tcp_test/pat_steps.go | 7 +-
bdd/go/tests/tcp_test/stream_steps.go | 12 +-
bdd/go/tests/tcp_test/test_helpers.go | 15 +-
bdd/go/tests/tcp_test/topic_steps.go | 9 +-
bdd/go/tests/tcp_test/users_steps.go | 15 +-
examples/go/getting-started/consumer/main.go | 24 +-
examples/go/getting-started/producer/main.go | 28 +-
examples/go/go.mod | 1 +
examples/go/go.sum | 10 +
.../go/benchmarks/send_messages_benchmark_test.go | 16 +-
foreign/go/{iggycli => client}/iggy_client.go | 50 +-
.../tcp/cluster.go} | 19 +-
.../tcp/tcp_access_token_managament.go | 12 +-
.../go/{ => client}/tcp/tcp_clients_managament.go | 8 +-
.../tcp/tcp_consumer_group_managament.go | 24 +-
foreign/go/client/tcp/tcp_core.go | 376 +++++++++++++++
foreign/go/{ => client}/tcp/tcp_messaging.go | 10 +-
.../go/{ => client}/tcp/tcp_offset_managament.go | 12 +-
.../{ => client}/tcp/tcp_partition_managament.go | 8 +-
foreign/go/client/tcp/tcp_session_managament.go | 124 +++++
.../go/{ => client}/tcp/tcp_stream_managament.go | 20 +-
.../go/{ => client}/tcp/tcp_topic_managament.go | 20 +-
foreign/go/{ => client}/tcp/tcp_user_managament.go | 28 +-
foreign/go/{ => client}/tcp/tcp_utilities.go | 8 +-
foreign/go/contracts/client.go | 260 +++++++++-
foreign/go/contracts/{client.go => client_info.go} | 0
.../{compression_algorithm.go => cluster.go} | 14 +-
foreign/go/contracts/cluster_node.go | 161 +++++++
.../{compression_algorithm.go => command.go} | 12 +-
foreign/go/contracts/command_codes.go | 2 +
foreign/go/contracts/config.go | 7 +-
.../go/contracts/connection_info.go | 8 +-
...ccess_tokens.go => leader_redirection_state.go} | 28 +-
foreign/go/contracts/meta_data.go | 112 +++++
foreign/go/contracts/node_status.go | 84 ++++
foreign/go/contracts/role.go | 67 +++
foreign/go/contracts/{config.go => state.go} | 38 +-
foreign/go/contracts/transport_endpoints.go | 76 +++
foreign/go/go.mod | 7 +
foreign/go/go.sum | 8 +
foreign/go/iggycli/client.go | 265 -----------
foreign/go/internal/util/leader_aware.go | 123 +++++
foreign/go/internal/util/leader_aware_test.go | 83 ++++
foreign/go/samples/consumer/consumer.go | 12 +-
foreign/go/samples/producer/producer.go | 12 +-
foreign/go/tcp/tcp_core.go | 192 --------
foreign/go/tcp/tcp_session_managament.go | 54 ---
56 files changed, 2392 insertions(+), 809 deletions(-)
rename bdd/go/tests/{basic_messaging_test.go => basic_messaging.go} (70%)
create mode 100644 bdd/go/tests/leader_redirection.go
copy bdd/go/tests/{tcp_test/tcp_suite_test.go => suite_test.go} (58%)
rename foreign/go/{iggycli => client}/iggy_client.go (65%)
copy foreign/go/{binary_serialization/consumer_serializer.go =>
client/tcp/cluster.go} (72%)
rename foreign/go/{ => client}/tcp/tcp_access_token_managament.go (73%)
rename foreign/go/{ => client}/tcp/tcp_clients_managament.go (79%)
rename foreign/go/{ => client}/tcp/tcp_consumer_group_managament.go (66%)
create mode 100644 foreign/go/client/tcp/tcp_core.go
rename foreign/go/{ => client}/tcp/tcp_messaging.go (86%)
rename foreign/go/{ => client}/tcp/tcp_offset_managament.go (69%)
rename foreign/go/{ => client}/tcp/tcp_partition_managament.go (76%)
create mode 100644 foreign/go/client/tcp/tcp_session_managament.go
rename foreign/go/{ => client}/tcp/tcp_stream_managament.go (71%)
rename foreign/go/{ => client}/tcp/tcp_topic_managament.go (81%)
rename foreign/go/{ => client}/tcp/tcp_user_managament.go (66%)
rename foreign/go/{ => client}/tcp/tcp_utilities.go (82%)
copy foreign/go/contracts/{client.go => client_info.go} (100%)
copy foreign/go/contracts/{compression_algorithm.go => cluster.go} (79%)
create mode 100644 foreign/go/contracts/cluster_node.go
copy foreign/go/contracts/{compression_algorithm.go => command.go} (84%)
copy core/bench/dashboard/server/src/github/mod.rs =>
foreign/go/contracts/connection_info.go (89%)
copy foreign/go/contracts/{access_tokens.go => leader_redirection_state.go}
(57%)
create mode 100644 foreign/go/contracts/meta_data.go
create mode 100644 foreign/go/contracts/node_status.go
create mode 100644 foreign/go/contracts/role.go
copy foreign/go/contracts/{config.go => state.go} (62%)
create mode 100644 foreign/go/contracts/transport_endpoints.go
delete mode 100644 foreign/go/iggycli/client.go
create mode 100644 foreign/go/internal/util/leader_aware.go
create mode 100644 foreign/go/internal/util/leader_aware_test.go
delete mode 100644 foreign/go/tcp/tcp_core.go
delete mode 100644 foreign/go/tcp/tcp_session_managament.go
