This is an automated email from the ASF dual-hosted git repository.
bashirbekov pushed a change to branch feat/add-background-send
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 70f68e1a run pipeline
add 98d251f5 changes after review
No new revisions were added by this update.
Summary of changes:
core/common/src/error/iggy_error.rs | 4 +-
core/connectors/runtime/src/source.rs | 11 +-
core/examples/src/multi-tenant/producer/main.rs | 8 +-
core/examples/src/new-sdk/producer/main.rs | 8 +-
core/examples/src/sink-data-producer/main.rs | 9 +-
core/integration/tests/mod.rs | 1 +
core/integration/tests/sdk/mod.rs | 1 +
core/integration/tests/sdk/producer/background.rs | 382 +++++++++++++++++++++
core/integration/tests/sdk/producer/mod.rs | 64 ++++
core/sdk/src/clients/producer.rs | 13 +-
core/sdk/src/clients/producer_builder.rs | 244 +------------
core/sdk/src/clients/producer_config.rs | 118 ++++++-
core/sdk/src/clients/producer_dispatcher.rs | 77 +++--
core/sdk/src/clients/producer_error_callback.rs | 1 -
core/sdk/src/clients/producer_sharding.rs | 63 ++--
core/sdk/src/prelude.rs | 1 +
.../stream_builder/build/build_iggy_producer.rs | 8 +-
17 files changed, 680 insertions(+), 333 deletions(-)
create mode 100644 core/integration/tests/sdk/mod.rs
create mode 100644 core/integration/tests/sdk/producer/background.rs
create mode 100644 core/integration/tests/sdk/producer/mod.rs
