This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch sim-workload-faults
in repository https://gitbox.apache.org/repos/asf/iggy.git
discard e5cc7ba94 feat(simulator): drive the workload under network and
replica faults
add 3cd0860a9 fix(connectors): stop rendering counter metrics with a
doubled _total (#3921)
add 3db955eae ci: bound apt-get so a dead mirror cannot wedge a job (#3924)
add 8ed41c7db refactor(server): consensus restore, fail-stop, linear
cleanup batch (#3911)
add 565e1a7b2 refactor(shard): drop journal generic, metrics scrape, poll
cursor (#3914)
add 21fc4d849 feat(shard): split the inbox into consensus and client-reply
lanes (#3915)
add 89dea0ed3 fix(metadata): truncate the WAL suffix above the
state-transfer floor (#3918)
add 9f3468bd5 chore(repo): remove incubating references after TLP
graduation (#3928)
add 2b52fe0bd ci: replace Ana06/get-changed-files with dorny/paths-filter
(#3916)
add 35d2c4244 feat(python): let poll_messages take a consumer (#3877)
add c0c74931b chore(deps): Bump taiki-e/install-action from 2.85.8 to
2.85.11 in the github-actions group (#3920)
add f53b33cf7 feat(simulator): drive the workload under network and
replica faults
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 (e5cc7ba94)
\
N -- N -- N refs/heads/sim-workload-faults (f53b33cf7)
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:
.claude/skills/connector-runtime/SKILL.md | 4 +-
.github/actions/cpp-bazel/pre-merge/action.yml | 3 +-
.github/actions/node-npm/pre-merge/action.yml | 2 +-
.github/actions/php/pre-merge/action.yml | 3 +-
.github/actions/rust/pre-merge/action.yml | 4 +-
.../actions/utils/setup-rust-with-cache/action.yml | 4 +-
.github/workflows/_build_rust_artifacts.yml | 2 +-
.github/workflows/_common.yml | 2 +-
.github/workflows/_detect.yml | 9 +-
.github/workflows/_test_examples.yml | 3 +-
.github/workflows/coverage-baseline.yml | 9 +-
.github/workflows/edge-release.yml | 6 -
.github/workflows/post-merge.yml | 2 +-
AGENTS.md | 2 +-
DISCLAIMER | 5 -
Dockerfile | 12 -
LICENSE | 4 +-
NOTICE | 2 +-
README.md | 2 +-
SECURITY.md | 6 +-
about.hbs | 4 +-
bdd/csharp/Dockerfile | 12 -
bdd/go/Dockerfile | 12 -
bdd/java/Dockerfile | 12 -
bdd/node/Dockerfile | 12 -
bdd/python/Dockerfile | 11 -
bdd/python/tests/test_basic_messaging.py | 3 +-
bdd/rust/Dockerfile | 12 -
core/bench/dashboard/frontend/assets/style.css | 11 -
.../dashboard/frontend/src/components/footer.rs | 1 -
core/bench/dashboard/server/Dockerfile | 12 -
core/binary_protocol/README.md | 6 -
core/cli/README.md | 6 -
core/common/README.md | 6 -
core/configs/src/common/server.rs | 14 +-
core/configs/src/server_config/cluster.rs | 37 ++
core/configs/src/server_config/defaults.rs | 4 +-
core/configs/src/server_config/sharding.rs | 46 ++-
core/connectors/runtime/src/main.rs | 2 +-
core/connectors/runtime/src/metrics.rs | 91 ++++-
core/consensus/src/impls.rs | 10 +-
.../tests/connectors/runtime/benchmark.rs | 7 +
core/journal/src/lib.rs | 9 +-
core/journal/src/prepare_journal.rs | 3 +-
core/metadata/src/impls/metadata.rs | 186 +++++++---
core/partitions/src/iggy_index_reader.rs | 82 ++++-
core/partitions/src/iggy_partition.rs | 11 +-
core/partitions/src/journal.rs | 2 +-
core/partitions/src/lib.rs | 14 +-
core/partitions/src/log.rs | 37 +-
core/partitions/src/poll_plan.rs | 138 ++++++-
core/partitions/src/types.rs | 82 ++---
core/sdk/README.md | 6 -
core/server/Dockerfile | 12 -
core/server/config.toml | 33 +-
core/server/src/args.rs | 4 +-
core/server/src/auth.rs | 12 +-
core/server/src/bootstrap.rs | 121 +++++--
core/server/src/consumer_group.rs | 8 +-
core/server/src/dispatch.rs | 225 +++++++++---
core/server/src/dispatch/authz.rs | 24 +-
core/server/src/http.rs | 3 +-
core/server/src/http/metrics.rs | 36 +-
core/server/src/main.rs | 4 +-
core/server/src/partition_reconciler.rs | 281 ++++++++++++++-
core/server/src/responses.rs | 218 +++++++----
core/server/src/server_error.rs | 2 +
core/server/src/users.rs | 2 +-
core/server_common/src/buffer.rs | 4 +-
core/server_common/src/executor.rs | 100 +++++-
core/server_common/src/lib.rs | 2 +-
core/server_common/src/memory_pool.rs | 23 +-
core/shard/src/builder.rs | 9 +-
core/shard/src/config.rs | 9 +-
core/shard/src/coordinator.rs | 12 +-
core/shard/src/lib.rs | 398 ++++++++++-----------
core/shard/src/metrics.rs | 157 +++++---
core/shard/src/router.rs | 58 ++-
core/simulator/src/bin/simulator-ui.rs | 4 +-
core/simulator/src/bin/workload-fuzz.rs | 4 +-
core/simulator/src/deps.rs | 3 +-
core/simulator/src/lib.rs | 71 ++--
core/simulator/src/replica.rs | 5 +-
core/simulator/src/workload/mod.rs | 2 +-
examples/python/basic/consumer.py | 4 +-
examples/python/getting-started/consumer.py | 3 +
examples/python/message-headers/common.py | 7 +-
.../message-headers/plain-headers/consumer.py | 2 +-
.../message-headers/typed-headers/consumer.py | 2 +-
foreign/cpp/README.md | 6 -
foreign/csharp/NOTICE | 2 +-
foreign/csharp/README.md | 9 -
foreign/go/NOTICE | 2 +-
foreign/go/README.md | 6 -
foreign/java/LICENSE | 2 +-
foreign/java/NOTICE | 2 +-
foreign/java/README.md | 6 -
.../docker/Dockerfile.flink2_10-java21 | 12 -
foreign/java/java-sdk/build.gradle.kts | 4 +-
foreign/node/NOTICE | 2 +-
foreign/node/README.md | 6 -
foreign/php/NOTICE | 2 +-
foreign/php/composer.json | 2 +-
foreign/python/Dockerfile.test | 11 -
foreign/python/NOTICE | 2 +-
foreign/python/README.md | 6 -
foreign/python/apache_iggy.pyi | 302 +++++++++-------
foreign/python/src/client.rs | 17 +-
foreign/python/src/consumer.rs | 31 +-
foreign/python/src/identifier.rs | 20 +-
foreign/python/src/lib.rs | 3 +-
foreign/python/tests/test_message_operations.py | 377 +++++++++++++++++++
foreign/python/tests/test_tls.py | 3 +-
licenserc.toml | 1 -
scripts/ci/apt-install.sh | 78 ++++
scripts/ci/render-node-licenses.mjs | 4 +-
scripts/prepare-release.sh | 7 +-
web/Dockerfile | 12 -
118 files changed, 2638 insertions(+), 1150 deletions(-)
delete mode 100644 DISCLAIMER
create mode 100755 scripts/ci/apt-install.sh
