This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch stm-output
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 50b5ff6cb Merge branch 'master' into stm-output
omit 8b96f6203 feat(go): implement Go leader redirection scenario (#2580)
omit a939ab053 Merge branch 'master' into stm-output
omit 1b171164e feat(java): Add test for AsyncIggyTcpClientBuilder (#2726)
omit 223e8ba15 feat(server): cooperative partition reassignment for
consumer groups (#2734)
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/stm-output (1b8dcfd1a)
\
O -- O -- O (50b5ff6cb)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 2 +-
DEPENDENCIES.md | 2 +-
bdd/docker-compose.yml | 7 +-
bdd/go/go.mod | 1 -
bdd/go/go.sum | 6 +-
...{basic_messaging.go => basic_messaging_test.go} | 126 +-
bdd/go/tests/leader_redirection.go | 530 ----
bdd/go/tests/suite_test.go | 47 -
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 +-
.../tests/connectors/postgres/postgres_source.rs | 23 +-
core/integration/tests/data_integrity/mod.rs | 1 -
.../verify_consumer_group_partition_assignment.rs | 3269 --------------------
core/server/Cargo.toml | 2 +-
core/server/config.toml | 7 -
core/server/src/bootstrap.rs | 1 -
core/server/src/configs/defaults.rs | 25 +-
core/server/src/configs/displays.rs | 17 +-
core/server/src/configs/server.rs | 12 -
core/server/src/metadata/absorb.rs | 83 +-
core/server/src/metadata/consumer_group.rs | 262 +-
core/server/src/metadata/consumer_group_member.rs | 19 -
core/server/src/metadata/ops.rs | 16 +-
core/server/src/metadata/partition.rs | 4 -
core/server/src/metadata/reader.rs | 213 +-
core/server/src/metadata/writer.rs | 37 +-
core/server/src/shard/handlers.rs | 26 -
core/server/src/shard/mod.rs | 4 -
core/server/src/shard/system/consumer_groups.rs | 15 +-
core/server/src/shard/system/consumer_offsets.rs | 71 +-
core/server/src/shard/system/messages.rs | 26 +-
core/server/src/shard/system/partitions.rs | 1 -
core/server/src/shard/system/utils.rs | 55 +-
core/server/src/shard/tasks/periodic/mod.rs | 2 -
.../src/shard/tasks/periodic/revocation_timeout.rs | 106 -
core/server/src/shard/transmission/frame.rs | 1 -
core/server/src/shard/transmission/message.rs | 9 -
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 -
.../ConsumerGroupTests.cs | 5 +-
.../go/benchmarks/send_messages_benchmark_test.go | 16 +-
foreign/go/client/tcp/cluster.go | 33 -
foreign/go/client/tcp/tcp_core.go | 376 ---
foreign/go/client/tcp/tcp_session_managament.go | 124 -
foreign/go/contracts/client.go | 260 +-
foreign/go/contracts/client_info.go | 31 -
foreign/go/contracts/cluster.go | 29 -
foreign/go/contracts/cluster_node.go | 161 -
foreign/go/contracts/command.go | 27 -
foreign/go/contracts/command_codes.go | 2 -
foreign/go/contracts/config.go | 7 +-
foreign/go/contracts/connection_info.go | 23 -
foreign/go/contracts/leader_redirection_state.go | 44 -
foreign/go/contracts/meta_data.go | 112 -
foreign/go/contracts/node_status.go | 84 -
foreign/go/contracts/role.go | 67 -
foreign/go/contracts/state.go | 48 -
foreign/go/contracts/transport_endpoints.go | 76 -
foreign/go/go.mod | 7 -
foreign/go/go.sum | 8 -
foreign/go/{contracts => iggycli}/client.go | 162 +-
foreign/go/{client => iggycli}/iggy_client.go | 50 +-
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 +-
.../tcp/tcp_access_token_managament.go | 12 +-
.../go/{client => }/tcp/tcp_clients_managament.go | 8 +-
.../tcp/tcp_consumer_group_managament.go | 24 +-
foreign/go/tcp/tcp_core.go | 192 ++
foreign/go/{client => }/tcp/tcp_messaging.go | 10 +-
.../go/{client => }/tcp/tcp_offset_managament.go | 12 +-
.../{client => }/tcp/tcp_partition_managament.go | 8 +-
.../tcp_session_managament.go} | 35 +-
.../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 +-
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 330 +-
87 files changed, 659 insertions(+), 7198 deletions(-)
rename bdd/go/tests/{basic_messaging.go => basic_messaging_test.go} (70%)
delete mode 100644 bdd/go/tests/leader_redirection.go
delete mode 100644 bdd/go/tests/suite_test.go
delete mode 100644
core/integration/tests/data_integrity/verify_consumer_group_partition_assignment.rs
delete mode 100644 core/server/src/shard/tasks/periodic/revocation_timeout.rs
delete mode 100644 foreign/go/client/tcp/cluster.go
delete mode 100644 foreign/go/client/tcp/tcp_core.go
delete mode 100644 foreign/go/client/tcp/tcp_session_managament.go
delete mode 100644 foreign/go/contracts/client_info.go
delete mode 100644 foreign/go/contracts/cluster.go
delete mode 100644 foreign/go/contracts/cluster_node.go
delete mode 100644 foreign/go/contracts/command.go
delete mode 100644 foreign/go/contracts/connection_info.go
delete mode 100644 foreign/go/contracts/leader_redirection_state.go
delete mode 100644 foreign/go/contracts/meta_data.go
delete mode 100644 foreign/go/contracts/node_status.go
delete mode 100644 foreign/go/contracts/role.go
delete mode 100644 foreign/go/contracts/state.go
delete mode 100644 foreign/go/contracts/transport_endpoints.go
copy foreign/go/{contracts => iggycli}/client.go (72%)
rename foreign/go/{client => iggycli}/iggy_client.go (65%)
delete mode 100644 foreign/go/internal/util/leader_aware.go
delete mode 100644 foreign/go/internal/util/leader_aware_test.go
copy 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/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%)
rename foreign/go/{client/tcp/tcp_access_token_managament.go =>
tcp/tcp_session_managament.go} (54%)
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%)
