This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch
dependabot/npm_and_yarn/examples/node/node-a57050c326
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 559a5b952 chore(deps): Bump the node group across 2 directories with 6
updates
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 ad07e09a3 Merge branch 'master' into
dependabot/npm_and_yarn/examples/node/node-a57050c326
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 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/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 | 1 +
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/partition_helpers.rs | 35 +-
core/server-ng/src/partition_reconciler.rs | 1 +
core/server-ng/src/responses.rs | 80 +++-
core/server-ng/src/server_error.rs | 12 -
core/server/Cargo.toml | 1 +
core/server/config.toml | 23 +-
core/server/src/http/jwt/jwks.rs | 86 +++--
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 +
63 files changed, 2922 insertions(+), 1227 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%)
