This is an automated email from the ASF dual-hosted git repository.
piotr pushed a change to branch fix-background-producer
in repository https://gitbox.apache.org/repos/asf/iggy.git
from fe68b30b6 fix(sdk): acquire max_in_flight permits at network send, not
dispatch
add 42a6ad72f fix(configs): support internally-tagged enums in ConfigEnv
derive macro (#2631)
add 7f6d3fed9 chore(sdk): Adds Rust example for message compression using
user_headers (#2613)
add b27d27229 Merge branch 'master' into fix-background-producer
No new revisions were added by this update.
Summary of changes:
.github/workflows/_common.yml | 1 +
Cargo.lock | 3 +
.../configs/src/configs_impl/typed_env_provider.rs | 4 +-
core/configs_derive/src/config_env.rs | 20 +-
core/connectors/runtime/src/configs/runtime.rs | 1 +
core/integration/Cargo.toml | 2 +
core/integration/tests/config_provider/mod.rs | 157 +++++++++++-
examples/rust/Cargo.toml | 17 +-
examples/rust/README.md | 11 +-
.../message-headers/message-compression/README.md | 282 +++++++++++++++++++++
.../message-compression/consumer/main.rs | 89 +++++++
.../message-compression/producer/main.rs | 101 ++++++++
.../{ => message-type}/consumer/main.rs | 0
.../{ => message-type}/producer/main.rs | 0
examples/rust/src/shared/codec.rs | 112 ++++++++
examples/rust/src/shared/mod.rs | 1 +
16 files changed, 791 insertions(+), 10 deletions(-)
create mode 100644
examples/rust/src/message-headers/message-compression/README.md
create mode 100644
examples/rust/src/message-headers/message-compression/consumer/main.rs
create mode 100644
examples/rust/src/message-headers/message-compression/producer/main.rs
rename examples/rust/src/message-headers/{ => message-type}/consumer/main.rs
(100%)
rename examples/rust/src/message-headers/{ => message-type}/producer/main.rs
(100%)
create mode 100644 examples/rust/src/shared/codec.rs
