This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch durable-offset-watermark
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 512c9dc35 fix(partitions): retry a refused first claim instead of
tombstoning
add b44724213 fix(cluster): serve metadata reads at or above the client's
own writes (#4024)
add c60564a00 Merge branch 'master' into durable-offset-watermark
No new revisions were added by this update.
Summary of changes:
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 10 +-
bdd/rust/tests/steps/streams.rs | 31 +-
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/mod.rs | 3 +
core/metadata/src/applied_frontier.rs | 400 ++++++++++++++++++
core/metadata/src/impls/metadata.rs | 80 +++-
core/metadata/src/lib.rs | 5 +
core/server/src/boot/mod.rs | 17 +-
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/responses.rs | 130 ++++--
core/server/src/session_manager.rs | 144 ++++++-
core/shard/src/lib.rs | 6 +-
core/shard/src/metrics.rs | 52 +++
core/simulator/src/client.rs | 88 ++--
core/simulator/src/lib.rs | 457 +++++++++++++++++++++
core/simulator/src/replica.rs | 8 +-
32 files changed, 2793 insertions(+), 319 deletions(-)
create mode 100644 core/integration/tests/server/http_read_your_writes.rs
create mode 100644 core/metadata/src/applied_frontier.rs
