You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by gi...@apache.org on 2026/06/18 20:05:07 UTC
(iggy) branch dependabot/bazel/foreign/cpp/cpp-13e7475b8e updated (f29de2cee -> 62a613a7f)
This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch dependabot/bazel/foreign/cpp/cpp-13e7475b8e
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit f29de2cee chore(deps): Bump rules_cc
add f1ee269a5 feat(csharp): enhance message handling with rented payloads (#3471)
add 53959c029 feat(cluster): add TLS 1.3 to replica plane with PSK channel binding (#3461)
add 6c4b74ce0 perf(go): pool the request-path wire payload (#3442)
add fe168eeec chore(deps): Bump com.github.spotbugs:spotbugs-annotations from 4.9.8 to 4.10.1 in /foreign/java in the java group across 1 directory (#3489)
add 281e4672b fix(connectors): prevent silent failures in FlatBuffer conversions (#3431)
add 7f41bb920 chore(deps): Bump the node group across 1 directory with 2 updates (#3493)
add 5fcf40cbf feat(php): add consumer message iterator (#3463)
add 988194d55 feat: replace ingress-nginx smoke cluster with Gateway API and Envoy Gateway (#3386)
add 9a0f799b7 fix(web): use explicit css import to support latest vite build (#3502)
add df5dbef48 chore(deps): bump java jackson to 3.2 (#3501)
add e37231886 feat(server-ng): add expired personal access token cleaner (#3448)
add b52e40eeb chore(deps): Bump vite and @sveltejs/vite-plugin-svelte in /web (#3494)
add 52b060d96 fix(integration): fix partitions,permissions integration tests (#3487)
add 62a613a7f chore(deps): Bump rules_cc
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 (f29de2cee)
\
N -- N -- N refs/heads/dependabot/bazel/foreign/cpp/cpp-13e7475b8e (62a613a7f)
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.
No new revisions were added by this update.
Summary of changes:
.github/config/components.yml | 2 +
Cargo.lock | 29 +-
Cargo.toml | 8 +-
core/binary_protocol/src/consensus/header.rs | 10 +-
core/configs/src/server_config/cluster.rs | 40 +
core/configs/src/server_config/defaults.rs | 5 +-
core/configs/src/server_config/validators.rs | 103 +-
.../sdk/src/transforms/flatbuffer_convert.rs | 259 +++-
core/connectors/sdk/src/transforms/mod.rs | 2 +-
.../connectors/sdk/tests/flatbuffer_integration.rs | 4 +-
core/consensus/src/impls.rs | 28 +-
core/consensus/src/observability.rs | 10 +-
core/consensus/src/plane_helpers.rs | 47 +-
core/integration/src/harness/handle/common.rs | 24 +
core/integration/src/harness/handle/server.rs | 20 +-
.../src/harness/orchestrator/harness.rs | 20 +
core/integration/src/harness/port_reserver.rs | 14 +-
.../tests/connectors/random_source_liveness.rs | 5 +-
core/integration/tests/mod.rs | 1 -
core/integration/tests/sdk/clients.rs | 85 --
core/integration/tests/sdk/messages.rs | 172 +++
core/integration/tests/sdk/mod.rs | 4 +-
core/integration/tests/server/general.rs | 48 +-
core/integration/tests/server/mod.rs | 13 +
core/integration/tests/server/scenarios/mod.rs | 78 ++
.../tests/server/scenarios/offset_scenario.rs | 42 +-
.../tests/server/scenarios/timestamp_scenario.rs | 42 +-
core/integration/tests/server/specific.rs | 26 +-
core/journal/src/file_storage.rs | 41 +-
core/journal/src/prepare_journal.rs | 43 +-
core/message_bus/Cargo.toml | 1 +
core/message_bus/src/config.rs | 11 +
core/message_bus/src/connector.rs | 313 +----
core/message_bus/src/framing.rs | 10 +-
core/message_bus/src/installer/mod.rs | 73 +-
core/message_bus/src/installer/replica.rs | 296 ++++-
core/message_bus/src/installer/tcp.rs | 6 +-
core/message_bus/src/lib.rs | 290 ++++-
core/message_bus/src/replica/auth.rs | 89 +-
core/message_bus/src/replica/handshake.rs | 466 +++++++
core/message_bus/src/replica/io.rs | 71 +-
core/message_bus/src/replica/listener.rs | 407 +-----
core/message_bus/src/replica/mod.rs | 6 +-
core/message_bus/src/socket_opts.rs | 3 +-
core/message_bus/src/transports/tcp_tls.rs | 180 ++-
core/message_bus/src/transports/tls/mod.rs | 98 +-
core/message_bus/tests/backpressure.rs | 34 +-
core/message_bus/tests/common/mod.rs | 120 +-
core/message_bus/tests/connection_lost_notify.rs | 24 +-
core/message_bus/tests/directional_connection.rs | 60 +-
core/message_bus/tests/head_of_line.rs | 40 +-
core/message_bus/tests/reconnect.rs | 33 +-
core/message_bus/tests/reconnect_skip_connected.rs | 105 +-
core/message_bus/tests/replica_auth_handshake.rs | 117 +-
core/message_bus/tests/replica_roundtrip.rs | 25 +-
core/message_bus/tests/replica_tls_bench.rs | 164 +++
core/message_bus/tests/replica_tls_mitm.rs | 168 +++
core/message_bus/tests/replica_tls_roundtrip.rs | 235 ++++
core/message_bus/tests/shard_zero_gating.rs | 55 +-
core/message_bus/tests/tcp_tls_client_roundtrip.rs | 12 +-
core/message_bus/tests/vectored_batch.rs | 34 +-
core/message_bus/tests/wss_client_roundtrip.rs | 12 +-
core/metadata/src/impls/metadata.rs | 301 +++--
core/metadata/src/lib.rs | 2 +-
core/metadata/src/stm/user.rs | 212 ++-
core/partitions/src/iggy_partition.rs | 576 ++++++--
core/partitions/src/journal.rs | 21 +-
core/partitions/src/log.rs | 5 +
core/sdk/src/tcp/tcp_client.rs | 70 +-
core/sdk/src/vsr.rs | 42 +-
core/sdk/src/websocket/websocket_client.rs | 34 +-
core/server-ng/config.toml | 26 +
core/server-ng/src/auth.rs | 10 +-
core/server-ng/src/bootstrap.rs | 315 ++++-
core/server-ng/src/dispatch.rs | 549 +++++++-
core/server-ng/src/lib.rs | 2 +
core/server-ng/src/login_register.rs | 6 +-
core/server-ng/src/main.rs | 40 +-
core/server-ng/src/partition_helpers.rs | 5 +
core/server-ng/src/pat.rs | 30 +-
.../server-ng/src/personal_access_token_cleaner.rs | 150 +++
core/server-ng/src/responses.rs | 145 ++-
core/server-ng/src/users.rs | 63 +
core/server-ng/src/wire.rs | 29 +
core/server_common/src/send_messages2.rs | 63 +-
core/shard/src/builder.rs | 7 +-
core/shard/src/coordinator.rs | 121 +-
core/shard/src/lib.rs | 293 ++++-
core/shard/src/metrics.rs | 7 +-
core/shard/src/router.rs | 160 ++-
core/simulator/src/client.rs | 105 +-
examples/java/build.gradle.kts | 2 +-
foreign/csharp/Directory.Packages.props | 1 -
.../BasicMessagingOperationsSteps.cs | 2 +-
.../IggyPublisherTests.cs | 145 ++-
.../IggyTypedPublisherTests.cs | 349 +++++
.../SendMessagesRentedTests.cs | 318 +++++
.../Iggy_SDK/Consumers/IggyConsumer.Rented.cs | 14 +-
foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs | 2 +-
.../Iggy_SDK/Consumers/ReceivedRentedMessage.cs | 7 +-
.../Iggy_SDK/Contracts/Auth/GlobalPermissions.cs | 2 +-
foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/StreamPermissions.cs | 2 +-
.../csharp/Iggy_SDK/Contracts/Tcp/TcpContracts.cs | 221 +---
.../csharp/Iggy_SDK/Contracts/TopicPermissions.cs | 2 +-
.../Iggy_SDK/Encryption/AesMessageEncryptor.cs | 101 +-
.../Iggy_SDK/Encryption/IMessageEncryptor.cs | 16 +-
.../csharp/Iggy_SDK/IggyClient/IIggyPublisher.cs | 14 +
.../IggyClient/Implementations/TcpMessageStream.cs | 61 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 3 +-
.../Iggy_SDK/JsonConverters/MessageConverter.cs | 10 +-
foreign/csharp/Iggy_SDK/Messages/Message.cs | 52 +-
foreign/csharp/Iggy_SDK/Messages/MessageHeader.cs | 23 +-
.../csharp/Iggy_SDK/Messages/PooledBufferWriter.cs | 155 +++
.../Iggy_SDK/Messages/RentedMemoryManager.cs | 74 ++
.../csharp/Iggy_SDK/Messages/RentedMessageBatch.cs | 186 +++
.../BackgroundMessageProcessor.Logging.cs | 20 +-
.../Publishers/BackgroundMessageProcessor.cs | 475 +++++--
foreign/csharp/Iggy_SDK/Publishers/ISerializer.cs | 38 +-
.../csharp/Iggy_SDK/Publishers/IggyPublisher.cs | 266 ++--
.../Iggy_SDK/Publishers/IggyPublisherBuilder.cs | 4 +-
.../Iggy_SDK/Publishers/IggyPublisherConfig.cs | 25 +-
.../csharp/Iggy_SDK/Publishers/IggyPublisherOfT.cs | 155 ++-
.../Publishers/MessageBatchFailedEventArgs.cs | 4 +-
.../Iggy_SDK/Publishers/PublisherEncryption.cs | 81 ++
.../Iggy_SDK/Publishers/PublisherErrorEventArgs.cs | 10 +-
foreign/csharp/Iggy_SDK/Publishers/SendUnit.cs | 248 ++++
.../Publishers/SystemTextJsonSerializer.cs | 79 ++
foreign/csharp/Iggy_SDK/Utils/EventAggregator.cs | 19 +-
.../Iggy_SDK/Utils/TcpMessageStreamHelpers.cs | 16 +-
.../ConsumerTests/RentedConsumerTests.cs | 4 +-
.../MapperTests/HeaderEncryptionTests.cs | 16 +-
.../PublisherTests/IggyTypedPublisherTests.cs | 456 +++++++
.../PublisherTests/PublisherEncryptionTests.cs | 76 ++
.../UtilityTests/HeaderValueTests.cs | 1 -
.../UtilityTests/PooledBufferWriterTests.cs | 190 +++
.../UtilityTests/RentedMessageBatchTests.cs | 265 ++++
.../Iggy_SDK_Tests/UtilityTests/SendUnitTests.cs | 319 +++++
.../go/benchmarks/poll_encode_benchmark_test.go | 109 ++
foreign/go/client/tcp/tcp_core.go | 119 +-
foreign/go/client/tcp/tcp_core_encode_test.go | 210 +++
foreign/go/client/tcp/tcp_core_test.go | 37 +-
foreign/go/contracts/identifier.go | 63 +-
foreign/go/contracts/identifier_test.go | 21 +
foreign/go/internal/command/message.go | 52 +-
foreign/java/gradle/libs.versions.toml | 4 +-
foreign/node/package-lock.json | 484 ++-----
foreign/node/package.json | 4 +-
foreign/php/README.md | 11 +
foreign/php/iggy-php.stubs.php | 36 +
foreign/php/src/consumer.rs | 8 +-
foreign/php/src/lib.rs | 3 +
foreign/php/src/message_iterator.rs | 99 ++
foreign/php/tests/IggySdkTest.php | 60 +
scripts/ci/setup-helm-smoke-cluster.sh | 216 ++-
scripts/ci/test-helm.sh | 182 ++-
web/package-lock.json | 1377 +++++++++-----------
web/package.json | 4 +-
web/src/styles/app.css | 2 +-
159 files changed, 11933 insertions(+), 3871 deletions(-)
delete mode 100644 core/integration/tests/sdk/clients.rs
create mode 100644 core/integration/tests/sdk/messages.rs
create mode 100644 core/message_bus/src/replica/handshake.rs
create mode 100644 core/message_bus/tests/replica_tls_bench.rs
create mode 100644 core/message_bus/tests/replica_tls_mitm.rs
create mode 100644 core/message_bus/tests/replica_tls_roundtrip.rs
create mode 100644 core/server-ng/src/personal_access_token_cleaner.rs
create mode 100644 core/server-ng/src/users.rs
create mode 100644 foreign/csharp/Iggy_SDK.Tests.Integration/IggyTypedPublisherTests.cs
create mode 100644 foreign/csharp/Iggy_SDK.Tests.Integration/SendMessagesRentedTests.cs
create mode 100644 foreign/csharp/Iggy_SDK/Messages/PooledBufferWriter.cs
create mode 100644 foreign/csharp/Iggy_SDK/Messages/RentedMemoryManager.cs
create mode 100644 foreign/csharp/Iggy_SDK/Messages/RentedMessageBatch.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/PublisherEncryption.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/SendUnit.cs
create mode 100644 foreign/csharp/Iggy_SDK/Publishers/SystemTextJsonSerializer.cs
create mode 100644 foreign/csharp/Iggy_SDK_Tests/PublisherTests/IggyTypedPublisherTests.cs
create mode 100644 foreign/csharp/Iggy_SDK_Tests/PublisherTests/PublisherEncryptionTests.cs
create mode 100644 foreign/csharp/Iggy_SDK_Tests/UtilityTests/PooledBufferWriterTests.cs
create mode 100644 foreign/csharp/Iggy_SDK_Tests/UtilityTests/RentedMessageBatchTests.cs
create mode 100644 foreign/csharp/Iggy_SDK_Tests/UtilityTests/SendUnitTests.cs
create mode 100644 foreign/go/benchmarks/poll_encode_benchmark_test.go
create mode 100644 foreign/go/client/tcp/tcp_core_encode_test.go
create mode 100644 foreign/php/src/message_iterator.rs