This is an automated email from the ASF dual-hosted git repository.
piotr pushed a change to branch postres_connector
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 2a18d33be Fix tests and postgres logic, add verbose flag
add 5b864bedc refactor(server): consolidate permissions into metadata
crate and fix inheritance bugs (#2564)
add 1f0017516 Merge branch 'master' into postres_connector
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1 +
Cargo.toml | 1 +
core/integration/tests/server/general.rs | 3 +-
core/integration/tests/server/mod.rs | 6 +-
core/integration/tests/server/scenarios/mod.rs | 1 +
.../tests/server/scenarios/permissions_scenario.rs | 2511 ++++++++++++++++++++
core/metadata/src/lib.rs | 2 +-
core/metadata/src/permissioner/mod.rs | 8 +-
.../permissioner_rules/consumer_groups.rs | 4 -
.../permissioner_rules/consumer_offsets.rs | 4 -
.../permissioner/permissioner_rules/messages.rs | 84 +-
.../permissioner/permissioner_rules/partitions.rs | 4 -
.../permissioner/permissioner_rules/segments.rs | 4 -
.../src/permissioner/permissioner_rules/streams.rs | 4 -
.../src/permissioner/permissioner_rules/system.rs | 4 -
.../src/permissioner/permissioner_rules/topics.rs | 72 +-
.../src/permissioner/permissioner_rules/users.rs | 4 -
core/metadata/src/stm/user.rs | 6 +-
core/server/Cargo.toml | 1 +
.../cluster/get_cluster_metadata_handler.rs | 6 +-
.../create_consumer_group_handler.rs | 11 +-
.../delete_consumer_group_handler.rs | 26 +-
.../consumer_groups/get_consumer_group_handler.rs | 29 +-
.../consumer_groups/get_consumer_groups_handler.rs | 15 +-
.../consumer_groups/join_consumer_group_handler.rs | 10 +-
.../leave_consumer_group_handler.rs | 13 +-
.../delete_consumer_offset_handler.rs | 8 +-
.../get_consumer_offset_handler.rs | 16 +-
.../store_consumer_offset_handler.rs | 8 +-
.../handlers/messages/send_messages_handler.rs | 20 +-
.../partitions/create_partitions_handler.rs | 14 +-
.../partitions/delete_partitions_handler.rs | 14 +-
.../create_personal_access_token_handler.rs | 5 +-
.../delete_personal_access_token_handler.rs | 5 +-
.../get_personal_access_tokens_handler.rs | 7 +-
.../handlers/segments/delete_segments_handler.rs | 22 +-
.../handlers/streams/create_stream_handler.rs | 6 +-
.../handlers/streams/delete_stream_handler.rs | 15 +-
.../binary/handlers/streams/get_stream_handler.rs | 23 +-
.../handlers/streams/purge_stream_handler.rs | 8 +-
.../handlers/streams/update_stream_handler.rs | 13 +-
.../binary/handlers/system/get_client_handler.rs | 11 +-
.../binary/handlers/system/get_clients_handler.rs | 10 +-
.../src/binary/handlers/system/get_me_handler.rs | 11 +-
.../binary/handlers/system/get_snapshot_handler.rs | 2 +-
.../binary/handlers/system/get_stats_handler.rs | 4 +
.../binary/handlers/topics/create_topic_handler.rs | 7 +-
.../binary/handlers/topics/delete_topic_handler.rs | 7 +-
.../binary/handlers/topics/get_topic_handler.rs | 30 +-
.../binary/handlers/topics/get_topics_handler.rs | 9 +-
.../binary/handlers/topics/purge_topic_handler.rs | 7 +-
.../binary/handlers/topics/update_topic_handler.rs | 6 +-
.../handlers/users/change_password_handler.rs | 26 +-
.../binary/handlers/users/create_user_handler.rs | 6 +-
.../binary/handlers/users/delete_user_handler.rs | 6 +-
.../src/binary/handlers/users/get_user_handler.rs | 10 +-
.../src/binary/handlers/users/get_users_handler.rs | 10 +-
.../handlers/users/update_permissions_handler.rs | 19 +-
.../binary/handlers/users/update_user_handler.rs | 23 +-
core/server/src/http/consumer_groups.rs | 96 +-
core/server/src/http/consumer_offsets.rs | 46 +-
core/server/src/http/http_shard_wrapper.rs | 79 +-
core/server/src/http/messages.rs | 6 +-
core/server/src/http/partitions.rs | 27 +-
core/server/src/http/personal_access_tokens.rs | 14 +-
core/server/src/http/streams.rs | 78 +-
core/server/src/http/system.rs | 67 +-
core/server/src/http/topics.rs | 94 +-
core/server/src/http/users.rs | 98 +-
core/server/src/shard/handlers.rs | 71 +-
core/server/src/shard/mod.rs | 10 +-
core/server/src/shard/system/clients.rs | 35 +-
core/server/src/shard/system/cluster.rs | 11 +-
core/server/src/shard/system/consumer_groups.rs | 114 +-
core/server/src/shard/system/consumer_offsets.rs | 67 +-
core/server/src/shard/system/partitions.rs | 43 -
.../src/shard/system/personal_access_tokens.rs | 13 +-
core/server/src/shard/system/snapshot/mod.rs | 2 -
core/server/src/shard/system/streams.rs | 79 +-
core/server/src/shard/system/topics.rs | 68 -
core/server/src/shard/system/users.rs | 100 +-
core/server/src/shard/system/utils.rs | 116 +-
core/server/src/streaming/users/mod.rs | 2 -
core/server/src/streaming/users/permissioner.rs | 101 -
.../users/permissioner_rules/consumer_groups.rs | 76 -
.../users/permissioner_rules/consumer_offsets.rs | 49 -
.../streaming/users/permissioner_rules/messages.rs | 135 --
.../src/streaming/users/permissioner_rules/mod.rs | 27 -
.../users/permissioner_rules/partitions.rs | 40 -
.../streaming/users/permissioner_rules/segments.rs | 30 -
.../streaming/users/permissioner_rules/streams.rs | 86 -
.../streaming/users/permissioner_rules/system.rs | 44 -
.../streaming/users/permissioner_rules/topics.rs | 153 --
.../streaming/users/permissioner_rules/users.rs | 70 -
examples/rust/src/multi-tenant/consumer/main.rs | 18 +-
examples/rust/src/multi-tenant/producer/main.rs | 19 +-
96 files changed, 3375 insertions(+), 2031 deletions(-)
create mode 100644
core/integration/tests/server/scenarios/permissions_scenario.rs
delete mode 100644 core/server/src/streaming/users/permissioner.rs
delete mode 100644
core/server/src/streaming/users/permissioner_rules/consumer_groups.rs
delete mode 100644
core/server/src/streaming/users/permissioner_rules/consumer_offsets.rs
delete mode 100644
core/server/src/streaming/users/permissioner_rules/messages.rs
delete mode 100644 core/server/src/streaming/users/permissioner_rules/mod.rs
delete mode 100644
core/server/src/streaming/users/permissioner_rules/partitions.rs
delete mode 100644
core/server/src/streaming/users/permissioner_rules/segments.rs
delete mode 100644
core/server/src/streaming/users/permissioner_rules/streams.rs
delete mode 100644 core/server/src/streaming/users/permissioner_rules/system.rs
delete mode 100644 core/server/src/streaming/users/permissioner_rules/topics.rs
delete mode 100644 core/server/src/streaming/users/permissioner_rules/users.rs
