This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch global-metadata-leftright
in repository https://gitbox.apache.org/repos/asf/iggy.git
from c53f2c4f9 refactor(server): WIP, don't merge: replace slab ECS with
LeftRight-based global metadata
add ce8660bc3 revert auth
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 13 +
DEPENDENCIES.md | 1 +
core/server/Cargo.toml | 1 +
core/server/src/binary/command.rs | 403 +++------------------
.../cluster/get_cluster_metadata_handler.rs | 10 +-
.../create_consumer_group_handler.rs | 13 +-
.../delete_consumer_group_handler.rs | 15 +-
.../consumer_groups/get_consumer_group_handler.rs | 9 +-
.../consumer_groups/get_consumer_groups_handler.rs | 9 +-
.../consumer_groups/join_consumer_group_handler.rs | 11 +-
.../leave_consumer_group_handler.rs | 11 +-
.../delete_consumer_offset_handler.rs | 7 +-
.../get_consumer_offset_handler.rs | 7 +-
.../store_consumer_offset_handler.rs | 7 +-
.../messages/flush_unsaved_buffer_handler.rs | 11 +-
.../handlers/messages/poll_messages_handler.rs | 9 +-
.../handlers/messages/send_messages_handler.rs | 11 +-
.../partitions/create_partitions_handler.rs | 15 +-
.../partitions/delete_partitions_handler.rs | 15 +-
.../create_personal_access_token_handler.rs | 13 +-
.../delete_personal_access_token_handler.rs | 13 +-
.../get_personal_access_tokens_handler.rs | 7 +-
.../login_with_personal_access_token_handler.rs | 4 +-
.../handlers/segments/delete_segments_handler.rs | 11 +-
.../handlers/streams/create_stream_handler.rs | 15 +-
.../handlers/streams/delete_stream_handler.rs | 15 +-
.../binary/handlers/streams/get_stream_handler.rs | 11 +-
.../binary/handlers/streams/get_streams_handler.rs | 11 +-
.../handlers/streams/purge_stream_handler.rs | 11 +-
.../handlers/streams/update_stream_handler.rs | 15 +-
.../binary/handlers/system/get_client_handler.rs | 7 +-
.../binary/handlers/system/get_clients_handler.rs | 7 +-
.../src/binary/handlers/system/get_me_handler.rs | 7 +-
.../src/binary/handlers/system/get_snapshot.rs | 7 +-
.../binary/handlers/system/get_stats_handler.rs | 9 +-
.../src/binary/handlers/system/ping_handler.rs | 4 +-
.../binary/handlers/topics/create_topic_handler.rs | 15 +-
.../binary/handlers/topics/delete_topic_handler.rs | 15 +-
.../binary/handlers/topics/get_topic_handler.rs | 9 +-
.../binary/handlers/topics/get_topics_handler.rs | 9 +-
.../binary/handlers/topics/purge_topic_handler.rs | 11 +-
.../binary/handlers/topics/update_topic_handler.rs | 15 +-
.../handlers/users/change_password_handler.rs | 15 +-
.../binary/handlers/users/create_user_handler.rs | 15 +-
.../binary/handlers/users/delete_user_handler.rs | 11 +-
.../src/binary/handlers/users/get_user_handler.rs | 7 +-
.../src/binary/handlers/users/get_users_handler.rs | 7 +-
.../binary/handlers/users/login_user_handler.rs | 4 +-
.../binary/handlers/users/logout_user_handler.rs | 13 +-
.../handlers/users/update_permissions_handler.rs | 15 +-
.../binary/handlers/users/update_user_handler.rs | 15 +-
core/server/src/binary/macros.rs | 141 ++-----
core/server/src/quic/listener.rs | 4 +-
core/server/src/shard/mod.rs | 23 --
core/server/src/streaming/auth.rs | 105 ------
core/server/src/streaming/mod.rs | 1 -
core/server/src/tcp/connection_handler.rs | 3 +-
core/server/src/websocket/connection_handler.rs | 3 +-
58 files changed, 327 insertions(+), 874 deletions(-)
delete mode 100644 core/server/src/streaming/auth.rs
