This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch ci/enable-python-windows-wheels
in repository https://gitbox.apache.org/repos/asf/iggy.git
from a921ffdae ci(python): restore Windows wheels for the PyPI release
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 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 1a9a94b3d Merge branch 'master' into ci/enable-python-windows-wheels
No new revisions were added by this update.
Summary of changes:
.github/actions/java-gradle/pre-merge/action.yml | 6 +
.github/workflows/pr-triage-apply.yml | 106 +-
CONTRIBUTING.md | 16 +-
bdd/go/go.mod | 2 +-
bdd/go/go.sum | 4 +-
.../tests/tcp_test/offset_feature_deserialize.go | 9 +-
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 10 +-
bdd/rust/tests/steps/streams.rs | 31 +-
core/configs/src/server_config/cluster.rs | 54 +-
core/configs/src/server_config/defaults.rs | 8 +
core/configs/src/server_config/displays.rs | 7 +-
core/configs/src/server_config/partition.rs | 109 +
core/connectors/runtime/README.md | 86 +-
core/connectors/runtime/config.toml | 9 +-
core/connectors/runtime/example_config/config.toml | 9 +-
core/connectors/runtime/src/api/config.rs | 111 +-
core/connectors/runtime/src/api/mod.rs | 573 ++++-
core/consensus/src/impls.rs | 4 +-
core/consensus/src/observability.rs | 22 +
core/consensus/src/vsr_state.rs | 160 +-
.../tests/cluster/crash_offset_reuse.rs | 446 +++-
.../tests/cluster/parked_frame_redispatch.rs | 19 +-
.../tests/data_integrity/storage_compat.rs | 146 +-
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 | 10 +
.../integration/tests/server/poll_semantics_vsr.rs | 57 +-
core/integration/tests/server/raw_tcp.rs | 207 ++
core/integration/tests/server/unknown_code_vsr.rs | 92 +
core/journal/src/superblock.rs | 4 +-
core/metadata/src/applied_frontier.rs | 400 ++++
core/metadata/src/impls/metadata.rs | 98 +-
core/metadata/src/impls/recovery.rs | 1 +
core/metadata/src/lib.rs | 5 +
core/partitions/Cargo.toml | 8 +
core/partitions/src/iggy_partition.rs | 2375 ++++++++++++++++++--
core/partitions/src/journal.rs | 105 +-
core/partitions/src/lib.rs | 22 +-
core/partitions/src/log.rs | 27 +-
core/partitions/src/segment_anchor.rs | 329 +++
core/partitions/src/state_transfer.rs | 37 +-
core/partitions/src/types.rs | 28 +
core/server/config.toml | 59 +-
core/server/src/boot/mod.rs | 143 +-
core/server/src/boot/recovery.rs | 198 +-
core/server/src/boot/threads.rs | 604 ++++-
core/server/src/dispatch/authz.rs | 309 ++-
core/server/src/dispatch/failure.rs | 629 ++++++
core/server/src/dispatch/mod.rs | 1700 +++++++-------
core/server/src/dispatch/partition.rs | 569 +++--
core/server/src/dispatch/reads.rs | 510 ++++-
core/server/src/dispatch/session_ops.rs | 282 +--
core/server/src/dispatch/submit.rs | 116 +
core/server/src/dispatch/test_support.rs | 13 +-
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 | 144 +-
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 | 50 +-
core/server/src/lib.rs | 2 +
core/server/src/partition_helpers.rs | 424 +++-
core/server/src/partition_reconciler.rs | 38 +-
core/server/src/responses.rs | 141 +-
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 | 1391 +++++++++++-
core/shard/src/metrics.rs | 108 +-
core/shard/src/router.rs | 2 +
core/simulator/Cargo.toml | 4 +
core/simulator/README.md | 236 ++
core/simulator/src/client.rs | 88 +-
core/simulator/src/lib.rs | 1315 +++++++++++
core/simulator/src/replica.rs | 10 +-
examples/node/package-lock.json | 8 +-
examples/node/package.json | 2 +-
.../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 +-
scripts/ci/storage-compat.sh | 17 +
web/package-lock.json | 140 +-
web/package.json | 6 +-
95 files changed, 15427 insertions(+), 2764 deletions(-)
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/unknown_code_vsr.rs
create mode 100644 core/metadata/src/applied_frontier.rs
create mode 100644 core/partitions/src/segment_anchor.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
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
