You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by gk...@apache.org on 2026/08/24 09:38:00 UTC
(iggy) branch http-connectors-state updated (0274642cd -> b5ab798cc)
This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch http-connectors-state
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 0274642cd feat(connectors): store source state on an HTTP state server
add 0f48afd62 chore(deps): Bump the node group across 2 directories with 7 updates (#3938)
add 3a3d32387 chore(deps): Bump googletest from 1.17.0.bcr.2 to 1.18.0 in /foreign/cpp in the cpp group across 1 directory (#3937)
add ba10371a4 chore(deps): Bump the web group across 1 directory with 9 updates (#3936)
add 127a33c3b ci(rust): don't fail when a DAG scope matches no tests (#3943)
add 2b1406b18 chore(deps): Bump the python group across 3 directories with 1 update (#3926)
add cc269ef70 ci(rust): fail the build on rustdoc and rustc warnings (#3925)
add e1c868165 chore: migrate HawkEye to v7 (#3952)
add a65f177dc fix(server): truncate torn segment tails instead of resurrecting them (#3946)
add b5ab798cc Merge branch 'master' into http-connectors-state
No new revisions were added by this update.
Summary of changes:
.github/actions/csharp-dotnet/pre-merge/action.yml | 1 -
.github/actions/rust/pre-merge/action.yml | 9 +-
.github/config/hawkeye.version | 2 +-
CONTRIBUTING.md | 2 +-
Cargo.toml | 3 +
bdd/php/phpunit.xml.dist | 31 +-
bdd/python/uv.lock | 291 +-
bdd/rust/Cargo.toml | 3 +
core/ai/mcp/Cargo.toml | 3 +
core/bench/Cargo.toml | 3 +
core/bench/dashboard/frontend/Cargo.toml | 3 +
core/bench/dashboard/frontend/index.dev.html | 31 +-
core/bench/dashboard/frontend/index.html | 28 +-
core/bench/dashboard/frontend/index.prod.html | 31 +-
core/bench/dashboard/server/Cargo.toml | 3 +
core/bench/dashboard/shared/Cargo.toml | 3 +
core/bench/report/Cargo.toml | 3 +
core/bench/runner/Cargo.toml | 3 +
core/binary_protocol/Cargo.toml | 3 +
core/cli/Cargo.toml | 3 +
core/cli/src/args/context.rs | 2 +-
core/clock/Cargo.toml | 3 +
core/common/Cargo.toml | 3 +
core/common/src/error/iggy_error.rs | 5 +
core/common/src/lib.rs | 19 +
core/common/src/types/options/mod.rs | 12 +-
core/common/src/wire_conversions.rs | 4 +-
core/configs/Cargo.toml | 3 +
core/configs/src/server_config/cluster.rs | 2 +-
core/configs/src/server_config/message_bus.rs | 26 +-
core/configs/src/server_config/server.rs | 4 +-
core/configs/src/server_config/validators.rs | 62 +-
core/configs_derive/Cargo.toml | 3 +
core/configs_derive/src/lib.rs | 4 +-
core/connectors/runtime/Cargo.toml | 2 +
.../connectors/http_provider/response_extractor.rs | 2 +-
core/connectors/sdk/Cargo.toml | 3 +
core/connectors/sinks/clickhouse_sink/Cargo.toml | 3 +
core/connectors/sinks/delta_sink/Cargo.toml | 3 +
core/connectors/sinks/doris_sink/Cargo.toml | 3 +
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 3 +
core/connectors/sinks/http_sink/Cargo.toml | 3 +
core/connectors/sinks/http_sink/src/lib.rs | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 3 +
core/connectors/sinks/influxdb_sink/Cargo.toml | 3 +
core/connectors/sinks/meilisearch_sink/Cargo.toml | 3 +
core/connectors/sinks/mongodb_sink/Cargo.toml | 3 +
core/connectors/sinks/postgres_sink/Cargo.toml | 3 +
core/connectors/sinks/quickwit_sink/Cargo.toml | 3 +
core/connectors/sinks/s3_sink/Cargo.toml | 3 +
core/connectors/sinks/stdout_sink/Cargo.toml | 3 +
core/connectors/sinks/surrealdb_sink/Cargo.toml | 3 +
.../sources/elasticsearch_source/Cargo.toml | 3 +
core/connectors/sources/influxdb_source/Cargo.toml | 3 +
core/connectors/sources/postgres_source/Cargo.toml | 3 +
core/connectors/sources/random_source/Cargo.toml | 3 +
core/consensus/Cargo.toml | 3 +
core/consensus/src/client_table.rs | 4 +-
core/consensus/src/dvc_merge.rs | 2 +-
core/consensus/src/impls.rs | 4 +-
core/consensus/src/vsr_state.rs | 2 +-
core/cpu_allocation/Cargo.toml | 3 +
core/harness_derive/Cargo.toml | 3 +
core/integration/Cargo.toml | 6 +-
core/integration/src/harness/config/resolve.rs | 2 +-
.../cli/context/test_context_create_command.rs | 2 +-
.../tests/cluster/crash_recovery_corruption.rs | 101 +-
core/journal/Cargo.toml | 3 +
core/journal/src/file_storage.rs | 5 +
core/journal/src/prepare_journal.rs | 2 +-
core/message_bus/Cargo.toml | 3 +
core/message_bus/src/lib.rs | 2 +-
.../src/lifecycle/connection_registry.rs | 2 +-
core/message_bus/src/replica/handshake.rs | 2 +-
core/message_bus/src/transports/quic.rs | 2 +-
core/metadata/Cargo.toml | 3 +
core/metadata/src/impls/metadata.rs | 4 +-
core/metadata/src/stm/authz.rs | 6 +-
core/metadata/src/stm/mod.rs | 8 +-
core/metadata/src/stm/stream.rs | 2 +-
core/partitions/Cargo.toml | 3 +
core/partitions/src/iggy_index_reader.rs | 6 +-
core/partitions/src/iggy_index_writer.rs | 56 +-
core/partitions/src/iggy_partition.rs | 6 +-
core/partitions/src/iggy_partitions.rs | 7 +
core/partitions/src/messages_writer.rs | 47 +-
core/partitions/src/state_transfer.rs | 30 +-
core/sdk/Cargo.toml | 3 +
core/server/Cargo.toml | 3 +
core/server/config.toml | 79 +-
core/server/src/bootstrap.rs | 153 +-
core/server/src/partition_helpers.rs | 5 +-
core/server/src/partition_reconciler.rs | 234 +-
core/server/src/responses.rs | 2 +-
core/server/src/segment_recovery.rs | 3015 ++++++++++++++++++--
core/server/src/server_error.rs | 234 +-
core/server/src/users.rs | 2 +-
core/server_common/Cargo.toml | 3 +
core/server_common/src/lib.rs | 2 +
core/server_common/src/reactor_yield.rs | 100 +
.../src/segment_storage/index_writer.rs | 18 +-
.../src/segment_storage/messages_writer.rs | 21 +-
core/shard/Cargo.toml | 3 +
core/shard/src/lib.rs | 34 +-
core/shard_allocator/Cargo.toml | 3 +
core/simulator/Cargo.toml | 3 +
core/simulator/src/bus.rs | 2 +-
core/simulator/src/deps.rs | 6 +-
core/simulator/src/lib.rs | 4 +
core/simulator/src/network.rs | 2 +-
core/simulator/src/workload/mod.rs | 2 +-
core/simulator/src/workload/ops/mod.rs | 2 +-
core/simulator/src/workload/shadow.rs | 2 +-
core/system_stats/Cargo.toml | 3 +
core/tools/Cargo.toml | 3 +
.../Iggy_SDK.Examples.Basic.Consumer.csproj | 31 +-
.../Iggy_SDK.Examples.Basic.Producer.csproj | 31 +-
...ggy_SDK.Examples.GettingStarted.Consumer.csproj | 31 +-
...ggy_SDK.Examples.GettingStarted.Producer.csproj | 31 +-
.../Iggy_SDK.Examples.Shared.csproj | 31 +-
...gy_SDK.Examples.MessageEnvelope.Consumer.csproj | 31 +-
...gy_SDK.Examples.MessageEnvelope.Producer.csproj | 31 +-
...ggy_SDK.Examples.MessageHeaders.Consumer.csproj | 31 +-
...ggy_SDK.Examples.MessageHeaders.Producer.csproj | 31 +-
.../Iggy_SDK.Examples.NewSdk.Consumer.csproj | 35 +-
.../Iggy_SDK.Examples.NewSdk.Producer.csproj | 31 +-
.../Iggy_SDK.Examples.TcpTls.Consumer.csproj | 31 +-
.../Iggy_SDK.Examples.TcpTls.Producer.csproj | 31 +-
examples/node/eslint.config.ts | 1 -
examples/node/package-lock.json | 19 +-
examples/node/package.json | 4 +-
examples/node/src/basic/consumer.ts | 1 -
examples/node/src/basic/producer.ts | 1 -
examples/node/src/getting-started/consumer.ts | 1 -
examples/node/src/getting-started/producer.ts | 1 -
examples/node/src/index.ts | 1 -
examples/node/src/message-envelope/consumer.ts | 1 -
examples/node/src/message-envelope/producer.ts | 1 -
examples/node/src/message-headers/consumer.ts | 1 -
examples/node/src/message-headers/producer.ts | 1 -
examples/node/src/multi-tenant/consumer.ts | 1 -
examples/node/src/multi-tenant/producer.ts | 1 -
examples/node/src/sink-data-producer/producer.ts | 1 -
examples/node/src/stream-builder/example.ts | 1 -
examples/node/src/tcp-tls/consumer.ts | 1 -
examples/node/src/tcp-tls/producer.ts | 1 -
examples/node/src/utils/index.ts | 1 -
examples/python/uv.lock | 38 +-
examples/rust/Cargo.toml | 3 +
foreign/cpp/MODULE.bazel | 2 +-
foreign/cpp/MODULE.bazel.lock | 21 +-
foreign/csharp/Benchmarks/Benchmarks.csproj | 35 +-
foreign/csharp/Directory.Build.props | 31 +-
foreign/csharp/Directory.Packages.props | 31 +-
.../Iggy_SDK.Tests.BDD/Iggy_SDK.Tests.BDD.csproj | 31 +-
.../Iggy_SDK.Tests.Integration.csproj | 31 +-
foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs | 1 -
.../csharp/Iggy_SDK/Contracts/StreamResponse.cs | 1 -
foreign/csharp/Iggy_SDK/Contracts/TopicResponse.cs | 1 -
foreign/csharp/Iggy_SDK/Enums/IdKind.cs | 1 -
foreign/csharp/Iggy_SDK/Enums/PartitioningKind.cs | 1 -
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 31 +-
.../csharp/Iggy_SDK_Tests/Iggy_SDK_Tests.csproj | 35 +-
foreign/csharp/Shared/Shared.csproj | 31 +-
foreign/csharp/scripts/pack.sh | 1 -
foreign/go/errors/errors.yaml | 8 +
foreign/go/errors/errors_gen.go | 20 +
foreign/java/bench/src/main/resources/logback.xml | 31 +-
foreign/java/dev-support/checkstyle/checkstyle.xml | 35 +-
.../java/dev-support/checkstyle/suppressions.xml | 31 +-
.../java-sdk/src/test/resources/logback-test.xml | 35 +-
foreign/node/commitlint.config.js | 34 +-
foreign/node/eslint.config.mjs | 34 +-
foreign/node/package-lock.json | 411 ++-
foreign/node/package.json | 8 +-
foreign/node/src/bdd/auth.ts | 1 -
foreign/node/src/bdd/message.ts | 1 -
foreign/node/src/bdd/stream.ts | 1 -
foreign/node/src/bdd/topic.ts | 1 -
foreign/node/src/bdd/world.ts | 1 -
foreign/node/src/client.e2e.ts | 1 -
foreign/node/src/client/client.connection.test.ts | 1 -
foreign/node/src/client/client.connection.ts | 1 -
foreign/node/src/client/client.debug.ts | 1 -
foreign/node/src/client/client.socket.test.ts | 1 -
foreign/node/src/client/client.socket.ts | 1 -
foreign/node/src/client/client.ts | 1 -
foreign/node/src/client/client.type.ts | 1 -
foreign/node/src/client/client.utils.test.ts | 1 -
foreign/node/src/client/client.utils.ts | 1 -
foreign/node/src/client/index.ts | 1 -
foreign/node/src/debug-send.ts | 1 -
foreign/node/src/debug.ts | 1 -
foreign/node/src/e2e/tcp.client.e2e.ts | 1 -
foreign/node/src/e2e/tcp.cluster.e2e.ts | 1 -
foreign/node/src/e2e/tcp.consumer-group.e2e.ts | 1 -
foreign/node/src/e2e/tcp.consumer-stream.e2e.ts | 1 -
foreign/node/src/e2e/tcp.parallel.e2e.ts | 1 -
foreign/node/src/e2e/tcp.raw.e2e.ts | 1 -
foreign/node/src/e2e/tcp.send-message.e2e.ts | 1 -
foreign/node/src/e2e/tcp.stream.e2e.ts | 1 -
foreign/node/src/e2e/tcp.system.e2e.ts | 1 -
foreign/node/src/e2e/tcp.token.e2e.ts | 1 -
foreign/node/src/e2e/tcp.topic.e2e.ts | 1 -
foreign/node/src/e2e/tcp.user.e2e.ts | 1 -
foreign/node/src/e2e/test-client.utils.ts | 1 -
foreign/node/src/e2e/tls.system.e2e.ts | 1 -
foreign/node/src/examples/stream-file-to-topic.ts | 1 -
foreign/node/src/examples/stream-topic-to-file.ts | 1 -
foreign/node/src/examples/utils.ts | 1 -
foreign/node/src/index.ts | 1 -
foreign/node/src/stream/consumer-stream.ts | 1 -
foreign/node/src/stream/index.ts | 1 -
foreign/node/src/tcp.e2e.ts | 1 -
foreign/node/src/tcp.sm.utils.ts | 1 -
foreign/node/src/tls.system.e2e.ts | 1 -
foreign/node/src/type.utils.ts | 1 -
foreign/node/src/wire/client/client.utils.ts | 1 -
foreign/node/src/wire/client/get-client.command.ts | 1 -
.../node/src/wire/client/get-clients.command.ts | 1 -
foreign/node/src/wire/client/get-me.command.ts | 1 -
foreign/node/src/wire/client/index.ts | 1 -
foreign/node/src/wire/cluster/cluster.type.ts | 1 -
foreign/node/src/wire/cluster/cluster.utils.ts | 1 -
.../wire/cluster/get-cluster-metadata.command.ts | 1 -
foreign/node/src/wire/cluster/index.ts | 1 -
foreign/node/src/wire/command-set.test.ts | 1 -
foreign/node/src/wire/command-set.ts | 1 -
foreign/node/src/wire/command.code.ts | 1 -
foreign/node/src/wire/command.utils.ts | 1 -
.../consumer-group/create-group.command.test.ts | 1 -
.../wire/consumer-group/create-group.command.ts | 1 -
.../wire/consumer-group/delete-group.command.ts | 1 -
.../consumer-group/ensure-group.virtual.command.ts | 1 -
.../src/wire/consumer-group/get-group.command.ts | 1 -
.../src/wire/consumer-group/get-groups.command.ts | 1 -
.../src/wire/consumer-group/group.command.test.ts | 1 -
.../node/src/wire/consumer-group/group.utils.ts | 1 -
foreign/node/src/wire/consumer-group/index.ts | 1 -
.../src/wire/consumer-group/join-group.command.ts | 1 -
.../src/wire/consumer-group/leave-group.command.ts | 1 -
.../wire/consumer-group/sync-group.command.test.ts | 1 -
.../src/wire/consumer-group/sync-group.command.ts | 1 -
foreign/node/src/wire/error.code.ts | 2 +-
foreign/node/src/wire/error.utils.ts | 1 -
foreign/node/src/wire/identifier.utils.test.ts | 1 -
foreign/node/src/wire/identifier.utils.ts | 1 -
foreign/node/src/wire/index.ts | 1 -
.../wire/message/flush-unsaved-buffers.command.ts | 1 -
foreign/node/src/wire/message/header.type.ts | 1 -
foreign/node/src/wire/message/header.utils.test.ts | 1 -
foreign/node/src/wire/message/header.utils.ts | 1 -
foreign/node/src/wire/message/iggy-header.utils.ts | 1 -
foreign/node/src/wire/message/index.ts | 1 -
.../node/src/wire/message/message-batch.test.ts | 1 -
foreign/node/src/wire/message/message.utils.ts | 1 -
.../node/src/wire/message/partitioning.utils.ts | 1 -
.../src/wire/message/poll-messages.command.test.ts | 1 -
.../node/src/wire/message/poll-messages.command.ts | 1 -
foreign/node/src/wire/message/poll.utils.ts | 1 -
.../src/wire/message/send-messages.command.test.ts | 1 -
.../node/src/wire/message/send-messages.command.ts | 1 -
foreign/node/src/wire/number.utils.ts | 1 -
.../node/src/wire/offset/delete-offset.command.ts | 1 -
foreign/node/src/wire/offset/get-offset.command.ts | 1 -
foreign/node/src/wire/offset/index.ts | 1 -
foreign/node/src/wire/offset/offset.utils.ts | 1 -
.../node/src/wire/offset/store-offset.command.ts | 1 -
foreign/node/src/wire/options.utils.test.ts | 1 -
foreign/node/src/wire/options.utils.ts | 1 -
.../src/wire/partition/create-partition.command.ts | 1 -
.../src/wire/partition/delete-partition.command.ts | 1 -
foreign/node/src/wire/partition/index.ts | 1 -
.../src/wire/partition/partition.utils.test.ts | 1 -
foreign/node/src/wire/partition/partition.utils.ts | 1 -
.../src/wire/segment/delete-segments.command.ts | 1 -
foreign/node/src/wire/segment/index.ts | 1 -
foreign/node/src/wire/segment/segment.utils.ts | 1 -
foreign/node/src/wire/serialize.utils.ts | 1 -
foreign/node/src/wire/session/index.ts | 1 -
.../wire/session/login-with-token.command.test.ts | 1 -
.../src/wire/session/login-with-token.command.ts | 1 -
.../node/src/wire/session/login.command.test.ts | 1 -
foreign/node/src/wire/session/login.command.ts | 1 -
foreign/node/src/wire/session/login.utils.ts | 1 -
foreign/node/src/wire/session/logout.command.ts | 1 -
.../src/wire/stream/create-stream.command.test.ts | 1 -
.../node/src/wire/stream/create-stream.command.ts | 1 -
.../node/src/wire/stream/delete-stream.command.ts | 1 -
.../wire/stream/ensure-stream.virtual.command.ts | 1 -
foreign/node/src/wire/stream/get-stream.command.ts | 1 -
.../node/src/wire/stream/get-streams.command.ts | 1 -
foreign/node/src/wire/stream/index.ts | 1 -
.../node/src/wire/stream/purge-stream.command.ts | 1 -
foreign/node/src/wire/stream/stream.utils.ts | 1 -
.../node/src/wire/stream/update-stream.command.ts | 1 -
.../src/wire/system/describe-options.command.ts | 1 -
foreign/node/src/wire/system/get-stats.command.ts | 1 -
foreign/node/src/wire/system/index.ts | 1 -
foreign/node/src/wire/system/ping.command.ts | 1 -
.../src/wire/token/create-token.command.test.ts | 1 -
.../node/src/wire/token/create-token.command.ts | 1 -
.../src/wire/token/delete-token.command.test.ts | 1 -
.../node/src/wire/token/delete-token.command.ts | 1 -
foreign/node/src/wire/token/get-tokens.command.ts | 1 -
foreign/node/src/wire/token/index.ts | 1 -
foreign/node/src/wire/token/token.utils.ts | 1 -
.../src/wire/topic/create-topic.command.test.ts | 1 -
.../node/src/wire/topic/create-topic.command.ts | 1 -
.../node/src/wire/topic/delete-topic.command.ts | 1 -
.../src/wire/topic/ensure-topic.virtual.command.ts | 1 -
foreign/node/src/wire/topic/get-topic.command.ts | 1 -
foreign/node/src/wire/topic/get-topics.command.ts | 1 -
foreign/node/src/wire/topic/index.ts | 1 -
foreign/node/src/wire/topic/purge-topic.command.ts | 1 -
foreign/node/src/wire/topic/topic.utils.test.ts | 1 -
foreign/node/src/wire/topic/topic.utils.ts | 1 -
.../node/src/wire/topic/update-topic.command.ts | 1 -
.../node/src/wire/user/change-password.command.ts | 1 -
.../node/src/wire/user/create-user.command.test.ts | 1 -
foreign/node/src/wire/user/create-user.command.ts | 1 -
foreign/node/src/wire/user/delete-user.command.ts | 1 -
foreign/node/src/wire/user/get-user.command.ts | 1 -
foreign/node/src/wire/user/get-users.command.ts | 1 -
foreign/node/src/wire/user/index.ts | 1 -
.../node/src/wire/user/permissions.utils.test.ts | 1 -
foreign/node/src/wire/user/permissions.utils.ts | 1 -
.../src/wire/user/update-permissions.command.ts | 1 -
foreign/node/src/wire/user/update-user.command.ts | 1 -
foreign/node/src/wire/user/user.utils.ts | 1 -
foreign/node/src/wire/uuid.utils.ts | 1 -
foreign/node/src/wire/vsr/header.ts | 1 -
foreign/node/src/wire/vsr/index.ts | 1 -
foreign/node/src/wire/vsr/operation.ts | 1 -
foreign/node/src/wire/vsr/register.ts | 1 -
foreign/node/src/wire/vsr/reply.ts | 1 -
foreign/node/src/wire/vsr/session.ts | 1 -
foreign/node/src/wire/vsr/vsr.test.ts | 1 -
foreign/php/phpunit.xml.dist | 31 +-
foreign/python/tests/__init__.py | 1 +
foreign/python/uv.lock | 752 ++---
licenserc.toml | 27 +-
scripts/ci/license-headers.sh | 27 +-
scripts/dashboard/build_release.sh | 1 -
scripts/dashboard/run_dev.sh | 1 -
web/package-lock.json | 420 +--
web/package.json | 18 +-
web/src/app.html | 31 +-
web/src/lib/components/AppToasts.svelte | 35 +-
web/src/lib/components/Breadcrumbs.svelte | 35 +-
web/src/lib/components/Button.svelte | 31 +-
web/src/lib/components/Checkbox.svelte | 35 +-
web/src/lib/components/Combobox.svelte | 35 +-
.../components/DeleteButtonWithConfirmation.svelte | 31 +-
.../components/DropdownMenu/DropdownMenu.svelte | 31 +-
web/src/lib/components/DurationInput.svelte | 35 +-
web/src/lib/components/FixedSvelteComponent.svelte | 35 +-
web/src/lib/components/Header.svelte | 31 +-
web/src/lib/components/Icon.svelte | 31 +-
web/src/lib/components/Input.svelte | 31 +-
.../lib/components/Layouts/SettingsLayout.svelte | 31 +-
web/src/lib/components/Listbox.svelte | 31 +-
web/src/lib/components/Loader.svelte | 35 +-
web/src/lib/components/LoadingIndicator.svelte | 31 +-
web/src/lib/components/Logo/Logo.svelte | 31 +-
web/src/lib/components/Logo/LogoMark.svelte | 31 +-
web/src/lib/components/Logo/LogoType.svelte | 31 +-
.../MessageDecoder/MessageDecoder.svelte | 35 +-
web/src/lib/components/ModalConfirmation.svelte | 31 +-
.../components/Modals/AddPartitionsModal.svelte | 31 +-
.../lib/components/Modals/AddStreamModal.svelte | 31 +-
web/src/lib/components/Modals/AddTopicModal.svelte | 35 +-
web/src/lib/components/Modals/AddUserModal.svelte | 35 +-
web/src/lib/components/Modals/AppModals.svelte | 31 +-
.../components/Modals/DeletePartitionsModal.svelte | 35 +-
.../lib/components/Modals/DeleteUserModal.svelte | 35 +-
web/src/lib/components/Modals/EditUserModal.svelte | 35 +-
.../Modals/EditUserPermissionsModal.svelte | 35 +-
.../lib/components/Modals/InspectMessage.svelte | 35 +-
web/src/lib/components/Modals/ModalBase.svelte | 31 +-
.../components/Modals/StreamSettingsModal.svelte | 35 +-
.../components/Modals/TopicSettingsModal.svelte | 35 +-
web/src/lib/components/Navbar.svelte | 31 +-
web/src/lib/components/Paginator.svelte | 35 +-
web/src/lib/components/PasswordInput.svelte | 31 +-
web/src/lib/components/PeriodicInvalidator.svelte | 31 +-
web/src/lib/components/PermissionsManager.svelte | 35 +-
.../lib/components/PreventEventsPropagation.svelte | 31 +-
web/src/lib/components/RangeInput.svelte | 31 +-
.../RouteComponents/Settings/UsersTab.svelte | 35 +-
.../Settings/UsersTabActions.svelte | 31 +-
web/src/lib/components/SegmentedControl.svelte | 31 +-
web/src/lib/components/Select.svelte | 31 +-
web/src/lib/components/SlimSortableList.svelte | 35 +-
web/src/lib/components/SortableList.svelte | 35 +-
web/src/lib/components/StopPropagation.svelte | 31 +-
web/src/lib/components/ThemeController.svelte | 31 +-
web/src/lib/components/Toggler.svelte | 35 +-
web/src/routes/+error.svelte | 31 +-
web/src/routes/+layout.svelte | 31 +-
web/src/routes/auth/+layout.svelte | 31 +-
web/src/routes/auth/logout/+page.svelte | 31 +-
web/src/routes/auth/sign-in/+page.svelte | 35 +-
web/src/routes/dashboard/+layout.svelte | 35 +-
web/src/routes/dashboard/clients/+page.svelte | 31 +-
web/src/routes/dashboard/logs/+page.svelte | 31 +-
web/src/routes/dashboard/overview/+page.svelte | 35 +-
.../routes/dashboard/settings/server/+page.svelte | 31 +-
.../dashboard/settings/terminal/+page.svelte | 31 +-
.../routes/dashboard/settings/users/+page.svelte | 35 +-
.../routes/dashboard/settings/webUI/+page.svelte | 31 +-
web/src/routes/dashboard/streams/+layout.svelte | 31 +-
web/src/routes/dashboard/streams/+page.svelte | 31 +-
.../dashboard/streams/[streamId=i32]/+page.svelte | 31 +-
.../streams/[streamId=i32]/topics/+page.svelte | 31 +-
.../topics/[topicId=i32]/+page.svelte | 31 +-
.../partitions/[partitionId=i32]/+page.svelte | 31 +-
.../[partitionId=i32]/messages/+page.svelte | 35 +-
418 files changed, 6797 insertions(+), 3326 deletions(-)
create mode 100644 core/server_common/src/reactor_yield.rs