This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch dependabot/npm_and_yarn/web/devalue-5.3.2
in repository https://gitbox.apache.org/repos/asf/iggy.git
from c71c2d28 chore(deps): bump devalue from 5.1.1 to 5.3.2 in /web
add d0c61806 fix(ci): correct dockerhub credentials and remove redundant
push trigger (#2137)
add 050943c5 fix(ci): make webui build docker image for `linux/arm64`
(#2138)
add 0c9ba69f chore(deps): upgrade rust dependencies, update readmes with
docker hub (#2139)
add 95308097 feat(ci): add `skip_tag_creation` option and improve
`use_latest_ci` (#2140)
add ccfff470 fix(ci): simplify use_latest_ci to download script from
master directly (#2141)
add 394d4835 fix(ci): auto-create directories in
copy-latest-from-master.sh (#2142)
add 28422628 fix(ci): use `1.89` as default Rust version instead of
`unknown` (#2143)
add adbfc967 fix(server,cli): use correct hashmap for cg offsets, add -c
flag to cli (#2145)
add 6f58eca3 fix(ci): remove duplicated bdd tests, handle IGGY_CI_BUILD
(#2149)
add d9f9ab45 fix(ci): add linux/arm64 platform support for
iggy-bench-dashboard (#2150)
add 2e03e6eb fix(ci): increase post-merge timeout to 120 min (#2151)
add 2456b3ec feat(server,sdk): implement GetClusterMetadata command (#2152)
add c2b26477 chore(python): fix typing issues and make Python SDK mypy
check blocking on errors (#2153)
add 8f59d91a feat(go): add DeleteConsumerOffset function. (#2147)
add 6638d612 feat(server): add environment variable support for array
config overrides (#2154)
add 23522dea feat(sdk): implement GetClusterMetadata command interface
(#2155)
add 2cf4b69b refactor(sdk,server): unify `enum TransportProtocol` across
codebase (#2158)
add 8a1ce2a4 Merge branch 'master' into
dependabot/npm_and_yarn/web/devalue-5.3.2
No new revisions were added by this update.
Summary of changes:
.../actions/python-maturin/pre-merge/action.yml | 11 +-
.github/actions/utils/docker-buildx/action.yml | 6 +-
.github/config/components.yml | 14 -
.github/config/publish.yml | 4 +-
.github/workflows/_build_python_wheels.yml | 76 +-
.github/workflows/post-merge.yml | 4 +-
.github/workflows/pre-merge.yml | 3 -
.github/workflows/publish.yml | 197 +++--
Cargo.lock | 848 ++++++++++-----------
Cargo.toml | 28 +-
DEPENDENCIES.md | 173 +++--
README.md | 2 +-
bdd/go/tests/tcp_test/offset_feature_delete.go | 155 ++++
.../tests/tcp_test/offset_feature_deserialize.go | 9 +-
core/ai/mcp/Cargo.toml | 2 +-
core/ai/mcp/Dockerfile | 2 +
core/ai/mcp/README.md | 2 +
core/ai/mcp/src/service/mod.rs | 2 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/README.md | 2 +
.../old_github_workflows/workflows/docker.yml | 4 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/bench/src/args/common.rs | 5 +-
core/bench/src/args/props.rs | 5 +-
core/bench/src/args/transport.rs | 16 +-
core/bench/src/utils/client_factory.rs | 9 +-
core/bench/src/utils/mod.rs | 8 +-
core/bench/src/utils/server_starter.rs | 9 +-
.../binary_consumer_offsets/get_consumer_offset.rs | 3 +-
.../binary_consumer_offsets/set_consumer_offset.rs | 3 +-
.../src/client/binary_clients/cluster_client.rs} | 13 +-
.../src/client/binary_clients/mod.rs | 2 +
.../binary_cluster/mod.rs} | 27 +-
core/binary_protocol/src/client/mod.rs | 1 +
core/binary_protocol/src/utils/mapper.rs | 6 +-
core/cli/Cargo.toml | 2 +-
core/cli/src/args/consumer_offset.rs | 14 +-
core/cli/src/main.rs | 2 +
.../system/{get_me.rs => get_cluster_metadata.rs} | 51 +-
core/common/src/commands/system/mod.rs | 1 +
core/common/src/lib.rs | 11 +-
core/common/src/types/cluster/metadata.rs | 179 +++++
.../src/types/cluster}/mod.rs | 11 +-
core/common/src/types/cluster/node.rs | 140 ++++
core/common/src/types/cluster/role.rs | 72 ++
core/common/src/types/cluster/status.rs | 80 ++
core/common/src/types/command/mod.rs | 3 +
.../configuration/auth_config/connection_string.rs | 21 +-
core/common/src/types/configuration/mod.rs | 3 +-
.../{quick_config => quic_config}/mod.rs | 0
.../quic_client_config.rs | 0
.../quic_client_config_builder.rs | 0
.../quic_client_reconnection_config.rs | 0
.../quic_connection_string_options.rs | 0
core/common/src/types/configuration/transport.rs | 157 ++++
core/common/src/types/consumer/consumer_kind.rs | 5 +-
core/common/src/types/mod.rs | 1 +
core/configs/server.toml | 36 +
core/connectors/README.md | 2 +
core/connectors/runtime/Dockerfile | 2 +
core/connectors/runtime/README.md | 4 +
core/integration/Cargo.toml | 3 +-
core/integration/src/bench_utils.rs | 4 +-
core/integration/src/http_client.rs | 7 +-
core/integration/src/quic_client.rs | 7 +-
core/integration/src/tcp_client.rs | 7 +-
core/integration/src/test_server.rs | 15 +-
core/integration/tests/cli/common/mod.rs | 8 +-
.../test_consumer_offset_get_command.rs | 22 +-
.../test_consumer_offset_set_command.rs | 20 +-
.../test_pat_create_command.rs | 4 +-
.../tests/cli/system/test_cli_session_scenario.rs | 7 +-
.../tests/cli/system/test_me_command.rs | 57 +-
.../cli/user/test_user_permissions_command.rs | 10 +-
core/integration/tests/config_provider/mod.rs | 220 ++++++
.../data_integrity/verify_after_server_restart.rs | 15 +-
core/integration/tests/mcp/mod.rs | 8 +-
core/integration/tests/server/cg.rs | 6 +-
core/integration/tests/server/general.rs | 6 +-
core/integration/tests/server/mod.rs | 11 +-
core/integration/tests/streaming/segment.rs | 2 +
core/integration/tests/streaming/snapshot.rs | 2 +
core/integration/tests/streaming/system.rs | 5 +
core/sdk/src/client_provider.rs | 36 +-
.../src/client_wrappers/binary_cluster_client.rs} | 26 +-
core/sdk/src/client_wrappers/mod.rs | 1 +
.../src/clients/binary_cluster.rs} | 17 +-
core/sdk/src/clients/mod.rs | 1 +
.../src/http/binary_cluster.rs} | 27 +-
core/sdk/src/http/mod.rs | 1 +
core/sdk/src/prelude.rs | 8 +-
core/sdk/src/quic/quic_client.rs | 5 +-
core/server/Cargo.toml | 2 +-
core/server/Dockerfile | 2 +
core/server/server.http | 6 +-
core/server/src/binary/command.rs | 7 +
.../get_cluster_metadata_handler.rs} | 31 +-
.../src/binary/handlers/cluster}/mod.rs | 3 +-
core/server/src/binary/handlers/mod.rs | 1 +
core/server/src/binary/mapper.rs | 11 +-
core/server/src/configs/{tcp.rs => cluster.rs} | 35 +-
core/server/src/configs/config_provider.rs | 166 +++-
core/server/src/configs/defaults.rs | 38 +-
core/server/src/configs/mod.rs | 1 +
core/server/src/configs/server.rs | 2 +
core/server/src/http/system.rs | 19 +-
core/server/src/main.rs | 1 +
core/server/src/quic/listener.rs | 4 +-
.../server/src/streaming/clients/client_manager.rs | 25 +-
.../src/streaming/partitions/consumer_offsets.rs | 2 +-
core/server/src/streaming/systems/clients.rs | 9 +-
core/server/src/streaming/systems/cluster/mod.rs | 73 ++
core/server/src/streaming/systems/mod.rs | 1 +
core/server/src/streaming/systems/streams.rs | 2 +
core/server/src/streaming/systems/system.rs | 6 +
core/server/src/tcp/tcp_listener.rs | 4 +-
core/server/src/tcp/tcp_tls_listener.rs | 4 +-
foreign/cpp/.devcontainer/devcontainer.json | 60 +-
.../binary_request_serializer.go | 17 +
.../go/binary_serialization/consumer_serializer.go | 14 +-
foreign/go/contracts/command_codes.go | 1 +
foreign/go/contracts/consumer.go | 2 +-
foreign/go/contracts/offets.go | 7 +
foreign/go/errors/constants.go | 4 +
foreign/go/errors/errors.go | 2 +
foreign/go/iggycli/client.go | 9 +
foreign/go/tcp/tcp_offset_managament.go | 11 +
foreign/python/python_examples/producer.py | 4 +-
helm/charts/iggy-ui/README.md | 2 +-
helm/charts/iggy-ui/values.yaml | 2 +-
scripts/DEPENDENCIES.md | 847 --------------------
scripts/copy-latest-from-master.sh | 139 ++++
web/README.md | 6 +-
133 files changed, 2631 insertions(+), 1971 deletions(-)
create mode 100644 bdd/go/tests/tcp_test/offset_feature_delete.go
copy core/{sdk/src/tcp/tcp_stream.rs =>
binary_protocol/src/client/binary_clients/cluster_client.rs} (70%)
copy core/binary_protocol/src/{cli/cli_command.rs =>
client/binary_cluster/mod.rs} (61%)
copy core/common/src/commands/system/{get_me.rs => get_cluster_metadata.rs}
(56%)
create mode 100644 core/common/src/types/cluster/metadata.rs
copy core/{binary_protocol/src/cli/binary_context =>
common/src/types/cluster}/mod.rs (82%)
create mode 100644 core/common/src/types/cluster/node.rs
create mode 100644 core/common/src/types/cluster/role.rs
create mode 100644 core/common/src/types/cluster/status.rs
rename core/common/src/types/configuration/{quick_config =>
quic_config}/mod.rs (100%)
rename core/common/src/types/configuration/{quick_config =>
quic_config}/quic_client_config.rs (100%)
rename core/common/src/types/configuration/{quick_config =>
quic_config}/quic_client_config_builder.rs (100%)
rename core/common/src/types/configuration/{quick_config =>
quic_config}/quic_client_reconnection_config.rs (100%)
rename core/common/src/types/configuration/{quick_config =>
quic_config}/quic_connection_string_options.rs (100%)
create mode 100644 core/common/src/types/configuration/transport.rs
copy core/{binary_protocol/src/cli/cli_command.rs =>
sdk/src/client_wrappers/binary_cluster_client.rs} (58%)
copy core/{server/src/streaming/topics/segments.rs =>
sdk/src/clients/binary_cluster.rs} (71%)
copy core/{binary_protocol/src/cli/cli_command.rs =>
sdk/src/http/binary_cluster.rs} (62%)
copy core/server/src/binary/handlers/{topics/get_topic_handler.rs =>
cluster/get_cluster_metadata_handler.rs} (70%)
copy core/{bench/report/src/plotting/text =>
server/src/binary/handlers/cluster}/mod.rs (95%)
copy core/server/src/configs/{tcp.rs => cluster.rs} (63%)
create mode 100644 core/server/src/streaming/systems/cluster/mod.rs
copy core/common/src/types/configuration/auth_config/auto_login.rs =>
foreign/go/binary_serialization/consumer_serializer.go (71%)
delete mode 100644 scripts/DEPENDENCIES.md
create mode 100755 scripts/copy-latest-from-master.sh
