This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch segmented-slab
in repository https://gitbox.apache.org/repos/asf/iggy.git
from d53ddfd80 feat(server): add SegmentedSlab collection
add 8a0df74cb feat(metadata): introduce `mux_state_machine` with state
impls (#2544)
add 4a44ffd8f Merge branch 'master' into segmented-slab
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 8 +-
core/common/Cargo.toml | 2 +
core/common/src/lib.rs | 2 +
core/common/src/types/consensus/message.rs | 19 +-
core/common/src/types/mod.rs | 1 +
.../src/types/personal_access_tokens/mod.rs} | 14 +-
.../src/streaming => common/src}/utils/hash.rs | 0
core/common/src/utils/mod.rs | 1 +
core/consensus/src/impls.rs | 33 +-
core/metadata/Cargo.toml | 3 +
core/metadata/src/impls/metadata.rs | 2 +-
core/metadata/src/lib.rs | 3 +
.../src/permissioner/mod.rs} | 67 ++-
.../permissioner_rules/consumer_groups.rs | 6 +-
.../permissioner_rules/consumer_offsets.rs | 6 +-
.../permissioner}/permissioner_rules/messages.rs | 6 +-
.../src/permissioner}/permissioner_rules/mod.rs | 0
.../permissioner}/permissioner_rules/partitions.rs | 6 +-
.../permissioner}/permissioner_rules/segments.rs | 7 +-
.../permissioner}/permissioner_rules/streams.rs | 6 +-
.../src/permissioner}/permissioner_rules/system.rs | 6 +-
.../src/permissioner}/permissioner_rules/topics.rs | 20 +-
.../src/permissioner}/permissioner_rules/users.rs | 6 +-
.../src/streaming => metadata/src}/stats/mod.rs | 4 +
core/metadata/src/stm/consumer_group.rs | 212 ++++++++-
core/metadata/src/stm/mod.rs | 99 ++++-
core/metadata/src/stm/mux.rs | 26 +-
core/metadata/src/stm/stream.rs | 483 ++++++++++++++++++++-
core/metadata/src/stm/user.rs | 290 ++++++++++++-
core/server/Cargo.toml | 3 -
core/server/src/binary/mapper.rs | 5 +-
core/server/src/bootstrap.rs | 3 +-
core/server/src/http/http_shard_wrapper.rs | 2 +-
core/server/src/http/mapper.rs | 2 +-
core/server/src/http/personal_access_tokens.rs | 2 +-
.../src/shard/system/personal_access_tokens.rs | 2 +-
core/server/src/shard/transmission/event.rs | 5 +-
core/server/src/state/system.rs | 2 +-
.../server/src/streaming/clients/client_manager.rs | 6 +-
core/server/src/streaming/mod.rs | 1 -
.../src/streaming/personal_access_tokens/mod.rs | 19 -
core/server/src/streaming/polling_consumer.rs | 5 +-
core/server/src/streaming/topics/helpers.rs | 5 +-
core/server/src/streaming/users/user.rs | 2 +-
core/server/src/streaming/utils/mod.rs | 1 -
45 files changed, 1243 insertions(+), 160 deletions(-)
rename
core/{server/src/streaming/personal_access_tokens/personal_access_token.rs =>
common/src/types/personal_access_tokens/mod.rs} (94%)
rename core/{server/src/streaming => common/src}/utils/hash.rs (100%)
copy core/{server/src/streaming/users/permissioner.rs =>
metadata/src/permissioner/mod.rs} (51%)
copy core/{server/src/streaming/users =>
metadata/src/permissioner}/permissioner_rules/consumer_groups.rs (92%)
copy core/{server/src/streaming/users =>
metadata/src/permissioner}/permissioner_rules/consumer_offsets.rs (90%)
copy core/{server/src/streaming/users =>
metadata/src/permissioner}/permissioner_rules/messages.rs (95%)
copy core/{server/src/streaming/users =>
metadata/src/permissioner}/permissioner_rules/mod.rs (100%)
copy core/{server/src/streaming/users =>
metadata/src/permissioner}/permissioner_rules/partitions.rs (88%)
copy core/{server/src/streaming/users =>
metadata/src/permissioner}/permissioner_rules/segments.rs (86%)
copy core/{server/src/streaming/users =>
metadata/src/permissioner}/permissioner_rules/streams.rs (94%)
copy core/{server/src/streaming/users =>
metadata/src/permissioner}/permissioner_rules/system.rs (90%)
copy core/{server/src/streaming/users =>
metadata/src/permissioner}/permissioner_rules/topics.rs (89%)
copy core/{server/src/streaming/users =>
metadata/src/permissioner}/permissioner_rules/users.rs (93%)
copy core/{server/src/streaming => metadata/src}/stats/mod.rs (98%)
delete mode 100644 core/server/src/streaming/personal_access_tokens/mod.rs
