This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch loopback-queue
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 33610e687 feat(consensus): add loopback queue for primary
self-addressed messages
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 fbda38a95 Merge branch 'master' into loopback-queue
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 2 +-
.github/actions/rust/pre-merge/action.yml | 8 +-
.github/workflows/_build_rust_artifacts.yml | 10 +-
Cargo.lock | 1260 +++++++++++++++++++-
DEPENDENCIES.md | 125 +-
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 +
core/connectors/runtime/Dockerfile | 6 +-
core/integration/tests/connectors/mod.rs | 2 +-
core/server/Dockerfile | 6 +-
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 ++++
102 files changed, 4951 insertions(+), 1072 deletions(-)
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
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
