This is an automated email from the ASF dual-hosted git repository.
yuxia pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/fluss-rust.git
from 4b8c289 chore: fix Box leaking and batch API refactor (#136)
add e01be26 chore: Improve write path error handling logic (#132)
No new revisions were added by this update.
Summary of changes:
crates/fluss/build.rs | 4 +-
crates/fluss/src/client/credentials.rs | 51 +++
crates/fluss/src/client/metadata.rs | 44 ++-
crates/fluss/src/client/write/accumulator.rs | 73 +++-
crates/fluss/src/client/write/batch.rs | 87 ++++-
crates/fluss/src/client/write/broadcast.rs | 4 +
crates/fluss/src/client/write/bucket_assigner.rs | 40 ++
crates/fluss/src/client/write/mod.rs | 18 +-
crates/fluss/src/client/write/sender.rs | 441 ++++++++++++++++++++---
crates/fluss/src/lib.rs | 3 +
crates/fluss/src/row/datum.rs | 66 ++++
crates/fluss/src/rpc/api_key.rs | 38 ++
crates/fluss/src/rpc/api_version.rs | 25 ++
crates/fluss/src/rpc/convert.rs | 48 +++
crates/fluss/src/rpc/fluss_api_error.rs | 35 ++
crates/fluss/src/rpc/message/produce_log.rs | 6 +-
crates/fluss/src/test_utils.rs | 88 +++++
17 files changed, 1006 insertions(+), 65 deletions(-)
create mode 100644 crates/fluss/src/test_utils.rs
