This is an automated email from the ASF dual-hosted git repository.
piotr pushed a change to branch named-edge-dockerhub
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 8c293cf9f feat(ci): add versioned edge Docker tags in post-merge
workflow
add d6e3c9584 fix(helm): fix volume mount path and add io_uring
requirements (#2526)
add 75e82c69f chore(repo): update `err-trail` to 0.11.0 (#2525)
add 9b53c4846 chore(connectors): Update sqlx version to address security
advisory (#2530)
add afed3e662 Merge branch 'master' into named-edge-dockerhub
No new revisions were added by this update.
Summary of changes:
.pre-commit-config.yaml | 1 +
Cargo.lock | 4 +-
Cargo.toml | 2 +-
DEPENDENCIES.md | 2 +-
core/common/src/sender/mod.rs | 4 +-
core/common/src/sender/quic_sender.rs | 22 +-
core/common/src/sender/tcp_sender.rs | 4 +-
core/common/src/sender/tcp_tls_sender.rs | 20 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
.../create_consumer_group_handler.rs | 4 +-
.../delete_consumer_group_handler.rs | 12 +-
.../consumer_groups/join_consumer_group_handler.rs | 4 +-
.../leave_consumer_group_handler.rs | 4 +-
.../delete_consumer_offset_handler.rs | 2 +-
.../store_consumer_offset_handler.rs | 2 +-
.../messages/flush_unsaved_buffer_handler.rs | 4 +-
.../partitions/create_partitions_handler.rs | 4 +-
.../partitions/delete_partitions_handler.rs | 4 +-
.../create_personal_access_token_handler.rs | 8 +-
.../delete_personal_access_token_handler.rs | 8 +-
.../get_personal_access_tokens_handler.rs | 4 +-
.../login_with_personal_access_token_handler.rs | 4 +-
.../handlers/segments/delete_segments_handler.rs | 8 +-
.../handlers/streams/create_stream_handler.rs | 8 +-
.../handlers/streams/delete_stream_handler.rs | 12 +-
.../binary/handlers/streams/get_stream_handler.rs | 2 +-
.../binary/handlers/streams/get_streams_handler.rs | 4 +-
.../handlers/streams/purge_stream_handler.rs | 8 +-
.../handlers/streams/update_stream_handler.rs | 8 +-
.../binary/handlers/system/get_clients_handler.rs | 4 +-
.../src/binary/handlers/system/get_me_handler.rs | 12 +-
.../binary/handlers/system/get_stats_handler.rs | 6 +-
.../binary/handlers/topics/create_topic_handler.rs | 8 +-
.../binary/handlers/topics/delete_topic_handler.rs | 8 +-
.../binary/handlers/topics/purge_topic_handler.rs | 8 +-
.../binary/handlers/topics/update_topic_handler.rs | 8 +-
.../handlers/users/change_password_handler.rs | 8 +-
.../binary/handlers/users/create_user_handler.rs | 12 +-
.../binary/handlers/users/delete_user_handler.rs | 12 +-
.../src/binary/handlers/users/get_users_handler.rs | 4 +-
.../binary/handlers/users/login_user_handler.rs | 4 +-
.../binary/handlers/users/logout_user_handler.rs | 4 +-
.../handlers/users/update_permissions_handler.rs | 2 +-
.../binary/handlers/users/update_user_handler.rs | 8 +-
core/server/src/bootstrap.rs | 6 +-
core/server/src/configs/server.rs | 15 +-
core/server/src/configs/validators.rs | 80 +++---
core/server/src/http/consumer_groups.rs | 10 +-
core/server/src/http/consumer_offsets.rs | 5 +-
core/server/src/http/http_server.rs | 18 +-
core/server/src/http/jwt/jwt_manager.rs | 24 +-
core/server/src/http/jwt/middleware.rs | 17 +-
core/server/src/http/jwt/storage.rs | 20 +-
core/server/src/http/messages.rs | 10 +-
core/server/src/http/partitions.rs | 17 +-
core/server/src/http/personal_access_tokens.rs | 57 ++---
core/server/src/http/streams.rs | 117 +++++----
core/server/src/http/system.rs | 28 ++-
core/server/src/http/topics.rs | 55 ++---
core/server/src/http/users.rs | 62 +++--
core/server/src/main.rs | 4 +-
core/server/src/quic/quic_server.rs | 43 ++--
core/server/src/shard/system/clients.rs | 8 +-
core/server/src/shard/system/consumer_groups.rs | 14 +-
core/server/src/shard/system/consumer_offsets.rs | 28 +--
core/server/src/shard/system/messages.rs | 12 +-
core/server/src/shard/system/partitions.rs | 4 +-
.../src/shard/system/personal_access_tokens.rs | 102 ++++----
core/server/src/shard/system/storage.rs | 12 +-
core/server/src/shard/system/streams.rs | 12 +-
core/server/src/shard/system/topics.rs | 16 +-
core/server/src/shard/system/users.rs | 68 +++---
.../src/shard/tasks/oneshot/config_writer.rs | 14 +-
core/server/src/slab/streams.rs | 22 +-
core/server/src/state/file.rs | 50 ++--
core/server/src/state/models.rs | 65 ++---
core/server/src/state/system.rs | 28 +--
core/server/src/streaming/partitions/helpers.rs | 10 +-
core/server/src/streaming/partitions/segments.rs | 8 +-
core/server/src/streaming/partitions/storage.rs | 16 +-
core/server/src/streaming/persistence/persister.rs | 52 ++--
.../src/streaming/segments/indexes/index_reader.rs | 26 +-
.../src/streaming/segments/indexes/index_writer.rs | 18 +-
.../streaming/segments/messages/messages_reader.rs | 18 +-
.../streaming/segments/messages/messages_writer.rs | 20 +-
core/server/src/tcp/connection_handler.rs | 4 +-
core/server/src/tcp/tcp_listener.rs | 2 +-
core/server/src/tcp/tcp_tls_listener.rs | 2 +-
core/server/src/websocket/connection_handler.rs | 4 +-
core/server/src/websocket/websocket_listener.rs | 8 +-
.../server/src/websocket/websocket_tls_listener.rs | 8 +-
helm/charts/iggy/README.md | 272 ++++++++++++++-------
helm/charts/iggy/templates/deployment.yaml | 2 +-
helm/charts/iggy/values.yaml | 69 +++---
94 files changed, 1017 insertions(+), 848 deletions(-)