This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch server-ng-auth-followups
in repository https://gitbox.apache.org/repos/asf/iggy.git
from ad86e13b0 feat(server-ng): verify trusted-issuer a2a JWT and expose
SDK refresh
add 6f68d921b feat(connectors): add SurrealDB sink connector (#3453)
add 128b24967 fix(server-ng): fix restart/reconnect hardening and cg
integration tests (#3625)
add 8f9c60a78 Merge branch 'master' into server-ng-auth-followups
No new revisions were added by this update.
Summary of changes:
.github/workflows/_build_rust_artifacts.yml | 2 +-
.github/workflows/edge-release.yml | 1 +
Cargo.lock | 18 +
Cargo.toml | 1 +
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/README.md | 1 +
core/connectors/sinks/README.md | 1 +
.../{influxdb_sink => surrealdb_sink}/Cargo.toml | 9 +-
core/connectors/sinks/surrealdb_sink/README.md | 99 +
.../{mongodb_sink => surrealdb_sink}/config.toml | 42 +-
core/connectors/sinks/surrealdb_sink/src/lib.rs | 1970 ++++++++++++++++++++
core/consensus/src/impls.rs | 167 +-
core/consensus/src/metadata_helpers.rs | 7 +
core/integration/tests/connectors/fixtures/mod.rs | 5 +
.../connectors/fixtures/surrealdb/container.rs | 330 ++++
.../connectors/fixtures/{http => surrealdb}/mod.rs | 5 +-
.../tests/connectors/fixtures/surrealdb/sink.rs | 220 +++
core/integration/tests/connectors/mod.rs | 1 +
.../connectors/{elasticsearch => surrealdb}/mod.rs | 6 +-
.../connectors/{doris => surrealdb}/sink.toml | 2 +-
.../tests/connectors/surrealdb/surrealdb_sink.rs | 354 ++++
core/integration/tests/data_integrity/mod.rs | 1 -
core/integration/tests/mod.rs | 33 +-
core/integration/tests/server/cg.rs | 11 +-
core/integration/tests/server/cg_vsr.rs | 85 -
core/integration/tests/server/mod.rs | 11 +-
core/integration/tests/server/purge_delete.rs | 50 +-
.../server/scenarios/authentication_scenario.rs | 7 +
core/integration/tests/server/scenarios/mod.rs | 4 -
.../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 | 22 +
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/src/auth.rs | 5 +-
core/server-ng/src/bootstrap.rs | 185 +-
core/server-ng/src/cluster_meta.rs | 24 +
core/server-ng/src/dispatch.rs | 177 +-
core/server-ng/src/http.rs | 5 +
core/server-ng/src/http/error.rs | 7 +-
core/server-ng/src/http/handlers.rs | 55 +-
core/server-ng/src/http/reads.rs | 48 +-
core/server-ng/src/http/reply.rs | 7 +-
core/server-ng/src/partition_helpers.rs | 35 +-
core/server-ng/src/responses.rs | 13 +-
core/server-ng/src/server_error.rs | 12 -
core/shard/src/lib.rs | 114 +-
core/shard/src/router.rs | 5 +
scripts/bump-version.sh | 2 +-
60 files changed, 4907 insertions(+), 759 deletions(-)
copy core/connectors/sinks/{influxdb_sink => surrealdb_sink}/Cargo.toml (84%)
create mode 100644 core/connectors/sinks/surrealdb_sink/README.md
copy core/connectors/sinks/{mongodb_sink => surrealdb_sink}/config.toml (60%)
create mode 100644 core/connectors/sinks/surrealdb_sink/src/lib.rs
create mode 100644
core/integration/tests/connectors/fixtures/surrealdb/container.rs
copy core/integration/tests/connectors/fixtures/{http => surrealdb}/mod.rs
(84%)
create mode 100644 core/integration/tests/connectors/fixtures/surrealdb/sink.rs
copy core/integration/tests/connectors/{elasticsearch => surrealdb}/mod.rs
(90%)
copy core/integration/tests/connectors/{doris => surrealdb}/sink.toml (94%)
create mode 100644
core/integration/tests/connectors/surrealdb/surrealdb_sink.rs
delete mode 100644 core/integration/tests/server/cg_vsr.rs
