This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch partition_remaster
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 64e51ff6f clippy fixes
add 169a09bcd fix(go): correct Permissions serialization and add unit
tests (#3015)
add 3e848424b feat(cli): Add context create/delete CLI commands to
complete login/logout workflow (#2998)
add 4ca3cf2b3 feat(security): encrypt user headers alongside message
payload (#3040)
add e0c55e6e4 fix(test): remove race condition in postgres source mark
test (#3052)
add 30fae4cef fix: stats semver wire alignment using a zero sentinel
(#3036)
new c82a84119 Merge branch 'master' into partition_remaster
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
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 ++++++++++++-
.../{use_context.rs => create_context.rs} | 57 +-
.../{use_context.rs => delete_context.rs} | 49 +-
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, 3200 insertions(+), 288 deletions(-)
copy core/cli/src/commands/binary_context/{use_context.rs =>
create_context.rs} (51%)
copy core/cli/src/commands/binary_context/{use_context.rs =>
delete_context.rs} (61%)
create mode 100644
core/integration/tests/cli/context/test_context_create_command.rs
create mode 100644
core/integration/tests/cli/context/test_context_delete_command.rs
create mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/HeaderEncryptionIntegrationTests.cs
create mode 100644
foreign/csharp/Iggy_SDK/JsonConverters/MessageResponseConverter.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/MapperTests/HeaderEncryptionTests.cs
create mode 100644 foreign/go/contracts/users_test.go
