This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch cg_port
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 30850e70f merge master
add 49fe8eaea chore(deps): Bump github.com/onsi/ginkgo/v2 from 2.29.0 to
2.30.0 in /bdd/go in the go group across 1 directory (#3513)
add f74359123 feat(java): add reporting suite to java bench (#3420)
add 18bcfb45e ci: auto-apply good first issue label from issue form
checkbox (#3528)
add 63deea39d chore(cpp): upgrade bazel to 9.1.1 (#3511)
add 2ec64c027 fix(partitions): persist data on vsr backups, add data
integrity test (#3512)
add d8903dde5 chore(deps): Bump the csharp group with 7 updates (#3531)
add 00913ab94 feat(go): align TCP client logging with Rust SDK (#3464)
add 832b45676 chore(deps): Bump the web group across 1 directory with 6
updates (#3509)
add 74d62eb89 chore(deps): bump Rust dependencies (#3551)
add 6765299e3 Merge branch 'master' into cg_port
No new revisions were added by this update.
Summary of changes:
.github/ISSUE_TEMPLATE/bug_report.yml | 2 +-
.github/ISSUE_TEMPLATE/feature_request.yml | 2 +-
.github/workflows/issue-labeler-assigner.yml | 44 +-
Cargo.lock | 1448 +++++++++-----------
Cargo.toml | 60 +-
bdd/go/go.mod | 2 +-
bdd/go/go.sum | 4 +-
codecov.yml | 1 +
core/consensus/src/impls.rs | 47 +-
core/consensus/src/plane_helpers.rs | 111 +-
core/integration/tests/data_integrity/mod.rs | 11 +
.../verify_cluster_replica_data_identical.rs | 446 ++++++
core/journal/src/prepare_journal.rs | 6 +-
core/metadata/src/impls/metadata.rs | 15 +-
core/partitions/src/iggy_partition.rs | 299 ++--
core/partitions/src/journal.rs | 346 ++++-
core/partitions/src/messages_writer.rs | 16 +
core/server-ng/build.rs | 12 +-
core/server/build.rs | 12 +-
core/shard/src/lib.rs | 37 +-
.../Iggy_SDK.Examples.Basic.Consumer.csproj | 8 +-
.../Iggy_SDK.Examples.Basic.Producer.csproj | 10 +-
...ggy_SDK.Examples.GettingStarted.Consumer.csproj | 4 +-
...ggy_SDK.Examples.GettingStarted.Producer.csproj | 4 +-
.../Iggy_SDK.Examples.Shared.csproj | 2 +-
...gy_SDK.Examples.MessageEnvelope.Consumer.csproj | 10 +-
...gy_SDK.Examples.MessageEnvelope.Producer.csproj | 10 +-
...ggy_SDK.Examples.MessageHeaders.Consumer.csproj | 4 +-
...ggy_SDK.Examples.MessageHeaders.Producer.csproj | 4 +-
.../Iggy_SDK.Examples.NewSdk.Consumer.csproj | 10 +-
.../Iggy_SDK.Examples.NewSdk.Producer.csproj | 10 +-
.../Iggy_SDK.Examples.TcpTls.Consumer.csproj | 4 +-
.../Iggy_SDK.Examples.TcpTls.Producer.csproj | 4 +-
foreign/cpp/.bazelversion | 2 +-
foreign/cpp/BUILD.bazel | 13 +-
foreign/cpp/MODULE.bazel | 15 +
foreign/cpp/MODULE.bazel.lock | 551 +++++---
foreign/cpp/tests/consumer_group/low_level_e2e.cpp | 8 +-
foreign/cpp/tests/stream/low_level_e2e.cpp | 4 +-
foreign/cpp/tests/unit_tests.cpp | 4 +-
foreign/csharp/Directory.Packages.props | 4 +-
foreign/go/client/tcp/tcp_core.go | 80 +-
foreign/go/client/tcp/tcp_core_test.go | 2 +-
foreign/go/client/tcp/tcp_session_management.go | 6 +
foreign/java/bench/build.gradle.kts | 1 +
.../tcp/async/TcpAsyncPinnedProducerActor.java | 156 ++-
.../runners/tcp/async/TcpAsyncPinnedProducer.java | 75 +-
.../apache/iggy/bench/cli/IggyBenchCommand.java | 2 +-
.../iggy/bench/cli/PinnedProducerCommand.java | 89 +-
.../iggy/bench/common/enums/BenchmarkKind.java | 25 +-
.../iggy/bench/common/enums/TimeSeriesKind.java} | 11 +-
.../iggy/bench/models/report/FinalReport.java | 50 +
.../report/context/BenchmarkCacheMetrics.java} | 9 +-
.../report/context/BenchmarkCacheMetricsKey.java} | 13 +-
.../models/report/context/BenchmarkHardware.java} | 21 +-
.../models/report/context/BenchmarkParams.java | 62 +
.../report/context/BenchmarkServerStats.java | 62 +
.../models/report/metrics/BenchmarkRecord.java} | 10 +-
.../report/metrics/DistributionPercentiles.java} | 9 +-
.../bench/models/report/metrics/GroupMetrics.java | 30 +-
.../models/report/metrics/GroupMetricsSummary.java | 47 +
.../bench/models/report/metrics/HistogramBin.java} | 9 +-
.../models/report/metrics/IndividualMetrics.java} | 29 +-
.../report/metrics/IndividualMetricsSummary.java | 54 +
.../report/metrics/LatencyDistribution.java} | 24 +-
.../metrics/LatencyMetrics.java} | 19 +-
.../models/report/metrics/LogNormalParams.java} | 9 +-
.../bench/models/report/metrics/TimePoint.java} | 9 +-
.../report/metrics/TimeSeries.java} | 29 +-
.../iggy/bench/report/FinalReportBuilder.java | 256 ++++
.../iggy/bench/report/GroupMetricsCalculator.java | 268 ++++
.../iggy/bench/report/HardwareInfoCollector.java | 115 ++
.../bench/report/IndividualMetricsCalculator.java | 358 +++++
.../iggy/bench/report/ServerStatsCollector.java | 90 ++
.../org/apache/iggy/bench/report/StatsHelper.java | 139 ++
.../src/main/resources/logback.xml} | 17 +-
web/package-lock.json | 177 +--
web/package.json | 12 +-
78 files changed, 4356 insertions(+), 1624 deletions(-)
create mode 100644
core/integration/tests/data_integrity/verify_cluster_replica_data_identical.rs
copy foreign/java/{buildSrc/build.gradle.kts =>
bench/src/main/java/org/apache/iggy/bench/common/enums/TimeSeriesKind.java}
(86%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/report/FinalReport.java
copy foreign/java/{buildSrc/build.gradle.kts =>
bench/src/main/java/org/apache/iggy/bench/models/report/context/BenchmarkCacheMetrics.java}
(85%)
copy
foreign/java/{java-sdk/src/test/java/org/apache/iggy/identifier/UserIdTest.java
=>
bench/src/main/java/org/apache/iggy/bench/models/report/context/BenchmarkCacheMetricsKey.java}
(76%)
copy
foreign/java/{java-sdk/src/main/java/org/apache/iggy/user/UserInfoDetails.java
=>
bench/src/main/java/org/apache/iggy/bench/models/report/context/BenchmarkHardware.java}
(59%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/report/context/BenchmarkParams.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/report/context/BenchmarkServerStats.java
copy foreign/java/{buildSrc/build.gradle.kts =>
bench/src/main/java/org/apache/iggy/bench/models/report/metrics/BenchmarkRecord.java}
(79%)
copy foreign/java/{buildSrc/build.gradle.kts =>
bench/src/main/java/org/apache/iggy/bench/models/report/metrics/DistributionPercentiles.java}
(84%)
copy bdd/java/src/test/java/org/apache/iggy/bdd/RunCucumberTest.java =>
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/report/metrics/GroupMetrics.java
(53%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/report/metrics/GroupMetricsSummary.java
copy foreign/java/{buildSrc/build.gradle.kts =>
bench/src/main/java/org/apache/iggy/bench/models/report/metrics/HistogramBin.java}
(87%)
copy
foreign/java/{java-sdk/src/main/java/org/apache/iggy/stream/StreamDetails.java
=>
bench/src/main/java/org/apache/iggy/bench/models/report/metrics/IndividualMetrics.java}
(51%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/report/metrics/IndividualMetricsSummary.java
copy
foreign/java/{java-sdk/src/main/java/org/apache/iggy/client/blocking/SystemClient.java
=>
bench/src/main/java/org/apache/iggy/bench/models/report/metrics/LatencyDistribution.java}
(63%)
copy
foreign/java/bench/src/main/java/org/apache/iggy/bench/models/{common/generator/DataBatch.java
=> report/metrics/LatencyMetrics.java} (72%)
copy foreign/java/{buildSrc/build.gradle.kts =>
bench/src/main/java/org/apache/iggy/bench/models/report/metrics/LogNormalParams.java}
(87%)
copy foreign/java/{buildSrc/build.gradle.kts =>
bench/src/main/java/org/apache/iggy/bench/models/report/metrics/TimePoint.java}
(88%)
copy
foreign/java/bench/src/main/java/org/apache/iggy/bench/{common/enums/ActorKind.java
=> models/report/metrics/TimeSeries.java} (58%)
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/report/FinalReportBuilder.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/report/GroupMetricsCalculator.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/report/HardwareInfoCollector.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/report/IndividualMetricsCalculator.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/report/ServerStatsCollector.java
create mode 100644
foreign/java/bench/src/main/java/org/apache/iggy/bench/report/StatsHelper.java
copy foreign/java/{java-sdk/src/test/resources/logback-test.xml =>
bench/src/main/resources/logback.xml} (70%)
