This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch split_shard_inbox
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 775952407 fix CI
add e71e3c61e chore(deps): Bump the csharp group with 1 update (#3906)
add 15fe5dce9 test(integration): add SIGKILL crash-durability cluster
tests (#3905)
add c9d38ee33 test(bdd): add stream CRUD coverage for Rust and Java (#3875)
add af9ce9548 feat(connectors): add source batch acknowledgments (#3855)
add ab257a039 refactor(consensus): single restore constructor +
wedge/replay/ack fixes (#3909)
add 3cd0860a9 fix(connectors): stop rendering counter metrics with a
doubled _total (#3921)
add 7876acaa6 Merge branch 'master' into split_shard_inbox
No new revisions were added by this update.
Summary of changes:
.claude/skills/connector-runtime/SKILL.md | 4 +-
bdd/docker-compose.coverage.yml | 12 +-
bdd/docker-compose.yml | 4 +
.../org/apache/iggy/bdd/BasicMessagingSteps.java | 50 ++
.../test/java/org/apache/iggy/bdd/TestContext.java | 1 +
bdd/rust/Cargo.toml | 5 +
bdd/rust/tests/common/global_context.rs | 1 +
bdd/rust/tests/steps/streams.rs | 125 ++-
.../tests/{basic_messaging.rs => stream_crud.rs} | 2 +-
bdd/scenarios/stream_crud.feature | 52 ++
core/connectors/runtime/src/main.rs | 14 +-
core/connectors/runtime/src/manager/source.rs | 28 +-
core/connectors/runtime/src/metrics.rs | 91 ++-
core/connectors/runtime/src/source.rs | 364 ++++++++-
core/connectors/sdk/README.md | 29 +
core/connectors/sdk/src/lib.rs | 12 +
core/connectors/sdk/src/source.rs | 897 ++++++++++++++++++++-
core/connectors/sources/README.md | 33 +-
core/connectors/sources/random_source/src/lib.rs | 91 ++-
core/consensus/src/client_table.rs | 2 +-
core/integration/src/harness/disk.rs | 478 +++++++++++
core/integration/src/harness/handle/server.rs | 26 +
core/integration/src/harness/mod.rs | 1 +
.../src/harness/orchestrator/harness.rs | 28 +
.../tests/cluster/client_table_adversarial.rs | 461 +++++++++++
core/integration/tests/cluster/crash_durability.rs | 519 ++++++++++++
.../tests/cluster/crash_offset_reuse.rs | 143 ++++
.../tests/cluster/crash_recovery_corruption.rs | 688 ++++++++++++++++
.../tests/cluster/failover_client_continuity.rs | 170 ++++
core/integration/tests/cluster/mod.rs | 5 +
.../tests/connectors/random/random_source.rs | 123 +++
.../tests/connectors/runtime/benchmark.rs | 7 +
.../verify_cluster_replica_data_identical.rs | 234 +-----
core/shard/src/router.rs | 73 ++
foreign/csharp/Directory.Packages.props | 2 +-
scripts/run-bdd-tests.sh | 36 +-
36 files changed, 4477 insertions(+), 334 deletions(-)
copy bdd/rust/tests/{basic_messaging.rs => stream_crud.rs} (93%)
create mode 100644 bdd/scenarios/stream_crud.feature
create mode 100644 core/integration/src/harness/disk.rs
create mode 100644 core/integration/tests/cluster/client_table_adversarial.rs
create mode 100644 core/integration/tests/cluster/crash_durability.rs
create mode 100644 core/integration/tests/cluster/crash_offset_reuse.rs
create mode 100644 core/integration/tests/cluster/crash_recovery_corruption.rs
create mode 100644 core/integration/tests/cluster/failover_client_continuity.rs
