This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch fix_metadata_cancel_safe
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 72bf394ec fix(metadata): fix metadata pipeline commit
add c0218f1c7 feat(cli): support vsr and enable the CLI suite under
server-ng (#3679)
add 6ca219f67 refactor(go): separate transport state and session state
(#3652)
add 6f1d5485d feat(cpp): add functions related to client lifecycle, and
message headers (#3610)
add 6b7f3e229 Merge branch 'master' into fix_metadata_cancel_safe
No new revisions were added by this update.
Summary of changes:
.../features/step_definitions/messaging_steps.cpp | 5 +-
core/cli/Cargo.toml | 1 +
core/cli/src/commands/binary_system/login.rs | 46 +-
core/cli/src/commands/cli_command.rs | 8 +
core/cli/src/credentials.rs | 41 +-
core/cli/src/main.rs | 7 +-
core/integration/src/harness/handle/server.rs | 10 +-
core/integration/src/harness/port_reserver.rs | 127 +++-
.../cli/message/test_message_flush_command.rs | 23 +-
.../tests/cli/stream/test_stream_purge_command.rs | 24 +-
.../tests/cli/system/test_cli_session_scenario.rs | 11 +
.../cli/system/test_cluster_metadata_command.rs | 4 -
.../integration/tests/cli/system/test_login_cmd.rs | 9 +-
.../tests/cli/system/test_me_command.rs | 11 +
.../tests/cli/topic/test_topic_purge_command.rs | 30 +-
core/integration/tests/mod.rs | 10 +-
core/metadata/src/impls/metadata.rs | 16 +-
core/server-ng/Cargo.toml | 1 -
core/server-ng/Dockerfile | 15 +-
core/server-ng/src/bootstrap.rs | 3 +
core/server-ng/src/responses.rs | 28 +-
core/server/Dockerfile | 7 +-
foreign/cpp/Cargo.toml | 1 +
foreign/cpp/MODULE.bazel | 7 -
foreign/cpp/MODULE.bazel.lock | 2 +-
foreign/cpp/src/client.rs | 115 +++-
foreign/cpp/src/lib.rs | 138 +++-
foreign/cpp/src/messages.rs | 7 +-
foreign/cpp/src/type_conversion.rs | 291 ++++++++-
foreign/cpp/tests/client/low_level_e2e.cpp | 691 ++++++++++++++++++++-
foreign/cpp/tests/common/test_helpers.hpp | 33 +
foreign/cpp/tests/consumer_group/low_level_e2e.cpp | 34 +
foreign/cpp/tests/message/low_level_e2e.cpp | 443 ++++++++++++-
foreign/cpp/tests/message/unit_tests.cpp | 14 +-
foreign/cpp/tests/partition/low_level_e2e.cpp | 8 +
foreign/cpp/tests/stream/low_level_e2e.cpp | 50 +-
foreign/cpp/tests/topic/low_level_e2e.cpp | 61 +-
foreign/go/client/tcp/tcp_core.go | 50 +-
foreign/go/client/tcp/tcp_core_test.go | 88 ++-
foreign/go/client/tcp/tcp_session_management.go | 42 +-
foreign/go/contracts/state.go | 42 +-
41 files changed, 2272 insertions(+), 282 deletions(-)