This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch refactor-post-merge
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 81be9c861 ci: unify publishing via workflow_call in publish.yml
add 0723a31c0 chore(cpp): delete old client (#2668)
add eecd8f48d refactor(integration): migrate connectors tests to
iggy_harness proc macro (#2667)
add cb0a5a6a3 feat(bench): add --message-expiry CLI option for benchmark
topics (#2672)
add 75a3f4064 feat(python): add message_expiry parameter to create_topic
(#2671)
add 407b56ec2 Merge branch 'master' into refactor-post-merge
No new revisions were added by this update.
Summary of changes:
.github/workflows/_common.yml | 19 +
.pre-commit-config.yaml | 18 +
Cargo.lock | 35 +-
DEPENDENCIES.md | 2 -
core/bench/src/args/common.rs | 6 +-
core/bench/src/args/examples.rs | 1 +
.../src/args/kinds/balanced/consumer_group.rs | 2 +-
core/bench/src/args/kinds/balanced/producer.rs | 10 +-
.../kinds/balanced/producer_and_consumer_group.rs | 10 +-
.../args/kinds/end_to_end/producing_consumer.rs | 10 +-
.../kinds/end_to_end/producing_consumer_group.rs | 10 +-
core/bench/src/args/kinds/pinned/producer.rs | 10 +-
.../src/args/kinds/pinned/producer_and_consumer.rs | 10 +-
core/bench/src/args/props.rs | 5 +-
core/bench/src/benchmarks/benchmark.rs | 7 +-
core/harness_derive/src/codegen.rs | 14 +-
core/integration/Cargo.toml | 6 +-
core/integration/src/harness/context.rs | 30 +-
.../src/harness/{fixtures/mod.rs => fixture.rs} | 13 -
core/integration/src/harness/fixtures/random.rs | 36 -
.../src/harness/handle/connectors_runtime.rs | 28 +-
core/integration/src/harness/handle/mcp.rs | 20 +-
core/integration/src/harness/handle/mod.rs | 2 +-
core/integration/src/harness/handle/server.rs | 138 +-
core/integration/src/harness/mod.rs | 4 +-
.../src/harness/orchestrator/builder.rs | 24 +-
.../src/harness/orchestrator/harness.rs | 79 +-
core/integration/tests/connectors/api/endpoints.rs | 107 +-
core/integration/tests/connectors/api/mod.rs | 9 -
.../postgres => tests/connectors/fixtures}/mod.rs | 17 +-
.../connectors}/fixtures/postgres/container.rs | 25 +-
.../connectors}/fixtures/postgres/mod.rs | 6 +-
.../connectors}/fixtures/postgres/sink.rs | 3 +-
.../connectors}/fixtures/postgres/source.rs | 110 +-
.../connectors/fixtures/quickwit/container.rs | 363 +++
.../tests/connectors/fixtures/quickwit/mod.rs | 4 +-
.../connectors}/fixtures/wiremock.rs | 15 +-
.../http_config_provider/direct_responses.rs | 151 +-
.../tests/connectors/http_config_provider/mod.rs | 82 -
.../http_config_provider/wrapped_responses.rs | 153 +-
core/integration/tests/connectors/mod.rs | 190 +-
core/integration/tests/connectors/postgres/mod.rs | 502 +---
.../tests/connectors/postgres/postgres_sink.rs | 136 +-
.../tests/connectors/postgres/postgres_source.rs | 314 ++-
core/integration/tests/connectors/quickwit/mod.rs | 265 --
.../tests/connectors/quickwit/quickwit_sink.rs | 283 ++-
core/integration/tests/connectors/random/mod.rs | 9 -
.../tests/connectors/random/random_source.rs | 32 +-
core/integration/tests/mod.rs | 84 +-
foreign/cpp/.clang-format | 7 -
foreign/cpp/.devcontainer/devcontainer.json | 32 -
foreign/cpp/.devcontainer/post-install.sh | 29 -
foreign/cpp/.gitignore | 5 -
foreign/cpp/.lcovrc | 3 -
foreign/cpp/.yamllint | 3 -
foreign/cpp/CMakeLists.txt | 124 -
foreign/cpp/CMakePresets.json | 54 -
foreign/cpp/CONTRIBUTORS.md | 71 -
foreign/cpp/CPPLINT.cfg | 3 -
foreign/cpp/Doxyfile | 2657 --------------------
foreign/cpp/LICENSE | 201 --
foreign/cpp/NOTICE | 19 -
foreign/cpp/README.md | 3 -
foreign/cpp/docs/CMakeLists.txt | 33 -
foreign/cpp/docs/images/init_act.png | Bin 161574 -> 0 bytes
foreign/cpp/docs/images/pre-commit_run.png | Bin 148646 -> 0 bytes
.../iggy-cpp-build/.devcontainer/devcontainer.json | 39 -
foreign/cpp/images/iggy-cpp-build/README.md | 6 -
foreign/cpp/sdk/binary.h | 77 -
foreign/cpp/sdk/client.cc | 40 -
foreign/cpp/sdk/client.h | 108 -
foreign/cpp/sdk/command.h | 481 ----
foreign/cpp/sdk/json.cc | 17 -
foreign/cpp/sdk/json.h | 42 -
foreign/cpp/sdk/model.cc | 17 -
foreign/cpp/sdk/model.h | 679 -----
foreign/cpp/sdk/net/address.cc | 51 -
foreign/cpp/sdk/net/address.h | 67 -
foreign/cpp/sdk/net/conn.cc | 21 -
foreign/cpp/sdk/net/conn.h | 67 -
foreign/cpp/sdk/net/http/conn.cc | 17 -
foreign/cpp/sdk/net/http/conn.h | 17 -
foreign/cpp/sdk/net/iggy.cc | 41 -
foreign/cpp/sdk/net/iggy.h | 61 -
foreign/cpp/sdk/net/protocol.cc | 40 -
foreign/cpp/sdk/net/protocol.h | 126 -
foreign/cpp/sdk/net/quic/address.h | 17 -
foreign/cpp/sdk/net/quic/conn.h | 17 -
foreign/cpp/sdk/net/quic/stream.h | 17 -
foreign/cpp/sdk/net/ssl/crypto.cc | 88 -
foreign/cpp/sdk/net/ssl/crypto.h | 328 ---
foreign/cpp/sdk/net/ssl/ssl.cc | 212 --
foreign/cpp/sdk/net/ssl/ssl.h | 166 --
foreign/cpp/sdk/net/ssl/ssl_engine.h | 21 -
foreign/cpp/sdk/net/tcp/conn.cc | 17 -
foreign/cpp/sdk/net/tcp/conn.h | 17 -
foreign/cpp/sdk/net/transport.h | 47 -
foreign/cpp/sdk/serialization.cc | 36 -
foreign/cpp/sdk/serialization.h | 45 -
foreign/cpp/sdk/types.h | 41 -
foreign/cpp/tests/CMakeLists.txt | 103 -
foreign/cpp/tests/e2e/e2e_testutils.cc | 49 -
foreign/cpp/tests/e2e/e2e_testutils.h | 38 -
foreign/cpp/tests/e2e/ping_cmd_test.cc | 30 -
foreign/cpp/tests/e2e/server.toml | 410 ---
foreign/cpp/tests/unit/client_test.cc | 25 -
foreign/cpp/tests/unit/crypto_test.cc | 50 -
.../cpp/tests/unit/iggy_protocol_provider_test.cc | 50 -
foreign/cpp/tests/unit/model_test.cc | 23 -
foreign/cpp/tests/unit/serialization_test.cc | 32 -
foreign/cpp/tests/unit/ssl_test.cc | 148 --
foreign/cpp/tests/unit/unit_testutils.cc | 63 -
foreign/cpp/tests/unit/unit_testutils.h | 44 -
foreign/cpp/vcpkg-configuration.json | 14 -
foreign/cpp/vcpkg.json | 14 -
foreign/python/Cargo.toml | 2 +-
foreign/python/apache_iggy.pyi | 3 +-
foreign/python/pyproject.toml | 2 +-
foreign/python/src/client.rs | 15 +-
scripts/ci/python-version-sync.sh | 205 ++
120 files changed, 1842 insertions(+), 9214 deletions(-)
rename core/integration/src/harness/{fixtures/mod.rs => fixture.rs} (79%)
delete mode 100644 core/integration/src/harness/fixtures/random.rs
copy core/integration/{src/harness/fixtures/postgres =>
tests/connectors/fixtures}/mod.rs (68%)
rename core/integration/{src/harness =>
tests/connectors}/fixtures/postgres/container.rs (91%)
rename core/integration/{src/harness =>
tests/connectors}/fixtures/postgres/mod.rs (85%)
rename core/integration/{src/harness =>
tests/connectors}/fixtures/postgres/sink.rs (98%)
rename core/integration/{src/harness =>
tests/connectors}/fixtures/postgres/source.rs (83%)
create mode 100644
core/integration/tests/connectors/fixtures/quickwit/container.rs
copy bdd/java/settings.gradle.kts =>
core/integration/tests/connectors/fixtures/quickwit/mod.rs (89%)
rename core/integration/{src/harness => tests/connectors}/fixtures/wiremock.rs
(94%)
delete mode 100644 foreign/cpp/.clang-format
delete mode 100644 foreign/cpp/.devcontainer/devcontainer.json
delete mode 100755 foreign/cpp/.devcontainer/post-install.sh
delete mode 100644 foreign/cpp/.gitignore
delete mode 100644 foreign/cpp/.lcovrc
delete mode 100644 foreign/cpp/.yamllint
delete mode 100644 foreign/cpp/CMakeLists.txt
delete mode 100644 foreign/cpp/CMakePresets.json
delete mode 100644 foreign/cpp/CONTRIBUTORS.md
delete mode 100644 foreign/cpp/CPPLINT.cfg
delete mode 100644 foreign/cpp/Doxyfile
delete mode 100644 foreign/cpp/LICENSE
delete mode 100644 foreign/cpp/NOTICE
delete mode 100644 foreign/cpp/README.md
delete mode 100644 foreign/cpp/docs/CMakeLists.txt
delete mode 100644 foreign/cpp/docs/images/init_act.png
delete mode 100644 foreign/cpp/docs/images/pre-commit_run.png
delete mode 100644
foreign/cpp/images/iggy-cpp-build/.devcontainer/devcontainer.json
delete mode 100644 foreign/cpp/images/iggy-cpp-build/README.md
delete mode 100644 foreign/cpp/sdk/binary.h
delete mode 100644 foreign/cpp/sdk/client.cc
delete mode 100644 foreign/cpp/sdk/client.h
delete mode 100644 foreign/cpp/sdk/command.h
delete mode 100644 foreign/cpp/sdk/json.cc
delete mode 100644 foreign/cpp/sdk/json.h
delete mode 100644 foreign/cpp/sdk/model.cc
delete mode 100644 foreign/cpp/sdk/model.h
delete mode 100644 foreign/cpp/sdk/net/address.cc
delete mode 100644 foreign/cpp/sdk/net/address.h
delete mode 100644 foreign/cpp/sdk/net/conn.cc
delete mode 100644 foreign/cpp/sdk/net/conn.h
delete mode 100644 foreign/cpp/sdk/net/http/conn.cc
delete mode 100644 foreign/cpp/sdk/net/http/conn.h
delete mode 100644 foreign/cpp/sdk/net/iggy.cc
delete mode 100644 foreign/cpp/sdk/net/iggy.h
delete mode 100644 foreign/cpp/sdk/net/protocol.cc
delete mode 100644 foreign/cpp/sdk/net/protocol.h
delete mode 100644 foreign/cpp/sdk/net/quic/address.h
delete mode 100644 foreign/cpp/sdk/net/quic/conn.h
delete mode 100644 foreign/cpp/sdk/net/quic/stream.h
delete mode 100644 foreign/cpp/sdk/net/ssl/crypto.cc
delete mode 100644 foreign/cpp/sdk/net/ssl/crypto.h
delete mode 100644 foreign/cpp/sdk/net/ssl/ssl.cc
delete mode 100644 foreign/cpp/sdk/net/ssl/ssl.h
delete mode 100644 foreign/cpp/sdk/net/ssl/ssl_engine.h
delete mode 100644 foreign/cpp/sdk/net/tcp/conn.cc
delete mode 100644 foreign/cpp/sdk/net/tcp/conn.h
delete mode 100644 foreign/cpp/sdk/net/transport.h
delete mode 100644 foreign/cpp/sdk/serialization.cc
delete mode 100644 foreign/cpp/sdk/serialization.h
delete mode 100644 foreign/cpp/sdk/types.h
delete mode 100644 foreign/cpp/tests/CMakeLists.txt
delete mode 100644 foreign/cpp/tests/e2e/e2e_testutils.cc
delete mode 100644 foreign/cpp/tests/e2e/e2e_testutils.h
delete mode 100644 foreign/cpp/tests/e2e/ping_cmd_test.cc
delete mode 100644 foreign/cpp/tests/e2e/server.toml
delete mode 100644 foreign/cpp/tests/unit/client_test.cc
delete mode 100644 foreign/cpp/tests/unit/crypto_test.cc
delete mode 100644 foreign/cpp/tests/unit/iggy_protocol_provider_test.cc
delete mode 100644 foreign/cpp/tests/unit/model_test.cc
delete mode 100644 foreign/cpp/tests/unit/serialization_test.cc
delete mode 100644 foreign/cpp/tests/unit/ssl_test.cc
delete mode 100644 foreign/cpp/tests/unit/unit_testutils.cc
delete mode 100644 foreign/cpp/tests/unit/unit_testutils.h
delete mode 100644 foreign/cpp/vcpkg-configuration.json
delete mode 100644 foreign/cpp/vcpkg.json
create mode 100755 scripts/ci/python-version-sync.sh
