This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch dependabot/bazel/foreign/cpp/cpp-1955dd2a46
in repository https://gitbox.apache.org/repos/asf/iggy.git
from d7da4659c chore(deps): Bump rules_rust in /foreign/cpp in the cpp group
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 3be6282cf Merge branch 'master' into
dependabot/bazel/foreign/cpp/cpp-1955dd2a46
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 15 +-
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/http_refresh.rs | 63 ++++
core/integration/tests/sdk/mod.rs | 2 +
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/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 | 2 +
core/server-ng/LISTENER_SUPPORT_PLAN.md | 286 --------------
core/server-ng/config.toml | 23 +-
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 | 14 +-
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 | 3 +-
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/node/package-lock.json | 22 +-
examples/node/package.json | 4 +-
foreign/node/package-lock.json | 220 +++++------
foreign/node/package.json | 6 +-
79 files changed, 3465 insertions(+), 1600 deletions(-)
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
