This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch partition_repair_and_commit_from_tick
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 7d88f33f4 merge master
add 858279b58 chore(deps): Bump @humanfs/node from 0.16.7 to 0.16.8 in
/web (#4045)
add a7fcf9282 chore(deps): Bump the python group across 2 directories with
1 update (#4039)
add 873c6ce6a docs: mention the PHP SDK in the README (#4041)
add 05b3d74b9 test(java): add Pinot connector E2E coverage (#3922)
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 4b12a9bc1 merge master
No new revisions were added by this update.
Summary of changes:
.github/actions/java-gradle/pre-merge/action.yml | 6 +
README.md | 2 +-
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 10 +-
bdd/python/uv.lock | 38 +-
bdd/rust/tests/steps/streams.rs | 31 +-
core/configs/src/server_config/cluster.rs | 9 +-
core/configs/src/server_config/defaults.rs | 3 +
core/configs/src/server_config/displays.rs | 7 +-
core/configs/src/server_config/partition.rs | 109 +
core/consensus/src/impls.rs | 4 +-
core/consensus/src/vsr_state.rs | 160 +-
.../tests/cluster/crash_offset_reuse.rs | 446 +++-
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/mod.rs | 3 +
core/journal/src/superblock.rs | 4 +-
core/metadata/src/applied_frontier.rs | 400 ++++
core/metadata/src/impls/metadata.rs | 80 +-
core/metadata/src/impls/recovery.rs | 1 +
core/metadata/src/lib.rs | 5 +
core/partitions/src/iggy_partition.rs | 2391 +++++++++++++++++---
core/partitions/src/lib.rs | 15 +
core/partitions/src/log.rs | 27 +-
core/partitions/src/segment_anchor.rs | 329 +++
core/partitions/src/state_transfer.rs | 37 +-
core/server/config.toml | 39 +-
core/server/src/boot/mod.rs | 17 +-
core/server/src/boot/recovery.rs | 131 +-
core/server/src/boot/threads.rs | 3 +
core/server/src/dispatch/mod.rs | 88 +-
core/server/src/dispatch/reads.rs | 419 +++-
core/server/src/dispatch/submit.rs | 116 +
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 | 131 +-
core/server/src/http/reads.rs | 271 ++-
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 | 27 +-
core/server/src/lib.rs | 1 +
core/server/src/partition_helpers.rs | 424 +++-
core/server/src/responses.rs | 130 +-
core/server/src/segment_recovery.rs | 390 +++-
core/server/src/server_error.rs | 15 +
core/server/src/session_manager.rs | 144 +-
core/shard/src/lib.rs | 142 +-
core/shard/src/metrics.rs | 52 +
core/simulator/README.md | 236 ++
core/simulator/src/client.rs | 88 +-
core/simulator/src/lib.rs | 457 ++++
core/simulator/src/replica.rs | 8 +-
examples/node/package-lock.json | 8 +-
examples/node/package.json | 2 +-
examples/python/uv.lock | 38 +-
.../iggy-connector-pinot/build.gradle.kts | 25 +-
.../iggy-connector-pinot/integration-test.sh | 234 --
.../connector/pinot/IggyPinotIntegrationTest.java | 460 ++++
.../apache/iggy/client/BaseIntegrationTest.java | 32 +-
foreign/node/package-lock.json | 142 +-
foreign/node/package.json | 2 +-
web/package-lock.json | 168 +-
web/package.json | 6 +-
67 files changed, 8061 insertions(+), 1225 deletions(-)
create mode 100644 core/integration/tests/server/http_read_your_writes.rs
create mode 100644 core/metadata/src/applied_frontier.rs
create mode 100644 core/partitions/src/segment_anchor.rs
create mode 100644 core/simulator/README.md
delete mode 100755
foreign/java/external-processors/iggy-connector-pinot/integration-test.sh
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/test/java/org/apache/iggy/connector/pinot/IggyPinotIntegrationTest.java
