You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by gk...@apache.org on 2026/08/10 15:46:34 UTC
(iggy) 01/01: Merge branch 'master' into fix_flaky_tests
This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a commit to branch fix_flaky_tests
in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 13d105689b870c4065951631f9d6426b7eda90c3
Merge: 1485fcb5f efcb88071
Author: Grzegorz Koszyk <11...@users.noreply.github.com>
AuthorDate: Mon Aug 10 17:46:29 2026 +0200
Merge branch 'master' into fix_flaky_tests
.claude/skills/connectors-overview/SKILL.md | 26 +-
.github/actions/cpp-bazel/pre-merge/action.yml | 6 +
.github/actions/go/pre-merge/action.yml | 35 +-
.github/actions/node-npm/pre-merge/action.yml | 100 +-
.github/config/components.yml | 4 +-
.github/workflows/_test.yml | 3 +-
.github/workflows/_test_bdd.yml | 14 +-
.github/workflows/_test_examples.yml | 10 +-
.github/workflows/coverage-baseline.yml | 11 +-
Cargo.lock | 2 +
codecov.yml | 3 -
core/binary_protocol/Cargo.toml | 1 +
core/binary_protocol/src/consensus/error.rs | 17 +
core/binary_protocol/src/consensus/header.rs | 601 ++++++-
core/binary_protocol/src/consensus/mod.rs | 12 +-
core/binary_protocol/src/lib.rs | 13 +-
core/common/src/utils/serde_secret.rs | 95 +-
core/configs/src/server_ng_config/metadata.rs | 54 +-
core/configs/src/server_ng_config/partition.rs | 36 +-
core/configs/src/server_ng_config/validators.rs | 9 -
core/consensus/Cargo.toml | 1 +
core/consensus/src/dvc_merge.rs | 981 +++++++++++
core/consensus/src/impls.rs | 734 ++++++++-
core/consensus/src/lib.rs | 3 +
core/consensus/src/plane_helpers.rs | 761 ++++++++-
core/consensus/src/view_change_quorum.rs | 429 ++++-
.../tests/cluster/metadata_checkpoint_restart.rs | 6 +-
core/integration/tests/server/mod.rs | 3 +
.../integration/tests/server/poll_semantics_vsr.rs | 68 +-
core/integration/tests/server/purge_vsr.rs | 99 ++
.../integration/tests/server/stats_vsr.rs | 32 +-
.../tests/server/topic_admission_vsr.rs | 69 +-
core/journal/src/lib.rs | 19 +
core/journal/src/prepare_journal.rs | 438 ++++-
core/metadata/src/impls/metadata.rs | 124 +-
core/metadata/src/impls/recovery.rs | 182 +-
core/metadata/src/stm/result.rs | 1 +
core/metadata/src/stm/stream.rs | 413 ++++-
core/partitions/src/iggy_partition.rs | 112 +-
core/partitions/src/iggy_partitions.rs | 87 +-
core/partitions/src/journal.rs | 180 ++
core/partitions/src/lib.rs | 2 +-
core/partitions/src/log.rs | 8 +
core/partitions/src/offset_storage.rs | 364 +++-
core/partitions/src/poll_plan.rs | 85 +-
core/partitions/src/types.rs | 7 +
core/sdk/src/clients/client.rs | 35 +-
core/sdk/src/vsr.rs | 37 +-
core/server-ng/config.toml | 17 +-
core/server-ng/src/bootstrap.rs | 17 +
core/server-ng/src/dispatch.rs | 66 +-
core/server-ng/src/http/reads.rs | 14 +-
core/server-ng/src/offset_recovery.rs | 57 +-
core/server-ng/src/partition_reconciler.rs | 1 +
core/server-ng/src/responses.rs | 41 +-
core/server-ng/src/wire.rs | 94 +-
core/server_common/src/consensus_message.rs | 68 +-
core/server_common/src/send_messages2.rs | 68 +-
core/shard/src/lib.rs | 1736 ++++++++++++++++++--
core/shard/src/router.rs | 2 +-
core/simulator/src/deps.rs | 49 +
core/simulator/src/lib.rs | 159 ++
core/simulator/src/replica.rs | 1 +
core/simulator/src/workload/effect.rs | 10 +
.../src/workload/ops/create_partitions.rs | 17 +-
.../src/workload/ops/delete_partitions.rs | 58 +-
core/simulator/src/workload/shadow.rs | 113 +-
examples/node/src/tcp-tls/consumer.ts | 5 +-
examples/node/src/tcp-tls/producer.ts | 20 +-
foreign/cpp/Cargo.toml | 2 +-
foreign/cpp/tests/e2e/client.cpp | 91 +-
foreign/cpp/tests/e2e/consumer_group.cpp | 44 +-
foreign/cpp/tests/e2e/message.cpp | 7 +-
.../FetchMessagesTests.cs | 29 +-
foreign/node/CHANGELOG.md | 95 --
foreign/node/README.md | 25 +-
foreign/node/docker-compose.yml | 9 +-
foreign/node/package-lock.json | 4 +-
foreign/node/package.json | 3 +-
foreign/node/src/bdd/auth.ts | 3 -
foreign/node/src/client/client.config.test.ts | 31 +-
foreign/node/src/client/client.config.ts | 17 +-
foreign/node/src/client/client.connection.test.ts | 37 +-
foreign/node/src/client/client.connection.ts | 17 +-
foreign/node/src/client/client.frame.test.ts | 113 +-
foreign/node/src/client/client.frame.ts | 40 +-
foreign/node/src/client/client.socket.test.ts | 1 -
foreign/node/src/client/client.socket.ts | 29 +-
foreign/node/src/client/client.type.ts | 7 -
foreign/node/src/client/client.utils.test.ts | 31 +-
foreign/node/src/client/client.utils.ts | 68 -
foreign/node/src/e2e/tcp.cluster.e2e.ts | 21 +-
foreign/node/src/e2e/tcp.consumer-group.e2e.ts | 6 +-
foreign/node/src/e2e/tcp.consumer-stream.e2e.ts | 6 +-
foreign/node/src/e2e/tcp.send-message.e2e.ts | 12 -
foreign/node/src/e2e/test-client.utils.ts | 2 -
foreign/node/src/e2e/tls.system.e2e.ts | 8 +-
foreign/node/src/wire/command-set.test.ts | 1 -
.../node/src/wire/message/poll-messages.command.ts | 3 +-
foreign/node/src/wire/vsr/namespace.ts | 2 +
foreign/python/tests/test_topic.py | 13 +-
foreign/python/tests/utils.py | 33 +-
scripts/run-bdd-tests.sh | 6 +-
scripts/run-examples-from-readme.sh | 5 +-
104 files changed, 8355 insertions(+), 1411 deletions(-)