This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch rework_clients_table_one_more_time
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 96bed066c address review
add f45f9dda9 refactor(server): split the dispatch spine into plane-named
leaves (#4026)
add 4dd877267 chore(sdk): IggyProducer docs for Rust SDK (#3989)
add 7ff4eb170 chore(deps): Bump com.github.spotbugs:spotbugs-annotations
from 4.10.3 to 4.10.4 in /foreign/java in the java group across 1 directory
(#4029)
add 9dbc5f303 test(integration): stop harness servers pinning shards to
cores (#4030)
add a7d5a2894 chore(sdk): IggyConsumer docs (#3913)
add bbfad594e chore(deps): Bump taiki-e/install-action from 2.86.3 to
2.86.7 in the github-actions group (#4028)
add e7f03879d docs: wait for the issue to be assigned, not for a label
(#4032)
add 38d58ca13 refactor(server): split bootstrap.rs into the boot/ tree
(#4031)
add ad9e5ddce test(integration): catch on-disk storage format breaks
pre-merge (#4003)
add ff5a86c66 merge master
No new revisions were added by this update.
Summary of changes:
.config/nextest.toml | 6 +
.github/actions/rust/pre-merge/action.yml | 33 +-
.../actions/utils/setup-rust-with-cache/action.yml | 7 +-
.github/config/components.yml | 37 +
.github/workflows/_common.yml | 2 +-
.github/workflows/_test.yml | 52 +-
.github/workflows/coverage-baseline.yml | 4 +-
.github/workflows/post-merge.yml | 2 +-
.github/workflows/pre-merge.yml | 2 +
CONTRIBUTING.md | 2 +-
core/integration/src/harness/config/common.rs | 11 +
core/integration/src/harness/config/server.rs | 5 +
core/integration/src/harness/handle/server.rs | 124 +-
.../src/harness/orchestrator/builder.rs | 15 +-
core/integration/src/harness/port_reserver.rs | 8 +-
core/integration/tests/data_integrity/mod.rs | 5 +
.../tests/data_integrity/storage_compat.rs | 1473 ++++++
core/integration/tests/server/http_view_header.rs | 228 +
core/integration/tests/server/mod.rs | 6 +
core/integration/tests/server/port_discovery.rs | 118 +
core/metadata/src/impls/metadata.rs | 2 +-
core/sdk/src/clients/consumer.rs | 563 +-
core/sdk/src/clients/consumer_builder.rs | 7 +-
core/sdk/src/clients/producer.rs | 439 +-
core/sdk/src/clients/producer_builder.rs | 2 +-
core/sdk/src/clients/producer_config.rs | 236 +-
core/sdk/src/clients/producer_dispatcher.rs | 434 +-
core/sdk/src/clients/producer_error_callback.rs | 139 +-
core/sdk/src/clients/producer_sharding.rs | 131 +-
core/server/src/auth.rs | 457 --
core/server/src/boot/credentials.rs | 502 ++
core/server/src/boot/handoff.rs | 434 ++
core/server/src/boot/listeners.rs | 636 +++
core/server/src/boot/mod.rs | 1038 ++++
core/server/src/boot/recovery.rs | 1392 +++++
core/server/src/{ => boot}/systemd.rs | 0
core/server/src/boot/threads.rs | 708 +++
core/server/src/boot/topology.rs | 729 +++
core/server/src/bootstrap.rs | 5144 -------------------
core/server/src/cluster_meta.rs | 89 +-
core/server/src/config_writer.rs | 75 +-
core/server/src/dispatch.rs | 5364 --------------------
core/server/src/dispatch/authz.rs | 14 +-
.../{login_register.rs => dispatch/login_error.rs} | 25 +-
core/server/src/dispatch/mod.rs | 1414 ++++++
core/server/src/dispatch/partition.rs | 1586 ++++++
core/server/src/dispatch/reads.rs | 491 ++
core/server/src/dispatch/session_ops.rs | 2096 ++++++++
core/server/src/dispatch/submit.rs | 194 +
core/server/src/dispatch/test_support.rs | 279 +
core/server/src/http.rs | 150 +-
core/server/src/http/error.rs | 3 +-
core/server/src/http/extractor.rs | 2 +-
core/server/src/http/forward.rs | 20 +-
core/server/src/http/handlers.rs | 8 +-
core/server/src/http/reply.rs | 2 +-
core/server/src/http/state.rs | 4 +-
core/server/src/http/submit.rs | 7 +-
core/server/src/http/tls.rs | 10 +-
core/server/src/lib.rs | 12 +-
core/server/src/main.rs | 6 +-
core/server/src/partition_helpers.rs | 2 +-
core/server/src/partition_reconciler.rs | 2 +-
core/server/src/server_error.rs | 6 +-
core/server/src/shell.rs | 4 +-
core/server/tests/module_graph.rs | 45 +-
core/simulator/src/replica.rs | 2 +-
foreign/java/gradle/libs.versions.toml | 2 +-
scripts/ci/storage-compat.sh | 270 +
69 files changed, 16012 insertions(+), 11305 deletions(-)
create mode 100644 core/integration/tests/data_integrity/storage_compat.rs
create mode 100644 core/integration/tests/server/http_view_header.rs
create mode 100644 core/integration/tests/server/port_discovery.rs
delete mode 100644 core/server/src/auth.rs
create mode 100644 core/server/src/boot/credentials.rs
create mode 100644 core/server/src/boot/handoff.rs
create mode 100644 core/server/src/boot/listeners.rs
create mode 100644 core/server/src/boot/mod.rs
create mode 100644 core/server/src/boot/recovery.rs
rename core/server/src/{ => boot}/systemd.rs (100%)
create mode 100644 core/server/src/boot/threads.rs
create mode 100644 core/server/src/boot/topology.rs
delete mode 100644 core/server/src/bootstrap.rs
delete mode 100644 core/server/src/dispatch.rs
rename core/server/src/{login_register.rs => dispatch/login_error.rs} (75%)
create mode 100644 core/server/src/dispatch/mod.rs
create mode 100644 core/server/src/dispatch/partition.rs
create mode 100644 core/server/src/dispatch/reads.rs
create mode 100644 core/server/src/dispatch/session_ops.rs
create mode 100644 core/server/src/dispatch/submit.rs
create mode 100644 core/server/src/dispatch/test_support.rs
create mode 100755 scripts/ci/storage-compat.sh
