This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch refactor-binary-7-http
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 38f132138 fix(server,sdk): fix O(n^2) memory in HTTP SendMessages and
missing transport codes
add 658d4d32d refactor(server,sdk): add wire validation for user headers
and fix encoding defects
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1 +
core/binary_protocol/src/lib.rs | 4 +
core/binary_protocol/src/primitives/mod.rs | 1 +
.../binary_protocol/src/primitives/user_headers.rs | 406 +++++++++++++++++++++
.../src/commands/binary_message/poll_messages.rs | 2 +-
.../src/commands/binary_message/send_messages.rs | 4 +-
core/common/src/error/iggy_error.rs | 2 +
core/common/src/http/messages/send_messages.rs | 4 +-
core/common/src/types/message/iggy_message.rs | 50 +--
core/common/src/types/message/message_view.rs | 21 +-
.../common/src/types/message/messages_batch_mut.rs | 9 +
core/common/src/types/message/user_headers.rs | 156 ++++----
core/common/src/utils/crypto.rs | 4 +-
core/connectors/runtime/src/sink.rs | 2 +-
core/connectors/runtime/src/source.rs | 4 +-
core/connectors/sdk/src/lib.rs | 10 +-
.../tests/cli/message/test_message_poll_command.rs | 4 +-
.../message/test_message_poll_to_file_command.rs | 8 +-
.../cli/message/test_message_reply_via_file.rs | 4 +-
.../tests/cli/message/test_message_send_command.rs | 8 +-
.../message/test_message_send_from_file_command.rs | 8 +-
.../server/scenarios/create_message_payload.rs | 6 +-
.../tests/server/scenarios/encryption_scenario.rs | 8 +-
.../server/scenarios/message_headers_scenario.rs | 6 +-
.../server/scenarios/message_size_scenario.rs | 6 +-
.../tests/server/scenarios/offset_scenario.rs | 6 +-
.../tests/server/scenarios/timestamp_scenario.rs | 6 +-
core/sdk/src/prelude.rs | 1 -
core/tools/src/data-seeder/seeder.rs | 4 +-
examples/rust/Cargo.toml | 1 +
.../message-compression/consumer/main.rs | 1 +
.../message-compression/producer/main.rs | 4 +-
.../message-headers/message-type/producer/main.rs | 4 +-
.../message-headers/typed-headers/producer/main.rs | 4 +-
34 files changed, 579 insertions(+), 190 deletions(-)
create mode 100644 core/binary_protocol/src/primitives/user_headers.rs