This is an automated email from the ASF dual-hosted git repository.
mmodzelewski pushed a change to branch gradle-update
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 75b337893 update deprecated delegate usage
add 1932014c7 feat(server-ng): port consumer group (#3527)
add 9091d8bb3 Merge branch 'master' into gradle-update
No new revisions were added by this update.
Summary of changes:
core/binary_protocol/src/codes.rs | 2 +
core/binary_protocol/src/consensus/header.rs | 4 +
core/binary_protocol/src/consensus/operation.rs | 21 +-
core/binary_protocol/src/dispatch.rs | 22 +-
core/binary_protocol/src/lib.rs | 2 +-
core/binary_protocol/src/primitives/consumer.rs | 4 +-
.../src/requests/consumer_groups/mod.rs | 2 +
...in_consumer_group.rs => sync_consumer_group.rs} | 32 +-
.../src/responses/consumer_groups/mod.rs | 2 +
.../consumer_groups/sync_consumer_group.rs | 114 +++
core/common/src/consumer_group_client_state.rs | 219 +++++
core/common/src/error/iggy_error.rs | 4 +
core/common/src/lib.rs | 13 +
.../src/traits/binary_impls/consumer_groups.rs | 13 +
core/common/src/traits/binary_impls/messages.rs | 237 +++++
core/common/src/traits/binary_impls/system.rs | 5 +
core/common/src/traits/binary_transport.rs | 8 +
core/common/src/traits/system_client.rs | 7 +
core/consensus/src/observability.rs | 4 +
core/integration/src/harness/port_reserver.rs | 180 ++--
core/integration/tests/data_integrity/mod.rs | 13 +-
core/integration/tests/mod.rs | 28 +-
core/integration/tests/server/{cg.rs => cg_vsr.rs} | 39 +-
core/integration/tests/server/mod.rs | 5 +-
.../server/scenarios/authentication_scenario.rs | 12 +-
...onsumer_group_duplicate_name_create_scenario.rs | 118 +++
core/integration/tests/server/scenarios/mod.rs | 13 +-
core/metadata/src/impls/metadata.rs | 153 +++-
core/metadata/src/stm/consumer_group.rs | 971 +++++++++++++++------
core/metadata/src/stm/mux.rs | 23 +-
core/metadata/src/stm/snapshot.rs | 12 +-
core/metadata/src/stm/stream.rs | 536 +++++++++++-
core/partitions/src/iggy_partition.rs | 57 ++
.../src/client_wrappers/binary_system_client.rs | 12 +
core/sdk/src/clients/client.rs | 7 +
core/sdk/src/quic/quic_client.rs | 9 +
core/sdk/src/tcp/tcp_client.rs | 9 +
core/sdk/src/vsr.rs | 1 +
core/sdk/src/websocket/websocket_client.rs | 9 +
core/server-ng/src/bootstrap.rs | 41 +-
core/server-ng/src/consumer_group.rs | 257 ++++++
core/server-ng/src/dispatch.rs | 356 +++++++-
core/server-ng/src/lib.rs | 1 +
core/server-ng/src/partition_reconciler.rs | 386 +++++++-
core/server-ng/src/responses.rs | 221 ++++-
core/server-ng/src/session_manager.rs | 55 +-
core/shard/src/lib.rs | 41 +
core/simulator/src/deps.rs | 3 +-
core/simulator/src/replica.rs | 4 +-
49 files changed, 3780 insertions(+), 507 deletions(-)
copy core/binary_protocol/src/requests/consumer_groups/{join_consumer_group.rs
=> sync_consumer_group.rs} (76%)
create mode 100644
core/binary_protocol/src/responses/consumer_groups/sync_consumer_group.rs
create mode 100644 core/common/src/consumer_group_client_state.rs
copy core/integration/tests/server/{cg.rs => cg_vsr.rs} (73%)
create mode 100644
core/integration/tests/server/scenarios/consumer_group_duplicate_name_create_scenario.rs
create mode 100644 core/server-ng/src/consumer_group.rs
