This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch iggy-67-62-pipeline
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 8881adcd6 Merge branch 'master' into iggy-67-62-pipeline
add 44be42fb7 fix(connectors): prevent state loss on source connector
restart (#2743)
add dfc8ba2e9 feat(partitions): impl first version of partitions module
(#2735)
add e69846923 fix(ci): replace BREAKING body match with breaking:storage
label check (#2742)
add 6e8c21f92 Merge branch 'master' into iggy-67-62-pipeline
No new revisions were added by this update.
Summary of changes:
.github/actions/rust/pre-merge/action.yml | 2 +-
Cargo.lock | 8 +
core/common/Cargo.toml | 1 +
core/common/src/lib.rs | 7 +
core/common/src/sharding/namespace.rs | 5 +
core/common/src/types/consensus/header.rs | 188 ++--
.../common/src/types/consumer/consumer_group_id.rs | 14 +-
.../src/types/consumer}/consumer_group_offsets.rs | 10 +-
.../src/types/consumer}/consumer_offset.rs | 4 +-
.../src/types/consumer}/consumer_offsets.rs | 8 +-
core/common/src/types/consumer/mod.rs | 4 +
.../src/types/message}/in_flight.rs | 35 +-
core/common/src/types/message/mod.rs | 2 +
core/common/src/types/mod.rs | 3 +
.../segments => common/src/types}/segment.rs | 35 +-
.../src/types/segment_storage}/index_reader.rs | 41 +-
.../src/types/segment_storage}/index_writer.rs | 41 +-
.../src/types/segment_storage}/messages_reader.rs | 37 +-
.../src/types/segment_storage}/messages_writer.rs | 39 +-
.../src/types/segment_storage/mod.rs} | 108 ++-
.../mod.rs => common/src/types/streaming_stats.rs} | 0
core/connectors/runtime/src/main.rs | 8 +-
core/connectors/runtime/src/source.rs | 10 +-
core/connectors/runtime/src/state.rs | 5 +
core/consensus/src/impls.rs | 4 +-
core/journal/src/lib.rs | 11 +-
core/metadata/src/impls/metadata.rs | 10 +-
core/partitions/Cargo.toml | 6 +
core/partitions/src/iggy_partition.rs | 39 +-
core/partitions/src/iggy_partitions.rs | 977 ++++++++++++++++++++-
core/partitions/src/journal.rs | 143 +++
core/partitions/src/lib.rs | 144 +--
.../streaming/partitions => partitions/src}/log.rs | 117 ++-
core/partitions/src/types.rs | 56 +-
.../streaming/partitions/consumer_group_offsets.rs | 35 +-
.../src/streaming/partitions/consumer_offset.rs | 67 +-
.../src/streaming/partitions/consumer_offsets.rs | 34 +-
core/server/src/streaming/partitions/in_flight.rs | 84 +-
core/server/src/streaming/polling_consumer.rs | 10 +-
.../src/streaming/segments/indexes/index_reader.rs | 419 +--------
.../src/streaming/segments/indexes/index_writer.rs | 153 +---
core/server/src/streaming/segments/indexes/mod.rs | 1 -
.../streaming/segments/messages/messages_reader.rs | 179 +---
.../streaming/segments/messages/messages_writer.rs | 154 +---
core/server/src/streaming/segments/messages/mod.rs | 53 --
core/server/src/streaming/segments/segment.rs | 64 +-
core/server/src/streaming/segments/storage.rs | 67 +-
core/server/src/streaming/stats/mod.rs | 315 +------
core/simulator/Cargo.toml | 1 +
core/simulator/src/client.rs | 80 +-
core/simulator/src/deps.rs | 12 +-
core/simulator/src/lib.rs | 32 +-
core/simulator/src/main.rs | 32 +-
core/simulator/src/replica.rs | 40 +-
rust_out | Bin 0 -> 3893768 bytes
55 files changed, 1930 insertions(+), 2024 deletions(-)
copy foreign/csharp/Iggy_SDK_Tests/Utils/TestPriorityAttribute.cs =>
core/common/src/types/consumer/consumer_group_id.rs (76%)
copy core/{server/src/streaming/partitions =>
common/src/types/consumer}/consumer_group_offsets.rs (82%)
copy core/{server/src/streaming/partitions =>
common/src/types/consumer}/consumer_offset.rs (96%)
copy core/{server/src/streaming/partitions =>
common/src/types/consumer}/consumer_offsets.rs (82%)
copy core/{server/src/streaming/partitions =>
common/src/types/message}/in_flight.rs (73%)
copy core/{server/src/streaming/segments => common/src/types}/segment.rs (66%)
copy core/{server/src/streaming/segments/indexes =>
common/src/types/segment_storage}/index_reader.rs (92%)
copy core/{server/src/streaming/segments/indexes =>
common/src/types/segment_storage}/index_writer.rs (79%)
copy core/{server/src/streaming/segments/messages =>
common/src/types/segment_storage}/messages_reader.rs (82%)
copy core/{server/src/streaming/segments/messages =>
common/src/types/segment_storage}/messages_writer.rs (79%)
copy core/{server/src/streaming/segments/storage.rs =>
common/src/types/segment_storage/mod.rs} (54%)
copy core/{server/src/streaming/stats/mod.rs =>
common/src/types/streaming_stats.rs} (100%)
create mode 100644 core/partitions/src/journal.rs
copy core/{server/src/streaming/partitions => partitions/src}/log.rs (61%)
create mode 100755 rust_out
