[WIP] Refactor(rust-sdk): rewrite and align with java sdk - #5271

Draft

daflyinbed wants to merge 59 commits into

apache:masterfrom

daflyinbed:refactor/rust-sdk

Commits on Aug 18, 2026

refactor(rust sdk): part 1
daflyinbed
committed
5c0dcb7
fix(rust sdk): align grpc codec/consumer with server key spellings and broker response codes
daflyinbed
committed
019ee38
feat(rust sdk): add self-contained e2e test suite with bundled docker-compose
daflyinbed
committed
ac13110
fix(rust sdk): make rocketmq compose profile boot on selinux/low-mem hosts
daflyinbed
committed
1b3d07b
test(rust sdk): switch e2e suite to the rocketmq compose profile
daflyinbed
committed
74f969c
fix(rust sdk): create e2e topics as form-encoded, not JSON
daflyinbed
committed
95bd544
fix(rust sdk): use per-call gRPC timeouts, not a channel-wide cap
daflyinbed
committed
a113d84
fix(rust sdk): relocate rocketmq jars so the storage plugin's shadow class wins
daflyinbed
committed
78094a0
fix(rust sdk): make request/reply replies correlate with the original request
daflyinbed
committed
b9a4a5f
fix(rust sdk): add graceful shutdown and axum-style stream driver
daflyinbed
committed
6a616e9
Merge pull request #2 from daflyinbed/feature/rust-sdk-http
daflyinbed
committed
eca18c0
feat(rust-sdk): tcp (#3)
daflyinbed
committed
4821675
feat(rust-sdk): TCP auto-reconnect and CloudEvents support
daflyinbed
committed
e49b70d
fix(rust sdk): route one-way publish to publishOneWay RPC and check status codes
daflyinbed
committed
a5410c5
chore: add asf license header and cleanup

wentongshi
authored and
daflyinbed
committed
34604c7
refactor: more idiomatic

wentongshi
authored and
daflyinbed
committed
11d0f5d
refactor: interval

wentongshi
authored and
daflyinbed
committed
28d52f2
refactor(rust-sdk): redesign consumer API — separate RPC from connection lifecycle

wentongshi
authored and
daflyinbed
committed
57454e9
test(rust-sdk): use eventmesh:jdk11-test image and harden e2e suite
daflyinbed
committed
028e68f
fix(rust-sdk): set datacontenttype=application/cloudevents+json for TCP CloudEvents
daflyinbed
committed
d9fe3ac
feat(rust-sdk): concurrent dispatch in gRPC stream receive loop

wentongshi
authored and
daflyinbed
committed
371c4d5
fix(rust-sdk): prevent silent hang of gRPC subscribe_stream on current-thread runtime
daflyinbed
committed
c5cd690
fix(rust-sdk): address all 8 release-blocking review findings
daflyinbed
committed
ffea4f6
fix(rust-sdk): strict is_success, TCP CloudEvent validation, unsubscribe error semantics, wire compat fixes
daflyinbed
committed
74527e1
fix(rust-sdk): prevent TCP ghost writes, slow-consumer drops, driver-panic hang, and surface redirect reason
daflyinbed
committed
17e1536
fix(rust-sdk): redact secrets in Debug, strict HTTP retCode, (topic,url) subscription key, gRPC error semantics, loadbalance OOM/overflow, webhook extFields retry
daflyinbed
committed
d823a80
fix(rust-sdk): bound gRPC resubscribe waits
daflyinbed
committed
18410b3
feat(sdk-rust): add OpenMessaging and CloudEvents APIs
daflyinbed
committed
5bf670e
fix(rust-sdk): preserve request reply metadata
daflyinbed
committed
5e06c30
feat(rust): add catalog and workflow clients
daflyinbed
committed
2478ce0
refactor: rust
daflyinbed
committed
2047e47
refactor: remove v2
daflyinbed
committed
7fd6ccf
Refactor Rust SDK transports to preserve message dialects
daflyinbed
committed
b721370
Strengthen Rust E2E publish assertions
daflyinbed
committed
c6c4093
Add Java/Rust interop E2E test wiring
daflyinbed
committed
2db072b
Add gRPC webhook consumers and per-call request timeouts
daflyinbed
committed
45158f0
Polish Rust SDK APIs and release checks
daflyinbed
committed
bf6577f
Fix request reply and TCP E2E readiness
daflyinbed
committed
fb12074
Refactor event mesh components
daflyinbed
committed
a7219fa
Expand Rust SDK integration coverage
daflyinbed
committed
f3f516f
Document Rust SDK API, features, and verification workflow
daflyinbed
committed
3517d2e
Make generated gRPC modules crate-private
daflyinbed
committed
ac4bc91
update
daflyinbed
committed
03624aa
Remove obsolete files and code
daflyinbed
committed
d60c101
fix(rust-sdk): align runtime compatibility coverage
daflyinbed
committed
2b1b8ea
Refine request-reply transport support and webhook protocol detection
daflyinbed
committed
1ffa122
Refine event mesh application workflows
daflyinbed
committed
9151dc6
Make Rust SDK transport dependencies feature-specific
daflyinbed
committed
c819786
Expand Rust SDK cross-SDK interoperability tests
daflyinbed
committed
ed725f8
Normalize Apache license headers in Rust SDK interop files
daflyinbed
committed
66d7a94
fix(rust-sdk): harden reconnects and CloudEvent conversion
daflyinbed
committed
3dd4d68
docs(rust-sdk): consolidate project guidance
daflyinbed
committed
fd6c1cf
refactor: remove grpc legacy config
daflyinbed
committed
8703959
refactor(rust-sdk): make gRPC channel explicit
daflyinbed
committed
4b52cc7
docs: update comment
daflyinbed
committed
1b9e506
refactor(grpc): use tonic's timeout
daflyinbed
committed
e80feb1
refactor(grepc): use tonic's timeout
daflyinbed
committed
91f6be9
Use unified subscription model across Rust SDK transports
daflyinbed
committed
34a6f9c
refactor(rust-sdk): remove HTTP/TCP legacy config adapters
daflyinbed
committed
fe22eaa