This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch perf/task-per-partition
in repository https://gitbox.apache.org/repos/asf/iggy.git
discard 50295e3c9 test(partitions): keep recovery tests compatible with Rust
1.99
discard 84181a322 fix(partitions): preserve teardown and dispatcher durability
discard dcaa3a9e3 fix(metadata): preserve deterministic simulator snapshot I/O
discard 663258e09 perf(server): keep filesystem work off shard executors
discard 80a959da4 perf(partitions): bound reference-WAL index spans
discard f6be99f20 fix(cluster): keep live prepares flowing during range repair
discard 07ed7d127 test(partitions): box offset history futures for macOS Clippy
discard 624d0592f test(server): box large futures for macOS Clippy
discard 3a98fab72 test(partitions): cover checkpoint waits for dispatched
run-ahead
discard 4bbd144c8 fix(partitions): preserve durability and progress during
file I/O
discard a5b2a889b perf(partitions): keep shard traffic moving during file I/O
add 5da16eba2 chore(deps): Bump the java group across 3 directories with 6
updates (#4427)
add 43fb44364 feat(node): wire up snapshot command in system client (#4389)
add 00e08b356 perf(partitions): keep shard traffic moving during file I/O
add 242f5e531 fix(partitions): preserve durability and progress during
file I/O
add bab736421 test(partitions): cover checkpoint waits for dispatched
run-ahead
add 00902d49e test(server): box large futures for macOS Clippy
add cebffd32c test(partitions): box offset history futures for macOS Clippy
add cc4e3464e fix(cluster): keep live prepares flowing during range repair
add a9df7b7c7 perf(partitions): bound reference-WAL index spans
add f595ac9cf perf(server): keep filesystem work off shard executors
add 3c3533430 fix(metadata): preserve deterministic simulator snapshot I/O
add db5fe6636 fix(partitions): preserve teardown and dispatcher durability
add cb1cddf45 test(partitions): keep recovery tests compatible with Rust
1.99
add c8b371be1 fix(partitions): preserve history and progress across file
I/O
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (50295e3c9)
\
N -- N -- N refs/heads/perf/task-per-partition (c8b371be1)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
bdd/java/Dockerfile | 2 +-
bdd/java/build.gradle.kts | 6 +-
bdd/java/gradle/wrapper/gradle-wrapper.properties | 2 +-
bdd/java/gradlew | 4 +-
core/common/src/error/iggy_error.rs | 2 +
core/configs/src/server_config/sharding.rs | 2 +
core/journal/src/durable_storage.rs | 14 +-
core/journal/src/local_gate.rs | 9 +
core/journal/src/prepare_journal.rs | 19 +-
core/metadata/src/impls/metadata.rs | 147 +-
core/metadata/src/stm/result.rs | 1 +
core/metadata/src/stm/stream.rs | 81 +-
core/partitions/src/consumer_offset_capacity.rs | 4 +
core/partitions/src/iggy_partition.rs | 1903 ++++++++++++++------
core/partitions/src/iggy_partitions.rs | 12 +-
core/partitions/src/io.rs | 122 +-
core/partitions/src/journal.rs | 81 +-
core/partitions/src/lib.rs | 8 +-
core/partitions/src/offset_storage.rs | 15 +-
core/partitions/src/state_transfer.rs | 124 +-
core/server/config.toml | 3 +-
core/server/src/boot/recovery.rs | 10 +-
core/server/src/boot/threads.rs | 22 +-
core/server/src/consumer_group/liveness.rs | 1 +
core/server/src/dispatch/partition.rs | 40 +-
core/server/src/sysinfo_printer.rs | 1 +
core/server_common/src/fs_utils.rs | 9 +-
core/shard/src/lib.rs | 23 +-
core/shard/src/partition_io.rs | 395 +++-
core/shard/src/poll.rs | 17 +-
core/shard/src/router.rs | 15 +-
examples/java/build.gradle.kts | 2 +-
.../java/gradle/wrapper/gradle-wrapper.properties | 2 +-
examples/java/gradlew | 4 +-
.../iggy/examples/MultiTenantAccessTest.java | 4 +-
foreign/java/gradle/libs.versions.toml | 6 +-
.../java/gradle/wrapper/gradle-wrapper.properties | 2 +-
foreign/java/gradlew | 4 +-
.../client/async/tcp/ClientRoutingStateTest.java | 5 +-
foreign/node/src/e2e/tcp.system.e2e.ts | 7 +
foreign/node/src/wire/command-set.ts | 2 +
foreign/node/src/wire/command.code.ts | 2 +-
foreign/node/src/wire/system/index.ts | 1 +
.../node/src/wire/system/snapshot.command.test.ts | 107 ++
foreign/node/src/wire/system/snapshot.command.ts | 103 ++
45 files changed, 2439 insertions(+), 906 deletions(-)
create mode 100644 foreign/node/src/wire/system/snapshot.command.test.ts
create mode 100644 foreign/node/src/wire/system/snapshot.command.ts
