This is an automated email from the ASF dual-hosted git repository.
piotr pushed a change to branch simulator_ui
in repository https://gitbox.apache.org/repos/asf/iggy.git
from d383e9495 Refactor simulator to use Bevy
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)
new 052dedc56 merge
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/_common.yml | 32 +-
.pre-commit-config.yaml | 12 +-
Cargo.lock | 389 +++++---
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/simulator_ui/Cargo.toml | 2 -
core/simulator_ui/src/main.rs | 444 ++++++---
core/simulator_ui/src/vsr/types.rs | 10 +-
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 +++--
271 files changed, 6820 insertions(+), 13054 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%)
