This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch refactor-binary-5-vsr-integration
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 88374f7fd refactor(consensus): consolidate VSR types in binary_protocol
add 298cd3282 fix(server): prevent consumer offset skip during concurrent
produce+consume (#2958)
add 7ed29dc69 fix(deps): resolve 15 Dependabot vulnerability alerts (#3016)
add 0766a2cf7 Merge branch 'master' into refactor-binary-5-vsr-integration
No new revisions were added by this update.
Summary of changes:
core/bench/dashboard/server/Cargo.lock | 1575 -------------
.../common/src/types/message/messages_batch_mut.rs | 2 +-
.../common/src/types/message/messages_batch_set.rs | 18 +-
core/common/src/types/segment.rs | 29 +-
core/integration/tests/server/message_cleanup.rs | 7 +
.../concurrent_produce_consume_scenario.rs | 196 ++
.../server/scenarios/message_cleanup_scenario.rs | 140 ++
core/integration/tests/server/scenarios/mod.rs | 2 +
.../scenarios/reconnect_after_restart_scenario.rs | 300 ++-
.../scenarios/restart_offset_skip_scenario.rs | 272 +++
core/integration/tests/server/specific.rs | 39 +-
core/server/src/bootstrap.rs | 4 +-
core/server/src/shard/mod.rs | 82 +-
core/server/src/shard/system/messages.rs | 2 +-
core/server/src/shard/system/partitions.rs | 74 +-
core/server/src/shard/system/segments.rs | 124 +-
core/server/src/streaming/partitions/journal.rs | 93 +-
.../src/streaming/partitions/local_partition.rs | 4 +-
core/server/src/streaming/partitions/log.rs | 12 +
core/server/src/streaming/partitions/mod.rs | 2 +
core/server/src/streaming/partitions/ops.rs | 297 +--
core/server/src/streaming/partitions/ops_tests.rs | 359 +++
examples/node/package-lock.json | 490 ++--
examples/node/package.json | 3 +
foreign/node/package-lock.json | 2374 ++++++++------------
foreign/node/package.json | 3 +
web/package-lock.json | 1003 +++++----
web/package.json | 5 +-
28 files changed, 3555 insertions(+), 3956 deletions(-)
delete mode 100644 core/bench/dashboard/server/Cargo.lock
create mode 100644
core/integration/tests/server/scenarios/concurrent_produce_consume_scenario.rs
create mode 100644
core/integration/tests/server/scenarios/restart_offset_skip_scenario.rs
create mode 100644 core/server/src/streaming/partitions/ops_tests.rs
