This is an automated email from the ASF dual-hosted git repository.
hgruszecki pushed a change to branch bump-versions-script
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 3caf1f21f feat(ci): add version bump tooling and consistency checks
add f0e85781d chore(python): bump Python SDK to 0.7.3-dev1 (#2989)
add ba8e865af ci: fix ASF github actions allowlist violations (#2993)
add 3863ad5b5 chore(ci): add uv lock check to pre-commit hooks (#2996)
add f762e4f2b feat(server): implement TwoHalves buffer (#2944)
add a6ba900a5 ci: pin Docker actions to SHA and bump setup-bazel per ASF
allowlist (#2999)
add b03914cd3 fix(ci): prevent flaky keyring tests by deferring unlock to
test phase (#2995)
add 01803cc0a ci: partition Rust tests across 2 parallel CI machines
(#3003)
add f66540010 fix: Helm chart install guidance and deployment defaults
(#2976)
add 50557dcef fix(bench): delete stale streams on re-run to prevent
corrupted latency (#2991)
add 38bf2dc4c refactor(csharp): rename asynchronous methods to have Async
suffix (#2994)
add dbd0e25cd deps(rust): bump workspace dependencies (#3005)
add d4a5287d6 feat: add UI /healthz endpoint (#2983)
add 5cc7c37db fix(docs): fix grammar errors in README, examples, and test
comments (#3011)
add c19a600a8 feat(rust): add sans-IO frame codec and command dispatch
table (#2967)
add 707ab2435 chore(python): bump SDK to 0.7.4-dev1, modernize CI and deps
(#2992)
add 6180d88e6 feat(go): implement binary reader/writer (#2986)
add 298cd3282 fix(server): prevent consumer offset skip during concurrent
produce+consume (#2958)
add 7ed29dc69 fix(deps): resolve 15 Dependabot vulnerability alerts (#3016)
add a81bcc601 feat(server): aligned buffer memory pool (#2921)
add 484f98a59 feat(server): add io_uring EINVAL diagnostics for shard
executors (#3021)
add 2098f4918 test(csharp): wait for HTTP readiness in fixture (#3024)
add 4e3029d6b refactor(consensus): consolidate VSR types in
binary_protocol (#3014)
add 93d7f8970 ci: split post-merge monolith and harden Codecov uploads
(#3006)
add 601e59776 feat(go): send SDK version in login request (#3025)
add cea62a95d fix(security): replace SecretString with String for API
response tokens (#3008)
add 3727d66d2 chore(deps): bump requests from 2.32.5 to 2.33.0 in
/foreign/python (#3031)
add 4659a2b51 ci: allow `deps-dev` scope in PR title (#3035)
add a78dd0726 chore(deps-dev): bump picomatch from 4.0.3 to 4.0.4 in
/foreign/node (#3034)
add 38e392abe chore(deps-dev): bump picomatch from 4.0.3 to 4.0.4 in
/examples/node (#3033)
new 38bbbf8c5 feat(ci): add version bump tooling and consistency checks
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (3caf1f21f)
\
N -- N -- N refs/heads/bump-versions-script (38bbbf8c5)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../actions/python-maturin/post-merge/action.yml | 14 +-
.../actions/python-maturin/pre-merge/action.yml | 2 +-
.github/actions/rust/pre-merge/action.yml | 40 +-
.github/actions/utils/docker-buildx/action.yml | 12 +-
.../actions/utils/setup-cpp-with-cache/action.yml | 2 +-
.github/config/components.yml | 3 +-
.github/workflows/_common.yml | 1 +
.github/workflows/_test.yml | 5 +-
.github/workflows/_test_examples.yml | 2 +-
.../{post-merge.yml => coverage-baseline.yml} | 277 +--
.github/workflows/edge-release.yml | 123 ++
.github/workflows/post-merge.yml | 503 +----
.github/workflows/pre-merge.yml | 4 +
.github/workflows/publish.yml | 4 +-
.pre-commit-config.yaml | 8 +
Cargo.lock | 525 +++--
Cargo.toml | 59 +-
DEPENDENCIES.md | 158 +-
README.md | 2 +-
bdd/python/uv.lock | 2 +-
codecov.yml | 29 +-
core/ai/mcp/src/main.rs | 4 +-
core/bench/dashboard/server/Cargo.lock | 1575 --------------
core/bench/src/args/common.rs | 10 +
core/bench/src/args/examples.rs | 1 +
core/bench/src/benchmarks/benchmark.rs | 64 +-
core/bench/src/main.rs | 4 +-
core/binary_protocol/Cargo.toml | 2 +-
core/binary_protocol/src/codec.rs | 58 +
core/binary_protocol/src/codes.rs | 54 +-
core/binary_protocol/src/consensus/message.rs | 113 +-
core/binary_protocol/src/consensus/mod.rs | 1 +
core/binary_protocol/src/consensus/operation.rs | 89 +-
core/binary_protocol/src/dispatch.rs | 450 ++++
core/binary_protocol/src/error.rs | 4 +-
core/binary_protocol/src/frame.rs | 32 -
core/binary_protocol/src/framing.rs | 289 +++
core/binary_protocol/src/lib.rs | 28 +-
core/binary_protocol/src/message_view.rs | 11 +-
core/binary_protocol/src/primitives/identifier.rs | 19 +-
.../binary_protocol/src/primitives/partitioning.rs | 25 +-
.../src/requests/users/create_user.rs | 5 +-
.../src/requests/users/update_permissions.rs | 5 +-
.../src/responses/clients/client_response.rs | 2 +-
.../src/responses/clients/get_client.rs | 7 +-
.../consumer_groups/get_consumer_group.rs | 15 +-
.../src/responses/streams/get_stream.rs | 5 +-
.../src/responses/system/get_cluster_metadata.rs | 244 +++
.../{streams/create_stream.rs => system/get_me.rs} | 8 +-
.../login_user.rs => system/get_snapshot.rs} | 48 +-
.../src/responses/system/get_stats.rs | 7 +-
core/binary_protocol/src/responses/system/mod.rs | 6 +
.../src/responses/topics/get_topic.rs | 5 +-
core/cli/src/args/mod.rs | 4 +-
.../create_personal_access_token.rs | 7 +-
core/cli/src/commands/binary_system/login.rs | 3 +-
core/common/Cargo.toml | 5 +-
core/common/src/alloc/buffer.rs | 145 +-
core/common/src/alloc/memory_pool.rs | 62 +-
core/common/src/lib.rs | 1 -
core/common/src/traits/binary_mapper.rs | 5 +-
core/common/src/types/consensus/header.rs | 879 --------
core/common/src/types/consensus/message.rs | 719 -------
core/common/src/types/consensus/mod.rs | 19 -
.../common/src/types/message/messages_batch_mut.rs | 25 +-
.../common/src/types/message/messages_batch_set.rs | 18 +-
core/common/src/types/mod.rs | 1 -
.../src/types/permissions/personal_access_token.rs | 16 +-
core/common/src/types/segment.rs | 29 +-
.../src/types/segment_storage/index_reader.rs | 31 +-
.../src/types/segment_storage/messages_reader.rs | 32 +-
core/common/src/types/user/user_identity_info.rs | 17 +-
core/connectors/runtime/src/main.rs | 4 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 1 +
core/connectors/sinks/iceberg_sink/src/catalog.rs | 18 +-
core/consensus/Cargo.toml | 1 +
core/consensus/src/impls.rs | 15 +-
core/consensus/src/lib.rs | 3 +-
core/consensus/src/namespaced_pipeline.rs | 5 +-
core/consensus/src/plane_helpers.rs | 7 +-
core/integration/src/bench_utils.rs | 14 +-
.../tests/cli/general/test_overview_command.rs | 16 +-
.../test_pat_login_options.rs | 3 +-
.../data_integrity/verify_after_server_restart.rs | 2 +-
.../verify_no_plaintext_credentials_on_disk.rs | 3 +-
core/integration/tests/mcp/mod.rs | 4 +-
core/integration/tests/server/message_cleanup.rs | 9 +-
.../server/scenarios/authentication_scenario.rs | 3 +-
.../concurrent_produce_consume_scenario.rs | 196 ++
.../scenarios/cross_protocol_pat_scenario.rs | 5 +-
.../server/scenarios/log_rotation_scenario.rs | 2 +-
.../server/scenarios/message_cleanup_scenario.rs | 169 +-
core/integration/tests/server/scenarios/mod.rs | 2 +
.../scenarios/reconnect_after_restart_scenario.rs | 300 ++-
.../scenarios/restart_offset_skip_scenario.rs | 272 +++
.../scenarios/stream_size_validation_scenario.rs | 4 +-
.../tests/server/scenarios/user_scenario.rs | 9 +-
core/integration/tests/server/specific.rs | 39 +-
core/{clock => iobuf}/Cargo.toml | 10 +-
core/iobuf/src/lib.rs | 604 ++++++
core/message_bus/Cargo.toml | 1 +
core/message_bus/src/lib.rs | 3 +-
core/metadata/Cargo.toml | 1 +
core/metadata/src/impls/metadata.rs | 8 +-
core/metadata/src/stm/mod.rs | 4 +-
core/metadata/src/stm/mux.rs | 5 +-
core/partitions/Cargo.toml | 1 +
core/partitions/src/iggy_partition.rs | 5 +-
core/partitions/src/iggy_partitions.rs | 9 +-
core/partitions/src/journal.rs | 7 +-
core/partitions/src/lib.rs | 14 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/http/http_client.rs | 3 +-
core/server/Cargo.toml | 1 -
.../handlers/messages/send_messages_handler.rs | 1 +
core/server/src/bootstrap.rs | 10 +-
core/server/src/diagnostics.rs | 226 ++
core/server/src/http/mapper.rs | 3 +-
core/server/src/http/messages.rs | 20 +-
core/server/src/http/personal_access_tokens.rs | 6 +-
core/server/src/main.rs | 32 +-
core/server/src/shard/mod.rs | 82 +-
core/server/src/shard/system/messages.rs | 2 +-
core/server/src/shard/system/partitions.rs | 74 +-
core/server/src/shard/system/segments.rs | 124 +-
core/server/src/streaming/partitions/journal.rs | 93 +-
.../src/streaming/partitions/local_partition.rs | 4 +-
core/server/src/streaming/partitions/log.rs | 12 +
core/server/src/streaming/partitions/mod.rs | 2 +
core/server/src/streaming/partitions/ops.rs | 297 +--
core/server/src/streaming/partitions/ops_tests.rs | 359 +++
core/server/src/websocket/mod.rs | 41 +
core/server/src/websocket/websocket_listener.rs | 4 +-
.../server/src/websocket/websocket_tls_listener.rs | 4 +-
core/shard/Cargo.toml | 1 +
core/shard/src/lib.rs | 7 +-
core/shard/src/router.rs | 3 +-
core/simulator/Cargo.toml | 1 +
core/simulator/src/bus.rs | 3 +-
core/simulator/src/client.rs | 11 +-
core/simulator/src/deps.rs | 3 +-
core/simulator/src/lib.rs | 9 +-
core/simulator/src/main.rs | 3 +-
core/simulator/src/network.rs | 2 +-
core/simulator/src/packet.rs | 3 +-
.../Iggy_SDK.Examples.Basic.Consumer/Program.cs | 2 +-
.../Iggy_SDK.Examples.Basic.Producer/Program.cs | 2 +-
.../Program.cs | 2 +-
.../Program.cs | 2 +-
.../Program.cs | 2 +-
.../Program.cs | 2 +-
.../Program.cs | 2 +-
.../Program.cs | 2 +-
.../Iggy_SDK.Examples.NewSdk.Consumer/Program.cs | 2 +-
.../Iggy_SDK.Examples.NewSdk.Producer/Program.cs | 4 +-
.../Iggy_SDK.Examples.NewSdk.Producer/Utils.cs | 2 +-
.../Iggy_SDK.Examples.TcpTls.Consumer/Program.cs | 2 +-
.../Iggy_SDK.Examples.TcpTls.Producer/Program.cs | 2 +-
examples/node/package-lock.json | 496 +++--
examples/node/package.json | 3 +
examples/python/uv.lock | 8 +-
.../message-headers/message-compression/README.md | 12 +-
foreign/csharp/Benchmarks/Program.cs | 2 +-
.../BasicMessagingOperationsSteps.cs | 2 +-
.../ClusterRedirectionTests.cs | 8 +-
.../ConsumerGroupTests.cs | 2 +-
.../Fixtures/IggyServerFixture.cs | 10 +-
.../IggyPublisherTests.cs | 24 +-
.../IggyTlsConnectionTests.cs | 6 +-
.../PersonalAccessTokenTests.cs | 2 +-
.../Iggy_SDK.Tests.Integration/SystemTests.cs | 4 +-
.../Iggy_SDK.Tests.Integration/UsersTests.cs | 46 +-
foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs | 10 +-
.../Iggy_SDK/Contracts/Auth/GlobalPermissions.cs | 14 +-
.../IggyClient/IIggyPersonalAccessToken.cs | 2 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyUsers.cs | 18 +-
.../Implementations/HttpMessageStream.cs | 20 +-
.../IggyClient/Implementations/TcpMessageStream.cs | 26 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
.../csharp/Iggy_SDK/Publishers/IggyPublisher.cs | 16 +-
.../csharp/Iggy_SDK/Publishers/IggyPublisherOfT.cs | 6 +-
foreign/csharp/README.md | 8 +-
foreign/go/contracts/version.go | 2 -
foreign/go/internal/codec/reader.go | 217 ++
foreign/go/internal/codec/reader_test.go | 358 +++
foreign/go/internal/codec/roundtrip_test.go | 105 +
foreign/go/internal/codec/writer.go | 151 ++
foreign/go/internal/codec/writer_test.go | 128 ++
foreign/go/internal/command/session.go | 4 +-
.../command/session_test.go} | 37 +-
foreign/node/package-lock.json | 2276 +++++++-------------
foreign/node/package.json | 3 +
foreign/python/Cargo.toml | 13 +-
foreign/python/pyproject.toml | 8 +-
foreign/python/uv.lock | 8 +-
helm/charts/iggy/Chart.yaml | 2 +-
helm/charts/iggy/README.md | 48 +-
helm/charts/iggy/templates/deployment.yaml | 27 +-
helm/charts/iggy/values.yaml | 12 +-
scripts/bump-version.sh | 9 +-
scripts/ci/shellcheck.sh | 6 +-
scripts/ci/uv-lock-check.sh | 98 +
web/README.md | 8 +-
web/package-lock.json | 1003 +++++----
web/package.json | 5 +-
.../src/routes/healthz/+server.ts | 14 +-
206 files changed, 8177 insertions(+), 7349 deletions(-)
copy .github/workflows/{post-merge.yml => coverage-baseline.yml} (61%)
create mode 100644 .github/workflows/edge-release.yml
delete mode 100644 core/bench/dashboard/server/Cargo.lock
create mode 100644 core/binary_protocol/src/dispatch.rs
delete mode 100644 core/binary_protocol/src/frame.rs
create mode 100644 core/binary_protocol/src/framing.rs
create mode 100644
core/binary_protocol/src/responses/system/get_cluster_metadata.rs
copy core/binary_protocol/src/responses/{streams/create_stream.rs =>
system/get_me.rs} (74%)
copy core/binary_protocol/src/responses/{users/login_user.rs =>
system/get_snapshot.rs} (56%)
delete mode 100644 core/common/src/types/consensus/header.rs
delete mode 100644 core/common/src/types/consensus/message.rs
delete mode 100644 core/common/src/types/consensus/mod.rs
create mode 100644
core/integration/tests/server/scenarios/concurrent_produce_consume_scenario.rs
create mode 100644
core/integration/tests/server/scenarios/restart_offset_skip_scenario.rs
copy core/{clock => iobuf}/Cargo.toml (87%)
create mode 100644 core/iobuf/src/lib.rs
create mode 100644 core/server/src/streaming/partitions/ops_tests.rs
create mode 100644 foreign/go/internal/codec/reader.go
create mode 100644 foreign/go/internal/codec/reader_test.go
create mode 100644 foreign/go/internal/codec/roundtrip_test.go
create mode 100644 foreign/go/internal/codec/writer.go
create mode 100644 foreign/go/internal/codec/writer_test.go
copy foreign/go/{client/tcp/tcp_clients_management.go =>
internal/command/session_test.go} (56%)
create mode 100755 scripts/ci/uv-lock-check.sh
copy foreign/node/src/client/client.debug.ts =>
web/src/routes/healthz/+server.ts (81%)
