This is an automated email from the ASF dual-hosted git repository.
maciej pushed a change to branch update-web-deps
in repository https://gitbox.apache.org/repos/asf/iggy.git
from dff32454d deps(web): update frontend dependencies
add 28e7c04c9 ci: add Codecov coverage for Python SDK (#2790)
add 6222c9801 ci(python,rust): fix publish dry-run and disable Windows
wheels (#2813)
add 586c66994 fix(ci): unblock wheel collection when Windows is disabled
(#2814)
add cca86fe26 feat(ci): impl typos automatically checks (#2803)
add 57da00785 feat(java): add async API parity with blocking client (#2718)
add f58577334 ci(js): add Codecov coverage for Node SDK (#2792)
add f3fef3dda feat(shard): create `shard` crate and generic `IggyShard`
(#2811)
add 6ec4ce7c1 Merge branch 'master' into update-web-deps
No new revisions were added by this update.
Summary of changes:
.github/actions/node-npm/pre-merge/action.yml | 7 +-
.../actions/python-maturin/pre-merge/action.yml | 3 +
.github/actions/rust/post-merge/action.yml | 8 +-
.github/workflows/_build_python_wheels.yml | 4 +-
.github/workflows/_common.yml | 25 ++
.github/workflows/_test.yml | 24 ++
.github/workflows/post-merge.yml | 125 ++++++
.github/workflows/pre-merge.yml | 4 +
.pre-commit-config.yaml | 8 +
.typos.toml | 136 ++++++
CONTRIBUTING.md | 12 +
Cargo.lock | 13 +
Cargo.toml | 1 +
DEPENDENCIES.md | 1 +
codecov.yml | 8 +-
core/ai/mcp/README.md | 2 +-
core/bench/src/actors/producing_consumer/mod.rs | 2 +-
...er.rs => typed_benchmark_producing_consumer.rs} | 0
core/bench/src/benchmarks/common.rs | 2 +-
core/cli/src/args/user.rs | 8 +-
core/common/src/commands/messages/send_messages.rs | 24 +-
core/consensus/src/plane_helpers.rs | 2 +-
.../tests/cli/user/test_user_create_command.rs | 4 +-
.../cli/user/test_user_permissions_command.rs | 4 +-
.../http_config_provider/config_wrapped.toml | 2 +-
.../scenarios/segment_rotation_race_scenario.rs | 2 +-
core/sdk/src/clients/producer_config.rs | 2 +-
.../handlers/messages/send_messages_handler.rs | 4 +-
core/server/src/io/storage.rs | 25 +-
core/{simulator => shard}/Cargo.toml | 5 +-
core/shard/src/lib.rs | 152 +++++++
core/simulator/Cargo.toml | 1 +
core/simulator/src/deps.rs | 19 +-
core/simulator/src/lib.rs | 42 +-
core/simulator/src/replica.rs | 119 +++--
.../message-headers/message-compression/README.md | 2 +-
foreign/csharp/Iggy_SDK.sln.DotSettings | 8 +-
...Exception.cs => InvalidBaseAddressException.cs} | 0
...yClientExtenstion.cs => IggyClientExtension.cs} | 2 +-
.../IdentifiersByteSerializationTests.cs | 2 +-
foreign/csharp/scripts/pack.sh | 2 +-
...anagament.go => tcp_access_token_management.go} | 0
...nts_managament.go => tcp_clients_management.go} | 0
...agament.go => tcp_consumer_group_management.go} | 0
...fset_managament.go => tcp_offset_management.go} | 0
...n_managament.go => tcp_partition_management.go} | 0
...ion_managament.go => tcp_session_management.go} | 0
...ream_managament.go => tcp_stream_management.go} | 0
...topic_managament.go => tcp_topic_management.go} | 0
...p_user_managament.go => tcp_user_management.go} | 0
foreign/go/contracts/{offets.go => offsets.go} | 0
foreign/go/samples/consumer/README.md | 4 +-
foreign/go/samples/consumer/consumer.go | 4 +-
foreign/go/samples/producer/README.md | 4 +-
.../iggy-connector-pinot/integration-test.sh | 2 +-
.../iggy/client/async/ConsumerGroupsClient.java | 92 ++++
.../iggy/client/async/ConsumerOffsetsClient.java | 90 ++++
.../apache/iggy/client/async/PartitionsClient.java | 75 ++++
.../client/async/PersonalAccessTokensClient.java | 66 +++
.../org/apache/iggy/client/async/SystemClient.java | 69 +++
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 64 +++
.../client/async/tcp/ConsumerGroupsTcpClient.java | 91 ++++
.../client/async/tcp/ConsumerOffsetsTcpClient.java | 102 +++++
.../iggy/client/async/tcp/PartitionsTcpClient.java | 69 +++
.../async/tcp/PersonalAccessTokensTcpClient.java | 121 ++++++
.../iggy/client/async/tcp/SystemTcpClient.java | 128 ++++++
.../client/async/AsyncClientIntegrationTest.java | 252 +++++++++++
.../async/tcp/AsyncIggyTcpClientBuilderTest.java | 56 +++
foreign/node/package-lock.json | 480 ++++++++++++++++++---
foreign/node/package.json | 1 +
foreign/node/src/client/client.socket.ts | 2 +-
foreign/node/src/wire/client/client.utils.ts | 4 +-
foreign/node/src/wire/command.code.ts | 2 +-
foreign/node/src/wire/message/header.utils.ts | 2 +-
foreign/node/src/wire/message/poll.utils.ts | 2 +-
foreign/python/pyproject.toml | 2 +
foreign/python/uv.lock | 136 ++++++
web/justfile | 6 +-
.../components/Modals/DeletePartitionsModal.svelte | 2 +-
.../components/Modals/StreamSettingsModal.svelte | 2 +-
.../components/Modals/TopicSettingsModal.svelte | 2 +-
web/src/lib/components/PermissionsManager.svelte | 4 +-
web/src/lib/utils/addOnKeyDownListener.ts | 2 +-
83 files changed, 2506 insertions(+), 248 deletions(-)
create mode 100644 .typos.toml
rename
core/bench/src/actors/producing_consumer/{typed_banchmark_producing_consumer.rs
=> typed_benchmark_producing_consumer.rs} (100%)
copy core/{simulator => shard}/Cargo.toml (90%)
create mode 100644 core/shard/src/lib.rs
rename foreign/csharp/Iggy_SDK/Exceptions/{InvalidBaseAdressException.cs =>
InvalidBaseAddressException.cs} (100%)
rename foreign/csharp/Iggy_SDK/Extensions/{IggyClientExtenstion.cs =>
IggyClientExtension.cs} (98%)
rename foreign/go/client/tcp/{tcp_access_token_managament.go =>
tcp_access_token_management.go} (100%)
rename foreign/go/client/tcp/{tcp_clients_managament.go =>
tcp_clients_management.go} (100%)
rename foreign/go/client/tcp/{tcp_consumer_group_managament.go =>
tcp_consumer_group_management.go} (100%)
rename foreign/go/client/tcp/{tcp_offset_managament.go =>
tcp_offset_management.go} (100%)
rename foreign/go/client/tcp/{tcp_partition_managament.go =>
tcp_partition_management.go} (100%)
rename foreign/go/client/tcp/{tcp_session_managament.go =>
tcp_session_management.go} (100%)
rename foreign/go/client/tcp/{tcp_stream_managament.go =>
tcp_stream_management.go} (100%)
rename foreign/go/client/tcp/{tcp_topic_managament.go =>
tcp_topic_management.go} (100%)
rename foreign/go/client/tcp/{tcp_user_managament.go =>
tcp_user_management.go} (100%)
rename foreign/go/contracts/{offets.go => offsets.go} (100%)
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/ConsumerOffsetsClient.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/PartitionsClient.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/PersonalAccessTokensClient.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/SystemClient.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/ConsumerOffsetsTcpClient.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/PartitionsTcpClient.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/PersonalAccessTokensTcpClient.java
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/SystemTcpClient.java