This is an automated email from the ASF dual-hosted git repository.
piotr pushed a change to branch fix-e2e-latency-calc
in repository https://gitbox.apache.org/repos/asf/iggy.git
from a2b1699d5 Merge branch 'master' into fix-e2e-latency-calc
add a7e36ca10 feat(connectors): add --version flag support to connector
runtime (#2502)
add f7ade4b60 fix(server): improve shutdown handling for critical task
failures (#2506)
add e09cceef5 fix(connectors): read only TOML files from local config
directory (#2510)
add d7afbb60e feat(ci): add automatic crates.io publishing for edge/rc
versions (#2508)
add 340a7f435 fix(sdk): fix high-level consumer polling strategies (#2495)
add 30f329604 feat(cluster): Impl `on_ack`, `send_prepare_ok` and
`replicate` (#2493)
add 96c3b1fb9 feat(server): socket migration across shard (#2476)
add 67fde0a87 Merge branch 'master' into fix-e2e-latency-calc
No new revisions were added by this update.
Summary of changes:
.github/workflows/_publish_rust_crates.yml | 214 ++++++++++++++++++++
.github/workflows/post-merge.yml | 74 +++++++
.github/workflows/publish.yml | 149 +-------------
Cargo.lock | 8 +-
Cargo.toml | 3 +-
DEPENDENCIES.md | 2 +-
core/common/Cargo.toml | 1 +
core/common/src/sender/mod.rs | 27 ++-
core/common/src/sender/tcp_sender.rs | 49 +++--
core/common/src/types/consensus/message.rs | 5 +-
core/configs/server.toml | 3 +
core/connectors/runtime/Cargo.toml | 1 +
.../src/configs/connectors/local_provider.rs | 5 +
core/connectors/runtime/src/main.rs | 16 +-
core/consensus/src/impls.rs | 117 +++++++++++
core/integration/tests/sdk/producer/background.rs | 88 +++++++++
core/integration/tests/server/general.rs | 6 +-
core/integration/tests/server/mod.rs | 9 +-
.../consumer_timestamp_polling_scenario.rs | 217 +++++++++++++++++++++
core/integration/tests/server/scenarios/mod.rs | 1 +
core/integration/tests/streaming/mod.rs | 7 +-
core/metadata/Cargo.toml | 1 +
core/metadata/src/impls/metadata.rs | 204 ++++++++++++++++++-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/consumer.rs | 39 ++--
core/sdk/src/clients/producer_sharding.rs | 2 +-
core/server/Cargo.toml | 2 +-
core/server/src/binary/command.rs | 11 +-
.../cluster/get_cluster_metadata_handler.rs | 8 +-
.../create_consumer_group_handler.rs | 8 +-
.../delete_consumer_group_handler.rs | 8 +-
.../consumer_groups/get_consumer_group_handler.rs | 12 +-
.../consumer_groups/get_consumer_groups_handler.rs | 8 +-
.../consumer_groups/join_consumer_group_handler.rs | 8 +-
.../leave_consumer_group_handler.rs | 8 +-
.../delete_consumer_offset_handler.rs | 8 +-
.../get_consumer_offset_handler.rs | 12 +-
.../store_consumer_offset_handler.rs | 8 +-
.../messages/flush_unsaved_buffer_handler.rs | 8 +-
.../handlers/messages/poll_messages_handler.rs | 8 +-
.../handlers/messages/send_messages_handler.rs | 111 +++++++++--
.../partitions/create_partitions_handler.rs | 8 +-
.../partitions/delete_partitions_handler.rs | 8 +-
.../create_personal_access_token_handler.rs | 8 +-
.../delete_personal_access_token_handler.rs | 8 +-
.../get_personal_access_tokens_handler.rs | 8 +-
.../login_with_personal_access_token_handler.rs | 8 +-
.../handlers/segments/delete_segments_handler.rs | 8 +-
.../handlers/streams/create_stream_handler.rs | 8 +-
.../handlers/streams/delete_stream_handler.rs | 8 +-
.../binary/handlers/streams/get_stream_handler.rs | 12 +-
.../binary/handlers/streams/get_streams_handler.rs | 8 +-
.../handlers/streams/purge_stream_handler.rs | 8 +-
.../handlers/streams/update_stream_handler.rs | 8 +-
.../binary/handlers/system/get_client_handler.rs | 12 +-
.../binary/handlers/system/get_clients_handler.rs | 8 +-
.../src/binary/handlers/system/get_me_handler.rs | 8 +-
.../src/binary/handlers/system/get_snapshot.rs | 8 +-
.../binary/handlers/system/get_stats_handler.rs | 8 +-
.../src/binary/handlers/system/ping_handler.rs | 6 +-
.../binary/handlers/topics/create_topic_handler.rs | 8 +-
.../binary/handlers/topics/delete_topic_handler.rs | 8 +-
.../binary/handlers/topics/get_topic_handler.rs | 12 +-
.../binary/handlers/topics/get_topics_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 | 8 +-
.../binary/handlers/users/delete_user_handler.rs | 8 +-
.../src/binary/handlers/users/get_user_handler.rs | 12 +-
.../src/binary/handlers/users/get_users_handler.rs | 8 +-
.../binary/handlers/users/login_user_handler.rs | 8 +-
.../binary/handlers/users/logout_user_handler.rs | 8 +-
.../handlers/users/update_permissions_handler.rs | 8 +-
.../binary/handlers/users/update_user_handler.rs | 8 +-
core/server/src/configs/defaults.rs | 1 +
core/server/src/configs/displays.rs | 4 +-
core/server/src/configs/tcp.rs | 1 +
core/server/src/http/http_server.rs | 90 ++++++---
core/server/src/http/http_shard_wrapper.rs | 35 +++-
core/server/src/main.rs | 21 +-
core/server/src/shard/builder.rs | 17 +-
core/server/src/shard/communication.rs | 2 +-
core/server/src/shard/handlers.rs | 93 ++++++++-
core/server/src/shard/mod.rs | 23 +--
core/server/src/shard/system/messages.rs | 33 +---
core/server/src/shard/task_registry/registry.rs | 74 +++++--
.../src/shard/tasks/continuous/http_server.rs | 1 +
.../src/shard/tasks/continuous/message_pump.rs | 4 +-
.../src/shard/tasks/oneshot/config_writer.rs | 33 ++--
core/server/src/shard/transmission/frame.rs | 1 +
core/server/src/shard/transmission/message.rs | 10 +
core/server/src/streaming/session.rs | 13 ++
core/server/src/tcp/connection_handler.rs | 33 +++-
core/server/src/tcp/tcp_listener.rs | 47 +++--
core/server/src/websocket/websocket_listener.rs | 4 +-
.../server/src/websocket/websocket_tls_listener.rs | 4 +-
97 files changed, 1797 insertions(+), 511 deletions(-)
create mode 100644 .github/workflows/_publish_rust_crates.yml
create mode 100644
core/integration/tests/server/scenarios/consumer_timestamp_polling_scenario.rs
