This is an automated email from the ASF dual-hosted git repository.
piotr pushed a change to branch simulator_ui
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 246b4b56d merge
add 051475a76 revert(test): remove shared_server, add nextest CI retries
(#3088)
add 70b8d361d chore(security): fix Dependabot security vulnerabilities
(#3087)
add e7be6ddd1 feat(server): support A2A protocol (#2656)
add 27f0f11c6 feat(consensus): wire up view change protocol in simulator
(#3092)
new 42f473653 merge
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:
.config/nextest.toml | 15 +-
.github/actions/rust/pre-merge/action.yml | 2 +-
.github/workflows/coverage-baseline.yml | 2 +-
.typos.toml | 2 +
Cargo.lock | 175 +++++---
Cargo.toml | 3 +-
DEPENDENCIES.md | 27 +-
bdd/go/go.mod | 2 +-
bdd/go/go.sum | 4 +-
core/binary_protocol/src/consensus/message.rs | 38 +-
core/common/src/error/iggy_error.rs | 2 +
.../http_config/http_client_config.rs | 4 +
.../http_config/http_client_config_builder.rs | 6 +
core/configs/src/server_config/defaults.rs | 1 +
core/configs/src/server_config/http.rs | 11 +
core/consensus/src/impls.rs | 143 ++++++-
core/consensus/src/observability.rs | 27 ++
core/harness_derive/src/attrs.rs | 74 +++-
core/harness_derive/src/codegen.rs | 205 ++-------
core/integration/Cargo.toml | 3 +-
.../integration/src/harness/config/jwks.rs | 13 +-
core/integration/src/harness/config/mod.rs | 2 +
core/integration/src/harness/handle/mod.rs | 2 +-
core/integration/src/harness/handle/server.rs | 2 +-
core/integration/src/harness/mod.rs | 4 +-
.../src/harness/orchestrator/builder.rs | 15 +-
.../src/harness/orchestrator/harness.rs | 234 +++--------
core/integration/src/harness/seeds.rs | 71 +---
core/integration/src/harness/shared.rs | 159 -------
core/integration/src/lib.rs | 3 +-
core/integration/tests/connectors/api/endpoints.rs | 24 +-
.../connectors/elasticsearch/elasticsearch_sink.rs | 9 +-
.../elasticsearch/elasticsearch_source.rs | 9 +-
.../integration/tests/connectors/http/http_sink.rs | 26 +-
.../http_config_provider/direct_responses.rs | 30 +-
.../http_config_provider/wrapped_responses.rs | 30 +-
.../tests/connectors/iceberg/iceberg_sink.rs | 9 +-
.../tests/connectors/influxdb/influxdb_sink.rs | 18 +-
.../connectors/influxdb/influxdb_sink_formats.rs | 36 +-
.../tests/connectors/influxdb/influxdb_source.rs | 12 +-
.../connectors/influxdb/influxdb_source_formats.rs | 27 +-
.../tests/connectors/mongodb/mongodb_sink.rs | 31 +-
.../tests/connectors/postgres/postgres_sink.rs | 9 +-
.../tests/connectors/postgres/postgres_source.rs | 15 +-
.../tests/connectors/postgres/restart.rs | 6 +-
.../tests/connectors/quickwit/quickwit_sink.rs | 12 +-
.../tests/connectors/random/random_source.rs | 3 +-
.../tests/connectors/stdout/stdout_sink.rs | 9 +-
.../{connectors/api => server/a2a_jwt}/config.toml | 51 ++-
core/integration/tests/server/a2a_jwt/jwt_tests.rs | 331 +++++++++++++++
.../{connectors/api => server/a2a_jwt}/mod.rs | 2 +-
.../server/a2a_jwt/wiremock/__files/jwks.json | 10 +
.../a2a_jwt/wiremock/mappings/jwks.json} | 4 +-
core/integration/tests/server/mod.rs | 1 +
core/metadata/src/impls/metadata.rs | 4 +-
core/partitions/src/iggy_partitions.rs | 4 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/client_provider.rs | 1 +
core/sdk/src/clients/client_builder.rs | 6 +
core/sdk/src/clients/consumer.rs | 3 +
core/sdk/src/http/http_client.rs | 4 +-
core/server/Cargo.toml | 1 +
core/server/config.toml | 6 +
core/server/src/http/jwt/json_web_token.rs | 109 ++++-
core/server/src/http/jwt/jwks.rs | 316 ++++++++++++++
core/server/src/http/jwt/jwt_manager.rs | 200 ++++++++-
core/server/src/http/jwt/middleware.rs | 12 +-
core/server/src/http/jwt/mod.rs | 1 +
core/shard/src/lib.rs | 468 ++++++++++++++++++++-
core/shard/src/router.rs | 65 ++-
core/simulator/src/lib.rs | 188 ++++++++-
core/simulator/src/replica.rs | 10 +-
examples/go/go.mod | 2 +-
examples/go/go.sum | 4 +-
foreign/go/go.mod | 29 +-
foreign/go/go.sum | 86 ++--
web/package-lock.json | 12 +-
web/package.json | 3 +-
78 files changed, 2447 insertions(+), 1054 deletions(-)
copy foreign/java/buildSrc/build.gradle.kts =>
core/integration/src/harness/config/jwks.rs (80%)
delete mode 100644 core/integration/src/harness/shared.rs
copy core/integration/tests/{connectors/api => server/a2a_jwt}/config.toml
(50%)
create mode 100644 core/integration/tests/server/a2a_jwt/jwt_tests.rs
copy core/integration/tests/{connectors/api => server/a2a_jwt}/mod.rs (98%)
create mode 100644
core/integration/tests/server/a2a_jwt/wiremock/__files/jwks.json
copy
core/integration/tests/{connectors/http_config_provider/wiremock/mappings/direct/get-active-configs.json
=> server/a2a_jwt/wiremock/mappings/jwks.json} (64%)
create mode 100644 core/server/src/http/jwt/jwks.rs
