This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch partition_remaster
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 9cb4d86ed address review
add f8be02437 refactor(server): replace ServerCommand enum and binary
mapper with wire types (#3027)
add b55d065d8 feat(metadata): Persistent WAL journal with recovery and
compaction (#2916)
add 9ee1f6dfa feat(java): Support connection timeout (#3026)
add 411a697eb ci: add Helm chart validation (#3019)
add f25ed8961 merge master
No new revisions were added by this update.
Summary of changes:
.github/actions/utils/setup-helm-tools/action.yml | 67 ++
.github/config/components.yml | 5 +
.github/workflows/_test.yml | 23 +
Cargo.lock | 28 +-
Cargo.toml | 1 -
DEPENDENCIES.md | 1 -
core/binary_protocol/src/framing.rs | 52 +-
.../src/requests/system/get_snapshot.rs | 98 ++-
.../src/requests/users/create_user.rs | 18 +-
.../src/requests/users/update_permissions.rs | 14 +-
core/integration/Cargo.toml | 2 +-
.../server/scenarios/authentication_scenario.rs | 349 ++++------
core/journal/Cargo.toml | 8 +
core/journal/src/file_storage.rs | 149 +++++
core/journal/src/lib.rs | 43 +-
core/journal/src/metadata_journal.rs | 724 +++++++++++++++++++++
core/metadata/Cargo.toml | 7 +
core/metadata/src/impls/metadata.rs | 211 +++++-
core/metadata/src/impls/mod.rs | 4 +
core/metadata/src/impls/recovery.rs | 271 ++++++++
core/metadata/src/stm/snapshot.rs | 54 ++
core/partitions/src/iggy_partition.rs | 6 +-
core/partitions/src/journal.rs | 54 +-
core/partitions/src/log.rs | 2 +-
core/server/Cargo.toml | 2 +-
core/server/src/binary/command.rs | 432 ------------
core/server/src/binary/dispatch.rs | 581 +++++++++++++++++
.../cluster/get_cluster_metadata_handler.rs | 72 +-
.../create_consumer_group_handler.rs | 88 ++-
.../delete_consumer_group_handler.rs | 73 +--
.../consumer_groups/get_consumer_group_handler.rs | 97 +--
.../consumer_groups/get_consumer_groups_handler.rs | 86 ++-
.../consumer_groups/join_consumer_group_handler.rs | 74 +--
.../leave_consumer_group_handler.rs | 74 +--
.../delete_consumer_offset_handler.rs | 76 +--
.../get_consumer_offset_handler.rs | 108 ++-
.../store_consumer_offset_handler.rs | 86 +--
.../messages/flush_unsaved_buffer_handler.rs | 93 +--
.../handlers/messages/poll_messages_handler.rs | 128 ++--
.../handlers/messages/send_messages_handler.rs | 343 +++++-----
core/server/src/binary/handlers/mod.rs | 1 -
.../partitions/create_partitions_handler.rs | 74 +--
.../partitions/delete_partitions_handler.rs | 74 +--
.../create_personal_access_token_handler.rs | 85 ++-
.../delete_personal_access_token_handler.rs | 75 +--
.../get_personal_access_tokens_handler.rs | 79 +--
.../login_with_personal_access_token_handler.rs | 78 +--
.../handlers/segments/delete_segments_handler.rs | 101 ++-
core/server/src/binary/handlers/segments/mod.rs | 2 +-
.../handlers/streams/create_stream_handler.rs | 86 ++-
.../handlers/streams/delete_stream_handler.rs | 68 +-
.../binary/handlers/streams/get_stream_handler.rs | 126 ++--
.../binary/handlers/streams/get_streams_handler.rs | 68 +-
.../handlers/streams/purge_stream_handler.rs | 68 +-
.../handlers/streams/update_stream_handler.rs | 74 +--
.../binary/handlers/system/get_client_handler.rs | 67 +-
.../binary/handlers/system/get_clients_handler.rs | 57 +-
.../src/binary/handlers/system/get_me_handler.rs | 79 ++-
.../binary/handlers/system/get_snapshot_handler.rs | 60 +-
.../binary/handlers/system/get_stats_handler.rs | 105 +--
.../src/binary/handlers/system/ping_handler.rs | 48 +-
.../binary/handlers/topics/create_topic_handler.rs | 126 ++--
.../binary/handlers/topics/delete_topic_handler.rs | 70 +-
.../binary/handlers/topics/get_topic_handler.rs | 92 +--
.../binary/handlers/topics/get_topics_handler.rs | 74 +--
.../binary/handlers/topics/purge_topic_handler.rs | 70 +-
.../binary/handlers/topics/update_topic_handler.rs | 84 +--
.../handlers/users/change_password_handler.rs | 84 ++-
.../binary/handlers/users/create_user_handler.rs | 97 +--
.../binary/handlers/users/delete_user_handler.rs | 70 +-
.../src/binary/handlers/users/get_user_handler.rs | 78 +--
.../src/binary/handlers/users/get_users_handler.rs | 67 +-
.../binary/handlers/users/login_user_handler.rs | 88 ++-
.../binary/handlers/users/logout_user_handler.rs | 65 +-
.../handlers/users/update_permissions_handler.rs | 88 ++-
.../binary/handlers/users/update_user_handler.rs | 78 +--
core/server/src/binary/handlers/utils.rs | 43 --
core/server/src/binary/macros.rs | 114 ----
core/server/src/binary/mapper.rs | 431 ------------
core/server/src/binary/mod.rs | 6 +-
core/server/src/http/partitions.rs | 4 +-
core/server/src/http/streams.rs | 2 +-
core/server/src/http/topics.rs | 2 +-
core/server/src/quic/listener.rs | 52 +-
core/server/src/shard/execution.rs | 43 +-
core/server/src/shard/handlers.rs | 20 +-
core/server/src/shard/transmission/frame.rs | 8 +-
core/server/src/tcp/connection_handler.rs | 82 ++-
core/server/src/websocket/connection_handler.rs | 136 ++--
core/simulator/src/deps.rs | 39 +-
core/simulator/src/replica.rs | 13 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 7 +-
.../async/tcp/AsyncIggyTcpClientBuilder.java | 54 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 17 +-
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 74 +++
helm/charts/iggy/README.md | 79 ++-
helm/charts/iggy/templates/hpa.yaml | 13 +-
helm/charts/iggy/templates/ingress.yaml | 12 +-
scripts/ci/setup-helm-smoke-cluster.sh | 235 +++++++
scripts/ci/setup-helm-tools.sh | 111 ++++
scripts/ci/test-helm.sh | 452 +++++++++++++
101 files changed, 5575 insertions(+), 3784 deletions(-)
create mode 100644 .github/actions/utils/setup-helm-tools/action.yml
create mode 100644 core/journal/src/file_storage.rs
create mode 100644 core/journal/src/metadata_journal.rs
create mode 100644 core/metadata/src/impls/recovery.rs
delete mode 100644 core/server/src/binary/command.rs
create mode 100644 core/server/src/binary/dispatch.rs
delete mode 100644 core/server/src/binary/handlers/utils.rs
delete mode 100644 core/server/src/binary/macros.rs
delete mode 100644 core/server/src/binary/mapper.rs
create mode 100755 scripts/ci/setup-helm-smoke-cluster.sh
create mode 100755 scripts/ci/setup-helm-tools.sh
create mode 100755 scripts/ci/test-helm.sh
