This is an automated email from the ASF dual-hosted git repository.

gkoszyk pushed a change to branch store_consumer_offset
in repository https://gitbox.apache.org/repos/asf/iggy.git


    from 3608257f8 reuse code
     add 50fe8ec77 feat(ci): add version bump tooling and consistency checks 
(#2990)
     add 702c9b3e5 feat(simulator): wire Network into tick loop with 
per-replica outboxes and replica_crash (#3049)
     add cea344cd8 refactor(server,sdk): replace 
ServerCommand/BytesSerializable with wire types (#3041)
     add b19daa9fd feat(server-ng): create iggy-server-ng binary crate (#3053)
     add 4a886c032 Merge branch 'master' into store_consumer_offset

No new revisions were added by this update.

Summary of changes:
 .github/workflows/_common.yml                      |   32 +-
 .pre-commit-config.yaml                            |   12 +-
 Cargo.lock                                         |  373 ++++---
 Cargo.toml                                         |    2 +
 DEPENDENCIES.md                                    |  125 +--
 core/binary_protocol/src/lib.rs                    |    7 +
 core/binary_protocol/src/primitives/mod.rs         |    1 +
 .../binary_protocol/src/primitives/user_headers.rs |  544 +++++++++++
 core/cli/Cargo.toml                                |    2 +-
 core/cli/src/args/permissions/mod.rs               |    8 +-
 core/cli/src/args/permissions/stream.rs            |   10 +-
 core/cli/src/commands/binary_client/get_client.rs  |   20 +-
 core/cli/src/commands/binary_client/get_clients.rs |    8 +-
 .../binary_consumer_groups/get_consumer_group.rs   |   23 +-
 .../binary_consumer_groups/get_consumer_groups.rs  |   19 +-
 .../binary_consumer_offsets/get_consumer_offset.rs |   53 +-
 .../binary_consumer_offsets/set_consumer_offset.rs |   43 +-
 .../src/commands/binary_message/poll_messages.rs   |   13 +-
 .../src/commands/binary_message/send_messages.rs   |    8 +-
 .../get_personal_access_tokens.rs                  |    7 +-
 core/cli/src/commands/binary_streams/get_stream.rs |   20 +-
 .../cli/src/commands/binary_streams/get_streams.rs |    8 +-
 core/cli/src/commands/binary_system/me.rs          |   14 +-
 core/cli/src/commands/binary_system/ping.rs        |    7 +-
 core/cli/src/commands/binary_system/snapshot.rs    |   36 +-
 core/cli/src/commands/binary_system/stats.rs       |    8 +-
 core/cli/src/commands/binary_topics/get_topic.rs   |   18 +-
 core/cli/src/commands/binary_topics/get_topics.rs  |   19 +-
 core/cli/src/commands/binary_users/get_user.rs     |   15 +-
 core/cli/src/commands/binary_users/get_users.rs    |    8 +-
 core/common/Cargo.toml                             |    1 -
 .../consumer_groups/create_consumer_group.rs       |  189 ----
 .../consumer_groups/delete_consumer_group.rs       |  147 ---
 .../commands/consumer_groups/get_consumer_group.rs |  147 ---
 .../consumer_groups/get_consumer_groups.rs         |  126 ---
 .../consumer_groups/join_consumer_group.rs         |  147 ---
 .../consumer_groups/leave_consumer_group.rs        |  147 ---
 core/common/src/commands/consumer_groups/mod.rs    |   26 -
 .../consumer_offsets/delete_consumer_offset.rs     |  220 -----
 .../consumer_offsets/get_consumer_offset.rs        |  225 -----
 .../consumer_offsets/store_consumer_offset.rs      |  240 -----
 .../src/commands/messages/flush_unsaved_buffer.rs  |  132 ---
 core/common/src/commands/messages/poll_messages.rs |  341 -------
 .../src/commands/partitions/create_partitions.rs   |  167 ----
 .../src/commands/partitions/delete_partitions.rs   |  167 ----
 .../create_personal_access_token.rs                |  157 ---
 .../delete_personal_access_token.rs                |  156 ---
 .../get_personal_access_tokens.rs                  |   86 --
 .../login_with_personal_access_token.rs            |  173 ----
 .../src/commands/segments/delete_segments.rs       |  202 ----
 core/common/src/commands/streams/create_stream.rs  |  153 ---
 core/common/src/commands/streams/delete_stream.rs  |   99 --
 core/common/src/commands/streams/get_stream.rs     |   99 --
 core/common/src/commands/streams/get_streams.rs    |   86 --
 core/common/src/commands/streams/purge_stream.rs   |  102 --
 core/common/src/commands/streams/update_stream.rs  |  151 ---
 core/common/src/commands/system/get_client.rs      |  113 ---
 core/common/src/commands/system/get_clients.rs     |   86 --
 .../src/commands/system/get_cluster_metadata.rs    |   59 --
 core/common/src/commands/system/get_me.rs          |   86 --
 core/common/src/commands/system/get_snapshot.rs    |  168 ----
 core/common/src/commands/system/get_stats.rs       |   86 --
 core/common/src/commands/system/mod.rs             |   25 -
 core/common/src/commands/system/ping.rs            |   87 --
 core/common/src/commands/topics/create_topic.rs    |  301 ------
 core/common/src/commands/topics/delete_topic.rs    |  126 ---
 core/common/src/commands/topics/get_topic.rs       |  126 ---
 core/common/src/commands/topics/get_topics.rs      |   99 --
 core/common/src/commands/topics/purge_topic.rs     |  124 ---
 core/common/src/commands/topics/update_topic.rs    |  302 ------
 core/common/src/commands/users/change_password.rs  |  246 -----
 core/common/src/commands/users/create_user.rs      |  347 -------
 core/common/src/commands/users/delete_user.rs      |   99 --
 core/common/src/commands/users/get_user.rs         |   99 --
 core/common/src/commands/users/get_users.rs        |   88 --
 core/common/src/commands/users/login_user.rs       |  399 --------
 core/common/src/commands/users/logout_user.rs      |   87 --
 .../src/commands/users/update_permissions.rs       |  189 ----
 core/common/src/commands/users/update_user.rs      |  231 -----
 core/common/src/error/iggy_error.rs                |    2 +
 .../http/consumer_groups/create_consumer_group.rs  |   60 ++
 .../http/consumer_groups/delete_consumer_group.rs  |   46 +
 .../src/http/consumer_groups}/mod.rs               |    4 +-
 .../consumer_offsets/delete_consumer_offset.rs}    |    9 +-
 .../http/consumer_offsets/get_consumer_offset.rs}  |   17 +-
 .../src/{commands => http}/consumer_offsets/mod.rs |    0
 .../consumer_offsets/store_consumer_offset.rs}     |   14 +-
 .../messages/flush_unsaved_buffer.rs}              |    9 +-
 core/common/src/{commands => http}/messages/mod.rs |    0
 core/common/src/http/messages/poll_messages.rs     |   89 ++
 .../{commands => http}/messages/send_messages.rs   |  131 +--
 core/common/src/{commands => http}/mod.rs          |    0
 .../src/http/partitions/create_partitions.rs       |   60 ++
 .../src/http/partitions/delete_partitions.rs       |   60 ++
 .../src/{commands => http}/partitions/mod.rs       |    2 +-
 .../create_personal_access_token.rs                |   57 ++
 .../delete_personal_access_token.rs                |   52 +
 .../login_with_personal_access_token.rs}           |   15 +-
 .../personal_access_tokens/mod.rs                  |    1 -
 core/common/src/http/segments/delete_segments.rs   |   59 ++
 core/common/src/{commands => http}/segments/mod.rs |    0
 .../src/http/streams/create_stream.rs}             |   42 +-
 .../streams/delete_stream.rs}                      |   31 +-
 core/common/src/{commands => http}/streams/mod.rs  |    4 +-
 .../streams/purge_stream.rs}                       |   27 +-
 core/common/src/http/streams/update_stream.rs      |   55 ++
 .../src/http/system/get_snapshot.rs}               |   16 +-
 .../users => common/src/http/system}/mod.rs        |    2 +-
 core/common/src/http/topics/create_topic.rs        |   89 ++
 .../partitioner.rs => http/topics/delete_topic.rs} |   31 +-
 core/common/src/{commands => http}/topics/mod.rs   |    5 +-
 .../partitioner.rs => http/topics/purge_topic.rs}  |   31 +-
 core/common/src/http/topics/update_topic.rs        |   86 ++
 core/common/src/http/users/change_password.rs      |   74 ++
 core/common/src/http/users/create_user.rs          |   76 ++
 .../src/{commands => http}/users/defaults.rs       |    0
 .../users/delete_user.rs}                          |   31 +-
 core/common/src/http/users/login_user.rs           |   55 ++
 core/common/src/{commands => http}/users/mod.rs    |    3 -
 .../users/update_permissions.rs}                   |   31 +-
 core/common/src/http/users/update_user.rs          |   55 ++
 core/common/src/lib.rs                             |   29 +-
 core/common/src/traits/binary_impls/cluster.rs     |   19 +-
 .../src/traits/binary_impls/consumer_groups.rs     |  138 ++-
 .../src/traits/binary_impls/consumer_offsets.rs    |   82 +-
 core/common/src/traits/binary_impls/messages.rs    |   82 +-
 core/common/src/traits/binary_impls/mod.rs         |   11 +
 core/common/src/traits/binary_impls/partitions.rs  |   43 +-
 .../traits/binary_impls/personal_access_tokens.rs  |   71 +-
 core/common/src/traits/binary_impls/segments.rs    |   26 +-
 core/common/src/traits/binary_impls/streams.rs     |   86 +-
 core/common/src/traits/binary_impls/system.rs      |   75 +-
 core/common/src/traits/binary_impls/topics.rs      |  140 ++-
 core/common/src/traits/binary_impls/users.rs       |  151 ++-
 core/common/src/traits/binary_mapper.rs            | 1033 --------------------
 core/common/src/traits/binary_transport.rs         |    4 +-
 core/common/src/traits/bytes_serializable.rs       |   41 -
 core/common/src/traits/mod.rs                      |    2 -
 core/common/src/types/cluster/metadata.rs          |   95 +-
 core/common/src/types/cluster/node.rs              |   98 +-
 core/common/src/types/cluster/role.rs              |   27 +-
 core/common/src/types/cluster/status.rs            |   27 +-
 .../src/types/cluster/transport_endpoints.rs       |   69 --
 core/common/src/types/command/mod.rs               |  173 ----
 core/common/src/types/configuration/transport.rs   |   23 +-
 core/common/src/types/consumer/consumer_kind.rs    |   27 -
 core/common/src/types/identifier/mod.rs            |   76 +-
 core/common/src/types/message/iggy_message.rs      |  201 ++--
 core/common/src/types/message/message_header.rs    |    8 +-
 .../src/types/message/message_header_view.rs       |   25 +-
 core/common/src/types/message/message_view.rs      |   44 +-
 core/common/src/types/message/messages_batch.rs    |   24 +-
 .../common/src/types/message/messages_batch_mut.rs |    6 +-
 core/common/src/types/message/mod.rs               |    5 +-
 core/common/src/types/message/partitioning.rs      |   71 +-
 core/common/src/types/message/polled_messages.rs   |   12 +-
 core/common/src/types/message/polling_strategy.rs  |   27 -
 core/common/src/types/message/user_headers.rs      |  176 +---
 core/common/src/types/mod.rs                       |    1 -
 .../src/types/permissions/permissions_global.rs    |  264 +----
 core/common/src/utils/crypto.rs                    |    4 +-
 core/common/src/wire_conversions.rs                |  785 +++++++++++++++
 core/connectors/runtime/src/sink.rs                |    2 +-
 core/connectors/runtime/src/source.rs              |    4 +-
 core/connectors/sdk/src/lib.rs                     |   10 +-
 core/connectors/sinks/http_sink/src/lib.rs         |    3 +-
 core/integration/Cargo.toml                        |    1 -
 .../tests/cli/message/test_message_poll_command.rs |    4 +-
 .../message/test_message_poll_to_file_command.rs   |    8 +-
 .../cli/message/test_message_reply_via_file.rs     |    4 +-
 .../tests/cli/message/test_message_send_command.rs |    8 +-
 .../message/test_message_send_from_file_command.rs |    8 +-
 .../tests/cli/user/test_user_create_command.rs     |   12 +-
 .../tests/cli/user/test_user_get_command.rs        |    6 +-
 .../cli/user/test_user_permissions_command.rs      |   12 +-
 .../server/scenarios/create_message_payload.rs     |    6 +-
 .../tests/server/scenarios/encryption_scenario.rs  |    8 +-
 .../server/scenarios/message_headers_scenario.rs   |    6 +-
 .../server/scenarios/message_size_scenario.rs      |    6 +-
 .../tests/server/scenarios/offset_scenario.rs      |    8 +-
 .../tests/server/scenarios/permissions_scenario.rs |   36 +-
 .../tests/server/scenarios/timestamp_scenario.rs   |    8 +-
 core/integration/tests/state/file.rs               |   35 +-
 core/integration/tests/state/system.rs             |  154 +--
 core/metadata/Cargo.toml                           |    1 -
 core/metadata/src/stm/consumer_group.rs            |  115 +--
 core/metadata/src/stm/mod.rs                       |   10 +-
 core/metadata/src/stm/stream.rs                    |  107 +-
 core/metadata/src/stm/user.rs                      |   84 +-
 core/sdk/src/http/consumer_offsets.rs              |    4 -
 core/sdk/src/http/messages.rs                      |    7 +-
 core/sdk/src/prelude.rs                            |   18 +-
 core/sdk/src/quic/quic_client.rs                   |    8 +-
 core/sdk/src/tcp/tcp_client.rs                     |   12 +-
 core/sdk/src/websocket/websocket_client.rs         |    8 +-
 core/{ai/mcp => server-ng}/.dockerignore           |    0
 core/{server => server-ng}/Cargo.toml              |   78 +-
 core/{server => server-ng}/Dockerfile              |   46 +-
 core/{server => server-ng}/build.rs                |    4 +-
 core/{server => server-ng}/config.toml             |    0
 .../server.http => server-ng/server-ng.http}       |    0
 .../connectors/api/mod.rs => server-ng/src/lib.rs} |    2 -
 .../build.gradle.kts => core/server-ng/src/main.rs |   10 +-
 core/server/src/binary/dispatch.rs                 |  125 +--
 .../create_consumer_group_handler.rs               |   20 +-
 .../delete_consumer_group_handler.rs               |   17 +-
 .../consumer_groups/join_consumer_group_handler.rs |   17 +-
 .../leave_consumer_group_handler.rs                |   17 +-
 .../partitions/create_partitions_handler.rs        |   22 +-
 .../partitions/delete_partitions_handler.rs        |   21 +-
 .../create_personal_access_token_handler.rs        |   19 +-
 .../delete_personal_access_token_handler.rs        |   10 +-
 .../login_with_personal_access_token_handler.rs    |    9 +-
 .../handlers/streams/create_stream_handler.rs      |   10 +-
 .../handlers/streams/delete_stream_handler.rs      |    8 +-
 .../handlers/streams/purge_stream_handler.rs       |    8 +-
 .../handlers/streams/update_stream_handler.rs      |   14 +-
 .../binary/handlers/topics/create_topic_handler.rs |   31 +-
 .../binary/handlers/topics/delete_topic_handler.rs |   15 +-
 .../binary/handlers/topics/purge_topic_handler.rs  |   15 +-
 .../binary/handlers/topics/update_topic_handler.rs |   29 +-
 .../handlers/users/change_password_handler.rs      |   28 +-
 .../binary/handlers/users/create_user_handler.rs   |   34 +-
 .../binary/handlers/users/delete_user_handler.rs   |    9 +-
 .../src/binary/handlers/users/get_user_handler.rs  |    5 +-
 .../binary/handlers/users/login_user_handler.rs    |   25 +-
 .../handlers/users/update_permissions_handler.rs   |   22 +-
 .../binary/handlers/users/update_user_handler.rs   |   23 +-
 core/server/src/http/consumer_groups.rs            |   27 +-
 core/server/src/http/consumer_offsets.rs           |   38 +-
 core/server/src/http/partitions.rs                 |   23 +-
 core/server/src/http/personal_access_tokens.rs     |   20 +-
 core/server/src/http/segments.rs                   |   10 +-
 core/server/src/http/streams.rs                    |   29 +-
 core/server/src/http/system.rs                     |   10 +-
 core/server/src/http/topics.rs                     |   42 +-
 core/server/src/http/users.rs                      |   50 +-
 core/server/src/quic/listener.rs                   |    4 +-
 core/server/src/shard/execution.rs                 |  273 +++---
 core/server/src/shard/system/messages.rs           |    3 +-
 core/server/src/shard/transmission/message.rs      |   55 +-
 core/server/src/state/command.rs                   |  342 ++++---
 core/server/src/state/entry.rs                     |   70 +-
 core/server/src/state/file.rs                      |   13 +-
 core/server/src/state/models.rs                    |  511 +++++-----
 core/server/src/state/system.rs                    |  193 ++--
 core/server/src/tcp/connection_handler.rs          |    4 +-
 core/shard/src/lib.rs                              |   27 +
 core/simulator/src/bus.rs                          |   42 +-
 core/simulator/src/client.rs                       |   26 +-
 core/simulator/src/lib.rs                          |  259 +++--
 core/simulator/src/main.rs                         |  228 ++---
 core/simulator/src/network.rs                      |   12 +
 core/simulator/src/packet.rs                       |   27 +
 core/simulator/src/replica.rs                      |   24 +-
 core/tools/src/data-seeder/seeder.rs               |    4 +-
 examples/rust/Cargo.toml                           |    2 +-
 .../message-compression/consumer/main.rs           |   12 +-
 .../message-compression/producer/main.rs           |    4 +-
 .../message-headers/message-type/producer/main.rs  |    4 +-
 .../message-headers/typed-headers/producer/main.rs |    4 +-
 examples/rust/src/multi-tenant/consumer/main.rs    |    6 +-
 examples/rust/src/multi-tenant/producer/main.rs    |    4 +-
 justfile                                           |    3 +
 scripts/bump-version.sh                            |  639 ++++++++++++
 ...-version-sync.sh => python-sdk-version-sync.sh} |   13 +-
 scripts/ci/shellcheck.sh                           |    4 +-
 scripts/extract-version.sh                         |  271 +++--
 268 files changed, 6517 insertions(+), 12885 deletions(-)
 create mode 100644 core/binary_protocol/src/primitives/user_headers.rs
 delete mode 100644 
core/common/src/commands/consumer_groups/create_consumer_group.rs
 delete mode 100644 
core/common/src/commands/consumer_groups/delete_consumer_group.rs
 delete mode 100644 
core/common/src/commands/consumer_groups/get_consumer_group.rs
 delete mode 100644 
core/common/src/commands/consumer_groups/get_consumer_groups.rs
 delete mode 100644 
core/common/src/commands/consumer_groups/join_consumer_group.rs
 delete mode 100644 
core/common/src/commands/consumer_groups/leave_consumer_group.rs
 delete mode 100644 core/common/src/commands/consumer_groups/mod.rs
 delete mode 100644 
core/common/src/commands/consumer_offsets/delete_consumer_offset.rs
 delete mode 100644 
core/common/src/commands/consumer_offsets/get_consumer_offset.rs
 delete mode 100644 
core/common/src/commands/consumer_offsets/store_consumer_offset.rs
 delete mode 100644 core/common/src/commands/messages/flush_unsaved_buffer.rs
 delete mode 100644 core/common/src/commands/messages/poll_messages.rs
 delete mode 100644 core/common/src/commands/partitions/create_partitions.rs
 delete mode 100644 core/common/src/commands/partitions/delete_partitions.rs
 delete mode 100644 
core/common/src/commands/personal_access_tokens/create_personal_access_token.rs
 delete mode 100644 
core/common/src/commands/personal_access_tokens/delete_personal_access_token.rs
 delete mode 100644 
core/common/src/commands/personal_access_tokens/get_personal_access_tokens.rs
 delete mode 100644 
core/common/src/commands/personal_access_tokens/login_with_personal_access_token.rs
 delete mode 100644 core/common/src/commands/segments/delete_segments.rs
 delete mode 100644 core/common/src/commands/streams/create_stream.rs
 delete mode 100644 core/common/src/commands/streams/delete_stream.rs
 delete mode 100644 core/common/src/commands/streams/get_stream.rs
 delete mode 100644 core/common/src/commands/streams/get_streams.rs
 delete mode 100644 core/common/src/commands/streams/purge_stream.rs
 delete mode 100644 core/common/src/commands/streams/update_stream.rs
 delete mode 100644 core/common/src/commands/system/get_client.rs
 delete mode 100644 core/common/src/commands/system/get_clients.rs
 delete mode 100644 core/common/src/commands/system/get_cluster_metadata.rs
 delete mode 100644 core/common/src/commands/system/get_me.rs
 delete mode 100644 core/common/src/commands/system/get_snapshot.rs
 delete mode 100644 core/common/src/commands/system/get_stats.rs
 delete mode 100644 core/common/src/commands/system/mod.rs
 delete mode 100644 core/common/src/commands/system/ping.rs
 delete mode 100644 core/common/src/commands/topics/create_topic.rs
 delete mode 100644 core/common/src/commands/topics/delete_topic.rs
 delete mode 100644 core/common/src/commands/topics/get_topic.rs
 delete mode 100644 core/common/src/commands/topics/get_topics.rs
 delete mode 100644 core/common/src/commands/topics/purge_topic.rs
 delete mode 100644 core/common/src/commands/topics/update_topic.rs
 delete mode 100644 core/common/src/commands/users/change_password.rs
 delete mode 100644 core/common/src/commands/users/create_user.rs
 delete mode 100644 core/common/src/commands/users/delete_user.rs
 delete mode 100644 core/common/src/commands/users/get_user.rs
 delete mode 100644 core/common/src/commands/users/get_users.rs
 delete mode 100644 core/common/src/commands/users/login_user.rs
 delete mode 100644 core/common/src/commands/users/logout_user.rs
 delete mode 100644 core/common/src/commands/users/update_permissions.rs
 delete mode 100644 core/common/src/commands/users/update_user.rs
 create mode 100644 
core/common/src/http/consumer_groups/create_consumer_group.rs
 create mode 100644 
core/common/src/http/consumer_groups/delete_consumer_group.rs
 copy core/{cli/src/commands/binary_consumer_groups => 
common/src/http/consumer_groups}/mod.rs (93%)
 copy core/common/src/{traits/sizeable.rs => 
http/consumer_offsets/delete_consumer_offset.rs} (82%)
 copy core/{bench/report/src/plotting/chart_kind.rs => 
common/src/http/consumer_offsets/get_consumer_offset.rs} (74%)
 rename core/common/src/{commands => http}/consumer_offsets/mod.rs (100%)
 copy core/{bench/src/analytics/time_series/processors/mod.rs => 
common/src/http/consumer_offsets/store_consumer_offset.rs} (77%)
 copy core/common/src/{traits/sizeable.rs => 
http/messages/flush_unsaved_buffer.rs} (83%)
 rename core/common/src/{commands => http}/messages/mod.rs (100%)
 create mode 100644 core/common/src/http/messages/poll_messages.rs
 rename core/common/src/{commands => http}/messages/send_messages.rs (80%)
 rename core/common/src/{commands => http}/mod.rs (100%)
 create mode 100644 core/common/src/http/partitions/create_partitions.rs
 create mode 100644 core/common/src/http/partitions/delete_partitions.rs
 rename core/common/src/{commands => http}/partitions/mod.rs (95%)
 create mode 100644 
core/common/src/http/personal_access_tokens/create_personal_access_token.rs
 create mode 100644 
core/common/src/http/personal_access_tokens/delete_personal_access_token.rs
 copy core/{bench/report/src/plotting/chart_kind.rs => 
common/src/http/personal_access_tokens/login_with_personal_access_token.rs} 
(76%)
 rename core/common/src/{commands => http}/personal_access_tokens/mod.rs (96%)
 create mode 100644 core/common/src/http/segments/delete_segments.rs
 rename core/common/src/{commands => http}/segments/mod.rs (100%)
 copy core/{bench/report/src/types/actor_kind.rs => 
common/src/http/streams/create_stream.rs} (52%)
 copy core/common/src/{types/diagnostic/diagnostic_event.rs => 
http/streams/delete_stream.rs} (61%)
 rename core/common/src/{commands => http}/streams/mod.rs (92%)
 copy core/common/src/{traits/partitioner.rs => http/streams/purge_stream.rs} 
(61%)
 create mode 100644 core/common/src/http/streams/update_stream.rs
 copy core/{bench/report/src/plotting/chart_kind.rs => 
common/src/http/system/get_snapshot.rs} (75%)
 copy core/{server/src/streaming/users => common/src/http/system}/mod.rs (97%)
 create mode 100644 core/common/src/http/topics/create_topic.rs
 copy core/common/src/{traits/partitioner.rs => http/topics/delete_topic.rs} 
(56%)
 rename core/common/src/{commands => http}/topics/mod.rs (88%)
 copy core/common/src/{traits/partitioner.rs => http/topics/purge_topic.rs} 
(55%)
 create mode 100644 core/common/src/http/topics/update_topic.rs
 create mode 100644 core/common/src/http/users/change_password.rs
 create mode 100644 core/common/src/http/users/create_user.rs
 rename core/common/src/{commands => http}/users/defaults.rs (100%)
 copy core/common/src/{types/diagnostic/diagnostic_event.rs => 
http/users/delete_user.rs} (61%)
 create mode 100644 core/common/src/http/users/login_user.rs
 rename core/common/src/{commands => http}/users/mod.rs (94%)
 copy core/common/src/{traits/partitioner.rs => 
http/users/update_permissions.rs} (53%)
 create mode 100644 core/common/src/http/users/update_user.rs
 delete mode 100644 core/common/src/traits/binary_mapper.rs
 delete mode 100644 core/common/src/traits/bytes_serializable.rs
 delete mode 100644 core/common/src/types/command/mod.rs
 create mode 100644 core/common/src/wire_conversions.rs
 copy core/{ai/mcp => server-ng}/.dockerignore (100%)
 copy core/{server => server-ng}/Cargo.toml (73%)
 copy core/{server => server-ng}/Dockerfile (85%)
 copy core/{server => server-ng}/build.rs (97%)
 copy core/{server => server-ng}/config.toml (100%)
 copy core/{server/server.http => server-ng/server-ng.http} (100%)
 copy core/{integration/tests/connectors/api/mod.rs => server-ng/src/lib.rs} 
(98%)
 copy foreign/java/buildSrc/build.gradle.kts => core/server-ng/src/main.rs (89%)
 create mode 100755 scripts/bump-version.sh
 rename scripts/ci/{python-version-sync.sh => python-sdk-version-sync.sh} (92%)

Reply via email to