* Initial attempt at a Rust AMQP stack, merged against feature/rust_amqp for now. (#5942) * Enabled building AMQP *without* uAMQP * Start integrating Rust AMQP Value to C++ AMQP Value * AMQP Value tests now pass * Moved AmqpValueType ostream inserter to its original location * Added Rust AMQP Message implementation * Added start of message source tests * Enabled building AMQP *without* uAMQP * Start integrating Rust AMQP Value to C++ AMQP Value * Moved AmqpValueType ostream inserter to its original location * Message target support * Message source and target support * Add connection support; restructured tests to fail on RUST AMQP rather than attempting to run; removed some uAMQP-only features (#5986) * Checkpoint of connection logic * Started implementing Rust based Connection by pulling out uAMQP artifacts * Implemented AMQP Connection in Rust; started API surface refactoring for Rust APIs; Refactored tests to remove some uAMQP only elements. * Don't leak runtime context on calls * Refactor AMQP logic to better isolate rust AMQP code from uAMQP code. (#6008) * refactor uAMQP and Rust AMQP into separate implementations for ease of use * Add connection support; restructured tests to fail on RUST AMQP rather than attempting to run; removed some uAMQP-only features (#5986) * Checkpoint of connection logic * Started implementing Rust based Connection by pulling out uAMQP artifacts * Implemented AMQP Connection in Rust; started API surface refactoring for Rust APIs; Refactored tests to remove some uAMQP only elements. * Don't leak runtime context on calls * export UUID from AMQP * Cleaned up some more elements; reduced scope of doxygen significantly * runtime context needs to be process global not thread global; all tests pass or fail at this point * Merged main into branch * Implement AMQP Session APIs in Rust. (#6033) * Checkpoint of rust session support * Session begin/end now works * Session tests pass * Removed accidental regression * Added rust per-call context (#6043) * Reworked runtime context to be call context * Added context parameter to blocking AMQP calls * Added comments around the lifetime of the RustRuntimeContext captured in the CallContext object * uAMQP changes corresponding to Rust changes Co-authored-by: Anton Kolesnyk <41349689+antkmsft@users.noreply.github.com> * sync rust SDK fixes to C++ --------- Co-authored-by: Anton Kolesnyk <41349689+antkmsft@users.noreply.github.com> * Enable Rust ClaimsBasedSecurity interoperability; Converted EventHubs producer client to work with Rust AMQP changes. (#6059) * canonicalized return values; initial CBS support * Implementation of CBS for C++ * Amqp Authentication works; Integrate Rust AMQP into Eventhubs Producer client * Implemented Rust AMQP message sender. (#6083) * Initial sender implementation * PR feedback * Management APIs work (#6096) * Management APIs work --------- Co-authored-by: Anton Kolesnyk <41349689+antkmsft@users.noreply.github.com> * Converted builders to be compliant with Rust guidelines. (#6102) * Converted builders to be compliant with Rust guidelines. * Bring rust changes back to C++ repo * Improved builder developer experience * Removed builders from AMQP layer to conform to Rust guidelines; Fixed AMQP bug in message sender tests (#6208) * Removed builders from AMQP layer to conform to Rust guidelines; Fixed AMQP related bug in message sender tests * Pr feedback * Implement receiving messages; Changes to eventhubs so that all eventhubs tests pass (#6254) * Eventhubs tests pass * Noise reduction; explain the task which spawns a task * Update sdk/eventhubs/azure-messaging-eventhubs/src/producer_client.cpp Co-authored-by: Anton Kolesnyk <41349689+antkmsft@users.noreply.github.com> * PR feedback --------- Co-authored-by: Anton Kolesnyk <41349689+antkmsft@users.noreply.github.com> * Integrate Rust 2 step message receive code to C++ (#6349) * Integrate Rust 2 step message receive code to C++ * If receiving a delivery failed, transmit the error to the message channel if at all possible * Enable Rust based AMQP by default (#6362) * AMQP tests now pass; Integrate TestAmqpBroker with CI pipeline * Updated changelogs to reflect API changes made during AMQP updates * Replace uAMQP with Rust AMQP as the default AMQP transport; Updated build configurationj to reflect that * Test fixes * PR feedback; test fixes * Fixed uninitialized variable tanking some tests (#6381) * Fixed uninitialized variable tanking some tests * Fixed Rust AMQP tests * Removed connection string support from Eventhubs and EH tests. (#6391) * Removed the ability to use connection strings from EventHubs * Enable Rust AMQP by default!!! * Update CMakePresets.json Co-authored-by: Anton Kolesnyk <41349689+antkmsft@users.noreply.github.com> --------- Co-authored-by: Anton Kolesnyk <41349689+antkmsft@users.noreply.github.com>
82 lines
2.3 KiB
TOML
82 lines
2.3 KiB
TOML
[workspace]
|
|
resolver = "2"
|
|
members = [
|
|
"sdk/core/azure-core-amqp/src/impl/rust_amqp/rust_amqp/azure_core_amqp",
|
|
"sdk/core/azure-core-amqp/src/impl/rust_amqp/rust_amqp/rust_wrapper",
|
|
]
|
|
|
|
[workspace.package]
|
|
authors = ["Microsoft"]
|
|
edition = "2021"
|
|
license = "MIT"
|
|
repository = "https://github.com/azure/azure-sdk-for-rust"
|
|
rust-version = "1.76"
|
|
|
|
[workspace.dependencies.azure_core_amqp]
|
|
path = "sdk/core/azure-core-amqp/src/impl/rust_amqp/rust_amqp/azure_core_amqp"
|
|
|
|
[workspace.dependencies]
|
|
azure_core = { version = "0.22" }
|
|
azure_identity = "0.22"
|
|
async-lock = "3.0"
|
|
async-process = "2.0"
|
|
async-std = { version = "1.12", features = ["attributes"] }
|
|
async-stream = { version = "0.3.5" }
|
|
async-trait = "0.1"
|
|
base64 = "0.22"
|
|
bytes = "1.0"
|
|
cargo_metadata = "0.18.1"
|
|
cbindgen = "0.28.0"
|
|
clap = { version = "4.4.16", features = ["derive"] }
|
|
dyn-clone = "1.0"
|
|
fe2o3-amqp = { version = "0.13", features = ["native-tls", "tracing", "uuid"] }
|
|
fe2o3-amqp-ext = { version = "0.13", features = [] }
|
|
fe2o3-amqp-management = { version = "0.13" }
|
|
fe2o3-amqp-cbs = { version = "0.13" }
|
|
fe2o3-amqp-types = { version = "0.13" }
|
|
futures = "0.3"
|
|
getrandom = { version = "0.2", features = ["js"] }
|
|
hmac = { version = "0.12" }
|
|
http-types = { version = "2.12", default-features = false }
|
|
log = "0.4"
|
|
oauth2 = { version = "4.0.0", default-features = false }
|
|
once_cell = "1.18"
|
|
openssl = { version = "0.10.46" }
|
|
paste = "1.0"
|
|
pin-project = "1.0"
|
|
proc-macro2 = "1.0.86"
|
|
quick-xml = { version = "0.31", features = ["serialize", "serde-types"] }
|
|
rand = "0.8"
|
|
reqwest = { version = "0.12", features = [
|
|
"json",
|
|
"stream",
|
|
], default-features = false }
|
|
rustc_version = "0.4"
|
|
serde = { version = "1.0", features = ["derive"] }
|
|
serde_amqp = { version = "0.13", features = ["uuid"] }
|
|
serde_bytes = { version = "0.11" }
|
|
serde_json = "1.0"
|
|
serde_test = "1"
|
|
serial_test = "3.0"
|
|
sha2 = { version = "0.10" }
|
|
syn = { version = "2.0.74", features = ["full"] }
|
|
quote = "1.0.36"
|
|
thiserror = "1.0"
|
|
time = { version = "0.3.10", features = [
|
|
"serde-well-known",
|
|
"macros",
|
|
"wasm-bindgen",
|
|
] }
|
|
tokio = { version = "1.0", default-features = false, features = [
|
|
"macros",
|
|
"time",
|
|
] }
|
|
tracing = "0.1.40"
|
|
tracing-subscriber = "0.3"
|
|
tz-rs = { version = "0.6" }
|
|
url = "2.2"
|
|
uuid = { version = "1.0", features = ["v4"] }
|
|
|
|
[workspace.lints.clippy]
|
|
large_futures = "deny"
|