Skip to content
GitLab
Menu
Projects
Groups
Snippets
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Menu
Open sidebar
OpenDAS
dynamo
Commits
ddf50359
Unverified
Commit
ddf50359
authored
Mar 11, 2026
by
Ryan Olson
Committed by
GitHub
Mar 11, 2026
Browse files
fix: removing reference to async-ucx (#7213)
Signed-off-by:
Ryan Olson
<
rolson@nvidia.com
>
parent
eb99f293
Changes
4
Show whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
18 additions
and
176 deletions
+18
-176
Cargo.lock
Cargo.lock
+17
-159
lib/velo-transports/Cargo.toml
lib/velo-transports/Cargo.toml
+0
-2
lib/velo-transports/README.md
lib/velo-transports/README.md
+1
-1
lib/velo-transports/tests/common/mod.rs
lib/velo-transports/tests/common/mod.rs
+0
-14
No files found.
Cargo.lock
View file @
ddf50359
...
@@ -306,25 +306,6 @@ dependencies = [
...
@@ -306,25 +306,6 @@ dependencies = [
"syn 2.0.117",
"syn 2.0.117",
]
]
[[package]]
name = "async-ucx"
version = "0.2.0"
source = "git+https://github.com/ryanolson/async-ucx.git?branch=ryan%2Fucx#fbcb8e3d281d7c910e3dcd84f7eb3e8ee253ac6e"
dependencies = [
"bytes",
"crossbeam",
"derivative",
"futures",
"futures-lite",
"lazy_static",
"log",
"pin-project",
"socket2 0.4.10",
"thiserror 1.0.69",
"tokio",
"ucx1-sys",
]
[[package]]
[[package]]
name = "async_zmq"
name = "async_zmq"
version = "0.4.0"
version = "0.4.0"
...
@@ -603,7 +584,7 @@ version = "1.6.0"
...
@@ -603,7 +584,7 @@ version = "1.6.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "cffb0e931875b666fc4fcb20fee52e9bbd1ef836fd9e9e04ec21555f9f85f7ef"
checksum = "cffb0e931875b666fc4fcb20fee52e9bbd1ef836fd9e9e04ec21555f9f85f7ef"
dependencies = [
dependencies = [
"fastrand
2.3.0
",
"fastrand",
"gloo-timers",
"gloo-timers",
"tokio",
"tokio",
]
]
...
@@ -661,29 +642,6 @@ dependencies = [
...
@@ -661,29 +642,6 @@ dependencies = [
"virtue",
"virtue",
]
]
[[package]]
name = "bindgen"
version = "0.66.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f2b84e06fc203107bfbad243f4aba2af864eb7db3b1cf46ea0a023b0b433d2a7"
dependencies = [
"bitflags 2.11.0",
"cexpr",
"clang-sys",
"lazy_static",
"lazycell",
"log",
"peeking_take_while",
"prettyplease",
"proc-macro2",
"quote",
"regex",
"rustc-hash 1.1.0",
"shlex",
"syn 2.0.117",
"which",
]
[[package]]
[[package]]
name = "bindgen"
name = "bindgen"
version = "0.70.1"
version = "0.70.1"
...
@@ -1663,17 +1621,6 @@ dependencies = [
...
@@ -1663,17 +1621,6 @@ dependencies = [
"serde_core",
"serde_core",
]
]
[[package]]
name = "derivative"
version = "2.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "fcc3dd5e9e9c0b295d6e1e4d811fb6f157d5ffd784b8d202fc62eac8035a770b"
dependencies = [
"proc-macro2",
"quote",
"syn 1.0.109",
]
[[package]]
[[package]]
name = "derive-getters"
name = "derive-getters"
version = "0.5.0"
version = "0.5.0"
...
@@ -2440,15 +2387,6 @@ dependencies = [
...
@@ -2440,15 +2387,6 @@ dependencies = [
"regex-syntax",
"regex-syntax",
]
]
[[package]]
name = "fastrand"
version = "1.9.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e51093e27b0797c359783294ca4f0a911c270184cb10f85783b118614a1501be"
dependencies = [
"instant",
]
[[package]]
[[package]]
name = "fastrand"
name = "fastrand"
version = "2.3.0"
version = "2.3.0"
...
@@ -2575,7 +2513,7 @@ version = "0.12.0"
...
@@ -2575,7 +2513,7 @@ version = "0.12.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "5e139bc46ca777eb5efaf62df0ab8cc5fd400866427e56c68b22e414e53bd3be"
checksum = "5e139bc46ca777eb5efaf62df0ab8cc5fd400866427e56c68b22e414e53bd3be"
dependencies = [
dependencies = [
"fastrand
2.3.0
",
"fastrand",
"futures-core",
"futures-core",
"futures-sink",
"futures-sink",
"spin",
"spin",
...
@@ -2707,21 +2645,6 @@ version = "0.3.32"
...
@@ -2707,21 +2645,6 @@ version = "0.3.32"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "cecba35d7ad927e23624b22ad55235f2239cfa44fd10428eecbeba6d6a717718"
checksum = "cecba35d7ad927e23624b22ad55235f2239cfa44fd10428eecbeba6d6a717718"
[[package]]
name = "futures-lite"
version = "1.13.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "49a9d51ce47660b1e808d3c990b4709f2f415d928835a17dfd16991515c46bce"
dependencies = [
"fastrand 1.9.0",
"futures-core",
"futures-io",
"memchr",
"parking",
"pin-project-lite",
"waker-fn",
]
[[package]]
[[package]]
name = "futures-macro"
name = "futures-macro"
version = "0.3.32"
version = "0.3.32"
...
@@ -3400,9 +3323,9 @@ dependencies = [
...
@@ -3400,9 +3323,9 @@ dependencies = [
[[package]]
[[package]]
name = "image"
name = "image"
version = "0.25.
9
"
version = "0.25.
10
"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "
e6506c6c10786659413faa717ceebcb8f70731c0a60cbae39795fdf114519c1a
"
checksum = "
85ab80394333c02fe689eaf900ab500fbd0c2213da414687ebf995a65d5a6104
"
dependencies = [
dependencies = [
"bytemuck",
"bytemuck",
"byteorder-lite",
"byteorder-lite",
...
@@ -3419,8 +3342,8 @@ dependencies = [
...
@@ -3419,8 +3342,8 @@ dependencies = [
"rgb",
"rgb",
"serde",
"serde",
"tiff",
"tiff",
"zune-core
0.5.1
",
"zune-core",
"zune-jpeg
0.5.12
",
"zune-jpeg",
]
]
[[package]]
[[package]]
...
@@ -4048,12 +3971,6 @@ version = "1.5.0"
...
@@ -4048,12 +3971,6 @@ version = "1.5.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bbd2bcb4c963f2ddae06a2efc7e9f3591312473c50c6685e1f298068316e66fe"
checksum = "bbd2bcb4c963f2ddae06a2efc7e9f3591312473c50c6685e1f298068316e66fe"
[[package]]
name = "lazycell"
version = "1.3.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "830d08ce1d1d941e6b30645f1a0eb5643013d835ce3779a5fc208261dbe10f55"
[[package]]
[[package]]
name = "leb128fmt"
name = "leb128fmt"
version = "0.1.0"
version = "0.1.0"
...
@@ -4590,9 +4507,9 @@ dependencies = [
...
@@ -4590,9 +4507,9 @@ dependencies = [
[[package]]
[[package]]
name = "moxcms"
name = "moxcms"
version = "0.
7.1
1"
version = "0.
8.
1"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "
ac9557c559cd6fc9867e122e20d2cbefc9ca29d80d027a8e39310920ed2f0a97
"
checksum = "
bb85c154ba489f01b25c0d36ae69a87e4a1c73a72631fc6c0eb6dde34a73e44b
"
dependencies = [
dependencies = [
"num-traits",
"num-traits",
"pxfm",
"pxfm",
...
@@ -5440,12 +5357,6 @@ dependencies = [
...
@@ -5440,12 +5357,6 @@ dependencies = [
"syn 2.0.117",
"syn 2.0.117",
]
]
[[package]]
name = "peeking_take_while"
version = "0.1.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "19b17cddbe7ec3f8bc800887bab5e717348c95ea2ca0b1bf0837fb964dc67099"
[[package]]
[[package]]
name = "pem"
name = "pem"
version = "3.0.6"
version = "3.0.6"
...
@@ -6209,9 +6120,9 @@ dependencies = [
...
@@ -6209,9 +6120,9 @@ dependencies = [
[[package]]
[[package]]
name = "ravif"
name = "ravif"
version = "0.1
2
.0"
version = "0.1
3
.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e
f69c1990ceef18a116855938e74793a5f7496ee907562bd0857b6ac734ab28
5"
checksum = "e
52310197d971b0f5be7fe6b57530dcd27beb35c1b013f29d66c1ad73fbbcc4
5"
dependencies = [
dependencies = [
"avif-serialize",
"avif-serialize",
"imgref",
"imgref",
...
@@ -7354,16 +7265,6 @@ version = "1.15.1"
...
@@ -7354,16 +7265,6 @@ version = "1.15.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "67b1b7a3b5fe4f1376887184045fcf45c69e92af734b7aaddc05fb777b6fbd03"
checksum = "67b1b7a3b5fe4f1376887184045fcf45c69e92af734b7aaddc05fb777b6fbd03"
[[package]]
name = "socket2"
version = "0.4.10"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9f7916fc008ca5542385b89a3d3ce689953c143e9304a9bf8beec1de48994c0d"
dependencies = [
"libc",
"winapi 0.3.9",
]
[[package]]
[[package]]
name = "socket2"
name = "socket2"
version = "0.5.10"
version = "0.5.10"
...
@@ -7602,11 +7503,11 @@ dependencies = [
...
@@ -7602,11 +7503,11 @@ dependencies = [
[[package]]
[[package]]
name = "tempfile"
name = "tempfile"
version = "3.2
6
.0"
version = "3.2
7
.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "
82a72c767771b47409d2345987fda8628641887d5466101319899796367354a0
"
checksum = "
32497e9a4c7b38532efcdebeef879707aa9f794296a4f0244f6f69e9bc8574bd
"
dependencies = [
dependencies = [
"fastrand
2.3.0
",
"fastrand",
"getrandom 0.4.2",
"getrandom 0.4.2",
"once_cell",
"once_cell",
"rustix 1.1.4",
"rustix 1.1.4",
...
@@ -7673,16 +7574,16 @@ dependencies = [
...
@@ -7673,16 +7574,16 @@ dependencies = [
[[package]]
[[package]]
name = "tiff"
name = "tiff"
version = "0.1
0
.3"
version = "0.1
1
.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "
af9605de7fee8d9551863fd692cce7637f548dbd9db9180fcc07ccc6d26c336f
"
checksum = "
b63feaf3343d35b6ca4d50483f94843803b0f51634937cc2ec519fc32232bc52
"
dependencies = [
dependencies = [
"fax",
"fax",
"flate2",
"flate2",
"half 2.7.1",
"half 2.7.1",
"quick-error 2.0.1",
"quick-error 2.0.1",
"weezl",
"weezl",
"zune-jpeg
0.4.21
",
"zune-jpeg",
]
]
[[package]]
[[package]]
...
@@ -8413,15 +8314,6 @@ version = "0.1.7"
...
@@ -8413,15 +8314,6 @@ version = "0.1.7"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "2896d95c02a80c6d6a5d6e953d479f5ddf2dfdb6a244441010e373ac0fb88971"
checksum = "2896d95c02a80c6d6a5d6e953d479f5ddf2dfdb6a244441010e373ac0fb88971"
[[package]]
name = "ucx1-sys"
version = "0.2.0"
source = "git+https://github.com/ryanolson/async-ucx.git?branch=ryan%2Fucx#fbcb8e3d281d7c910e3dcd84f7eb3e8ee253ac6e"
dependencies = [
"bindgen 0.66.1",
"pkg-config",
]
[[package]]
[[package]]
name = "unarray"
name = "unarray"
version = "0.1.4"
version = "0.1.4"
...
@@ -8793,7 +8685,6 @@ version = "0.1.0"
...
@@ -8793,7 +8685,6 @@ version = "0.1.0"
dependencies = [
dependencies = [
"anyhow",
"anyhow",
"async-nats",
"async-nats",
"async-ucx",
"axum 0.8.4",
"axum 0.8.4",
"bs58",
"bs58",
"bytes",
"bytes",
...
@@ -8862,12 +8753,6 @@ dependencies = [
...
@@ -8862,12 +8753,6 @@ dependencies = [
"libc",
"libc",
]
]
[[package]]
name = "waker-fn"
version = "1.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "317211a0dc0ceedd78fb2ca9a44aed3d7b9b26f81870d485c07122b4350673b7"
[[package]]
[[package]]
name = "walkdir"
name = "walkdir"
version = "2.5.0"
version = "2.5.0"
...
@@ -9061,18 +8946,6 @@ version = "0.1.12"
...
@@ -9061,18 +8946,6 @@ version = "0.1.12"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "a28ac98ddc8b9274cb41bb4d9d4d5c425b6020c50c46f25559911905610b4a88"
checksum = "a28ac98ddc8b9274cb41bb4d9d4d5c425b6020c50c46f25559911905610b4a88"
[[package]]
name = "which"
version = "4.4.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "87ba24419a2078cd2b0f2ede2691b6c66d8e47836da3b6db8265ebad47afbfc7"
dependencies = [
"either",
"home",
"once_cell",
"rustix 0.38.44",
]
[[package]]
[[package]]
name = "winapi"
name = "winapi"
version = "0.2.8"
version = "0.2.8"
...
@@ -9786,12 +9659,6 @@ dependencies = [
...
@@ -9786,12 +9659,6 @@ dependencies = [
"simd-adler32",
"simd-adler32",
]
]
[[package]]
name = "zune-core"
version = "0.4.12"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "3f423a2c17029964870cfaabb1f13dfab7d092a62a29a89264f4d36990ca414a"
[[package]]
[[package]]
name = "zune-core"
name = "zune-core"
version = "0.5.1"
version = "0.5.1"
...
@@ -9807,20 +9674,11 @@ dependencies = [
...
@@ -9807,20 +9674,11 @@ dependencies = [
"simd-adler32",
"simd-adler32",
]
]
[[package]]
name = "zune-jpeg"
version = "0.4.21"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "29ce2c8a9384ad323cf564b67da86e21d3cfdff87908bc1223ed5c99bc792713"
dependencies = [
"zune-core 0.4.12",
]
[[package]]
[[package]]
name = "zune-jpeg"
name = "zune-jpeg"
version = "0.5.12"
version = "0.5.12"
source = "registry+https://github.com/rust-lang/crates.io-index"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "410e9ecef634c709e3831c2cfdb8d9c32164fae1c67496d5b68fff728eec37fe"
checksum = "410e9ecef634c709e3831c2cfdb8d9c32164fae1c67496d5b68fff728eec37fe"
dependencies = [
dependencies = [
"zune-core
0.5.1
",
"zune-core",
]
]
lib/velo-transports/Cargo.toml
View file @
ddf50359
...
@@ -14,7 +14,6 @@ keywords.workspace = true
...
@@ -14,7 +14,6 @@ keywords.workspace = true
[features]
[features]
default
=
[
"http"
,
"nats"
,
"grpc"
]
default
=
[
"http"
,
"nats"
,
"grpc"
]
ucx
=
["dep:async-ucx"]
http
=
[
"dep:axum"
,
"dep:reqwest"
]
http
=
[
"dep:axum"
,
"dep:reqwest"
]
nats
=
[
"dep:async-nats"
,
"dep:bs58"
]
nats
=
[
"dep:async-nats"
,
"dep:bs58"
]
grpc
=
[
"dep:tonic"
,
"dep:prost"
,
"dep:tower"
,
"dep:hyper"
,
"dep:http"
,
"dep:http-body"
,
"dep:http-body-util"
,
"dep:hyper-util"
,
"dep:tokio-stream"
]
grpc
=
[
"dep:tonic"
,
"dep:prost"
,
"dep:tower"
,
"dep:hyper"
,
"dep:http"
,
"dep:http-body"
,
"dep:http-body-util"
,
"dep:hyper-util"
,
"dep:tokio-stream"
]
...
@@ -49,7 +48,6 @@ tokio-util = { version = "0.7", features = ["codec"] }
...
@@ -49,7 +48,6 @@ tokio-util = { version = "0.7", features = ["codec"] }
nix
=
{
version
=
"0.30"
,
features
=
["sched"]
}
nix
=
{
version
=
"0.30"
,
features
=
["sched"]
}
# optional dependencies
# optional dependencies
async-ucx
=
{
git
=
"https://github.com/ryanolson/async-ucx.git"
,
branch
=
"ryan/ucx"
,
optional
=
true
,
features
=
[
"am"
,
"event"
]
}
axum
=
{
version
=
"0.8"
,
optional
=
true
}
axum
=
{
version
=
"0.8"
,
optional
=
true
}
reqwest
=
{
workspace
=
true
,
optional
=
true
}
reqwest
=
{
workspace
=
true
,
optional
=
true
}
async-nats
=
{
workspace
=
true
,
optional
=
true
}
async-nats
=
{
workspace
=
true
,
optional
=
true
}
...
...
lib/velo-transports/README.md
View file @
ddf50359
...
@@ -42,7 +42,7 @@ graph TD
...
@@ -42,7 +42,7 @@ graph TD
|
`http`
| ✓ | axum, reqwest | HTTP transport with Axum server |
|
`http`
| ✓ | axum, reqwest | HTTP transport with Axum server |
|
`nats`
| ✓ | async-nats, bs58 | NATS pub-sub transport |
|
`nats`
| ✓ | async-nats, bs58 | NATS pub-sub transport |
|
`grpc`
| ✓ | tonic, prost, tower | gRPC bidirectional streaming |
|
`grpc`
| ✓ | tonic, prost, tower | gRPC bidirectional streaming |
|
`
ucx
`
| ✗ |
async-ucx
| UCX/RDMA transport
(requires UCX libraries
) |
|
`
nixl
`
| ✗ |
nixl-sys
| UCX/RDMA transport
via NIXL (future work
) |
TCP transport is always available (no feature gate).
TCP transport is always available (no feature gate).
...
...
lib/velo-transports/tests/common/mod.rs
View file @
ddf50359
...
@@ -14,8 +14,6 @@
...
@@ -14,8 +14,6 @@
// use velo_transports::http::{HttpTransport, HttpTransportBuilder};
// use velo_transports::http::{HttpTransport, HttpTransportBuilder};
// #[cfg(feature = "nats")]
// #[cfg(feature = "nats")]
// use velo_transports::nats::{NatsTransport, NatsTransportBuilder};
// use velo_transports::nats::{NatsTransport, NatsTransportBuilder};
// #[cfg(feature = "ucx")]
// use velo_transports::ucx::{UcxTransport, UcxTransportBuilder};
use
bytes
::
Bytes
;
use
bytes
::
Bytes
;
use
std
::
sync
::{
Arc
,
Mutex
};
use
std
::
sync
::{
Arc
,
Mutex
};
...
@@ -418,18 +416,6 @@ impl TestCluster<TcpTransport> {
...
@@ -418,18 +416,6 @@ impl TestCluster<TcpTransport> {
}
}
}
}
// UCX-specific convenience constructor
#[cfg(feature
=
"ucx"
)]
impl
TestCluster
<
UcxTransport
>
{
/// Create a new UCX test cluster with the specified number of transports
///
/// This is a convenience method for creating UCX clusters.
/// For other transport types, use `with_factory()`.
pub
async
fn
new_ucx
(
size
:
usize
)
->
anyhow
::
Result
<
Self
>
{
Self
::
with_factory
(
size
,
||
UcxTransportBuilder
::
new
()
.build
())
.await
}
}
// // HTTP-specific convenience constructor
// // HTTP-specific convenience constructor
// #[cfg(feature = "http")]
// #[cfg(feature = "http")]
// impl TestCluster<HttpTransport> {
// impl TestCluster<HttpTransport> {
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment