This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch send_messages_confirmation
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 1bd98b6b2 feat(server-ng): confirm committed sends with partition and
offset
add 3261a3f06 fix(server-ng): stop confirming sends that never committed
add fd321059d fix(sdk): drop the fabricated send confirmation from foreign
clients
add 81467580a test(integration): assert the legacy server reports no
confirmations
No new revisions were added by this update.
Summary of changes:
.../src/responses/messages/send_messages.rs | 30 ++-
core/common/src/error/iggy_error.rs | 5 +-
core/common/src/http/messages/send_messages.rs | 58 ++++-
core/common/src/traits/binary_impls/messages.rs | 83 ++++---
core/common/src/traits/binary_impls/mod.rs | 4 +-
core/common/src/traits/message_client.rs | 14 +-
core/common/src/traits/mod.rs | 4 +-
core/common/src/types/message/mod.rs | 4 +-
core/integration/tests/sdk/producer/background.rs | 4 +-
core/integration/tests/sdk/send_confirmation.rs | 28 +--
core/partitions/src/iggy_partition.rs | 241 ++++++++++++---------
core/sdk/src/clients/producer.rs | 149 +++++++++----
core/sdk/src/clients/producer_dispatcher.rs | 7 +-
core/sdk/src/clients/producer_error_callback.rs | 11 +-
core/sdk/src/clients/producer_sharding.rs | 11 +-
core/sdk/src/http/messages.rs | 55 ++---
core/server-ng/src/dispatch.rs | 36 +--
core/server-ng/src/dispatch/authz.rs | 11 +-
core/server-ng/src/http/error.rs | 17 +-
core/server-ng/src/http/handlers.rs | 71 ++----
core/server-ng/src/http/reply.rs | 79 ++++---
core/server-ng/src/http/submit.rs | 11 +-
foreign/cpp/src/lib.rs | 16 +-
foreign/cpp/src/type_conversion.rs | 3 -
foreign/cpp/tests/e2e/message.cpp | 6 +-
foreign/node/src/e2e/tcp.send-message.e2e.ts | 26 ++-
.../src/wire/message/send-messages.command.test.ts | 8 +-
.../node/src/wire/message/send-messages.command.ts | 34 ++-
foreign/php/iggy-php.stubs.php | 19 +-
foreign/php/src/client.rs | 2 +
foreign/php/src/lib.rs | 4 +-
foreign/php/src/send_message.rs | 30 ++-
foreign/php/tests/IggySdkTest.php | 25 +--
foreign/python/apache_iggy.pyi | 34 ++-
foreign/python/src/client.rs | 4 +-
foreign/python/src/lib.rs | 4 +-
foreign/python/src/send_message.rs | 37 +++-
foreign/python/tests/test_message_operations.py | 18 +-
38 files changed, 746 insertions(+), 457 deletions(-)
