This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch global-metadata
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 4aae5dce9 refactor(server): replace slab ECS with ArcSwap-based global
metadata
add bc9ff3e50 add segmented slab
add 3d7f4afaf hierarchical structure
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 141 ++
DEPENDENCIES.md | 14 +
core/integration/tests/streaming/mod.rs | 7 +-
core/server/Cargo.toml | 8 +
core/server/benches/segmented_slab.rs | 195 +++
core/server/src/binary/command.rs | 15 -
.../create_consumer_group_handler.rs | 7 +-
.../delete_consumer_group_handler.rs | 9 +-
.../consumer_groups/get_consumer_group_handler.rs | 7 +-
.../consumer_groups/get_consumer_groups_handler.rs | 29 +-
.../partitions/delete_partitions_handler.rs | 7 +-
.../handlers/streams/create_stream_handler.rs | 1 +
.../binary/handlers/topics/create_topic_handler.rs | 12 +-
.../binary/handlers/topics/update_topic_handler.rs | 11 +-
core/server/src/binary/mapper.rs | 2 +-
core/server/src/bootstrap.rs | 40 +-
core/server/src/http/consumer_groups.rs | 34 +-
core/server/src/http/mapper.rs | 156 +-
core/server/src/http/streams.rs | 10 +-
core/server/src/http/topics.rs | 32 +-
core/server/src/main.rs | 23 +-
core/server/src/metadata/consumer_group.rs | 33 +-
core/server/src/metadata/mod.rs | 1 +
core/server/src/metadata/partition.rs | 4 +-
core/server/src/metadata/segmented_slab.rs | 610 ++++++++
core/server/src/metadata/shared.rs | 1530 +++++++++++---------
core/server/src/metadata/snapshot.rs | 35 +-
core/server/src/metadata/stream.rs | 11 +-
core/server/src/metadata/topic.rs | 10 +-
core/server/src/shard/handlers.rs | 45 +-
core/server/src/shard/mod.rs | 19 +-
core/server/src/shard/system/consumer_groups.rs | 39 +-
core/server/src/shard/system/messages.rs | 12 +-
core/server/src/shard/system/partitions.rs | 134 +-
core/server/src/shard/system/stats.rs | 20 +-
core/server/src/shard/system/streams.rs | 128 +-
core/server/src/shard/system/topics.rs | 120 +-
core/server/src/shard/system/utils.rs | 28 +-
.../src/shard/tasks/periodic/message_cleaner.rs | 6 +-
core/server/src/shard/transmission/message.rs | 1 +
core/server/src/streaming/users/permissioner.rs | 2 +-
41 files changed, 2371 insertions(+), 1177 deletions(-)
create mode 100644 core/server/benches/segmented_slab.rs
create mode 100644 core/server/src/metadata/segmented_slab.rs
