This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch kafka-record-codec
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 8c5d66589 fix: address review commit round 3
add 7bd69670f refactor(partitions): make purge recovery testable with
SimStorage (#4240)
add f0bd70283 perf(message_bus): batch small replica frames per socket
read (#4224)
add da4f3188d feat(cpp): add functions related to consumers and offsets to
high level client (#4180)
add 18c5b1a64 Merge branch 'master' into kafka-record-codec
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1 +
.../features/step_definitions/background_steps.cpp | 3 +-
core/configs/src/server_config/defaults.rs | 1 +
core/configs/src/server_config/displays.rs | 8 +-
core/configs/src/server_config/message_bus.rs | 131 +-
core/integration/tests/cluster/mod.rs | 1 +
.../tests/cluster/replica_read_batching.rs | 150 ++
core/journal/Cargo.toml | 1 +
core/journal/src/durable_storage.rs | 192 +-
core/message_bus/src/config.rs | 8 +
core/message_bus/src/framing.rs | 95 +-
core/message_bus/src/installer/replica.rs | 12 +-
core/message_bus/src/lib.rs | 83 +
core/message_bus/src/transports/tcp.rs | 296 ++-
core/partitions/src/iggy_partition.rs | 137 +-
core/partitions/src/offset_storage.rs | 247 ++-
core/server/config.toml | 19 +
core/server/src/lib.rs | 5 +-
core/server/src/offset_recovery.rs | 179 +-
core/server/src/partition_helpers.rs | 105 +-
core/shard/src/lib.rs | 2 +
core/shard/src/metrics.rs | 27 +
core/simulator/src/storage.rs | 10 +-
core/simulator/src/storage/purge.rs | 469 ++++
core/simulator/src/storage/tests.rs | 2 +-
foreign/cpp/.clang-tidy | 49 +
foreign/cpp/BUILD.bazel | 1 +
foreign/cpp/MODULE.bazel | 1 +
foreign/cpp/include/iggy.hpp | 668 +++++-
foreign/cpp/src/client.cpp | 97 +
foreign/cpp/src/type_conversions.cpp | 68 +-
foreign/cpp/tests/e2e/client.cpp | 2 -
foreign/cpp/tests/e2e/consumer_group.cpp | 2337 ++++++++++++++------
foreign/cpp/tests/unit/unit_tests.cpp | 35 +-
licenserc.toml | 1 +
35 files changed, 4526 insertions(+), 917 deletions(-)
create mode 100644 core/integration/tests/cluster/replica_read_batching.rs
create mode 100644 core/simulator/src/storage/purge.rs
create mode 100644 foreign/cpp/.clang-tidy
