This is an automated email from the ASF dual-hosted git repository.
piotr pushed a change to branch fix_sdk_secrecy
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 27dafe576 Merge branch 'master' into fix_sdk_secrecy
add c19a600a8 feat(rust): add sans-IO frame codec and command dispatch
table (#2967)
add 707ab2435 chore(python): bump SDK to 0.7.4-dev1, modernize CI and deps
(#2992)
add 6180d88e6 feat(go): implement binary reader/writer (#2986)
add 298cd3282 fix(server): prevent consumer offset skip during concurrent
produce+consume (#2958)
add 7ed29dc69 fix(deps): resolve 15 Dependabot vulnerability alerts (#3016)
add a81bcc601 feat(server): aligned buffer memory pool (#2921)
add 484f98a59 feat(server): add io_uring EINVAL diagnostics for shard
executors (#3021)
add 2098f4918 test(csharp): wait for HTTP readiness in fixture (#3024)
add 4e3029d6b refactor(consensus): consolidate VSR types in
binary_protocol (#3014)
add 93d7f8970 ci: split post-merge monolith and harden Codecov uploads
(#3006)
add b4c6dcad7 Merge branch 'master' into fix_sdk_secrecy
No new revisions were added by this update.
Summary of changes:
.../actions/python-maturin/post-merge/action.yml | 14 +-
.github/actions/rust/pre-merge/action.yml | 3 +
.github/workflows/_test.yml | 1 +
.../{post-merge.yml => coverage-baseline.yml} | 262 +--
.github/workflows/edge-release.yml | 123 +
.github/workflows/post-merge.yml | 506 +----
.github/workflows/pre-merge.yml | 4 +
Cargo.lock | 9 +-
Cargo.toml | 3 +-
codecov.yml | 29 +-
core/bench/dashboard/server/Cargo.lock | 1575 -------------
core/binary_protocol/src/codec.rs | 58 +
core/binary_protocol/src/codes.rs | 54 +-
core/binary_protocol/src/consensus/message.rs | 113 +-
core/binary_protocol/src/consensus/mod.rs | 1 +
core/binary_protocol/src/consensus/operation.rs | 89 +-
core/binary_protocol/src/dispatch.rs | 450 ++++
core/binary_protocol/src/error.rs | 4 +-
core/binary_protocol/src/frame.rs | 32 -
core/binary_protocol/src/framing.rs | 289 +++
core/binary_protocol/src/lib.rs | 28 +-
core/binary_protocol/src/message_view.rs | 11 +-
core/binary_protocol/src/primitives/identifier.rs | 19 +-
.../binary_protocol/src/primitives/partitioning.rs | 25 +-
.../src/requests/users/create_user.rs | 5 +-
.../src/requests/users/update_permissions.rs | 5 +-
.../src/responses/clients/client_response.rs | 2 +-
.../src/responses/clients/get_client.rs | 7 +-
.../consumer_groups/get_consumer_group.rs | 15 +-
.../src/responses/streams/get_stream.rs | 5 +-
.../src/responses/system/get_cluster_metadata.rs | 244 ++
.../{streams/create_stream.rs => system/get_me.rs} | 8 +-
.../login_user.rs => system/get_snapshot.rs} | 48 +-
.../src/responses/system/get_stats.rs | 7 +-
core/binary_protocol/src/responses/system/mod.rs | 6 +
.../src/responses/topics/get_topic.rs | 5 +-
core/common/Cargo.toml | 3 +-
core/common/src/alloc/buffer.rs | 145 +-
core/common/src/alloc/memory_pool.rs | 62 +-
core/common/src/lib.rs | 1 -
core/common/src/types/consensus/header.rs | 879 --------
core/common/src/types/consensus/message.rs | 719 ------
core/common/src/types/consensus/mod.rs | 19 -
.../common/src/types/message/messages_batch_mut.rs | 25 +-
.../common/src/types/message/messages_batch_set.rs | 18 +-
core/common/src/types/mod.rs | 1 -
core/common/src/types/segment.rs | 29 +-
.../src/types/segment_storage/index_reader.rs | 31 +-
.../src/types/segment_storage/messages_reader.rs | 32 +-
core/consensus/Cargo.toml | 1 +
core/consensus/src/impls.rs | 7 +-
core/consensus/src/lib.rs | 3 +-
core/consensus/src/namespaced_pipeline.rs | 5 +-
core/consensus/src/plane_helpers.rs | 7 +-
core/integration/tests/server/message_cleanup.rs | 9 +-
.../concurrent_produce_consume_scenario.rs | 196 ++
.../server/scenarios/message_cleanup_scenario.rs | 169 +-
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/message_bus/Cargo.toml | 1 +
core/message_bus/src/lib.rs | 3 +-
core/metadata/Cargo.toml | 1 +
core/metadata/src/impls/metadata.rs | 8 +-
core/metadata/src/stm/mod.rs | 4 +-
core/metadata/src/stm/mux.rs | 5 +-
core/partitions/Cargo.toml | 1 +
core/partitions/src/iggy_partition.rs | 5 +-
core/partitions/src/iggy_partitions.rs | 9 +-
core/partitions/src/journal.rs | 7 +-
core/partitions/src/lib.rs | 14 +-
.../handlers/messages/send_messages_handler.rs | 1 +
core/server/src/bootstrap.rs | 10 +-
core/server/src/diagnostics.rs | 226 ++
core/server/src/http/messages.rs | 20 +-
core/server/src/main.rs | 28 +-
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 +++
core/shard/Cargo.toml | 1 +
core/shard/src/lib.rs | 7 +-
core/shard/src/router.rs | 3 +-
core/simulator/Cargo.toml | 1 +
core/simulator/src/bus.rs | 3 +-
core/simulator/src/client.rs | 11 +-
core/simulator/src/deps.rs | 3 +-
core/simulator/src/lib.rs | 9 +-
core/simulator/src/main.rs | 3 +-
core/simulator/src/network.rs | 2 +-
core/simulator/src/packet.rs | 3 +-
examples/node/package-lock.json | 490 ++--
examples/node/package.json | 3 +
.../Fixtures/IggyServerFixture.cs | 6 +-
foreign/go/internal/codec/reader.go | 217 ++
foreign/go/internal/codec/reader_test.go | 358 +++
foreign/go/internal/codec/roundtrip_test.go | 105 +
foreign/go/internal/codec/writer.go | 151 ++
foreign/go/internal/codec/writer_test.go | 128 ++
foreign/node/package-lock.json | 2374 ++++++++------------
foreign/node/package.json | 3 +
foreign/python/Cargo.toml | 9 +-
foreign/python/pyproject.toml | 6 +-
web/package-lock.json | 1003 +++++----
web/package.json | 5 +-
112 files changed, 6590 insertions(+), 6739 deletions(-)
copy .github/workflows/{post-merge.yml => coverage-baseline.yml} (62%)
create mode 100644 .github/workflows/edge-release.yml
delete mode 100644 core/bench/dashboard/server/Cargo.lock
create mode 100644 core/binary_protocol/src/dispatch.rs
delete mode 100644 core/binary_protocol/src/frame.rs
create mode 100644 core/binary_protocol/src/framing.rs
create mode 100644
core/binary_protocol/src/responses/system/get_cluster_metadata.rs
copy core/binary_protocol/src/responses/{streams/create_stream.rs =>
system/get_me.rs} (74%)
copy core/binary_protocol/src/responses/{users/login_user.rs =>
system/get_snapshot.rs} (56%)
delete mode 100644 core/common/src/types/consensus/header.rs
delete mode 100644 core/common/src/types/consensus/message.rs
delete mode 100644 core/common/src/types/consensus/mod.rs
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
create mode 100644 foreign/go/internal/codec/reader.go
create mode 100644 foreign/go/internal/codec/reader_test.go
create mode 100644 foreign/go/internal/codec/roundtrip_test.go
create mode 100644 foreign/go/internal/codec/writer.go
create mode 100644 foreign/go/internal/codec/writer_test.go
