This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch rework_clients_table_one_more_time
in repository https://gitbox.apache.org/repos/asf/iggy.git
from b8c0b019a review changes
add 343ef06eb feat(server,deps,ci): update deps, fix CI scoping, panic
exit, crash recovery (#4033)
add e6ec86950 feat(helm): deploy a cluster with one release per node
(#4035)
add ca0b578a2 fix(sdk): correct consumer group polling and commits in
IggyConsumer (#4034)
add c3df915ff docs: fix partition IDs and auto commit wording in the
README quickstart (#4040)
add d3028f9b2 chore(deps): Bump fast-uri from 3.1.5 to 3.1.7 in
/foreign/node (#4042)
add 2c08f1e6c merge master
No new revisions were added by this update.
Summary of changes:
.github/actions/rust/pre-merge/action.yml | 44 +-
.github/config/hawkeye.version | 2 +-
.github/workflows/post-merge.yml | 4 +-
Cargo.lock | 1688 +++++++++++---------
Cargo.toml | 144 +-
README.md | 14 +-
bdd/python/uv.lock | 4 +-
core/bench/report/src/prints.rs | 6 +-
.../src/actors/consumer/benchmark_consumer.rs | 6 +-
core/bench/src/actors/consumer/client/low_level.rs | 28 +-
.../src/actors/producer/benchmark_producer.rs | 6 +-
.../benchmark_producing_consumer.rs | 6 +-
core/cli/src/commands/binary_client/get_client.rs | 2 +-
.../binary_consumer_groups/get_consumer_group.rs | 2 +-
core/common/src/consumer_group_client_state.rs | 38 +
core/common/src/lib.rs | 7 +
core/common/src/traits/binary_impls/messages.rs | 43 +-
core/common/src/traits/message_client.rs | 41 +-
core/common/src/types/message/polled_messages.rs | 6 +-
.../src/types/permissions/permissions_global.rs | 6 +-
core/connectors/sdk/src/decoders/avro.rs | 18 +-
core/connectors/sdk/src/encoders/avro.rs | 16 +-
core/connectors/sdk/src/transforms/avro_convert.rs | 6 +-
core/integration/Cargo.toml | 2 +-
core/integration/src/harness/handle/server.rs | 21 +-
core/integration/tests/cluster/crash_durability.rs | 7 +-
core/integration/tests/sdk/consumer_group.rs | 83 +
.../tests/sdk/consumer_group_membership.rs | 276 ++++
core/integration/tests/sdk/consumer_shutdown.rs | 112 ++
core/integration/tests/sdk/mod.rs | 1 +
core/partitions/src/iggy_partition.rs | 6 +-
.../src/client_wrappers/binary_message_client.rs | 42 +-
core/sdk/src/clients/binary_message.rs | 26 +-
core/sdk/src/clients/consumer.rs | 762 +++++----
core/sdk/src/clients/consumer_builder.rs | 25 +-
core/sdk/src/prelude.rs | 3 +-
core/sdk/src/quic/quic_client.rs | 7 +
core/sdk/src/tcp/tcp_client.rs | 7 +
core/sdk/src/websocket/websocket_client.rs | 7 +
core/server/src/boot/mod.rs | 9 +-
core/server/src/boot/recovery.rs | 535 +------
core/server/src/boot/threads.rs | 113 +-
core/server/src/partition_helpers.rs | 591 ++++++-
core/server/src/partition_reconciler.rs | 84 +-
core/server/src/server_error.rs | 7 +
core/server_common/src/crypto.rs | 19 +-
core/shard/Cargo.toml | 16 +-
core/simulator/Cargo.toml | 24 +-
examples/python/uv.lock | 4 +-
foreign/cpp/Cargo.toml | 4 +-
foreign/cpp/MODULE.bazel | 6 +-
foreign/cpp/MODULE.bazel.lock | 44 +-
foreign/node/package-lock.json | 7 +-
foreign/php/Cargo.toml | 6 +-
foreign/php/README.md | 6 +-
foreign/php/composer.json | 2 +-
foreign/php/iggy-php.stubs.php | 3 +
foreign/php/phpunit.xml.dist | 2 +-
foreign/php/src/client.rs | 3 +
foreign/python/Cargo.toml | 4 +-
foreign/python/apache_iggy.pyi | 2 +
foreign/python/pylock.toml | 838 +++++-----
foreign/python/pyproject.toml | 6 +-
foreign/python/src/client.rs | 2 +
foreign/python/uv.lock | 404 ++---
gateways/kafka/Cargo.toml | 2 +-
gateways/kafka/tools/kafka-tool/Cargo.toml | 6 +-
gateways/kafka/tools/kafka-tool/src/main.rs | 1 +
helm/charts/iggy/Chart.yaml | 4 +-
helm/charts/iggy/README.md | 211 ++-
helm/charts/iggy/README.md.gotmpl | 170 +-
helm/charts/iggy/examples/cluster-3-node.yaml | 130 ++
helm/charts/iggy/templates/_helpers.tpl | 234 +++
helm/charts/iggy/templates/deployment.yaml | 75 +-
helm/charts/iggy/templates/hpa.yaml | 61 -
...t-user-credentials.yaml => server-secrets.yaml} | 23 +-
helm/charts/iggy/templates/service.yaml | 6 +-
helm/charts/iggy/values.yaml | 132 +-
scripts/ci/test-helm.sh | 72 +-
79 files changed, 4778 insertions(+), 2614 deletions(-)
create mode 100644 core/integration/tests/sdk/consumer_shutdown.rs
create mode 100644 helm/charts/iggy/examples/cluster-3-node.yaml
delete mode 100644 helm/charts/iggy/templates/hpa.yaml
copy helm/charts/iggy/templates/{root-user-credentials.yaml =>
server-secrets.yaml} (50%)
