This is an automated email from the ASF dual-hosted git repository.
mmodzelewski pushed a change to branch java-strings-serialization
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 8fb78ab98 review fixes
add 6730542bf fixes
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 c47174e7e Merge branch 'master' into java-strings-serialization
No new revisions were added by this update.
Summary of changes:
.../actions/python-maturin/pre-merge/action.yml | 9 +
CONTRIBUTING.md | 17 +
Cargo.lock | 22 +-
Cargo.toml | 10 +-
bdd/go/tests/tcp_test/offset_feature_delete.go | 21 +-
bdd/python/uv.lock | 2 +-
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 +
core/common/src/types/stats/mod.rs | 2 +-
core/configs/src/server_config/cluster.rs | 8 +-
core/configs/src/server_config/defaults.rs | 2 +
core/configs/src/server_config/displays.rs | 6 +-
core/configs/src/server_config/partition.rs | 72 +
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sdk/src/decoders/proto.rs | 135 +-
core/integration/src/harness/disk.rs | 33 +-
.../tests/cluster/consumer_offset_quota.rs | 357 +++
core/integration/tests/cluster/mod.rs | 1 +
.../tests/server/consumer_offset_quota_vsr.rs | 514 ++++
core/integration/tests/server/mod.rs | 1 +
core/integration/tests/server/raw_tcp.rs | 5 +
core/message_bus/src/lib.rs | 2 +-
core/metadata/src/impls/metadata.rs | 159 +-
core/metadata/src/stm/user.rs | 4 +-
core/partitions/src/consumer_offset_capacity.rs | 717 +++++
core/partitions/src/iggy_partition.rs | 2775 +++++++++++++++++---
core/partitions/src/iggy_partitions.rs | 51 +-
core/partitions/src/lib.rs | 19 +-
core/partitions/src/offset_storage.rs | 197 +-
core/partitions/src/poll_plan.rs | 352 ++-
core/partitions/src/state_transfer.rs | 727 +++--
core/partitions/src/types.rs | 5 +
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/consumer.rs | 32 +-
core/sdk/src/leader_aware.rs | 25 +
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 | 49 +-
core/server/src/boot/recovery.rs | 17 +-
core/server/src/consumer_group.rs | 46 +-
core/server/src/dispatch/mod.rs | 1 +
core/server/src/dispatch/partition.rs | 399 ++-
core/server/src/dispatch/session_ops.rs | 1 +
core/server/src/dispatch/test_support.rs | 1 +
core/server/src/http/handlers.rs | 18 +-
core/server/src/offset_recovery.rs | 354 ++-
core/server/src/partition_helpers.rs | 119 +-
core/server/src/partition_reconciler.rs | 380 ++-
core/server/src/responses.rs | 51 +-
core/server/src/shell.rs | 6 +-
core/shard/src/lib.rs | 1052 ++++++--
core/shard/src/metrics.rs | 163 +-
core/shard/src/router.rs | 9 +
core/simulator/src/client.rs | 4 +-
core/simulator/src/deps.rs | 14 +
core/simulator/src/lib.rs | 965 ++++++-
core/simulator/src/replica.rs | 1 +
core/simulator/src/workload/effect.rs | 2 +-
core/simulator/src/workload/shadow.rs | 2 +-
examples/node/package-lock.json | 2 +-
examples/python/uv.lock | 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 +-
.../iggy/client/async/tcp/StreamsTcpClient.java | 9 +-
.../iggy/client/async/tcp/UsersTcpClient.java | 9 +-
.../org/apache/iggy/exception/IggyErrorCode.java | 3 +
.../org/apache/iggy/serde/BytesSerializer.java | 4 +-
.../org/apache/iggy/serde/MessageIdGenerator.java | 74 +
.../client/async/tcp/vsr/VsrLoginCodecTest.java | 22 +-
.../apache/iggy/exception/IggyErrorCodeTest.java | 1 +
.../apache/iggy/serde/MessageIdGeneratorTest.java | 80 +
foreign/node/package-lock.json | 4 +-
foreign/node/package.json | 2 +-
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/apache_iggy.pyi | 245 ++
foreign/python/pyproject.toml | 2 +-
foreign/python/src/client.rs | 25 +
foreign/python/src/lib.rs | 5 +
foreign/python/src/stats.rs | 449 ++++
foreign/python/tests/test_stats.py | 250 ++
foreign/python/uv.lock | 2 +-
123 files changed, 10799 insertions(+), 1418 deletions(-)
create mode 100644 core/integration/tests/cluster/consumer_offset_quota.rs
create mode 100644 core/integration/tests/server/consumer_offset_quota_vsr.rs
create mode 100644 core/partitions/src/consumer_offset_capacity.rs
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/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/stats.rs
create mode 100644 foreign/python/tests/test_stats.py
