You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by pi...@apache.org on 2026/07/13 07:28:38 UTC
(iggy) branch dotnet-encryption updated (37a2f9570 -> 47d9f15ce)
This is an automated email from the ASF dual-hosted git repository.
spetz pushed a change to branch dotnet-encryption
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 37a2f9570 fix(csharp): correct typo in InvalidResponseException documentation
add 128b24967 fix(server-ng): fix restart/reconnect hardening and cg integration tests (#3625)
add 3c935261e feat(server-ng): verify trusted-issuer a2a JWT and expose SDK refresh (#3626)
add f318b79a7 fix(server-ng): add messages encryption (#3644)
add a860cef24 chore(deps): Bump the node group across 2 directories with 6 updates (#3638)
add 2ec7d8964 feat: respect CPU and cgroup limits in server-ng and connectors stats (#3647)
add f238b8cdc chore(deps): Bump github.com/klauspost/compress from 1.18.6 to 1.19.0 in /bdd/go in the go group across 1 directory (#3649)
add 8e12709c5 chore(deps): Bump the web group across 1 directory with 10 updates (#3636)
add 45fac4441 ci(python): bump setup-uv to ASF-allowlisted v8.3.2 (#3653)
add 60d9a6614 feat(server-ng): honor [http.cors] config on the HTTP listener (#3646)
add 7b79dbdc4 feat(python): expose consumer group delete join and leave APIs (#3607)
add 925706dc8 chore(rust): bump sdk, common, binary_protocol, server patch versions (#3659)
add a5a08ba14 ci: add/cpp to dependabot config (#3655)
add 47d9f15ce Merge branch 'master' into dotnet-encryption
No new revisions were added by this update.
Summary of changes:
.../actions/python-maturin/post-merge/action.yml | 2 +-
.../actions/python-maturin/pre-merge/action.yml | 2 +-
.github/dependabot.yml | 4 +-
Cargo.lock | 23 +-
Cargo.toml | 8 +-
bdd/go/go.mod | 2 +-
bdd/go/go.sum | 4 +-
core/binary_protocol/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/common/src/error/iggy_error.rs | 2 +
core/common/src/traits/binary_impls/cluster.rs | 2 -
core/common/src/traits/cluster_client.rs | 3 +-
core/connectors/runtime/Cargo.toml | 1 +
core/connectors/runtime/src/main.rs | 2 +
core/connectors/runtime/src/stats.rs | 44 +--
core/connectors/sdk/src/api.rs | 18 +
core/consensus/src/impls.rs | 167 ++++++++-
core/consensus/src/metadata_helpers.rs | 7 +
.../src/harness/orchestrator/harness.rs | 13 +
core/integration/tests/data_integrity/mod.rs | 1 -
core/integration/tests/mod.rs | 33 +-
core/integration/tests/sdk/consumer_group.rs | 163 ++++++++
core/integration/tests/sdk/http_refresh.rs | 63 ++++
core/integration/tests/sdk/mod.rs | 3 +
core/integration/tests/server/a2a_jwt/jwt_tests.rs | 195 +++++++++-
core/integration/tests/server/cg.rs | 11 +-
core/integration/tests/server/cg_vsr.rs | 85 -----
core/integration/tests/server/mod.rs | 16 +-
core/integration/tests/server/purge_delete.rs | 50 ++-
.../server/scenarios/authentication_scenario.rs | 7 +
.../tests/server/scenarios/encryption_scenario.rs | 23 +-
core/integration/tests/server/scenarios/mod.rs | 5 -
.../server/scenarios/purge_delete_scenario.rs | 414 ++++++++++++++-------
.../scenarios/reconnect_after_restart_scenario.rs | 4 +
.../scenarios/restart_offset_skip_scenario.rs | 6 +-
core/integration/tests/server/specific.rs | 15 +-
core/metadata/src/impls/metadata.rs | 53 ++-
core/metadata/src/impls/recovery.rs | 115 +++++-
core/metadata/src/stm/result.rs | 9 +
core/metadata/src/stm/stream.rs | 18 +-
core/partitions/src/iggy_partition.rs | 320 ++++++++++------
core/partitions/src/iggy_partitions.rs | 51 ++-
core/partitions/src/types.rs | 10 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/consumer.rs | 29 ++
core/sdk/src/http/http_client.rs | 67 ++--
core/sdk/src/http/http_transport.rs | 6 +-
core/sdk/src/leader_aware.rs | 81 ++--
core/sdk/src/quic/quic_client.rs | 31 +-
core/sdk/src/tcp/tcp_client.rs | 410 +++++++++++++-------
core/sdk/src/websocket/websocket_client.rs | 24 +-
core/server-ng/Cargo.toml | 3 +-
core/server-ng/LISTENER_SUPPORT_PLAN.md | 286 --------------
core/server-ng/config.toml | 36 +-
core/server-ng/src/auth.rs | 5 +-
core/server-ng/src/bootstrap.rs | 198 ++++++++--
core/server-ng/src/cluster_meta.rs | 24 ++
core/server-ng/src/dispatch.rs | 200 +++++++---
core/server-ng/src/http.rs | 344 ++++++++++++++++-
core/server-ng/src/http/error.rs | 7 +-
core/server-ng/src/http/extractor.rs | 44 ++-
core/server-ng/src/http/handlers.rs | 82 ++--
.../src/http/jwt => server-ng/src/http}/jwks.rs | 150 +++++---
core/server-ng/src/http/jwt.rs | 310 ++++++++++++++-
core/server-ng/src/http/reads.rs | 48 ++-
core/server-ng/src/http/reply.rs | 7 +-
core/server-ng/src/http/wire.rs | 10 +-
core/server-ng/src/main.rs | 4 +
core/server-ng/src/partition_helpers.rs | 35 +-
core/server-ng/src/partition_reconciler.rs | 1 +
core/server-ng/src/responses.rs | 149 +++++---
core/server-ng/src/server_error.rs | 12 -
core/server/Cargo.toml | 5 +-
core/server/config.toml | 23 +-
core/server/src/http/jwt/jwks.rs | 86 +++--
core/server/src/main.rs | 4 +
core/server/src/shard/system/mod.rs | 1 -
core/server/src/shard/system/stats.rs | 224 ++++-------
core/server_common/src/send_messages2.rs | 61 ++-
core/shard/src/lib.rs | 114 +++++-
core/shard/src/router.rs | 5 +
core/simulator/src/replica.rs | 1 +
core/{bench/runner => system_stats}/Cargo.toml | 20 +-
.../system => system_stats/src}/cgroup_memory.rs | 0
core/system_stats/src/lib.rs | 259 +++++++++++++
examples/go/go.mod | 2 +-
examples/go/go.sum | 4 +-
examples/node/package-lock.json | 22 +-
examples/node/package.json | 4 +-
foreign/go/go.mod | 2 +-
foreign/go/go.sum | 4 +-
foreign/node/package-lock.json | 220 +++++------
foreign/node/package.json | 6 +-
foreign/python/Cargo.toml | 2 +-
foreign/python/apache_iggy.pyi | 71 ++++
foreign/python/src/client.rs | 113 ++++++
foreign/python/tests/test_consumer_group.py | 384 +++++++++++++++++++
web/package-lock.json | 330 ++++++++--------
web/package.json | 18 +-
web/src/lib/utils/utilTypes.ts | 3 +-
100 files changed, 4760 insertions(+), 1811 deletions(-)
create mode 100644 core/integration/tests/sdk/consumer_group.rs
create mode 100644 core/integration/tests/sdk/http_refresh.rs
delete mode 100644 core/integration/tests/server/cg_vsr.rs
delete mode 100644 core/server-ng/LISTENER_SUPPORT_PLAN.md
copy core/{server/src/http/jwt => server-ng/src/http}/jwks.rs (62%)
copy core/{bench/runner => system_stats}/Cargo.toml (73%)
rename core/{server/src/shard/system => system_stats/src}/cgroup_memory.rs (100%)
create mode 100644 core/system_stats/src/lib.rs