This is an automated email from the ASF dual-hosted git repository.
piotr pushed a change to branch connectors_fix
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 54e8d1e0f Merge branch 'master' into connectors_fix
add cc3746448 feat(simulator): implement bare bone version of simulator
(#2688)
add 0b4cc907d chore(server): move `IggyBatchSet` and it's utilities to
common (#2704)
add 2e74a3e10 ci(Java): add JaCoCo code coverage with Codecov integration
(#2623)
add 5306a9185 fix(java): resolve Gradle 9 task dependency error in Pinot
connector publish (#2706)
add 807bd1a34 Merge branch 'master' into connectors_fix
No new revisions were added by this update.
Summary of changes:
.github/actions/java-gradle/pre-merge/action.yml | 21 +++
.github/workflows/_common.yml | 1 +
.github/workflows/_test.yml | 12 ++
Cargo.lock | 20 ++-
Cargo.toml | 1 +
DEPENDENCIES.md | 1 +
codecov.yml | 9 +-
core/common/Cargo.toml | 4 +
.../src}/deduplication/message_deduplicator.rs | 9 +-
.../src/deduplication}/mod.rs | 5 +-
core/common/src/lib.rs | 3 +
core/common/src/sender/mod.rs | 1 +
core/common/src/types/consensus/header.rs | 28 +++-
core/common/src/types/consensus/message.rs | 71 +++-----
.../src/types/message}/indexes_mut.rs | 4 +-
.../src/types/message}/message_header_view_mut.rs | 2 +-
.../src/types/message}/message_view_mut.rs | 6 +-
.../src/types/message}/messages_batch_mut.rs | 10 +-
.../src/types/message}/messages_batch_set.rs | 12 +-
core/common/src/types/message/mod.rs | 12 ++
.../src/types/message/poll_metadata.rs} | 21 +--
core/common/src/utils/mod.rs | 1 +
.../streaming => common/src}/utils/random_id.rs | 0
core/consensus/src/impls.rs | 102 ++++++-----
core/consensus/src/lib.rs | 18 +-
core/consensus/src/vsr_timeout.rs | 1 +
core/journal/src/lib.rs | 12 +-
core/message_bus/src/cache/connection.rs | 5 +-
core/message_bus/src/lib.rs | 7 +-
core/metadata/src/impls/metadata.rs | 184 ++++++++++++--------
core/metadata/src/lib.rs | 8 +-
core/metadata/src/stm/mod.rs | 34 ++--
core/metadata/src/stm/mux.rs | 20 ++-
core/metadata/src/stm/stream.rs | 1 +
core/server/Cargo.toml | 2 -
.../handlers/messages/poll_messages_handler.rs | 15 --
core/server/src/http/http_shard_wrapper.rs | 2 +-
core/server/src/shard/system/messages.rs | 2 +-
core/server/src/shard/transmission/frame.rs | 3 +-
core/server/src/streaming/deduplication/mod.rs | 2 +-
core/server/src/streaming/partitions/helpers.rs | 5 +-
.../src/streaming/partitions/local_partition.rs | 4 +-
core/server/src/streaming/partitions/ops.rs | 2 +-
core/server/src/streaming/segments/indexes/mod.rs | 3 +-
core/server/src/streaming/segments/types/mod.rs | 12 +-
core/server/src/streaming/utils/mod.rs | 2 +-
.../dashboard/shared => simulator}/Cargo.toml | 15 +-
core/simulator/src/bus.rs | 186 +++++++++++++++++++++
core/simulator/src/client.rs | 99 +++++++++++
core/simulator/src/deps.rs | 155 +++++++++++++++++
core/simulator/src/lib.rs | 165 ++++++++++++++++++
core/simulator/src/main.rs | 100 +++++++++++
core/simulator/src/replica.rs | 67 ++++++++
foreign/java/build.gradle.kts | 39 +++++
.../kotlin/iggy.java-common-conventions.gradle.kts | 31 ++++
.../iggy-connector-pinot/build.gradle.kts | 10 +-
.../iggy-connector-pinot/docker-compose.yml | 6 +-
foreign/java/gradle/libs.versions.toml | 1 +
.../org/apache/iggy/serde/BytesSerializer.java | 3 +-
59 files changed, 1280 insertions(+), 297 deletions(-)
rename core/{server/src/streaming =>
common/src}/deduplication/message_deduplicator.rs (96%)
copy core/{binary_protocol/src/cli/binary_context =>
common/src/deduplication}/mod.rs (91%)
rename core/{server/src/streaming/segments/indexes =>
common/src/types/message}/indexes_mut.rs (99%)
rename core/{server/src/streaming/segments/types =>
common/src/types/message}/message_header_view_mut.rs (99%)
rename core/{server/src/streaming/segments/types =>
common/src/types/message}/message_view_mut.rs (95%)
rename core/{server/src/streaming/segments/types =>
common/src/types/message}/messages_batch_mut.rs (99%)
rename core/{server/src/streaming/segments/types =>
common/src/types/message}/messages_batch_set.rs (97%)
copy core/{connectors/sdk/src/decoders/raw.rs =>
common/src/types/message/poll_metadata.rs} (74%)
rename core/{server/src/streaming => common/src}/utils/random_id.rs (100%)
copy core/{bench/dashboard/shared => simulator}/Cargo.toml (73%)
create mode 100644 core/simulator/src/bus.rs
create mode 100644 core/simulator/src/client.rs
create mode 100644 core/simulator/src/deps.rs
create mode 100644 core/simulator/src/lib.rs
create mode 100644 core/simulator/src/main.rs
create mode 100644 core/simulator/src/replica.rs
