This is an automated email from the ASF dual-hosted git repository. hgruszecki pushed a commit to branch io_uring_tpc_direct_io_socket_transfer in repository https://gitbox.apache.org/repos/asf/iggy.git
commit bf33f9cc264c3ccc8826b892b2afbe2a60b9a6d4 Author: Hubert Gruszecki <[email protected]> AuthorDate: Thu Jul 10 18:59:45 2025 +0200 gxhash, uuid v4 --- Cargo.lock | 1003 +++++++++++++++++++++----- Cargo.toml | 1 + core/common/Cargo.toml | 1 + core/common/src/utils/checksum.rs | 2 +- core/server/Cargo.toml | 9 +- core/server/src/streaming/utils/random_id.rs | 2 +- 6 files changed, 831 insertions(+), 187 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index 20d0a61bd..ab698f94d 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -307,6 +307,15 @@ dependencies = [ "memchr", ] +[[package]] +name = "aligned-array" +version = "1.0.1" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "e05c92d086290f52938013f6242ac62bf7d401fab8ad36798a609faa65c3fd2c" +dependencies = [ + "generic-array", +] + [[package]] name = "aligned-vec" version = "0.6.4" @@ -619,6 +628,15 @@ dependencies = [ "tokio-util", ] +[[package]] +name = "atoi" +version = "2.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "f28d99ec8bfea296261ca1af174f24225171fea9664ba9003cbebee704810528" +dependencies = [ + "num-traits", +] + [[package]] name = "atomic" version = "0.6.1" @@ -643,44 +661,12 @@ version = "1.1.2" source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "1505bd5d3d116872e7271a6d4e16d81d0c8570876c8de68093a09ac269d8aac0" -[[package]] -name = "attohttpc" -version = "0.28.5" -source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "07a9b245ba0739fc90935094c29adbaee3f977218b5fb95e822e261cda7f56a3" -dependencies = [ - "http 1.3.1", - "log", - "rustls", - "serde", - "serde_json", - "url", - "webpki-roots 0.26.11", -] - [[package]] name = "autocfg" version = "1.5.0" source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "c08606f8c3cbf4ce6ec8e28fb0014a2c086708fe954eaa885384a6165172e7e8" -[[package]] -name = "aws-creds" -version = "0.38.0" -source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "ba912106484991c456adb3364338a2534d0818bd9374b324b608074e3b55f581" -dependencies = [ - "attohttpc", - "home", - "log", - "quick-xml 0.32.0", - "rust-ini", - "serde", - "thiserror 1.0.69", - "time", - "url", -] - [[package]] name = "aws-lc-rs" version = "1.13.1" @@ -704,15 +690,6 @@ dependencies = [ "fs_extra", ] -[[package]] -name = "aws-region" -version = "0.26.0" -source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "73ae4ae7c45238b60af0a3b27ef2fcc7bd5b8fdcd8a6d679919558b40d3eff7a" -dependencies = [ - "thiserror 1.0.69", -] - [[package]] name = "axum" version = "0.7.9" @@ -863,6 +840,12 @@ version = "0.22.1" source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "72b3254f16251a8381aa12e40e3c4d2f0199f8c6508fbecb9d91f575e0fbb8c6" +[[package]] +name = "base64ct" +version = "1.8.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "55248b47b0caf0546f7988906588779981c43bb1bc9d0c44087278f80cdb44ba" + [[package]] name = "bcrypt" version = "0.17.0" @@ -1311,15 +1294,6 @@ dependencies = [ "thiserror 2.0.12", ] -[[package]] -name = "castaway" -version = "0.2.3" -source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "0abae9be0aaf9ea96a3b1b8b1b55c602ca751eba1b1500220cea4ecbafe7c0d5" -dependencies = [ - "rustversion", -] - [[package]] name = "cc" version = "1.2.27" @@ -1527,16 +1501,23 @@ dependencies = [ ] [[package]] -name = "compact_str" -version = "0.7.1" +name = "compio" +version = "0.15.0" source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "f86b9c4c00838774a6d902ef931eff7470720c51d90c2e32cfe15dc304737b3f" +checksum = "713c6293af093c202ad318e8f7bdc1de1a36d7a793bb77f7fc6bd6f1788659a9" dependencies = [ - "castaway", - "cfg-if", - "itoa", - "ryu", - "static_assertions", + "compio-buf 0.6.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-dispatcher", + "compio-driver 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-fs 0.8.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-io 0.7.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-log 0.1.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-net 0.8.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-process", + "compio-quic", + "compio-runtime 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-signal", + "compio-tls 0.6.0 (registry+https://github.com/rust-lang/crates.io-index)", ] [[package]] @@ -1544,15 +1525,26 @@ name = "compio" version = "0.15.0" source = "git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be#fe4243f0b6811ebc325afd081c9b087b4d9817be"; dependencies = [ - "compio-buf", - "compio-driver", - "compio-fs", - "compio-io", - "compio-log", + "compio-buf 0.6.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-driver 0.8.1 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-fs 0.8.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-io 0.7.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-log 0.1.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", "compio-macros", - "compio-net", - "compio-runtime", - "compio-tls", + "compio-net 0.8.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-runtime 0.8.1 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-tls 0.6.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", +] + +[[package]] +name = "compio-buf" +version = "0.6.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "3ce94a45a47ef8c0e3f44084fe67c8effc25e7ac1de6de2ee1a29a59e6c6ba8e" +dependencies = [ + "arrayvec", + "bytes", + "libc", ] [[package]] @@ -1565,6 +1557,43 @@ dependencies = [ "libc", ] +[[package]] +name = "compio-dispatcher" +version = "0.7.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "0cdf8c613be826be410d8744ab30acc49cc5134a78e2aa25efae9efa44bed6a7" +dependencies = [ + "compio-driver 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-runtime 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "flume", + "futures-channel", +] + +[[package]] +name = "compio-driver" +version = "0.8.1" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "737212fe00b4af769f7e8f156c25ffafd5888d4d21834e100ea068dea1086ef8" +dependencies = [ + "aligned-array", + "cfg-if", + "cfg_aliases", + "compio-buf 0.6.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-log 0.1.0 (registry+https://github.com/rust-lang/crates.io-index)", + "crossbeam-channel", + "crossbeam-queue", + "futures-util", + "io-uring", + "io_uring_buf_ring", + "libc", + "once_cell", + "paste", + "polling", + "slab", + "socket2 0.5.10", + "windows-sys 0.52.0", +] + [[package]] name = "compio-driver" version = "0.8.1" @@ -1572,8 +1601,8 @@ source = "git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd dependencies = [ "cfg-if", "cfg_aliases", - "compio-buf", - "compio-log", + "compio-buf 0.6.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-log 0.1.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", "crossbeam-channel", "crossbeam-queue", "futures-util", @@ -1588,6 +1617,24 @@ dependencies = [ "windows-sys 0.60.2", ] +[[package]] +name = "compio-fs" +version = "0.8.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "9bcf65e631d521c666bca25595f8e5c78173e96f0b3b61f0a7d93f31d9661d32" +dependencies = [ + "cfg-if", + "cfg_aliases", + "compio-buf 0.6.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-driver 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-io 0.7.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-runtime 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "libc", + "os_pipe", + "widestring", + "windows-sys 0.52.0", +] + [[package]] name = "compio-fs" version = "0.8.0" @@ -1595,27 +1642,48 @@ source = "git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd dependencies = [ "cfg-if", "cfg_aliases", - "compio-buf", - "compio-driver", - "compio-io", - "compio-runtime", + "compio-buf 0.6.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-driver 0.8.1 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-io 0.7.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-runtime 0.8.1 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", "libc", "os_pipe", "widestring", "windows-sys 0.60.2", ] +[[package]] +name = "compio-io" +version = "0.7.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "c2b05cc4142659f2c90b6e44c68568ff71c83c6fb9285aca686952250b914932" +dependencies = [ + "compio-buf 0.6.0 (registry+https://github.com/rust-lang/crates.io-index)", + "futures-util", + "paste", + "pin-project-lite", +] + [[package]] name = "compio-io" version = "0.7.0" source = "git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be#fe4243f0b6811ebc325afd081c9b087b4d9817be"; dependencies = [ - "compio-buf", + "compio-buf 0.6.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", "futures-util", "paste", "pin-project-lite", ] +[[package]] +name = "compio-log" +version = "0.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "fc4e560213c1996b618da369b7c9109564b41af9033802ae534465c4ee4e132f" +dependencies = [ + "tracing", +] + [[package]] name = "compio-log" version = "0.1.0" @@ -1635,16 +1703,35 @@ dependencies = [ "syn 2.0.104", ] +[[package]] +name = "compio-net" +version = "0.8.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "0c1fabe3393bc0c3a0dca8e99a35bf97e42caa12bb3cc6bba83df04e28c9c142" +dependencies = [ + "cfg-if", + "compio-buf 0.6.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-driver 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-io 0.7.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-runtime 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "either", + "libc", + "once_cell", + "socket2 0.5.10", + "widestring", + "windows-sys 0.52.0", +] + [[package]] name = "compio-net" version = "0.8.0" source = "git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be#fe4243f0b6811ebc325afd081c9b087b4d9817be"; dependencies = [ "cfg-if", - "compio-buf", - "compio-driver", - "compio-io", - "compio-runtime", + "compio-buf 0.6.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-driver 0.8.1 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-io 0.7.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-runtime 0.8.1 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", "either", "libc", "once_cell", @@ -1653,6 +1740,64 @@ dependencies = [ "windows-sys 0.60.2", ] +[[package]] +name = "compio-process" +version = "0.5.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "3867cfe7b23eaae89ff815aba4fdde61cb6fd55f81fd368128300c6b7e645016" +dependencies = [ + "cfg-if", + "compio-buf 0.6.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-driver 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-io 0.7.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-runtime 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "futures-util", + "windows-sys 0.52.0", +] + +[[package]] +name = "compio-quic" +version = "0.4.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "6f107e044329f1e171930801b09bfc6e764c5e171e45c7a3e382f98561da619a" +dependencies = [ + "cfg_aliases", + "compio-buf 0.6.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-io 0.7.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-log 0.1.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-net 0.8.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-runtime 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "flume", + "futures-util", + "libc", + "quinn-proto", + "rustc-hash 2.1.1", + "rustls", + "thiserror 2.0.12", + "windows-sys 0.52.0", +] + +[[package]] +name = "compio-runtime" +version = "0.8.1" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "b7df559e87b7ab05ba61c32619f6076dd5cc2daf5a8cb30cb9931fb355d20aff" +dependencies = [ + "async-task", + "cfg-if", + "compio-buf 0.6.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-driver 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-log 0.1.0 (registry+https://github.com/rust-lang/crates.io-index)", + "crossbeam-queue", + "futures-util", + "libc", + "once_cell", + "scoped-tls", + "slab", + "socket2 0.5.10", + "windows-sys 0.52.0", +] + [[package]] name = "compio-runtime" version = "0.8.1" @@ -1660,9 +1805,9 @@ source = "git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd dependencies = [ "async-task", "cfg-if", - "compio-buf", - "compio-driver", - "compio-log", + "compio-buf 0.6.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-driver 0.8.1 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-log 0.1.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", "core_affinity", "crossbeam-queue", "futures-util", @@ -1674,13 +1819,40 @@ dependencies = [ "windows-sys 0.60.2", ] +[[package]] +name = "compio-signal" +version = "0.6.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "03d2931880b03b33d4df7d2b8a008e93731366d185358c7442fc8d24d5f9c1bd" +dependencies = [ + "compio-buf 0.6.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-driver 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-runtime 0.8.1 (registry+https://github.com/rust-lang/crates.io-index)", + "libc", + "once_cell", + "os_pipe", + "slab", + "windows-sys 0.52.0", +] + +[[package]] +name = "compio-tls" +version = "0.6.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "542bb0e0f6f65cb84bc09b7e052fa54f006d1ba228a8dfad6d7b9676defe7232" +dependencies = [ + "compio-buf 0.6.0 (registry+https://github.com/rust-lang/crates.io-index)", + "compio-io 0.7.0 (registry+https://github.com/rust-lang/crates.io-index)", + "rustls", +] + [[package]] name = "compio-tls" version = "0.6.0" source = "git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be#fe4243f0b6811ebc325afd081c9b087b4d9817be"; dependencies = [ - "compio-buf", - "compio-io", + "compio-buf 0.6.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", + "compio-io 0.7.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", "rustls", ] @@ -1774,6 +1946,12 @@ dependencies = [ "wasm-bindgen", ] +[[package]] +name = "const-oid" +version = "0.9.6" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "c2459377285ad874054d797f3ccebf984978aa39129f6eafde5cdc8315b612f8" + [[package]] name = "const-random" version = "0.1.18" @@ -1871,6 +2049,21 @@ dependencies = [ "libc", ] +[[package]] +name = "crc" +version = "3.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "9710d3b3739c2e349eb44fe848ad0b7c8cb1e42bd87ee49371df2f7acaf3e675" +dependencies = [ + "crc-catalog", +] + +[[package]] +name = "crc-catalog" +version = "2.4.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "19d374276b40fb8bbdee95aef7c7fa6b5316ec764510eb64b8dd0e2ed0d7e7f5" + [[package]] name = "crc32fast" version = "1.4.2" @@ -2075,6 +2268,46 @@ dependencies = [ "regex-syntax 0.7.5", ] +[[package]] +name = "cyper" +version = "0.4.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "89b65af5073b4f53c9697b611b414042e71c6a14e11088438a67b1ef36f51ca2" +dependencies = [ + "async-stream", + "base64 0.22.1", + "compio 0.15.0 (registry+https://github.com/rust-lang/crates.io-index)", + "cyper-core", + "encoding_rs", + "futures-util", + "http 1.3.1", + "http-body-util", + "hyper", + "hyper-util", + "mime", + "send_wrapper", + "serde", + "serde_urlencoded", + "thiserror 2.0.12", + "url", +] + +[[package]] +name = "cyper-core" +version = "0.4.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "6343deaa569c748860d9afefab636648e7e6f9abdfc26b3b9dde327170ae6b2b" +dependencies = [ + "cfg-if", + "compio 0.15.0 (registry+https://github.com/rust-lang/crates.io-index)", + "futures-util", + "hyper", + "hyper-util", + "rustls-platform-verifier 0.6.0", + "send_wrapper", + "tower-service", +] + [[package]] name = "darling" version = "0.20.11" @@ -2155,6 +2388,17 @@ version = "0.1.9" source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "da692b8d1080ea3045efaab14434d40468c3d8657e42abddfffca87b428f4c1b" +[[package]] +name = "der" +version = "0.7.10" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "e7c1832837b905bbfb5101e07cc24c8deddf52f93225eee6ead5f4d63d53ddcb" +dependencies = [ + "const-oid", + "pem-rfc7468", + "zeroize", +] + [[package]] name = "deranged" version = "0.4.0" @@ -2266,6 +2510,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "9ed9a281f7bc9b7576e61468ba615a66a5c8cfdff42420a70aa82701a3b1e292" dependencies = [ "block-buffer", + "const-oid", "crypto-common", "subtle", ] @@ -2407,6 +2652,9 @@ name = "either" version = "1.15.0" source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "48c757948c5ede0e46177b7add2e67155f70e33c07fea8284df6576da70b3719" +dependencies = [ + "serde", +] [[package]] name = "embedded-io" @@ -2539,6 +2787,17 @@ dependencies = [ "syn 2.0.104", ] +[[package]] +name = "etcetera" +version = "0.8.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "136d1b5283a1ab77bd9257427ffd09d8667ced0570b6f938942bc7568ed5b943" +dependencies = [ + "cfg-if", + "home", + "windows-sys 0.48.0", +] + [[package]] name = "event-listener" version = "5.4.0" @@ -2812,6 +3071,17 @@ dependencies = [ "futures-util", ] +[[package]] +name = "futures-intrusive" +version = "0.5.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "1d930c203dd0b6ff06e0201a4a2fe9149b43c684fd4420555b26d21b1a02956f" +dependencies = [ + "futures-core", + "lock_api", + "parking_lot 0.12.4", +] + [[package]] name = "futures-io" version = "0.3.31" @@ -3437,6 +3707,15 @@ dependencies = [ "web-time", ] +[[package]] +name = "gxhash" +version = "3.5.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "f3ce1bab7aa741d4e7042b2aae415b78741f267a98a7271ea226cd5ba6c43d7d" +dependencies = [ + "rustversion", +] + [[package]] name = "h2" version = "0.3.26" @@ -3602,6 +3881,15 @@ version = "0.4.3" source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "7f24254aa9a54b5c858eaee2f5bccdb46aaf0e486a595ed5fd8f86ba55232a70" +[[package]] +name = "hkdf" +version = "0.12.4" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "7b5f8eb2ad728638ea2c7d47a21db23b7b58a72ed6a38256b8a1849f15fbbdf7" +dependencies = [ + "hmac", +] + [[package]] name = "hmac" version = "0.12.1" @@ -3969,6 +4257,7 @@ dependencies = [ "integration", "nonzero_lit", "rand 0.9.1", + "rayon", "serde", "sysinfo 0.35.2", "tokio", @@ -4066,6 +4355,7 @@ dependencies = [ "crc32fast", "derive_more 2.0.1", "fast-async-mutex", + "gxhash", "humantime", "rcgen", "rustls", @@ -4078,6 +4368,43 @@ dependencies = [ "tracing", ] +[[package]] +name = "iggy_connector_postgres_sink" +version = "0.1.0" +dependencies = [ + "async-trait", + "chrono", + "dashmap", + "futures", + "iggy_connector_sdk", + "once_cell", + "serde", + "simd-json", + "sqlx", + "tokio", + "tracing", +] + +[[package]] +name = "iggy_connector_postgres_source" +version = "0.1.0" +dependencies = [ + "async-trait", + "chrono", + "dashmap", + "futures", + "humantime", + "iggy_connector_sdk", + "once_cell", + "serde", + "serde_json", + "simd-json", + "sqlx", + "tokio", + "tracing", + "uuid", +] + [[package]] name = "iggy_connector_quickwit_sink" version = "0.1.0" @@ -4303,6 +4630,7 @@ dependencies = [ "async-trait", "bytes", "chrono", + "compio 0.15.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", "ctor", "derive_more 2.0.1", "env_logger", @@ -4580,6 +4908,9 @@ name = "lazy_static" version = "1.5.0" source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "bbd2bcb4c963f2ddae06a2efc7e9f3591312473c50c6685e1f298068316e66fe" +dependencies = [ + "spin", +] [[package]] name = "lazycell" @@ -4676,6 +5007,12 @@ dependencies = [ "pkg-config", ] +[[package]] +name = "libm" +version = "0.2.15" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "f9fbbcab51052fe104eb5e5d351cf728d30a5be1fe14d9be8a3b097481fb97de" + [[package]] name = "libmimalloc-sys" version = "0.1.43" @@ -4697,6 +5034,16 @@ dependencies = [ "redox_syscall 0.5.13", ] +[[package]] +name = "libsqlite3-sys" +version = "0.30.1" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "2e99fb7a497b1e3339bc746195567ed8d3e24945ecd636e3619d20b9de9e9149" +dependencies = [ + "pkg-config", + "vcpkg", +] + [[package]] name = "libyml" version = "0.0.5" @@ -4876,22 +5223,15 @@ source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "47e1ffaa40ddd1f3ed91f717a33c8c0ee23fff369e3aa8772b9605cc1d22f4c3" [[package]] -name = "maybe-async" -version = "0.2.10" +name = "md-5" +version = "0.10.6" source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "5cf92c10c7e361d6b99666ec1c6f9805b0bea2c3bd8c78dc6fe98ac5bd78db11" +checksum = "d89e7ee0cfbedfc4da3340218492196241d89eefb6dab27de5df917a6d2e78cf" dependencies = [ - "proc-macro2", - "quote", - "syn 2.0.104", + "cfg-if", + "digest", ] -[[package]] -name = "md5" -version = "0.7.0" -source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "490cc448043f947bae3cbee9c203358d62dbee0db12107a74be5c30ccfd09771" - [[package]] name = "memchr" version = "2.7.5" @@ -4945,15 +5285,6 @@ dependencies = [ "unicase", ] -[[package]] -name = "minidom" -version = "0.16.0" -source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "e394a0e3c7ccc2daea3dffabe82f09857b6b510cb25af87d54bf3e910ac1642d" -dependencies = [ - "rxml", -] - [[package]] name = "minimal-lexical" version = "0.2.1" @@ -5184,6 +5515,23 @@ dependencies = [ "num-traits", ] +[[package]] +name = "num-bigint-dig" +version = "0.8.4" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "dc84195820f291c7697304f3cbdadd1cb7199c0efc917ff5eafd71225c136151" +dependencies = [ + "byteorder", + "lazy_static", + "libm", + "num-integer", + "num-iter", + "num-traits", + "rand 0.8.5", + "smallvec", + "zeroize", +] + [[package]] name = "num-complex" version = "0.4.6" @@ -5252,6 +5600,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "071dfc062690e90b734c0b2273ce72ad0ffa95f0c74596bc250dcfd960262841" dependencies = [ "autocfg", + "libm", ] [[package]] @@ -5686,6 +6035,15 @@ dependencies = [ "serde", ] +[[package]] +name = "pem-rfc7468" +version = "0.7.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "88b39c9bfcfc231068454382784bb460aae594343fb030d46e9f50a645418412" +dependencies = [ + "base64ct", +] + [[package]] name = "percent-encoding" version = "2.3.1" @@ -5779,6 +6137,27 @@ dependencies = [ "thiserror 1.0.69", ] +[[package]] +name = "pkcs1" +version = "0.7.5" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "c8ffb9f10fa047879315e6625af03c164b16962a5368d724ed16323b68ace47f" +dependencies = [ + "der", + "pkcs8", + "spki", +] + +[[package]] +name = "pkcs8" +version = "0.10.2" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "f950b2377845cebe5cf8b5165cb3cc1a5e0fa5cfa3e1f7f55707d8fd82e0a7b7" +dependencies = [ + "der", + "spki", +] + [[package]] name = "pkg-config" version = "0.3.32" @@ -6123,19 +6502,9 @@ dependencies = [ [[package]] name = "quick-xml" -version = "0.32.0" +version = "0.37.5" source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "1d3a6e5838b60e0e8fa7a43f22ade549a37d61f8bdbe636d0d7816191de969c2" -dependencies = [ - "memchr", - "serde", -] - -[[package]] -name = "quick-xml" -version = "0.36.2" -source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "f7649a7b4df05aed9ea7ec6f628c67c9953a43869b8bc50929569b2999d443fe" +checksum = "331e97a1af0bf59823e6eadffe373d7b27f485be8748f71471c662c1f269b7fb" dependencies = [ "memchr", "serde", @@ -6176,7 +6545,7 @@ dependencies = [ "rustc-hash 2.1.1", "rustls", "rustls-pki-types", - "rustls-platform-verifier", + "rustls-platform-verifier 0.5.3", "slab", "thiserror 2.0.12", "tinyvec", @@ -6464,14 +6833,12 @@ dependencies = [ "sync_wrapper", "tokio", "tokio-rustls", - "tokio-util", "tower 0.5.2", "tower-http", "tower-service", "url", "wasm-bindgen", "wasm-bindgen-futures", - "wasm-streams", "web-sys", "webpki-roots 1.0.1", ] @@ -6584,48 +6951,34 @@ source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "afab94fb28594581f62d981211a9a4d53cc8130bbcbbb89a0440d9b8e81a7746" [[package]] -name = "rust-ini" -version = "0.21.1" +name = "rsa" +version = "0.9.8" source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "4e310ef0e1b6eeb79169a1171daf9abcb87a2e17c03bee2c4bb100b55c75409f" +checksum = "78928ac1ed176a5ca1d17e578a1825f3d81ca54cf41053a592584b020cfd691b" dependencies = [ - "cfg-if", - "ordered-multimap", - "trim-in-place", + "const-oid", + "digest", + "num-bigint-dig", + "num-integer", + "num-traits", + "pkcs1", + "pkcs8", + "rand_core 0.6.4", + "signature", + "spki", + "subtle", + "zeroize", ] [[package]] -name = "rust-s3" -version = "0.36.0-beta.2" +name = "rust-ini" +version = "0.21.1" source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "cc7d6f3a3dd397743e8f344ffc80ea7137aee423983ae25b512e5332ad11362f" +checksum = "4e310ef0e1b6eeb79169a1171daf9abcb87a2e17c03bee2c4bb100b55c75409f" dependencies = [ - "async-trait", - "aws-creds", - "aws-region", - "base64 0.22.1", - "bytes", "cfg-if", - "futures", - "hex", - "hmac", - "http 1.3.1", - "log", - "maybe-async", - "md5", - "minidom", - "percent-encoding", - "quick-xml 0.36.2", - "reqwest", - "serde", - "serde_derive", - "serde_json", - "sha2", - "thiserror 1.0.69", - "time", - "tokio", - "tokio-stream", - "url", + "ordered-multimap", + "trim-in-place", ] [[package]] @@ -6765,6 +7118,27 @@ dependencies = [ "windows-sys 0.59.0", ] +[[package]] +name = "rustls-platform-verifier" +version = "0.6.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "eda84358ed17f1f354cf4b1909ad346e6c7bc2513e8c40eb08e0157aa13a9070" +dependencies = [ + "core-foundation", + "core-foundation-sys", + "jni", + "log", + "once_cell", + "rustls", + "rustls-native-certs", + "rustls-platform-verifier-android", + "rustls-webpki", + "security-framework", + "security-framework-sys", + "webpki-root-certs 1.0.1", + "windows-sys 0.59.0", +] + [[package]] name = "rustls-platform-verifier-android" version = "0.1.1" @@ -6790,22 +7164,22 @@ source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "8a0d197bd2c9dc6e53b84da9556a69ba4cdfab8619eb41a8bd1cc2027a0f6b1d" [[package]] -name = "rxml" -version = "0.11.1" -source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "65bc94b580d0f5a6b7a2d604e597513d3c673154b52ddeccd1d5c32360d945ee" -dependencies = [ - "bytes", - "rxml_validation", -] - -[[package]] -name = "rxml_validation" -version = "0.11.0" +name = "rusty-s3" +version = "0.7.0" source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "826e80413b9a35e9d33217b3dcac04cf95f6559d15944b93887a08be5496c4a4" +checksum = "8f51a5a6b15f25d3e10c068039ee13befb6110fcb36c2b26317bcbdc23484d96" dependencies = [ - "compact_str", + "base64 0.22.1", + "hmac", + "md-5", + "percent-encoding", + "quick-xml", + "serde", + "serde_json", + "sha2", + "time", + "url", + "zeroize", ] [[package]] @@ -6939,6 +7313,15 @@ dependencies = [ "serde", ] +[[package]] +name = "send_wrapper" +version = "0.6.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "cd0b0ec5f1c1ca621c432a25813d8d60c88abe6d3e08a3eb9cf37d97a0fe3d73" +dependencies = [ + "futures-core", +] + [[package]] name = "serde" version = "1.0.219" @@ -7112,10 +7495,11 @@ dependencies = [ "bytes", "chrono", "clap", - "compio", + "compio 0.15.0 (git+https://github.com/compio-rs/compio.git?rev=fe4243f0b6811ebc325afd081c9b087b4d9817be)", "console-subscriber", "crossbeam", "ctrlc", + "cyper", "dashmap", "derive_more 2.0.1", "dotenvy", @@ -7125,6 +7509,7 @@ dependencies = [ "figment", "flume", "futures", + "gxhash", "hash32 1.0.0", "human-repr", "iggy_common", @@ -7144,9 +7529,9 @@ dependencies = [ "quinn", "reqwest", "ring", - "rust-s3", "rustls", "rustls-pemfile", + "rusty-s3", "serde", "serde_with", "serial_test", @@ -7227,6 +7612,16 @@ dependencies = [ "libc", ] +[[package]] +name = "signature" +version = "2.2.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "77549399552de45a898a580c1b41d445bf730df867cc44e6c0233bbc4b8329de" +dependencies = [ + "digest", + "rand_core 0.6.4", +] + [[package]] name = "simd-adler32" version = "0.3.7" @@ -7283,6 +7678,9 @@ name = "smallvec" version = "1.15.1" source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "67b1b7a3b5fe4f1376887184045fcf45c69e92af734b7aaddc05fb777b6fbd03" +dependencies = [ + "serde", +] [[package]] name = "smart-default" @@ -7360,6 +7758,214 @@ dependencies = [ "lock_api", ] +[[package]] +name = "spki" +version = "0.7.3" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "d91ed6c858b01f942cd56b37a94b3e0a1798290327d1236e4d9cf4eaca44d29d" +dependencies = [ + "base64ct", + "der", +] + +[[package]] +name = "sqlx" +version = "0.8.6" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "1fefb893899429669dcdd979aff487bd78f4064e5e7907e4269081e0ef7d97dc" +dependencies = [ + "sqlx-core", + "sqlx-macros", + "sqlx-mysql", + "sqlx-postgres", + "sqlx-sqlite", +] + +[[package]] +name = "sqlx-core" +version = "0.8.6" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "ee6798b1838b6a0f69c007c133b8df5866302197e404e8b6ee8ed3e3a5e68dc6" +dependencies = [ + "base64 0.22.1", + "bytes", + "chrono", + "crc", + "crossbeam-queue", + "either", + "event-listener", + "futures-core", + "futures-intrusive", + "futures-io", + "futures-util", + "hashbrown 0.15.4", + "hashlink", + "indexmap 2.10.0", + "log", + "memchr", + "once_cell", + "percent-encoding", + "rustls", + "serde", + "serde_json", + "sha2", + "smallvec", + "thiserror 2.0.12", + "tokio", + "tokio-stream", + "tracing", + "url", + "uuid", + "webpki-roots 0.26.11", +] + +[[package]] +name = "sqlx-macros" +version = "0.8.6" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "a2d452988ccaacfbf5e0bdbc348fb91d7c8af5bee192173ac3636b5fb6e6715d" +dependencies = [ + "proc-macro2", + "quote", + "sqlx-core", + "sqlx-macros-core", + "syn 2.0.104", +] + +[[package]] +name = "sqlx-macros-core" +version = "0.8.6" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "19a9c1841124ac5a61741f96e1d9e2ec77424bf323962dd894bdb93f37d5219b" +dependencies = [ + "dotenvy", + "either", + "heck 0.5.0", + "hex", + "once_cell", + "proc-macro2", + "quote", + "serde", + "serde_json", + "sha2", + "sqlx-core", + "sqlx-mysql", + "sqlx-postgres", + "sqlx-sqlite", + "syn 2.0.104", + "tokio", + "url", +] + +[[package]] +name = "sqlx-mysql" +version = "0.8.6" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "aa003f0038df784eb8fecbbac13affe3da23b45194bd57dba231c8f48199c526" +dependencies = [ + "atoi", + "base64 0.22.1", + "bitflags 2.9.1", + "byteorder", + "bytes", + "chrono", + "crc", + "digest", + "dotenvy", + "either", + "futures-channel", + "futures-core", + "futures-io", + "futures-util", + "generic-array", + "hex", + "hkdf", + "hmac", + "itoa", + "log", + "md-5", + "memchr", + "once_cell", + "percent-encoding", + "rand 0.8.5", + "rsa", + "serde", + "sha1", + "sha2", + "smallvec", + "sqlx-core", + "stringprep", + "thiserror 2.0.12", + "tracing", + "uuid", + "whoami", +] + +[[package]] +name = "sqlx-postgres" +version = "0.8.6" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "db58fcd5a53cf07c184b154801ff91347e4c30d17a3562a635ff028ad5deda46" +dependencies = [ + "atoi", + "base64 0.22.1", + "bitflags 2.9.1", + "byteorder", + "chrono", + "crc", + "dotenvy", + "etcetera", + "futures-channel", + "futures-core", + "futures-util", + "hex", + "hkdf", + "hmac", + "home", + "itoa", + "log", + "md-5", + "memchr", + "once_cell", + "rand 0.8.5", + "serde", + "serde_json", + "sha2", + "smallvec", + "sqlx-core", + "stringprep", + "thiserror 2.0.12", + "tracing", + "uuid", + "whoami", +] + +[[package]] +name = "sqlx-sqlite" +version = "0.8.6" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "c2d12fe70b2c1b4401038055f90f151b78208de1f9f89a7dbfd41587a10c3eea" +dependencies = [ + "atoi", + "chrono", + "flume", + "futures-channel", + "futures-core", + "futures-executor", + "futures-intrusive", + "futures-util", + "libsqlite3-sys", + "log", + "percent-encoding", + "serde", + "serde_urlencoded", + "sqlx-core", + "thiserror 2.0.12", + "tracing", + "url", + "uuid", +] + [[package]] name = "stable_deref_trait" version = "1.2.0" @@ -7381,10 +7987,15 @@ dependencies = [ ] [[package]] -name = "static_assertions" -version = "1.1.0" +name = "stringprep" +version = "0.1.5" source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "a2eb9349b6444b326872e140eb1cf5e7c522154d69e7a0ffb0fb81c06b37543f" +checksum = "7b4df3d392d81bd458a8a621b8bffbd2302a12ffe288a9d931670948749463b1" +dependencies = [ + "unicode-bidi", + "unicode-normalization", + "unicode-properties", +] [[package]] name = "strsim" @@ -8160,6 +8771,12 @@ version = "2.8.1" source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "75b844d17643ee918803943289730bec8aac480150456169e647ed0b576ba539" +[[package]] +name = "unicode-bidi" +version = "0.3.18" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "5c1cb5db39152898a79168971543b1cb5020dff7fe43c8dc468b0885f5e29df5" + [[package]] name = "unicode-ident" version = "1.0.18" @@ -8172,6 +8789,21 @@ version = "0.1.5" source = "registry+https://github.com/rust-lang/crates.io-index"; checksum = "3b09c83c3c29d37506a3e260c08c03743a6bb66a9cd432c6934ab501a190571f" +[[package]] +name = "unicode-normalization" +version = "0.1.24" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "5033c97c4262335cded6d6fc3e5c18ab755e1a3dc96376350f3d8e9f009ad956" +dependencies = [ + "tinyvec", +] + +[[package]] +name = "unicode-properties" +version = "0.1.3" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "e70f2a8b45122e719eb623c01822704c4e0907e7e426a05927e1a1cfff5b75d0" + [[package]] name = "unicode-segmentation" version = "1.12.0" @@ -8396,6 +9028,12 @@ dependencies = [ "wit-bindgen-rt", ] +[[package]] +name = "wasite" +version = "0.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "b8dad83b4f25e74f184f64c43b150b91efe7647395b42289f38e50566d82855b" + [[package]] name = "wasm-bindgen" version = "0.2.100" @@ -8467,19 +9105,6 @@ dependencies = [ "unicode-ident", ] -[[package]] -name = "wasm-streams" -version = "0.4.2" -source = "registry+https://github.com/rust-lang/crates.io-index"; -checksum = "15053d8d85c7eccdbefef60f06769760a563c7f0a9d6902a13d35c7800b0ad65" -dependencies = [ - "futures-util", - "js-sys", - "wasm-bindgen", - "wasm-bindgen-futures", - "web-sys", -] - [[package]] name = "wasm-timer" version = "0.2.5" @@ -8564,6 +9189,16 @@ dependencies = [ "rustix 0.38.44", ] +[[package]] +name = "whoami" +version = "1.6.0" +source = "registry+https://github.com/rust-lang/crates.io-index"; +checksum = "6994d13118ab492c3c80c1f81928718159254c53c472bf9ce36f8dae4add02a7" +dependencies = [ + "redox_syscall 0.5.13", + "wasite", +] + [[package]] name = "wide" version = "0.7.33" diff --git a/Cargo.toml b/Cargo.toml index 1faea63f2..c0533ea6f 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -137,6 +137,7 @@ uuid = { version = "1.17.0", features = [ "serde", "zerocopy", ] } +gxhash = "3.5.0" rust-s3 = { version = "0.36.0-beta.2", default-features = false, features = [ "tokio-rustls-tls", "tags", diff --git a/core/common/Cargo.toml b/core/common/Cargo.toml index 443b01507..9168ac2b3 100644 --- a/core/common/Cargo.toml +++ b/core/common/Cargo.toml @@ -43,6 +43,7 @@ chrono = { workspace = true } clap = { workspace = true } comfy-table = { workspace = true } crc32fast = { workspace = true } +gxhash = { workspace = true } derive_more = { workspace = true } fast-async-mutex = { version = "0.6.7", optional = true } humantime = { workspace = true } diff --git a/core/common/src/utils/checksum.rs b/core/common/src/utils/checksum.rs index 900b4fb98..c29a28e07 100644 --- a/core/common/src/utils/checksum.rs +++ b/core/common/src/utils/checksum.rs @@ -17,5 +17,5 @@ */ pub fn calculate_checksum(data: &[u8]) -> u32 { - crc32fast::hash(data) + gxhash::gxhash32(data, 0) } diff --git a/core/server/Cargo.toml b/core/server/Cargo.toml index 2932faf09..80a462924 100644 --- a/core/server/Cargo.toml +++ b/core/server/Cargo.toml @@ -58,6 +58,7 @@ error_set = { version = "0.8.5", features = ["tracing"] } figlet-rs = { workspace = true } figment = { version = "0.10.19", features = ["toml", "env"] } flume = { workspace = true } +gxhash = { workspace = true } async-channel = { workspace = true } futures = { workspace = true } human-repr = { workspace = true } @@ -68,6 +69,13 @@ lending-iterator = "0.1.7" hash32 = "1.0.0" mimalloc = { workspace = true, optional = true } moka = { version = "0.12.10", features = ["future"] } +compio = { git = "https://github.com/compio-rs/compio.git";, rev = "fe4243f0b6811ebc325afd081c9b087b4d9817be", features = [ + "runtime", + "macros", + "io-uring", + "time", + "rustls", +] } nix = { version = "0.30", features = ["fs"] } once_cell = "1.21.3" opentelemetry = { version = "0.30.0", features = ["trace", "logs"] } @@ -106,7 +114,6 @@ sysinfo = { workspace = true } tempfile = { workspace = true } thiserror = { workspace = true } tokio = { workspace = true } -compio = { workspace = true } cyper = { workspace = true } tokio-rustls = { workspace = true } tokio-util = { workspace = true } diff --git a/core/server/src/streaming/utils/random_id.rs b/core/server/src/streaming/utils/random_id.rs index 6fb6b411c..4dbfe5d49 100644 --- a/core/server/src/streaming/utils/random_id.rs +++ b/core/server/src/streaming/utils/random_id.rs @@ -20,7 +20,7 @@ use ulid::Ulid; use uuid::Uuid; pub fn get_uuid() -> u128 { - Uuid::now_v7().to_u128_le() + Uuid::new_v4().to_u128_le() } pub fn get_ulid() -> Ulid {
