This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch leader-change
in repository https://gitbox.apache.org/repos/asf/iggy.git
from d9a230ba7 test(integration): spec clients-table durability across node
restart
add 801b152a5 test(bdd): run Rust BDD against iggy-server-ng with VSR
(#3732)
add 700221b39 fix(python): pin python version and add uv caching (#3690)
add 6513b2f55 fix(connectors): fix postgres source CDC producing no
messages (#3640)
add 2fdd6e84a feat(bench): record cluster topology in reports and surface
it in UI (#3737)
add 4c30a88a0 feat(server-ng): add cluster.heartbeat_timeout for VSR
liveness window (#3738)
add f4580f9f4 chore(deps): Bump the node group across 2 directories with
15 updates (#3741)
add 64ae1e9cb feat(connectors): use TCP client for Flink sink (#3657)
add d9635b6d7 feat(server-ng): forward follower HTTP requests to VSR
primary (#3744)
add baf01b60d Merge branch 'master' into leader-change
No new revisions were added by this update.
Summary of changes:
.dockerignore | 1 +
.github/config/components.yml | 3 +-
.github/workflows/_test_bdd.yml | 37 +-
.gitignore | 2 +
.typos.toml | 1 +
Cargo.lock | 3 +-
Cargo.toml | 2 +-
bdd/README.md | 10 +
bdd/docker-compose.coverage.yml | 6 +-
bdd/docker-compose.vsr.yml | 95 ++
bdd/docker-compose.yml | 9 +-
bdd/python/.python-version | 1 +
bdd/rust/Cargo.toml | 1 +
core/bench/dashboard/frontend/assets/style.css | 11 +
.../src/components/layout/benchmark_meta.rs | 3 +
.../frontend/src/components/layout/sidebar.rs | 31 +-
.../frontend/src/components/layout/sweep_view.rs | 56 +
.../src/components/selectors/benchmarks_list.rs | 2 +
.../components/selectors/dense_benchmark_row.rs | 5 +
core/bench/dashboard/frontend/src/state/ui.rs | 68 +
core/bench/dashboard/shared/src/lib.rs | 7 +-
core/bench/dashboard/shared/src/subtext.rs | 52 +-
core/bench/report/src/types/cluster.rs | 125 ++
core/bench/report/src/types/mod.rs | 1 +
core/bench/report/src/types/report.rs | 49 +
core/bench/src/analytics/report_builder.rs | 147 +-
core/bench/src/runner.rs | 5 +-
core/configs/src/lib.rs | 4 +-
core/configs/src/server_ng_config/cluster.rs | 638 +++++++++
core/configs/src/server_ng_config/defaults.rs | 57 +-
core/configs/src/server_ng_config/mod.rs | 1 +
core/configs/src/server_ng_config/server_ng.rs | 2 +-
core/configs/src/server_ng_config/validators.rs | 95 ++
core/connectors/sources/postgres_source/README.md | 31 +-
.../sources/postgres_source/src/cdc_fixtures.rs | 89 ++
core/connectors/sources/postgres_source/src/lib.rs | 1100 +++++++++++---
core/consensus/src/impls.rs | 8 +
core/consensus/src/lib.rs | 1 +
core/consensus/src/vsr_timeout.rs | 15 +-
core/integration/tests/connectors/fixtures/mod.rs | 5 +-
.../tests/connectors/fixtures/postgres/cdc.rs | 206 +++
.../connectors/fixtures/postgres/container.rs | 21 +-
.../tests/connectors/fixtures/postgres/mod.rs | 2 +
.../postgres/cdc_restart_connectors}/config.toml | 0
core/integration/tests/connectors/postgres/mod.rs | 1 +
.../connectors/postgres/postgres_source_cdc.rs | 584 ++++++++
.../source_cdc_restart.toml} | 17 +-
core/integration/tests/server/http_vsr.rs | 4 +-
core/integration/tests/server/message_retrieval.rs | 13 +
core/server-ng/Cargo.toml | 4 +-
core/server-ng/config.toml | 24 +-
core/server-ng/src/bootstrap.rs | 42 +-
core/server-ng/src/cluster_meta.rs | 2 +-
core/server-ng/src/http.rs | 104 +-
core/server-ng/src/http/error.rs | 132 +-
core/server-ng/src/http/extractor.rs | 20 +-
core/server-ng/src/http/forward.rs | 632 +++++++++
core/server-ng/src/http/handlers.rs | 6 +-
core/server-ng/src/http/jwt.rs | 47 +-
core/server-ng/src/http/reply.rs | 51 +-
core/server-ng/src/http/state.rs | 36 +-
core/server-ng/src/http/submit.rs | 43 +-
core/server-ng/src/partition_helpers.rs | 1 +
core/server-ng/src/server_error.rs | 2 +
examples/node/package-lock.json | 20 +-
examples/node/package.json | 4 +-
examples/python/.gitignore | 3 -
examples/python/.python-version | 1 +
foreign/java/.gitignore | 1 +
.../iggy-connector-library/README.md | 33 +
.../apache/iggy/connector/config/TcpEndpoint.java | 92 ++
.../apache/iggy/connector/flink/sink/IggySink.java | 91 +-
.../iggy/connector/flink/sink/IggySinkWriter.java | 39 +-
.../iggy/connector/flink/source/IggySource.java | 24 +-
.../iggy/connector/config/TcpEndpointTest.java | 130 ++
foreign/node/package-lock.json | 1499 ++++++++++++--------
foreign/node/package.json | 6 +-
foreign/python/.gitignore | 2 -
foreign/python/.python-version | 1 +
foreign/python/pyproject.toml | 10 +
licenserc.toml | 1 +
scripts/ci/sync-python-interpreter-version.sh | 15 +
scripts/run-bdd-tests.sh | 27 +-
83 files changed, 5706 insertions(+), 1066 deletions(-)
create mode 100644 bdd/docker-compose.vsr.yml
create mode 100644 bdd/python/.python-version
create mode 100644 core/bench/report/src/types/cluster.rs
create mode 100644 core/configs/src/server_ng_config/cluster.rs
create mode 100644 core/connectors/sources/postgres_source/src/cdc_fixtures.rs
create mode 100644 core/integration/tests/connectors/fixtures/postgres/cdc.rs
copy core/{connectors/sources/postgres_source =>
integration/tests/connectors/postgres/cdc_restart_connectors}/config.toml (100%)
create mode 100644
core/integration/tests/connectors/postgres/postgres_source_cdc.rs
copy core/integration/tests/connectors/{api/config.toml =>
postgres/source_cdc_restart.toml} (61%)
create mode 100644 core/server-ng/src/http/forward.rs
create mode 100644 examples/python/.python-version
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/main/java/org/apache/iggy/connector/config/TcpEndpoint.java
create mode 100644
foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/src/test/java/org/apache/iggy/connector/config/TcpEndpointTest.java
create mode 100644 foreign/python/.python-version
