This is an automated email from the ASF dual-hosted git repository. piotr pushed a commit to branch simulator_ui in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 246b4b56d45e5433211149320c267a61c7b492d4 Merge: bb9fb34ce 52b198637 Author: spetz <[email protected]> AuthorDate: Tue Apr 7 13:58:17 2026 +0200 merge .config/nextest.toml | 14 +- Cargo.lock | 7 +- Cargo.toml | 4 +- DEPENDENCIES.md | 2 +- core/binary_protocol/src/consensus/header.rs | 8 +- core/binary_protocol/src/consensus/message.rs | 14 +- .../src/commands/binary_users/change_password.rs | 10 +- core/cli/src/credentials.rs | 6 +- core/common/src/lib.rs | 1 + .../tcp_config/tcp_client_config_builder.rs | 33 +- .../websocket_client_config_builder.rs | 19 +- core/common/src/utils/mod.rs | 1 + core/common/src/utils/net.rs | 310 +++++++++++ core/consensus/src/client_table.rs | 577 +++++++++++++++++++++ core/consensus/src/impls.rs | 221 ++++++-- core/consensus/src/lib.rs | 3 + core/consensus/src/namespaced_pipeline.rs | 86 ++- core/consensus/src/observability.rs | 17 +- core/consensus/src/plane_helpers.rs | 72 ++- core/harness_derive/src/attrs.rs | 23 + core/harness_derive/src/codegen.rs | 173 +++++- core/integration/Cargo.toml | 1 + core/integration/src/harness/handle/mod.rs | 2 +- core/integration/src/harness/mod.rs | 2 + .../src/harness/orchestrator/builder.rs | 2 + .../src/harness/orchestrator/harness.rs | 198 ++++++- core/integration/src/harness/seeds.rs | 71 ++- core/integration/src/harness/shared.rs | 159 ++++++ core/integration/src/lib.rs | 3 +- core/integration/tests/connectors/api/endpoints.rs | 24 +- .../connectors/elasticsearch/elasticsearch_sink.rs | 9 +- .../elasticsearch/elasticsearch_source.rs | 9 +- .../integration/tests/connectors/http/http_sink.rs | 26 +- .../http_config_provider/direct_responses.rs | 30 +- .../http_config_provider/wrapped_responses.rs | 30 +- .../tests/connectors/iceberg/iceberg_sink.rs | 9 +- .../tests/connectors/influxdb/influxdb_sink.rs | 18 +- .../connectors/influxdb/influxdb_sink_formats.rs | 36 +- .../tests/connectors/influxdb/influxdb_source.rs | 12 +- .../connectors/influxdb/influxdb_source_formats.rs | 27 +- .../tests/connectors/mongodb/mongodb_sink.rs | 31 +- .../tests/connectors/postgres/postgres_sink.rs | 9 +- .../tests/connectors/postgres/postgres_source.rs | 15 +- .../tests/connectors/postgres/restart.rs | 6 +- .../tests/connectors/quickwit/quickwit_sink.rs | 12 +- .../tests/connectors/random/random_source.rs | 3 +- .../tests/connectors/stdout/stdout_sink.rs | 9 +- core/iobuf/src/lib.rs | 2 +- core/journal/src/lib.rs | 2 +- .../{metadata_journal.rs => prepare_journal.rs} | 40 +- core/metadata/src/impls/metadata.rs | 157 ++++-- core/metadata/src/impls/recovery.rs | 10 +- core/partitions/src/iggy_partitions.rs | 299 ++++++++--- core/shard/src/lib.rs | 139 ++++- core/shard/src/router.rs | 26 +- core/simulator/src/lib.rs | 11 + core/simulator/src/replica.rs | 10 +- examples/rust/src/getting-started/consumer/main.rs | 7 - examples/rust/src/getting-started/producer/main.rs | 7 - foreign/go/scripts/run_tcp_e2e.sh | 28 - web/package-lock.json | 147 +++--- web/package.json | 2 +- 62 files changed, 2712 insertions(+), 529 deletions(-)
