This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch simulator
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 1b799401e simulator v1
add 8827588e8 feat(java): improve tests and clean up json mappings (#2658)
add 4f91d7d89 feat(java): add gradle wrapper with jar file autofetch
(#2659)
add e5cf2d2f4 feat(connectors): add connector version to stats endpoint
(#2660)
add c51e45f85 feat(integration): add iggy_harness proc macro and use it in
mcp tests (#2635)
add f774d9eda feat(server,sdk): add reserved u64 to iggy message header
(#2657)
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 43d2dd5a1 ci: unify publishing via workflow_call in publish.yml (#2655)
add 15d2f1572 ci: add pre-commit hooks for all SDKs (#2676)
add f1ff99a07 ci(rust): replace sccache with Swatinem/rust-cache (#2679)
add 7db7eeae1 feat(cluster): add `Partitions` trait that unifies both
single-node and VSR operations (#2620)
add 83f5d15ab ci(rust): add code coverage reporting with Codecov (#2677)
add 202fda739 fix(server): properly cleanup messages in message cleaner
(#2670)
add eccd4718f chore: update coverage badge (#2680)
add ff2da261b fix(ci): fix example jobs, pin images (#2681)
add d98176a36 fix(server): memory leak in segment rotation (#2686)
add 4052619bf refactor(integration): remove legacy test infrastructure
(#2678)
add 7f280adc3 Merge branch 'master' into simulator
No new revisions were added by this update.
Summary of changes:
.github/actions/csharp-dotnet/pre-merge/action.yml | 3 -
.github/actions/go/pre-merge/action.yml | 33 +-
.github/actions/java-gradle/post-merge/action.yml | 18 +-
.github/actions/java-gradle/pre-merge/action.yml | 13 +-
.github/actions/node-npm/pre-merge/action.yml | 11 +-
.../actions/python-maturin/pre-merge/action.yml | 27 +-
.github/actions/rust/post-merge/action.yml | 2 -
.github/actions/rust/pre-merge/action.yml | 40 +-
.../actions/utils/setup-go-with-cache/action.yml | 2 +-
.../actions/utils/setup-java-with-cache/action.yml | 21 +-
.../actions/utils/setup-rust-with-cache/action.yml | 213 +-
.github/workflows/_build_python_wheels.yml | 3 -
.github/workflows/_build_rust_artifacts.yml | 12 +-
.github/workflows/_common.yml | 21 +-
.github/workflows/_publish_rust_crates.yml | 3 -
.github/workflows/_test.yml | 19 +-
.github/workflows/_test_bdd.yml | 5 +-
.github/workflows/_test_examples.yml | 18 +-
.github/workflows/post-merge.yml | 502 +---
.github/workflows/pre-merge.yml | 4 +-
.github/workflows/publish.yml | 171 +-
.pre-commit-config.yaml | 115 +-
Cargo.lock | 84 +-
Cargo.toml | 10 +-
DEPENDENCIES.md | 37 +-
README.md | 2 +-
bdd/go/go.sum | 4 -
bdd/go/tests/basic_messaging_test.go | 32 +-
bdd/go/tests/tcp_test/consumers_steps.go | 8 +-
bdd/go/tests/tcp_test/stream_feature_create.go | 20 +-
bdd/go/tests/tcp_test/stream_feature_get_by_id.go | 8 +-
bdd/go/tests/tcp_test/stream_steps.go | 2 +-
bdd/go/tests/tcp_test/topic_steps.go | 8 +-
bdd/java/.gitignore | 3 +
bdd/java/Dockerfile | 12 +-
bdd/java/gradle/wrapper/gradle-wrapper.properties | 7 +
bdd/java/gradlew | 297 +++
bdd/python/tests/conftest.py | 5 +-
bdd/python/tests/test_basic_messaging.py | 96 +-
bdd/rust/Cargo.toml | 1 -
bdd/rust/tests/helpers/cluster.rs | 19 +-
bdd/rust/tests/steps/auth.rs | 26 +-
bdd/rust/tests/steps/leader_redirection.rs | 6 +-
bdd/go/Dockerfile => codecov.yml | 43 +-
core/ai/mcp/Cargo.toml | 3 +-
core/ai/mcp/src/api.rs | 64 +-
core/bench/Cargo.toml | 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/binary_protocol/Cargo.toml | 2 +-
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/common/src/error/iggy_error.rs | 2 +
core/common/src/types/message/iggy_message.rs | 1 +
core/common/src/types/message/message_header.rs | 142 +-
.../src/types/message/message_header_view.rs | 8 +
core/common/src/utils/duration.rs | 2 +-
.../configs/src/configs_impl/typed_env_provider.rs | 1 +
core/connectors/README.md | 2 +-
core/connectors/runtime/Cargo.toml | 2 +-
core/connectors/runtime/README.md | 51 +
core/connectors/runtime/src/context.rs | 2 +
core/connectors/runtime/src/main.rs | 4 +
core/connectors/runtime/src/manager/sink.rs | 1 +
core/connectors/runtime/src/manager/source.rs | 1 +
core/connectors/runtime/src/sink.rs | 13 +
core/connectors/runtime/src/source.rs | 13 +
core/connectors/runtime/src/stats.rs | 14 +
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sdk/README.md | 4 +-
core/connectors/sdk/src/sink.rs | 7 +
core/connectors/sdk/src/source.rs | 7 +
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
.../sources/elasticsearch_source/Cargo.toml | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/Cargo.toml | 2 +-
core/{configs_derive => harness_derive}/Cargo.toml | 4 +-
core/harness_derive/src/attrs.rs | 750 ++++++
core/harness_derive/src/codegen.rs | 826 ++++++
core/harness_derive/src/lib.rs | 94 +
core/harness_derive/src/params.rs | 257 ++
core/integration/.gitignore | 1 -
core/integration/Cargo.toml | 10 +-
core/integration/src/bench_utils.rs | 20 +-
core/integration/src/file.rs | 32 -
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/client_builder.rs | 350 +++
.../src/harness/handle/connectors_runtime.rs | 37 +-
core/integration/src/harness/handle/mcp.rs | 29 +-
core/integration/src/harness/handle/mod.rs | 4 +-
core/integration/src/harness/handle/server.rs | 408 ++-
core/integration/src/harness/helpers.rs | 5 +-
core/integration/src/harness/mod.rs | 8 +-
.../src/harness/orchestrator/builder.rs | 186 +-
.../src/harness/orchestrator/harness.rs | 335 +--
core/integration/src/harness/port_reserver.rs | 30 +
core/integration/src/http_client.rs | 52 -
core/integration/src/lib.rs | 26 +-
core/integration/src/quic_client.rs | 55 -
core/integration/src/tcp_client.rs | 82 -
core/integration/src/test_connectors_runtime.rs | 266 --
core/integration/src/test_mcp_server.rs | 274 --
core/integration/src/test_server.rs | 769 ------
core/integration/src/test_tls_utils.rs | 52 -
core/integration/src/websocket_client.rs | 76 -
core/integration/tests/cli/common/mod.rs | 72 +-
.../tests/cli/context/test_context_applied.rs | 8 +-
.../tests/cli/system/test_me_command.rs | 10 +-
.../tests/cluster/mod.rs} | 30 +-
core/integration/tests/config_provider/mod.rs | 16 +-
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 | 396 +++
.../tests/connectors/fixtures/quickwit/mod.rs | 4 +-
.../connectors}/fixtures/wiremock.rs | 19 +-
.../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 | 279 +-
core/integration/tests/connectors/random/mod.rs | 9 -
.../tests/connectors/random/random_source.rs | 32 +-
.../data_integrity/verify_after_server_restart.rs | 171 +-
core/integration/tests/mcp/mod.rs | 920 ++++---
core/integration/tests/mod.rs | 105 +-
core/integration/tests/sdk/producer/background.rs | 195 +-
core/integration/tests/server/cg.rs | 67 +-
.../tests/server/concurrent_addition.rs | 55 +-
core/integration/tests/server/general.rs | 157 +-
core/integration/tests/server/message_cleanup.rs | 124 +
core/integration/tests/server/message_retrieval.rs | 112 +-
core/integration/tests/server/mod.rs | 132 +-
.../server/scenarios/authentication_scenario.rs | 10 +-
.../tests/server/scenarios/bench_scenario.rs | 25 +-
.../tests/server/scenarios/concurrent_scenario.rs | 101 +-
...umer_group_auto_commit_reconnection_scenario.rs | 14 +-
.../scenarios/consumer_group_join_scenario.rs | 19 +-
.../consumer_group_offset_cleanup_scenario.rs | 12 +-
...h_multiple_clients_polling_messages_scenario.rs | 18 +-
...with_single_client_polling_messages_scenario.rs | 12 +-
.../consumer_timestamp_polling_scenario.rs | 12 +-
.../server/scenarios/create_message_payload.rs | 12 +-
.../scenarios/cross_protocol_pat_scenario.rs | 133 +-
.../tests/server/scenarios/encryption_scenario.rs | 91 +-
.../server/scenarios/log_rotation_scenario.rs | 71 +-
.../server/scenarios/message_cleanup_scenario.rs | 588 +++++
.../server/scenarios/message_headers_scenario.rs | 12 +-
.../server/scenarios/message_size_scenario.rs | 12 +-
core/integration/tests/server/scenarios/mod.rs | 11 +-
.../tests/server/scenarios/offset_scenario.rs | 11 +-
.../tests/server/scenarios/permissions_scenario.rs | 159 +-
.../scenarios/read_during_persistence_scenario.rs | 65 +-
.../scenarios/segment_rotation_race_scenario.rs | 83 +-
.../scenarios/single_message_per_batch_scenario.rs | 11 +-
.../tests/server/scenarios/snapshot_scenario.rs | 13 +-
.../stale_client_consumer_group_scenario.rs | 50 +-
.../scenarios/stream_size_validation_scenario.rs | 13 +-
.../tests/server/scenarios/system_scenario.rs | 18 +-
.../tests/server/scenarios/tcp_tls_scenario.rs | 4 +-
.../tests/server/scenarios/timestamp_scenario.rs | 11 +-
.../tests/server/scenarios/user_scenario.rs | 10 +-
.../server/scenarios/websocket_tls_scenario.rs | 4 +-
core/integration/tests/server/specific.rs | 303 +--
core/partitions/src/lib.rs | 127 +-
core/partitions/src/types.rs | 122 +-
core/sdk/Cargo.toml | 2 +-
core/server/Cargo.toml | 2 +-
core/server/config.toml | 66 +-
core/server/src/bootstrap.rs | 19 +-
core/server/src/configs/defaults.rs | 3 +-
core/server/src/configs/displays.rs | 8 +-
core/server/src/configs/system.rs | 9 +-
core/server/src/configs/validators.rs | 110 +-
core/server/src/shard/system/messages.rs | 9 +-
core/server/src/shard/system/partitions.rs | 6 +-
core/server/src/shard/system/segments.rs | 45 +-
.../src/shard/tasks/periodic/message_cleaner.rs | 224 +-
core/server/src/streaming/segments/segment.rs | 31 +-
.../server/src/websocket/websocket_tls_listener.rs | 2 +-
examples/go/getting-started/consumer/main.go | 8 +-
examples/go/getting-started/producer/main.go | 14 +-
examples/java/.gitignore | 3 +
examples/java/README.md | 24 +-
.../java/gradle/wrapper/gradle-wrapper.properties | 7 +
examples/java/gradlew | 297 +++
.../producer/MessageEnvelopeProducer.java | 4 +-
examples/node/package-lock.json | 774 +++---
examples/node/package.json | 2 +-
examples/node/src/basic/producer.ts | 120 +-
examples/node/src/getting-started/producer.ts | 88 +-
examples/node/src/message-headers/producer.ts | 75 +-
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 -
.../Iggy_SDK.Tests.Integration/StreamsTests.cs | 4 +-
.../Iggy_SDK.Tests.Integration/TopicsTests.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs | 7 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 14 +-
foreign/csharp/Iggy_SDK/Messages/Message.cs | 4 +-
foreign/csharp/Iggy_SDK/Messages/MessageHeader.cs | 5 +
.../Iggy_SDK/Utils/TcpMessageStreamHelpers.cs | 2 +-
.../csharp/Iggy_SDK_Tests/Utils/BinaryFactory.cs | 5 +-
.../go/benchmarks/send_messages_benchmark_test.go | 12 +-
.../binary_request_serializer.go | 146 +-
.../create_stream_serializer.go | 16 +-
.../create_stream_serializer_test.go | 2 +-
.../create_topic_serializer.go | 2 +-
.../fetch_messages_request_serializer.go | 30 +-
.../send_messages_request_serializer_test.go | 2 +-
foreign/go/contracts/consumer.go | 2 +-
foreign/go/contracts/consumer_groups.go | 6 +-
foreign/go/contracts/message_header.go | 8 +-
foreign/go/iggycli/client.go | 34 +-
foreign/go/samples/consumer/consumer.go | 20 +-
foreign/go/samples/producer/producer.go | 20 +-
foreign/go/tcp/tcp_consumer_group_managament.go | 6 +-
foreign/go/tcp/tcp_stream_managament.go | 2 +-
foreign/go/tcp/tcp_topic_managament.go | 2 +-
foreign/java/.gitignore | 3 +
foreign/java/BUILD_AND_TEST.md | 36 +-
foreign/java/README.md | 26 +-
.../java/dev-support/checkstyle/suppressions.xml | 3 +
.../iggy/connector/flink/sink/IggySinkWriter.java | 11 +-
foreign/java/gradle.properties | 2 +-
.../java/gradle/wrapper/gradle-wrapper.properties | 7 +
foreign/java/gradlew | 297 +++
.../blocking/http/MessageMixin.java} | 32 +-
.../client/blocking/http/ObjectMapperFactory.java | 11 +-
.../blocking/http}/UserHeadersSerializer.java | 4 +-
.../java/org/apache/iggy/message/HeaderKey.java | 34 +-
.../java/org/apache/iggy/message/HeaderKind.java | 16 -
.../java/org/apache/iggy/message/HeaderValue.java | 74 +-
.../main/java/org/apache/iggy/message/Message.java | 39 +-
.../org/apache/iggy/message/MessageHeader.java | 6 +-
.../java/org/apache/iggy/message/Partitioning.java | 6 +-
.../org/apache/iggy/serde/Base64Serializer.java | 35 -
.../org/apache/iggy/serde/BytesDeserializer.java | 5 +-
.../org/apache/iggy/serde/BytesSerializer.java | 1 +
.../java/org/apache/iggy/user/Permissions.java | 7 +-
.../org/apache/iggy/user/StreamPermissions.java | 5 +-
.../iggy/client/blocking/IntegrationTest.java | 6 +
.../blocking/http/HeaderKindSerializationTest.java | 120 +
.../client/blocking/http/ObjectMapperTest.java | 289 +++
.../client/blocking/tcp/BytesSerializerTest.java | 9 +-
.../apache/iggy/serde/BytesDeserializerTest.java | 79 +-
foreign/node/package-lock.json | 4 +-
foreign/node/package.json | 4 +-
foreign/node/src/wire/message/iggy-header.utils.ts | 35 +-
.../src/wire/message/send-messages.command.test.ts | 2 +-
foreign/python/Cargo.toml | 4 +-
foreign/python/apache_iggy.pyi | 3 +-
foreign/python/pyproject.toml | 2 +-
foreign/python/src/client.rs | 15 +-
foreign/python/src/send_message.rs | 1 +
scripts/ci/python-version-sync.sh | 205 ++
scripts/run-java-examples-from-readme.sh | 4 +-
.../lib/components/Layouts/SettingsLayout.svelte | 20 +-
.../lib/components/Modals/InspectMessage.svelte | 6 +-
web/src/lib/components/Navbar.svelte | 24 +-
web/src/routes/auth/sign-in/+page.svelte | 2 +-
.../[partitionId=i32]/messages/+page.svelte | 6 +-
349 files changed, 10529 insertions(+), 15392 deletions(-)
create mode 100644 bdd/java/gradle/wrapper/gradle-wrapper.properties
create mode 100755 bdd/java/gradlew
copy bdd/go/Dockerfile => codecov.yml (56%)
copy core/{configs_derive => harness_derive}/Cargo.toml (93%)
create mode 100644 core/harness_derive/src/attrs.rs
create mode 100644 core/harness_derive/src/codegen.rs
create mode 100644 core/harness_derive/src/lib.rs
create mode 100644 core/harness_derive/src/params.rs
delete mode 100644 core/integration/.gitignore
delete mode 100644 core/integration/src/file.rs
rename core/integration/src/harness/{fixtures/mod.rs => fixture.rs} (79%)
delete mode 100644 core/integration/src/harness/fixtures/random.rs
create mode 100644 core/integration/src/harness/handle/client_builder.rs
delete mode 100644 core/integration/src/http_client.rs
delete mode 100644 core/integration/src/quic_client.rs
delete mode 100644 core/integration/src/tcp_client.rs
delete mode 100644 core/integration/src/test_connectors_runtime.rs
delete mode 100644 core/integration/src/test_mcp_server.rs
delete mode 100644 core/integration/src/test_server.rs
delete mode 100644 core/integration/src/test_tls_utils.rs
delete mode 100644 core/integration/src/websocket_client.rs
copy core/{sdk/src/http/cluster.rs => integration/tests/cluster/mod.rs} (55%)
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
(92%)
create mode 100644 core/integration/tests/server/message_cleanup.rs
create mode 100644
core/integration/tests/server/scenarios/message_cleanup_scenario.rs
create mode 100644 examples/java/gradle/wrapper/gradle-wrapper.properties
create mode 100755 examples/java/gradlew
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 100644 foreign/java/gradle/wrapper/gradle-wrapper.properties
create mode 100755 foreign/java/gradlew
copy
foreign/java/java-sdk/src/main/java/org/apache/iggy/{serde/UserHeadersSerializer.java
=> client/blocking/http/MessageMixin.java} (55%)
rename foreign/java/java-sdk/src/main/java/org/apache/iggy/{serde =>
client/blocking/http}/UserHeadersSerializer.java (92%)
delete mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/serde/Base64Serializer.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/http/HeaderKindSerializationTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/blocking/http/ObjectMapperTest.java
create mode 100755 scripts/ci/python-version-sync.sh
