This is an automated email from the ASF dual-hosted git repository. gkoszyk pushed a commit to branch partition_remaster in repository https://gitbox.apache.org/repos/asf/iggy.git
commit c82a84119481a532d77d97b7eb0df52ff8a58a48 Merge: 64e51ff6f 30fae4cef Author: Grzegorz Koszyk <[email protected]> AuthorDate: Mon Mar 30 15:33:55 2026 +0200 Merge branch 'master' into partition_remaster Cargo.lock | 35 +- Cargo.toml | 10 +- DEPENDENCIES.md | 34 +- core/ai/mcp/Cargo.toml | 2 +- core/binary_protocol/Cargo.toml | 2 +- .../src/responses/system/get_stats.rs | 88 ++- core/cli/Cargo.toml | 6 +- core/cli/src/args/context.rs | 157 +++++ core/cli/src/commands/binary_context/common.rs | 483 ++++++++++++- .../src/commands/binary_context/create_context.rs | 94 +++ .../src/commands/binary_context/delete_context.rs | 84 +++ core/cli/src/commands/binary_context/mod.rs | 2 + core/cli/src/main.rs | 9 + core/common/Cargo.toml | 2 +- core/common/src/commands/messages/send_messages.rs | 75 ++- core/common/src/types/message/iggy_message.rs | 63 +- core/common/src/utils/crypto.rs | 70 ++ core/connectors/runtime/Cargo.toml | 2 +- core/connectors/sdk/Cargo.toml | 2 +- .../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +- core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +- core/connectors/sinks/mongodb_sink/Cargo.toml | 2 +- core/connectors/sinks/postgres_sink/Cargo.toml | 2 +- core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +- core/connectors/sinks/stdout_sink/Cargo.toml | 2 +- .../sources/elasticsearch_source/Cargo.toml | 2 +- core/connectors/sources/postgres_source/Cargo.toml | 2 +- core/connectors/sources/random_source/Cargo.toml | 2 +- .../src/harness/handle/client_builder.rs | 16 +- .../src/harness/orchestrator/harness.rs | 28 +- core/integration/tests/cli/context/common.rs | 4 + core/integration/tests/cli/context/mod.rs | 2 + .../tests/cli/context/test_context_applied.rs | 4 +- .../cli/context/test_context_create_command.rs | 239 +++++++ .../cli/context/test_context_delete_command.rs | 224 +++++++ .../tests/cli/context/test_context_list_command.rs | 6 +- .../tests/cli/context/test_context_use_command.rs | 4 +- .../tests/connectors/postgres/postgres_source.rs | 11 +- .../tests/server/scenarios/encryption_scenario.rs | 252 ++++++- core/sdk/Cargo.toml | 2 +- core/sdk/src/clients/binary_message.rs | 12 + core/sdk/src/clients/consumer.rs | 19 +- core/sdk/src/clients/producer.rs | 6 + core/server/Cargo.toml | 2 +- core/server/src/shard/system/messages.rs | 59 +- .../HeaderEncryptionIntegrationTests.cs | 211 ++++++ foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs | 12 +- .../csharp/Iggy_SDK/Contracts/MessageResponse.cs | 12 +- .../csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs | 4 +- foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +- .../Iggy_SDK/JsonConverters/MessageConverter.cs | 9 +- .../JsonConverters/MessageResponseConverter.cs | 98 +++ foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 108 ++- foreign/csharp/Iggy_SDK/Messages/Message.cs | 6 + .../csharp/Iggy_SDK/Publishers/IggyPublisher.cs | 13 +- .../Iggy_SDK/Utils/TcpMessageStreamHelpers.cs | 6 + .../MapperTests/HeaderEncryptionTests.cs | 174 +++++ foreign/go/contracts/users.go | 25 +- foreign/go/contracts/users_test.go | 746 +++++++++++++++++++++ foreign/python/Cargo.toml | 4 +- foreign/python/pyproject.toml | 2 +- 61 files changed, 3307 insertions(+), 253 deletions(-) diff --cc Cargo.toml index 8b2d6e8c2,ed714d5cd..c14d9f2e2 --- a/Cargo.toml +++ b/Cargo.toml @@@ -160,13 -160,12 +160,13 @@@ hwlocality = "1.0.0-alpha.11 iceberg = "0.9.0" iceberg-catalog-rest = "0.9.0" iceberg-storage-opendal = "0.9.0" - iggy = { path = "core/sdk", version = "0.9.4-edge.1" } - iggy-cli = { path = "core/cli", version = "0.11.3-edge.1" } - iggy_binary_protocol = { path = "core/binary_protocol", version = "0.9.4-edge.1" } - iggy_common = { path = "core/common", version = "0.9.4-edge.1" } - iggy_connector_sdk = { path = "core/connectors/sdk", version = "0.2.1-edge.1" } + iggy = { path = "core/sdk", version = "0.9.5-edge.1" } + iggy-cli = { path = "core/cli", version = "0.12.1-edge.1" } + iggy_binary_protocol = { path = "core/binary_protocol", version = "0.9.5-edge.1" } + iggy_common = { path = "core/common", version = "0.9.5-edge.1" } + iggy_connector_sdk = { path = "core/connectors/sdk", version = "0.2.2-edge.1" } integration = { path = "core/integration" } +iobuf = { path = "core/iobuf" } journal = { path = "core/journal" } js-sys = "0.3" jsonwebtoken = { version = "10.3.0", features = ["rust_crypto"] }
