This is an automated email from the ASF dual-hosted git repository.
slbotbm pushed a change to branch cpp-high-level-client-1
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 3659271e9 fix tests
omit 2913cdca8 remove dead code
omit 7b4c7376f fix shit
omit 2128529b4 additional fix
omit 9dfe91fbe align rust and cpp topic create and update surfaces
omit 3716c0bcf fix topic.cpp
omit b461980f6 add stream, topic, and partition functions to high level
client.
add 412014a7b docs(simulator): add a README for the deterministic harness
(#4047)
add 7f0bc26d1 chore(deps): Bump the node group across 2 directories with 3
updates (#4052)
add 02f844f4c chore(deps): Bump the web group across 1 directory with 3
updates (#4051)
add 3cfc7df0d test(java): boot the edge server consistently in both Java
suites (#4054)
add b44724213 fix(cluster): serve metadata reads at or above the client's
own writes (#4024)
add 39c1bd0a5 fix(partitions): reserve offsets before confirming them
(#3975)
add be2265c9e refactor(server): make dispatch routing and failure paths
explicit (#4036)
add bc9ef0c3f fix(connectors): warn when the runtime API is exposed
without a key (#3804)
add 9914f5a81 fix(shard): drive partition repair and the commit walk from
the tick (#4006)
add 40be16846 chore(deps): Bump github.com/onsi/gomega from 1.42.1 to
1.43.0 in /bdd/go in the go group across 1 directory (#4057)
add 63d3273b7 feat(ci): add /pin and /unpin triage commands (#4060)
add 6c47193fe docs: say where a closed PR's findings go, and fix the stale
timing (#4059)
add 59a9508cd ci(python): restore Windows wheels for the PyPI release
(#4049)
add 7b78014c9 fix(csharp): update string length validation to use UTF-8
byte count (#4072)
add 25e9d44dd fix(go): update MaxPayloadSize from 10 MB to 64 MB to match
size update in rust message construction (#4080)
add cb57ce2bd fix(connectors): validate protobuf field lengths
consistently (#4069)
add 3462fed5c fix(shard): widen partition repair when a view-adopted
suffix is missing bodies (#4074)
add 64b0bae71 feat(python): expose get_stats on IggyClient (#4018)
add 08ff476f6 docs: add AI assistance expectations to CONTRIBUTING (#4081)
add 9a7ead986 perf(node, csharp, java, go): generate message ids from
random bytes instead of via UUIDs (#4076)
add 227786432 fix(shard): drive metadata repair and the commit walk from
the tick (#4008)
add 0bdd8c6ca fix(partitions): bound consumer offset state per partition
(#4063)
add add0bd967 feat(python): add QuicConfig transport configuration (#3991)
add 03ca396bb feat(python): add stream listing, update, delete, and purge
(#3701)
add b87b6a6f7 fix(java): size wire strings by UTF-8 byte length, not char
count (#4068)
add ab734f17f fix(connectors): validate connector key before it becomes a
path (#4083)
add 06a12e306 chore: add Iggy banner to server startup (#4085)
add bd1a873fe feat(python): add HttpConfig transport configuration (#3992)
add 1004eee2d ci(connectors): run a plugin's integration suite when it
changes (#4077)
add be3663805 feat(python): support message partitioning strategies (#3927)
add 3c1a8ccf6 feat(python): add WebSocketConfig transport configuration
(#4000)
add 6c07954a0 chore(deps): Bump the csharp group with 1 update (#4087)
add a71ed7420 fix(metadata): roll deleted partitions and topics out of
parent stats (#4046)
add 2e3823196 feat(connectors): add RabbitMQ sink (#3973)
add a2a4a2cb9 fix(consensus): keep a replica off a hole in its committed
prefix (#4073)
add 8dde7e7f6 feat(java): let TCP clients run one I/O thread or share a
group (#4096)
add 422810f82 chore(deps): Bump the java group across 3 directories with 1
update (#4098)
add 6d894501b chore(deps): Bump the github-actions group with 3 updates
(#4099)
add 8b75646fd add stream, topic, and partition functions to high level
client.
add 8722c485b fix topic.cpp
add a873ba484 align rust and cpp topic create and update surfaces
add 5b05eb595 additional fix
add b8ade4ccb fix shit
add 521e88760 remove dead code
add b10026978 fix tests
add 4f3b0827b improvements
add d1a6e33f2 add [[nodiscard]]
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (3659271e9)
\
N -- N -- N refs/heads/cpp-high-level-client-1 (d1a6e33f2)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../actions/python-maturin/pre-merge/action.yml | 25 +-
.github/actions/rust/pre-merge/action.yml | 51 +-
.github/workflows/_build_python_wheels.yml | 78 +-
.github/workflows/_build_rust_artifacts.yml | 2 +-
.github/workflows/_common.yml | 4 +-
.github/workflows/coverage-baseline.yml | 19 +-
.github/workflows/edge-release.yml | 3 +-
.github/workflows/post-merge.yml | 2 +-
.github/workflows/pr-triage-apply.yml | 106 +-
CONTRIBUTING.md | 33 +-
Cargo.lock | 1517 ++++--
Cargo.toml | 18 +-
bdd/go/go.mod | 2 +-
bdd/go/go.sum | 4 +-
bdd/go/tests/tcp_test/offset_feature_delete.go | 21 +-
.../tests/tcp_test/offset_feature_deserialize.go | 9 +-
bdd/java/build.gradle.kts | 2 +-
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 10 +-
bdd/python/pylock.toml | 346 +-
bdd/python/uv.lock | 4 +-
bdd/rust/tests/steps/streams.rs | 31 +-
core/ai/mcp/Cargo.toml | 2 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/frontend/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/bench/report/Cargo.toml | 2 +-
core/bench/report/src/types/server_stats.rs | 2 +-
core/bench/src/benchmarks/common.rs | 10 +-
core/binary_protocol/Cargo.toml | 2 +-
core/binary_protocol/src/primitives/ack_level.rs | 9 +-
.../consumer_offsets/delete_consumer_offset.rs | 4 +-
.../consumer_offsets/store_consumer_offset.rs | 4 +-
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/common/src/error/iggy_error.rs | 10 +
core/common/src/traits/consumer_offset_client.rs | 7 +
core/common/src/traits/message_client.rs | 10 +
.../websocket_config/websocket_client_config.rs | 75 +-
core/common/src/types/stats/mod.rs | 2 +-
core/common/src/types/streaming_stats.rs | 367 +-
core/configs/src/server_config/cluster.rs | 56 +-
core/configs/src/server_config/defaults.rs | 10 +
core/configs/src/server_config/displays.rs | 11 +-
core/configs/src/server_config/partition.rs | 181 +
core/connectors/README.md | 1 +
core/connectors/runtime/README.md | 101 +-
core/connectors/runtime/config.toml | 9 +-
core/connectors/runtime/example_config/config.toml | 9 +-
.../example_config/connectors/rabbitmq_sink.toml} | 32 +-
core/connectors/runtime/src/api/config.rs | 111 +-
core/connectors/runtime/src/api/error.rs | 15 +-
.../mod.rs => connectors/runtime/src/api/key.rs} | 35 +-
core/connectors/runtime/src/api/mod.rs | 574 +-
core/connectors/runtime/src/api/sink.rs | 44 +-
core/connectors/runtime/src/api/source.rs | 44 +-
core/connectors/runtime/src/configs/connectors.rs | 182 +-
.../src/configs/connectors/http_provider.rs | 12 +-
.../src/configs/connectors/local_provider.rs | 50 +-
core/connectors/runtime/src/error.rs | 6 +
core/connectors/runtime/src/main.rs | 30 +-
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sdk/src/decoders/proto.rs | 135 +-
core/connectors/sinks/README.md | 1 +
.../Cargo.toml | 20 +-
core/connectors/sinks/rabbitmq_sink/README.md | 50 +
.../config.toml | 29 +-
core/connectors/sinks/rabbitmq_sink/src/lib.rs | 783 +++
core/consensus/src/impls.rs | 444 +-
core/consensus/src/observability.rs | 22 +
core/consensus/src/plane_helpers.rs | 169 +-
core/consensus/src/vsr_state.rs | 160 +-
core/integration/Cargo.toml | 5 +
core/integration/src/harness/disk.rs | 33 +-
.../tests/cluster/consumer_offset_quota.rs | 357 ++
.../tests/cluster/crash_offset_reuse.rs | 446 +-
core/integration/tests/cluster/mod.rs | 1 +
.../tests/cluster/parked_frame_redispatch.rs | 19 +-
core/integration/tests/connectors/api/endpoints.rs | 104 +
.../api/{config.toml => key_validation.toml} | 4 +-
core/integration/tests/connectors/fixtures/mod.rs | 6 +
.../connectors/fixtures/rabbitmq/container.rs | 327 ++
.../fixtures/{clickhouse => rabbitmq}/mod.rs | 5 +-
.../tests/connectors/fixtures/rabbitmq/sink.rs | 273 +
core/integration/tests/connectors/mod.rs | 1 +
.../tests/connectors/{quickwit => rabbitmq}/mod.rs | 2 +-
.../tests/connectors/rabbitmq/rabbitmq_sink.rs | 429 ++
.../tests/connectors/{delta => rabbitmq}/sink.toml | 2 +-
.../tests/data_integrity/storage_compat.rs | 146 +-
.../data_integrity/verify_after_server_restart.rs | 52 +
.../tests/server/consumer_offset_quota_vsr.rs | 514 ++
core/integration/tests/server/general.rs | 14 +-
core/integration/tests/server/http_client.rs | 75 +-
.../tests/server/http_read_your_writes.rs | 219 +
core/integration/tests/server/http_view_header.rs | 71 +-
core/integration/tests/server/http_vsr.rs | 98 +
core/integration/tests/server/legacy_login_vsr.rs | 53 +-
core/integration/tests/server/mod.rs | 11 +
.../integration/tests/server/poll_semantics_vsr.rs | 57 +-
core/integration/tests/server/raw_tcp.rs | 212 +
.../scenarios/delete_stats_rollback_scenario.rs | 225 +
core/integration/tests/server/scenarios/mod.rs | 137 +-
.../server/scenarios/purge_delete_scenario.rs | 26 +-
.../scenarios/stream_size_validation_scenario.rs | 140 +-
core/integration/tests/server/unknown_code_vsr.rs | 92 +
core/journal/src/superblock.rs | 4 +-
core/message_bus/src/lib.rs | 2 +-
core/metadata/src/applied_frontier.rs | 400 ++
core/metadata/src/impls/metadata.rs | 275 +-
core/metadata/src/impls/recovery.rs | 1 +
core/metadata/src/lib.rs | 5 +
core/metadata/src/stm/stream.rs | 899 ++-
core/metadata/src/stm/user.rs | 4 +-
core/partitions/Cargo.toml | 8 +
core/partitions/src/consumer_offset_capacity.rs | 717 +++
core/partitions/src/iggy_partition.rs | 5703 +++++++++++++++++---
core/partitions/src/iggy_partitions.rs | 51 +-
core/partitions/src/journal.rs | 105 +-
core/partitions/src/lib.rs | 41 +-
core/partitions/src/log.rs | 27 +-
core/partitions/src/offset_storage.rs | 197 +-
core/partitions/src/poll_plan.rs | 352 +-
core/partitions/src/segment_anchor.rs | 329 ++
core/partitions/src/state_transfer.rs | 764 ++-
core/partitions/src/types.rs | 33 +
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/consumer.rs | 32 +-
core/sdk/src/leader_aware.rs | 25 +
core/sdk/src/prelude.rs | 6 +-
core/sdk/src/quic/quic_client.rs | 14 +-
core/sdk/src/tcp/tcp_client.rs | 27 +-
core/sdk/src/websocket/websocket_client.rs | 14 +-
core/server/Cargo.toml | 2 +-
core/server/config.toml | 90 +-
core/server/src/banner.rs | 80 +
core/server/src/boot/mod.rs | 159 +-
core/server/src/boot/recovery.rs | 211 +-
core/server/src/boot/threads.rs | 604 ++-
core/server/src/consumer_group.rs | 46 +-
core/server/src/dispatch/authz.rs | 309 +-
core/server/src/dispatch/failure.rs | 629 +++
core/server/src/dispatch/mod.rs | 1701 +++---
core/server/src/dispatch/partition.rs | 948 +++-
core/server/src/dispatch/reads.rs | 510 +-
core/server/src/dispatch/session_ops.rs | 283 +-
core/server/src/dispatch/submit.rs | 116 +
core/server/src/dispatch/test_support.rs | 14 +-
core/server/src/http.rs | 1 +
core/server/src/http/error.rs | 26 +-
core/server/src/http/extractor.rs | 4 +-
core/server/src/http/forward.rs | 59 +-
core/server/src/http/handlers.rs | 162 +-
core/server/src/http/metrics.rs | 71 +-
core/server/src/http/reads.rs | 281 +-
core/server/src/http/reply.rs | 30 +-
core/server/src/http/session.rs | 12 +-
core/server/src/http/state.rs | 128 +-
core/server/src/http/submit.rs | 50 +-
core/server/src/lib.rs | 2 +
core/server/src/main.rs | 2 +
core/server/src/offset_recovery.rs | 354 +-
core/server/src/partition_helpers.rs | 541 +-
core/server/src/partition_reconciler.rs | 747 ++-
core/server/src/responses.rs | 220 +-
core/server/src/rewrite.rs | 570 ++
core/server/src/segment_recovery.rs | 390 +-
core/server/src/server_error.rs | 36 +
core/server/src/session_manager.rs | 230 +-
core/server/src/shell.rs | 13 +
core/shard/src/lib.rs | 3036 ++++++++++-
core/shard/src/metrics.rs | 263 +-
core/shard/src/router.rs | 20 +
core/simulator/Cargo.toml | 4 +
core/simulator/README.md | 236 +
core/simulator/src/bin/workload-fuzz.rs | 44 +-
core/simulator/src/client.rs | 92 +-
core/simulator/src/deps.rs | 14 +
core/simulator/src/lib.rs | 2404 ++++++++-
core/simulator/src/replica.rs | 11 +-
core/simulator/src/workload/effect.rs | 2 +-
core/simulator/src/workload/invariants.rs | 164 +-
core/simulator/src/workload/oracle.rs | 14 +
core/simulator/src/workload/shadow.rs | 2 +-
core/simulator/src/workload/state_checker.rs | 170 +-
examples/java/build.gradle.kts | 2 +-
.../apache/iggy/examples/async/AsyncConsumer.java | 3 +-
examples/node/package-lock.json | 10 +-
examples/node/package.json | 2 +-
examples/python/README.md | 2 +-
examples/python/basic/producer.py | 8 +-
examples/python/getting-started/consumer.py | 42 +-
examples/python/getting-started/producer.py | 42 +-
examples/python/pylock.toml | 81 +-
examples/python/uv.lock | 4 +-
foreign/cpp/include/iggy.hpp | 665 ++-
foreign/cpp/src/client.cpp | 36 +-
foreign/cpp/src/client.rs | 15 +-
foreign/cpp/tests/e2e/stream.cpp | 17 +
foreign/cpp/tests/unit/unit_tests.cpp | 122 +-
foreign/csharp/Directory.Packages.props | 2 +-
foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs | 65 +-
foreign/csharp/Iggy_SDK/Extensions/Extensions.cs | 8 +-
foreign/csharp/Iggy_SDK/Headers/HeaderKey.cs | 17 +-
foreign/csharp/Iggy_SDK/Headers/HeaderValue.cs | 12 +-
foreign/csharp/Iggy_SDK/Identifier.cs | 56 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyStream.cs | 2 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs | 4 +-
.../Implementations/HttpMessageStream.cs | 2 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
foreign/csharp/Iggy_SDK/Kinds/Partitioning.cs | 46 +-
.../Iggy_SDK/Utils/TcpMessageStreamHelpers.cs | 5 +-
foreign/csharp/Iggy_SDK/Utils/WireName.cs | 53 +
.../ContractsTests/WireNameLengthContractsTests.cs | 217 +
.../UtilityTests/HeaderValueTests.cs | 7 +
.../IdentifiersByteSerializationTests.cs | 131 +
foreign/go/contracts/messages.go | 4 +-
foreign/go/contracts/version.go | 2 +-
foreign/go/errors/errors.yaml | 4 +
foreign/go/errors/errors_gen.go | 17 +
foreign/go/errors/errors_test.go | 19 +
foreign/go/internal/command/message.go | 9 +-
foreign/java/README.md | 30 +
.../connector/pinot/IggyPinotIntegrationTest.java | 21 +-
foreign/java/gradle/libs.versions.toml | 2 +-
.../apache/iggy/client/async/MessagesClient.java | 2 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 32 +-
.../async/tcp/AsyncIggyTcpClientBuilder.java | 79 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 88 +-
.../client/async/tcp/ConsumerGroupsTcpClient.java | 10 +-
.../async/tcp/PersonalAccessTokensTcpClient.java | 14 +-
.../iggy/client/async/tcp/StreamsTcpClient.java | 22 +-
.../iggy/client/async/tcp/TopicsTcpClient.java | 4 +-
.../iggy/client/async/tcp/UsersTcpClient.java | 46 +-
.../iggy/client/async/tcp/vsr/VsrLoginCodec.java | 58 +-
.../client/blocking/tcp/IggyTcpClientBuilder.java | 31 +
.../org/apache/iggy/exception/IggyErrorCode.java | 3 +
.../org/apache/iggy/identifier/Identifier.java | 32 +-
.../main/java/org/apache/iggy/message/Message.java | 3 +-
.../java/org/apache/iggy/message/Partitioning.java | 42 +-
.../org/apache/iggy/serde/BytesSerializer.java | 41 +-
.../org/apache/iggy/serde/MessageIdGenerator.java | 74 +
.../apache/iggy/client/BaseIntegrationTest.java | 32 +-
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 94 +
.../tcp/AsyncIggyTcpClientEventLoopGroupTest.java | 464 ++
.../tcp/AsyncTcpConnectionConcurrencyTest.java | 4 +
.../client/async/tcp/vsr/VsrLoginCodecTest.java | 159 +
.../client/blocking/tcp/BytesSerializerTest.java | 109 +-
.../client/blocking/tcp/MessagesTcpClientTest.java | 35 +
.../client/blocking/tcp/StreamTcpClientTest.java | 24 +
.../apache/iggy/exception/IggyErrorCodeTest.java | 1 +
.../org/apache/iggy/identifier/IdentifierTest.java | 49 +
.../java/org/apache/iggy/message/MessageTest.java | 9 +
.../org/apache/iggy/message/PartitioningTest.java | 60 +
.../apache/iggy/serde/MessageIdGeneratorTest.java | 80 +
foreign/node/package-lock.json | 146 +-
foreign/node/package.json | 4 +-
foreign/node/src/wire/error.code.test.ts | 4 +
foreign/node/src/wire/error.code.ts | 1 +
.../node/src/wire/message/message.utils.test.ts | 129 +
foreign/node/src/wire/message/message.utils.ts | 44 +-
foreign/node/src/wire/number.utils.test.ts | 67 +
foreign/node/src/wire/number.utils.ts | 25 +-
foreign/python/Cargo.toml | 4 +-
foreign/python/README.md | 38 +-
foreign/python/apache_iggy.pyi | 910 +++-
foreign/python/docker-compose.test.yml | 2 +
foreign/python/pylock.toml | 37 +-
foreign/python/pyproject.toml | 4 +-
foreign/python/src/client.rs | 306 +-
foreign/python/src/config.rs | 1162 +++-
foreign/python/src/duration.rs | 33 +
foreign/python/src/lib.rs | 22 +-
foreign/python/src/options.rs | 2 +
foreign/python/src/partitioning.rs | 105 +
foreign/python/src/stats.rs | 449 ++
foreign/python/src/stream.rs | 78 +-
foreign/python/src/topic.rs | 19 +
foreign/python/tests/conftest.py | 27 +-
foreign/python/tests/test_client_config.py | 4 +-
foreign/python/tests/test_connectivity.py | 2 +-
foreign/python/tests/test_http_config.py | 363 ++
foreign/python/tests/test_message_operations.py | 137 +
foreign/python/tests/test_quic_config.py | 494 ++
foreign/python/tests/test_stats.py | 250 +
foreign/python/tests/test_stream.py | 444 +-
foreign/python/tests/test_websocket_config.py | 522 ++
foreign/python/tests/utils.py | 55 +-
foreign/python/uv.lock | 28 +-
licenserc.toml | 1 +
scripts/bump-version.sh | 2 +-
scripts/ci/storage-compat.sh | 17 +
scripts/ci/sync-python-interpreter-version.sh | 87 +-
web/package-lock.json | 140 +-
web/package.json | 6 +-
294 files changed, 40151 insertions(+), 5941 deletions(-)
copy core/connectors/{sinks/mongodb_sink/config.toml =>
runtime/example_config/connectors/rabbitmq_sink.toml} (68%)
copy core/{integration/tests/connectors/postgres/mod.rs =>
connectors/runtime/src/api/key.rs} (50%)
copy core/connectors/sinks/{elasticsearch_sink => rabbitmq_sink}/Cargo.toml
(80%)
create mode 100644 core/connectors/sinks/rabbitmq_sink/README.md
copy core/connectors/sinks/{meilisearch_sink => rabbitmq_sink}/config.toml
(68%)
create mode 100644 core/connectors/sinks/rabbitmq_sink/src/lib.rs
create mode 100644 core/integration/tests/cluster/consumer_offset_quota.rs
copy core/integration/tests/connectors/api/{config.toml =>
key_validation.toml} (83%)
create mode 100644
core/integration/tests/connectors/fixtures/rabbitmq/container.rs
copy core/integration/tests/connectors/fixtures/{clickhouse =>
rabbitmq}/mod.rs (77%)
create mode 100644 core/integration/tests/connectors/fixtures/rabbitmq/sink.rs
copy core/integration/tests/connectors/{quickwit => rabbitmq}/mod.rs (97%)
create mode 100644 core/integration/tests/connectors/rabbitmq/rabbitmq_sink.rs
copy core/integration/tests/connectors/{delta => rabbitmq}/sink.toml (94%)
create mode 100644 core/integration/tests/server/consumer_offset_quota_vsr.rs
create mode 100644 core/integration/tests/server/http_read_your_writes.rs
create mode 100644 core/integration/tests/server/raw_tcp.rs
create mode 100644
core/integration/tests/server/scenarios/delete_stats_rollback_scenario.rs
create mode 100644 core/integration/tests/server/unknown_code_vsr.rs
create mode 100644 core/metadata/src/applied_frontier.rs
create mode 100644 core/partitions/src/consumer_offset_capacity.rs
create mode 100644 core/partitions/src/segment_anchor.rs
create mode 100644 core/server/src/banner.rs
create mode 100644 core/server/src/dispatch/failure.rs
create mode 100644 core/server/src/rewrite.rs
create mode 100644 core/simulator/README.md
create mode 100644 foreign/csharp/Iggy_SDK/Utils/WireName.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/ContractsTests/WireNameLengthContractsTests.cs
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/serde/MessageIdGenerator.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/AsyncIggyTcpClientEventLoopGroupTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/vsr/VsrLoginCodecTest.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/serde/MessageIdGeneratorTest.java
create mode 100644 foreign/node/src/wire/message/message.utils.test.ts
create mode 100644 foreign/node/src/wire/number.utils.test.ts
create mode 100644 foreign/python/src/partitioning.rs
create mode 100644 foreign/python/src/stats.rs
create mode 100644 foreign/python/tests/test_http_config.py
create mode 100644 foreign/python/tests/test_quic_config.py
create mode 100644 foreign/python/tests/test_stats.py
create mode 100644 foreign/python/tests/test_websocket_config.py
