This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch fix_mux_plane_generics
in repository https://gitbox.apache.org/repos/asf/iggy.git
from b0af52de0 fix(cluster): fix type mismatch for variadic plane impl
add 6f01169b8 fix(ci): use cargo-llvm-cov for Python SDK coverage (#2817)
add 3432714ab feat(simulator): implement PacketSimulator for deterministic
simulator (#2769)
add 1ca37f199 perf(bench): downsample time series charts with LTTB (#2831)
add 71eb4d5f0 feat(bench): add latency distribution chart with log-normal
fit (#2832)
add 7ebce1bb9 fix(integration): prevent flaky connector sink tests from
f64 round-trip mismatch (#2838)
add 29a27cc00 feat(java): add missing methods to async TCP UsersClient
(#2837)
add effbab6f6 feat(bench): add embeddable chart endpoints with PNG
rendering (#2833)
add ab8834d92 fix(ci): prevent v8/musl build failures in artifacts and
Docker (#2844)
add 448fb8caf docs(csharp): update dotnet SDK README (#2836)
add 2eefbc3ca refactor(go): Introduce Command interface to improve Go
client request handling (#2737)
add 88f43f525 feat(cpp): add bazel building and testing infrastructure
(#2785)
add 0423f52c9 feat(cli): add cluster metadata command (#2839)
add 4f1044dce fix(csharp): fix .net node redirection in tcp client (#2843)
add be23a351a feat(consensus): add loopback queue for primary
self-addressed messages (#2825)
add 28c846ee1 Merge branch 'master' into fix_mux_plane_generics
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 2 +-
.github/actions/cpp-bazel/pre-merge/action.yml | 80 ++
.../actions/python-maturin/pre-merge/action.yml | 74 +-
.github/actions/rust/pre-merge/action.yml | 8 +-
.../actions/utils/setup-cpp-with-cache/action.yml | 34 +-
.github/config/components.yml | 9 +
.github/workflows/_build_rust_artifacts.yml | 10 +-
.github/workflows/_detect.yml | 11 +-
.github/workflows/_test.yml | 23 +-
.github/workflows/post-merge.yml | 50 +-
.github/workflows/pre-merge.yml | 21 +-
Cargo.lock | 1285 +++++++++++++++++++-
Cargo.toml | 3 +-
DEPENDENCIES.md | 127 +-
core/ai/mcp/Dockerfile | 6 +-
core/bench/dashboard/README.md | 4 +-
core/bench/dashboard/frontend/Cargo.toml | 2 +-
core/bench/dashboard/frontend/assets/style.css | 139 +++
.../frontend/src/components/chart/single_chart.rs | 7 +
.../frontend/src/components/chart/trend_chart.rs | 4 +-
.../frontend/src/components/embed_modal.rs | 205 ++++
.../frontend/src/components/layout/topbar.rs | 76 ++
.../bench/dashboard/frontend/src/components/mod.rs | 2 +-
.../selectors/measurement_type_selector.rs | 15 +-
core/bench/dashboard/frontend/src/state/ui.rs | 7 +
core/bench/dashboard/server/Cargo.toml | 3 +-
core/bench/dashboard/server/src/cache/loader.rs | 1 +
core/bench/dashboard/server/src/cache/storage.rs | 4 +
core/bench/dashboard/server/src/cache/watcher.rs | 7 +
core/bench/dashboard/server/src/error.rs | 6 +
core/bench/dashboard/server/src/handlers.rs | 450 +++++++
core/bench/dashboard/server/src/main.rs | 8 +
core/bench/dashboard/server/src/render.rs | 93 ++
core/bench/dashboard/shared/src/lib.rs | 13 +-
core/bench/report/Cargo.toml | 2 +-
core/bench/report/src/lib.rs | 185 ++-
core/bench/report/src/plotting/chart.rs | 67 +-
core/bench/report/src/plotting/chart_kind.rs | 2 +
core/bench/report/src/types/group_metrics.rs | 12 +-
core/bench/report/src/types/individual_metrics.rs | 5 +
..._metrics_summary.rs => latency_distribution.rs} | 51 +-
core/bench/report/src/types/mod.rs | 1 +
core/bench/report/src/types/time_series.rs | 11 +
core/bench/report/src/utils.rs | 140 ++-
core/bench/src/analytics/metrics/group.rs | 14 +
core/bench/src/analytics/metrics/individual.rs | 42 +-
.../src/analytics/metrics/latency_distribution.rs | 202 +++
core/bench/src/analytics/metrics/mod.rs | 1 +
core/bench/src/plot.rs | 9 +
core/bench/src/runner.rs | 10 +
.../src/cli/binary_cluster/get_cluster_metadata.rs | 121 ++
.../src/cli/binary_cluster}/mod.rs | 2 +-
core/binary_protocol/src/cli/mod.rs | 1 +
.../src/client/binary_clients/client.rs | 5 +-
.../poll_metadata.rs => cli/src/args/cluster.rs} | 23 +-
core/cli/src/args/common.rs | 10 +
core/cli/src/args/mod.rs | 5 +
core/cli/src/main.rs | 13 +-
core/common/Cargo.toml | 1 +
core/common/src/types/consensus/header.rs | 3 +-
core/connectors/runtime/Dockerfile | 6 +-
core/consensus/Cargo.toml | 3 +
core/consensus/src/impls.rs | 76 +-
core/consensus/src/plane_helpers.rs | 244 +++-
.../tests/cli/general/test_help_command.rs | 1 +
.../tests/cli/general/test_overview_command.rs | 1 +
core/integration/tests/cli/system/mod.rs | 1 +
.../cli/system/test_cluster_metadata_command.rs | 184 +++
core/integration/tests/connectors/mod.rs | 2 +-
core/server/Dockerfile | 6 +-
core/shard/src/lib.rs | 51 +
core/simulator/Cargo.toml | 4 +
core/simulator/src/lib.rs | 11 +
core/simulator/src/network.rs | 150 +++
core/simulator/src/packet.rs | 982 +++++++++++++++
core/simulator/src/ready_queue.rs | 261 ++++
foreign/cpp/.bazelrc | 54 +
foreign/cpp/.bazelversion | 1 +
.../iggy/Chart.yaml => foreign/cpp/.clang-format | 25 +-
foreign/cpp/.gitignore | 1 +
foreign/cpp/BUILD.bazel | 115 ++
foreign/cpp/Cargo.lock | 291 +++++
{core/harness_derive => foreign/cpp}/Cargo.toml | 15 +-
bdd/node/Dockerfile => foreign/cpp/MODULE.bazel | 15 +-
foreign/cpp/MODULE.bazel.lock | 272 +++++
foreign/cpp/README.md | 10 +
.../auto_login.rs => foreign/cpp/build.rs | 10 +-
foreign/cpp/include/iggy.hpp | 120 ++
.../types/client/mod.rs => foreign/cpp/src/lib.rs | 6 +-
foreign/cpp/tests/test.cpp | 85 ++
.../ClusterRedirectionTests.cs | 129 ++
.../Fixtures/IggyClusterFixture.cs | 202 +++
foreign/csharp/Iggy_SDK/IggyClient/IIggyClient.cs | 6 +
.../Implementations/HttpMessageStream.cs | 9 +-
.../IggyClient/Implementations/TcpMessageStream.cs | 77 +-
foreign/csharp/README.md | 115 +-
.../binary_request_serializer.go | 410 -------
.../binary_response_deserializer.go | 8 +-
.../go/binary_serialization/consumer_serializer.go | 28 -
.../binary_serialization/identifier_serializer.go | 54 -
.../update_topic_serializer.go | 68 --
.../go/client/tcp/tcp_access_token_management.go | 8 +-
foreign/go/client/tcp/tcp_clients_management.go | 5 +-
.../go/client/tcp/tcp_consumer_group_management.go | 53 +-
foreign/go/client/tcp/tcp_messaging.go | 11 +-
foreign/go/client/tcp/tcp_offset_management.go | 9 +-
foreign/go/client/tcp/tcp_partition_management.go | 7 +-
foreign/go/client/tcp/tcp_session_management.go | 10 +-
foreign/go/client/tcp/tcp_stream_management.go | 16 +-
foreign/go/client/tcp/tcp_topic_management.go | 20 +-
foreign/go/client/tcp/tcp_user_management.go | 22 +-
foreign/go/client/tcp/tcp_utilities.go | 4 +-
foreign/go/contracts/access_tokens.go | 44 +-
foreign/go/contracts/change_password.go | 52 +
foreign/go/contracts/command.go | 29 +-
foreign/go/contracts/consumer.go | 11 +
foreign/go/contracts/consumer_groups.go | 111 +-
.../create_stream.go} | 14 +-
.../create_stream_test.go} | 12 +-
.../create_topic.go} | 48 +-
foreign/go/contracts/create_user.go | 77 ++
.../go/contracts/{cluster.go => delete_stream.go} | 11 +-
.../go/contracts/{cluster.go => delete_topic.go} | 12 +-
.../go/contracts/{command.go => delete_user.go} | 13 +-
foreign/go/contracts/{command.go => get_stats.go} | 11 +-
foreign/go/contracts/{cluster.go => get_stream.go} | 11 +-
.../go/contracts/{command.go => get_streams.go} | 11 +-
foreign/go/contracts/{cluster.go => get_topic.go} | 12 +-
foreign/go/contracts/{cluster.go => get_topics.go} | 11 +-
foreign/go/contracts/{command.go => get_user.go} | 13 +-
foreign/go/contracts/{command.go => get_users.go} | 11 +-
foreign/go/contracts/identifier.go | 32 +
.../identifier_test.go} | 25 +-
foreign/go/contracts/login.go | 36 -
foreign/go/contracts/offsets.go | 118 +-
foreign/go/contracts/partitions.go | 60 +-
.../go/contracts/{connection_info.go => ping.go} | 11 +-
.../poll_messages.go} | 57 +-
.../poll_messages_test.go} | 23 +-
.../send_messages.go} | 72 +-
.../send_messages_test.go} | 38 +-
.../session.go} | 53 +-
.../update_stream.go} | 28 +-
.../update_stream_test.go} | 16 +-
foreign/go/contracts/update_topic.go | 76 ++
.../update_topic_test.go} | 20 +-
foreign/go/contracts/update_user.go | 85 ++
foreign/go/contracts/update_user_permissions.go | 63 +
foreign/go/contracts/users.go | 118 +-
.../org/apache/iggy/client/async/UsersClient.java | 115 ++
.../iggy/client/async/tcp/AsyncTcpConnection.java | 56 +
.../iggy/client/async/tcp/UsersTcpClient.java | 95 +-
.../iggy/client/async/tcp/UsersTcpClientTest.java | 239 ++++
153 files changed, 8722 insertions(+), 1229 deletions(-)
create mode 100644 .github/actions/cpp-bazel/pre-merge/action.yml
copy bdd/python/pyproject.toml =>
.github/actions/utils/setup-cpp-with-cache/action.yml (61%)
create mode 100644 core/bench/dashboard/frontend/src/components/embed_modal.rs
create mode 100644 core/bench/dashboard/server/src/render.rs
copy core/bench/report/src/types/{group_metrics_summary.rs =>
latency_distribution.rs} (52%)
create mode 100644 core/bench/src/analytics/metrics/latency_distribution.rs
create mode 100644
core/binary_protocol/src/cli/binary_cluster/get_cluster_metadata.rs
copy core/{server/src/compat/index_rebuilding =>
binary_protocol/src/cli/binary_cluster}/mod.rs (96%)
copy core/{common/src/types/message/poll_metadata.rs =>
cli/src/args/cluster.rs} (66%)
create mode 100644
core/integration/tests/cli/system/test_cluster_metadata_command.rs
create mode 100644 core/simulator/src/network.rs
create mode 100644 core/simulator/src/packet.rs
create mode 100644 core/simulator/src/ready_queue.rs
create mode 100644 foreign/cpp/.bazelrc
create mode 100644 foreign/cpp/.bazelversion
copy helm/charts/iggy/Chart.yaml => foreign/cpp/.clang-format (69%)
create mode 100644 foreign/cpp/.gitignore
create mode 100644 foreign/cpp/BUILD.bazel
create mode 100644 foreign/cpp/Cargo.lock
copy {core/harness_derive => foreign/cpp}/Cargo.toml (83%)
copy bdd/node/Dockerfile => foreign/cpp/MODULE.bazel (81%)
create mode 100644 foreign/cpp/MODULE.bazel.lock
create mode 100644 foreign/cpp/README.md
copy core/common/src/types/configuration/auth_config/auto_login.rs =>
foreign/cpp/build.rs (83%)
create mode 100644 foreign/cpp/include/iggy.hpp
copy core/common/src/types/client/mod.rs => foreign/cpp/src/lib.rs (91%)
create mode 100644 foreign/cpp/tests/test.cpp
create mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/ClusterRedirectionTests.cs
create mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/Fixtures/IggyClusterFixture.cs
delete mode 100644 foreign/go/binary_serialization/binary_request_serializer.go
delete mode 100644 foreign/go/binary_serialization/consumer_serializer.go
delete mode 100644 foreign/go/binary_serialization/identifier_serializer.go
delete mode 100644 foreign/go/binary_serialization/update_topic_serializer.go
create mode 100644 foreign/go/contracts/change_password.go
rename foreign/go/{binary_serialization/create_stream_serializer.go =>
contracts/create_stream.go} (79%)
rename foreign/go/{binary_serialization/create_stream_serializer_test.go =>
contracts/create_stream_test.go} (89%)
rename foreign/go/{binary_serialization/create_topic_serializer.go =>
contracts/create_topic.go} (55%)
create mode 100644 foreign/go/contracts/create_user.go
copy foreign/go/contracts/{cluster.go => delete_stream.go} (79%)
copy foreign/go/contracts/{cluster.go => delete_topic.go} (77%)
copy foreign/go/contracts/{command.go => delete_user.go} (80%)
copy foreign/go/contracts/{command.go => get_stats.go} (83%)
copy foreign/go/contracts/{cluster.go => get_stream.go} (80%)
copy foreign/go/contracts/{command.go => get_streams.go} (82%)
copy foreign/go/contracts/{cluster.go => get_topic.go} (78%)
copy foreign/go/contracts/{cluster.go => get_topics.go} (80%)
copy foreign/go/contracts/{command.go => get_user.go} (81%)
copy foreign/go/contracts/{command.go => get_users.go} (83%)
rename foreign/go/{binary_serialization/identifier_serializer_test.go =>
contracts/identifier_test.go} (82%)
delete mode 100644 foreign/go/contracts/login.go
copy foreign/go/contracts/{connection_info.go => ping.go} (84%)
rename foreign/go/{binary_serialization/fetch_messages_request_serializer.go
=> contracts/poll_messages.go} (62%)
rename
foreign/go/{binary_serialization/fetch_messages_request_serializer_test.go =>
contracts/poll_messages_test.go} (85%)
rename foreign/go/{binary_serialization/send_messages_request_serializer.go =>
contracts/send_messages.go} (62%)
rename
foreign/go/{binary_serialization/send_messages_request_serializer_test.go =>
contracts/send_messages_test.go} (70%)
rename foreign/go/{binary_serialization/log_in_request_serializer.go =>
contracts/session.go} (62%)
rename foreign/go/{binary_serialization/update_stream_serializer.go =>
contracts/update_stream.go} (69%)
rename foreign/go/{binary_serialization/update_stream_serializer_test.go =>
contracts/update_stream_test.go} (85%)
create mode 100644 foreign/go/contracts/update_topic.go
rename foreign/go/{binary_serialization/update_topic_serializer_test.go =>
contracts/update_topic_test.go} (85%)
create mode 100644 foreign/go/contracts/update_user.go
create mode 100644 foreign/go/contracts/update_user_permissions.go
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/UsersTcpClientTest.java
