diff --git a/Cargo.lock b/Cargo.lock index 96b4e039a..f0e8561ec 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -17,6 +17,12 @@ version = "1.0.2" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "f26201604c87b1e01bd3d98f8d5d9a8fcbb815e8cedb41ffccbeb4bf593a35fe" +[[package]] +name = "adler2" +version = "2.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "512761e0bb2578dd7380c6baaa0f4ce03e84f95e960231d1dec8bf4d7d6e2627" + [[package]] name = "ahash" version = "0.8.11" @@ -113,9 +119,9 @@ checksum = "9d151e35f61089500b617991b791fc8bfd237ae50cd5950803758a179b41e67a" [[package]] name = "arrayvec" -version = "0.7.4" +version = "0.7.6" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "96d30a06541fbafbc7f82ed10c06164cfbd2c401138f6addd8404629c4b16711" +checksum = "7c02d123df017efcdfbd739ef81735b36c5ba83ec3c59c80a9d7ecc718f92e50" [[package]] name = "assert-json-diff" @@ -158,18 +164,18 @@ checksum = "16e62a023e7c117e27523144c5d2459f4397fcc3cab0085af8e2224f643a0193" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] name = "async-trait" -version = "0.1.81" +version = "0.1.82" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6e0c28dcc82d7c8ead5cb13beb15405b57b8546e93215673ff8ca0349a028107" +checksum = "a27b8a3a6e1a44fa4c8baf1f653e4172e81486d4941f2237e20dc2d0cf4ddff1" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -447,7 +453,7 @@ dependencies = [ "httparse", "hyper 0.14.30", "hyper-rustls", - "indexmap 2.3.0", + "indexmap 2.5.0", "once_cell", "pin-project-lite", "pin-utils", @@ -461,9 +467,9 @@ dependencies = [ [[package]] name = "aws-smithy-runtime-api" -version = "1.7.2" +version = "1.7.1" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "e086682a53d3aa241192aa110fa8dfce98f2f5ac2ead0de84d41582c7e8fdb96" +checksum = "30819352ed0a04ecf6a2f3477e344d2d1ba33d43e0f09ad9047c12e0d923616f" dependencies = [ "aws-smithy-async", "aws-smithy-types", @@ -478,9 +484,9 @@ dependencies = [ [[package]] name = "aws-smithy-types" -version = "1.2.0" +version = "1.2.4" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "cfe321a6b21f5d8eabd0ade9c55d3d0335f3c3157fc2b3e87f05f34b539e4df5" +checksum = "273dcdfd762fae3e1650b8024624e7cd50e484e37abdab73a7a706188ad34543" dependencies = [ "base64-simd", "bytes", @@ -582,7 +588,7 @@ dependencies = [ "cc", "cfg-if", "libc", - "miniz_oxide", + "miniz_oxide 0.7.4", "object", "rustc-demangle", ] @@ -618,12 +624,6 @@ dependencies = [ "serde", ] -[[package]] -name = "bitflags" -version = "1.3.2" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a" - [[package]] name = "bitflags" version = "2.6.0" @@ -632,9 +632,9 @@ checksum = "b048fb63fd8b5923fc5aa7b340d8e156aec7ec02f0c78fa8a6ddc2613f6f71de" [[package]] name = "blake3" -version = "1.5.3" +version = "1.5.4" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "e9ec96fe9a81b5e365f9db71fe00edc4fe4ca2cc7dcb7861f0603012a7caa210" +checksum = "d82033247fd8e890df8f740e407ad4d038debb9eb1f40533fffb32e7d17dc6f7" dependencies = [ "arrayref", "arrayvec", @@ -693,9 +693,12 @@ dependencies = [ [[package]] name = "cc" -version = "1.1.8" +version = "1.1.16" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "504bdec147f2cc13c8b57ed9401fd8a147cc66b67ad5cb241394244f2c947549" +checksum = "e9d013ecb737093c0e86b151a7b837993cf9ec6c502946cfb44bedc392421e0b" +dependencies = [ + "shlex", +] [[package]] name = "cfg-if" @@ -705,9 +708,9 @@ checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd" [[package]] name = "clap" -version = "4.5.15" +version = "4.5.16" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "11d8838454fda655dafd3accb2b6e2bea645b9e4078abe84a22ceb947235c5cc" +checksum = "ed6719fffa43d0d87e5fd8caeab59be1554fb028cd30edc88fc4369b17971019" dependencies = [ "clap_builder", "clap_derive", @@ -734,7 +737,7 @@ dependencies = [ "heck", "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -797,9 +800,9 @@ dependencies = [ [[package]] name = "constant_time_eq" -version = "0.3.0" +version = "0.3.1" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f7144d30dcf0fafbce74250a3963025d8d52177934239851c917d29f1df280c2" +checksum = "7c74b8349d32d297c9134b8c88677813a227df8f779daa29bfc29c183fe3dca6" [[package]] name = "cookie-factory" @@ -819,15 +822,15 @@ dependencies = [ [[package]] name = "core-foundation-sys" -version = "0.8.6" +version = "0.8.7" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "06ea2b9bc92be3c2baa9334a323ebca2d6f074ff852cd1d7b11064035cd3868f" +checksum = "773648b94d0e5d620f64f280777445740e61fe701025087ec8b57f45c791888b" [[package]] name = "cpufeatures" -version = "0.2.12" +version = "0.2.13" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "53fe5e26ff1b7aef8bca9c6080520cfb8d9333c7568e1829cef191a9723e5504" +checksum = "51e852e6dc9a5bed1fae92dd2375037bf2b768725bf3be87811edee3249d09ad" dependencies = [ "libc", ] @@ -973,20 +976,20 @@ dependencies = [ [[package]] name = "fastrand" -version = "2.1.0" +version = "2.1.1" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "9fc0510504f03c51ada170672ac806f1f105a88aa97a5281117e1ddc3368e51a" +checksum = "e8c02a5121d4ea3eb16a80748c74f5549a5665e4c21333c6098f283870fbdea6" [[package]] name = "filetime" -version = "0.2.23" +version = "0.2.25" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "1ee447700ac8aa0b2f2bd7bc4462ad686ba06baa6727ac149a2d6277f0d240fd" +checksum = "35c0522e981e68cbfa8c3f978441a5f34b30b96e146b33cd3359176b50fe8586" dependencies = [ "cfg-if", "libc", - "redox_syscall 0.4.1", - "windows-sys 0.52.0", + "libredox", + "windows-sys 0.59.0", ] [[package]] @@ -997,12 +1000,12 @@ checksum = "0ce7134b9999ecaf8bcd65542e436736ef32ddca1b3e06094cb6ec5755203b80" [[package]] name = "flate2" -version = "1.0.31" +version = "1.0.33" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "7f211bbe8e69bbd0cfdea405084f128ae8b4aaa6b0b522fc8f2b009084797920" +checksum = "324a1be68054ef05ad64b861cc9eaf1d623d2d8cb25b4bf2cb9cdd902b4bf253" dependencies = [ "crc32fast", - "miniz_oxide", + "miniz_oxide 0.8.0", ] [[package]] @@ -1037,9 +1040,9 @@ checksum = "db0f0c49aba98a3b2578315766960bd242885ff672fd62610c5557cd6c6efe03" [[package]] name = "fred" -version = "9.0.3" +version = "9.1.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "915e065b377f6e16d5c01eae96bf31eeaf81e1e300b76f938761b3c21307cad8" +checksum = "152397076bd317aa06bca9666e954ad15cde1a8f17b6ea4b007cf0bfc074d1d0" dependencies = [ "arc-swap", "async-trait", @@ -1053,7 +1056,7 @@ dependencies = [ "rand", "redis-protocol", "rustls 0.23.12", - "rustls-native-certs 0.7.1", + "rustls-native-certs 0.7.3", "semver", "socket2", "tokio", @@ -1120,7 +1123,7 @@ checksum = "87750cf4b7a4c0625b1529e4c543c2182106e4dedc60a2a6455e00d212c489ac" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -1198,7 +1201,7 @@ dependencies = [ "futures-sink", "futures-util", "http 0.2.12", - "indexmap 2.3.0", + "indexmap 2.5.0", "slab", "tokio", "tokio-util", @@ -1207,9 +1210,9 @@ dependencies = [ [[package]] name = "h2" -version = "0.4.5" +version = "0.4.6" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "fa82e28a107a8cc405f0839610bdc9b15f1e25ec7d696aa5cf173edbcb1486ab" +checksum = "524e8ac6999421f49a846c2d4411f337e53497d8ec55d67753beffa43c5d9205" dependencies = [ "atomic-waker", "bytes", @@ -1217,7 +1220,7 @@ dependencies = [ "futures-core", "futures-sink", "http 1.1.0", - "indexmap 2.3.0", + "indexmap 2.5.0", "slab", "tokio", "tokio-util", @@ -1387,7 +1390,7 @@ dependencies = [ "bytes", "futures-channel", "futures-util", - "h2 0.4.5", + "h2 0.4.6", "http 1.1.0", "http-body 1.0.1", "httparse", @@ -1471,9 +1474,9 @@ dependencies = [ [[package]] name = "indexmap" -version = "2.3.0" +version = "2.5.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "de3fc2e30ba82dd1b3911c8de1ffc143c74a914a14e99514d7637e3099df5ea0" +checksum = "68b900aa2f7301e21c36462b170ee99994de34dff39a4a6a528e80e7376d07e5" dependencies = [ "equivalent", "hashbrown 0.14.5", @@ -1503,9 +1506,9 @@ checksum = "49f1f14873335454500d59611f1cf4a4b0f786f9ac11f4312a78e4cf2566695b" [[package]] name = "js-sys" -version = "0.3.69" +version = "0.3.70" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "29c15563dc2726973df627357ce0c9ddddbea194836909d655df6a75d2cf296d" +checksum = "1868808506b929d7b0cfa8f75951347aa71bb21144b7791bae35d9bccfcfe37a" dependencies = [ "wasm-bindgen", ] @@ -1518,9 +1521,9 @@ checksum = "bbd2bcb4c963f2ddae06a2efc7e9f3591312473c50c6685e1f298068316e66fe" [[package]] name = "libc" -version = "0.2.155" +version = "0.2.158" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "97b3888a4aecf77e811145cadf6eef5901f4782c53886191b2f693f24761847c" +checksum = "d8adc4bb1803a324070e64a98ae98f38934d91957a99cfb3a43dcbc01bc56439" [[package]] name = "libmimalloc-sys" @@ -1532,6 +1535,17 @@ dependencies = [ "libc", ] +[[package]] +name = "libredox" +version = "0.1.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c0ff37bd590ca25063e35af745c343cb7a0271906fb7b37e4813e8f79f00268d" +dependencies = [ + "bitflags", + "libc", + "redox_syscall", +] + [[package]] name = "linux-raw-sys" version = "0.4.14" @@ -1655,11 +1669,20 @@ dependencies = [ "adler", ] +[[package]] +name = "miniz_oxide" +version = "0.8.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e2d80299ef12ff69b16a84bb182e3b9df68b5a91574d3d4fa6e41b65deec4df1" +dependencies = [ + "adler2", +] + [[package]] name = "mio" -version = "1.0.1" +version = "1.0.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "4569e456d394deccd22ce1c1913e6ea0e54519f577285001215d33557431afe4" +checksum = "80e04d1dcff3aae0704555fe5fee3bcfaf3d1fdf8a7e521d5b9d2b42acb52cec" dependencies = [ "hermit-abi", "libc", @@ -1749,7 +1772,7 @@ version = "0.5.1" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -1786,7 +1809,7 @@ version = "0.4.0" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -1921,7 +1944,7 @@ version = "0.5.1" dependencies = [ "async-lock", "async-trait", - "bitflags 2.6.0", + "bitflags", "blake3", "bytes", "console-subscriber", @@ -2037,9 +2060,9 @@ dependencies = [ [[package]] name = "object" -version = "0.36.3" +version = "0.36.4" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "27b64972346851a39438c60b341ebc01bba47464ae329e55cf343eb93964efd9" +checksum = "084f1a5821ac4c651660a94a7153d27ac9d8a53736203f58b31945ded098070a" dependencies = [ "memchr", ] @@ -2146,7 +2169,7 @@ checksum = "1e401f977ab385c9e4e3ab30627d6f26d00e2c73eef317493c4ec6d468726cf8" dependencies = [ "cfg-if", "libc", - "redox_syscall 0.5.3", + "redox_syscall", "smallvec", "windows-targets", ] @@ -2188,7 +2211,7 @@ dependencies = [ "pest_meta", "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -2209,7 +2232,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "b4c5cc86750666a3ed20bdaf5ca2a0344f9c67674cae0515bec2da16fbaa47db" dependencies = [ "fixedbitset", - "indexmap 2.3.0", + "indexmap 2.5.0", ] [[package]] @@ -2229,7 +2252,7 @@ checksum = "2f38a4412a78282e09a2cf38d195ea5420d15ba0602cb375210efbc877243965" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -2271,12 +2294,12 @@ dependencies = [ [[package]] name = "prettyplease" -version = "0.2.20" +version = "0.2.22" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5f12335488a2f3b0a83b14edad48dca9879ce89b2edd10e80237e4e852dd645e" +checksum = "479cf940fbbb3426c32c5d5176f62ad57549a0bb84773423ba8be9d089f5faba" dependencies = [ "proc-macro2", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -2329,9 +2352,9 @@ dependencies = [ [[package]] name = "prost" -version = "0.13.1" +version = "0.13.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "e13db3d3fde688c61e2446b4d843bc27a7e8af269a69440c0308021dc92333cc" +checksum = "3b2ecbe40f08db5c006b5764a2645f7f3f141ce756412ac9e1dd6087e6d32995" dependencies = [ "bytes", "prost-derive", @@ -2339,9 +2362,9 @@ dependencies = [ [[package]] name = "prost-build" -version = "0.13.1" +version = "0.13.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5bb182580f71dd070f88d01ce3de9f4da5021db7115d2e1c3605a754153b77c1" +checksum = "f8650aabb6c35b860610e9cff5dc1af886c9e25073b7b1712a68972af4281302" dependencies = [ "bytes", "heck", @@ -2354,28 +2377,28 @@ dependencies = [ "prost", "prost-types", "regex", - "syn 2.0.72", + "syn 2.0.77", "tempfile", ] [[package]] name = "prost-derive" -version = "0.13.1" +version = "0.13.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "18bec9b0adc4eba778b33684b7ba3e7137789434769ee3ce3930463ef904cfca" +checksum = "acf0c195eebb4af52c752bec4f52f645da98b6e92077a04110c7f349477ae5ac" dependencies = [ "anyhow", "itertools", "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] name = "prost-types" -version = "0.13.1" +version = "0.13.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "cee5168b05f49d4b0ca581206eb14a7b22fafd963efe729ac48eb03266e25cc2" +checksum = "60caa6738c7369b940c3d49246a8d1749323674c65cb13010134f5c9bad5b519" dependencies = [ "prost", ] @@ -2388,9 +2411,9 @@ checksum = "106dd99e98437432fed6519dedecfade6a06a73bb7b2a1e019fdd2bee5778d94" [[package]] name = "quote" -version = "1.0.36" +version = "1.0.37" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "0fa76aaf39101c457836aec0ce2316dbdc3ab723cdda1c6bd4e6ad4208acaca7" +checksum = "b5b9d34b8991d19d98081b46eacdd8eb58c6f2b201139f7c5f643cc155a633af" dependencies = [ "proc-macro2", ] @@ -2439,22 +2462,13 @@ dependencies = [ "nom", ] -[[package]] -name = "redox_syscall" -version = "0.4.1" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "4722d768eff46b75989dd134e5c353f0d6296e5aaa3132e776cbdb56be7731aa" -dependencies = [ - "bitflags 1.3.2", -] - [[package]] name = "redox_syscall" version = "0.5.3" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "2a908a6e00f1fdd0dfd9c0eb08ce85126f6d8bbda50017e74bc4a4b7d4a926a4" dependencies = [ - "bitflags 2.6.0", + "bitflags", ] [[package]] @@ -2539,9 +2553,9 @@ dependencies = [ [[package]] name = "rust_decimal" -version = "1.35.0" +version = "1.36.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "1790d1c4c0ca81211399e0e0af16333276f375209e71a37b67698a373db5b47a" +checksum = "b082d80e3e3cc52b2ed634388d436fe1f4de6af5786cc2de9ba9737527bdf555" dependencies = [ "arrayvec", "num-traits", @@ -2555,20 +2569,20 @@ checksum = "719b953e2095829ee67db738b3bfa9fa368c94900df327b3f07fe6e794d2fe1f" [[package]] name = "rustc_version" -version = "0.4.0" +version = "0.4.1" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "bfa0f585226d2e68097d4f95d113b15b83a82e819ab25717ec0590d9584ef366" +checksum = "cfcb3a22ef46e85b45de6ee7e79d063319ebb6594faafcf1c225ea92ab6e9b92" dependencies = [ "semver", ] [[package]] name = "rustix" -version = "0.38.34" +version = "0.38.35" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "70dc5ec042f7a43c4a73241207cecc9873a06d45debb38b329f8541d85c2730f" +checksum = "a85d50532239da68e9addb745ba38ff4612a242c1c7ceea689c4bc7c2f43c36f" dependencies = [ - "bitflags 2.6.0", + "bitflags", "errno", "libc", "linux-raw-sys", @@ -2595,7 +2609,7 @@ checksum = "bf4ef73721ac7bcd79b2b315da7779d8fc09718c6b3d2d1b2d94850eb8c18432" dependencies = [ "ring", "rustls-pki-types", - "rustls-webpki 0.102.6", + "rustls-webpki 0.102.7", "subtle", "zeroize", ] @@ -2610,7 +2624,7 @@ dependencies = [ "once_cell", "ring", "rustls-pki-types", - "rustls-webpki 0.102.6", + "rustls-webpki 0.102.7", "subtle", "zeroize", ] @@ -2629,9 +2643,9 @@ dependencies = [ [[package]] name = "rustls-native-certs" -version = "0.7.1" +version = "0.7.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a88d6d420651b496bdd98684116959239430022a115c1240e6c3993be0b15fba" +checksum = "e5bfb394eeed242e909609f56089eecfe5fda225042e8b171791b9c95f5931e5" dependencies = [ "openssl-probe", "rustls-pemfile 2.1.3", @@ -2677,9 +2691,9 @@ dependencies = [ [[package]] name = "rustls-webpki" -version = "0.102.6" +version = "0.102.7" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "8e6b52d4fda176fd835fdc55a835d4a89b8499cad995885a21149d5ad62f852e" +checksum = "84678086bd54edf2b415183ed7a94d0efb049f1b646a33e22a36f3794be6ae56" dependencies = [ "ring", "rustls-pki-types", @@ -2700,9 +2714,9 @@ checksum = "f3cb5ba0dc43242ce17de99c180e96db90b235b8a9fdc9543c96d2209116bd9f" [[package]] name = "scc" -version = "2.1.9" +version = "2.1.16" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "06ff467073ddaff34c3a39e5b454f25dd982484a26fff50254ca793c56a1b714" +checksum = "aeb7ac86243095b70a7920639507b71d51a63390d1ba26c4f60a552fbb914a37" dependencies = [ "sdd", ] @@ -2734,9 +2748,9 @@ dependencies = [ [[package]] name = "sdd" -version = "2.1.0" +version = "3.0.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "177258b64c0faaa9ffd3c65cd3262c2bc7e2588dbbd9c1641d0346145c1bbda8" +checksum = "0495e4577c672de8254beb68d01a9b62d0e8a13c099edecdbedccce3223cd29f" [[package]] name = "security-framework" @@ -2744,7 +2758,7 @@ version = "2.11.1" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "897b2245f0b511c87893af39b033e5ca9cce68824c4d7e7630b5a1d339658d02" dependencies = [ - "bitflags 2.6.0", + "bitflags", "core-foundation", "core-foundation-sys", "libc", @@ -2769,31 +2783,31 @@ checksum = "61697e0a1c7e512e84a621326239844a24d8207b4669b41bc18b32ea5cbf988b" [[package]] name = "serde" -version = "1.0.205" +version = "1.0.209" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "e33aedb1a7135da52b7c21791455563facbbcc43d0f0f66165b42c21b3dfb150" +checksum = "99fce0ffe7310761ca6bf9faf5115afbc19688edd00171d81b1bb1b116c63e09" dependencies = [ "serde_derive", ] [[package]] name = "serde_derive" -version = "1.0.205" +version = "1.0.209" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "692d6f5ac90220161d6774db30c662202721e64aed9058d2c394f451261420c1" +checksum = "a5831b979fd7b5439637af1752d535ff49f4860c0f341d1baeb6faf0f4242170" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] name = "serde_json" -version = "1.0.122" +version = "1.0.127" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "784b6203951c57ff748476b126ccb5e8e2959a5c19e5c617ab1956be3dbc68da" +checksum = "8043c06d9f82bd7271361ed64f415fe5e12a77fdb52e573e7f06a516dea329ad" dependencies = [ - "indexmap 2.3.0", + "indexmap 2.5.0", "itoa", "memchr", "ryu", @@ -2832,7 +2846,7 @@ checksum = "82fe9db325bcef1fbcde82e078a5cc4efdf787e96b3b9cf45b50b529f2083d67" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -2949,9 +2963,9 @@ dependencies = [ [[package]] name = "syn" -version = "2.0.72" +version = "2.0.77" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "dc4b9b9bf2add8093d3f2c0204471e951b2285580335de42f9d2534f3ae7a8af" +checksum = "9f35bcdf61fd8e7be6caf75f429fdca8beb3ed76584befb503b1569faee373ed" dependencies = [ "proc-macro2", "quote", @@ -3000,7 +3014,7 @@ checksum = "a4558b58466b9ad7ca0f102865eccc95938dca1a74a856f2b57b6629050da261" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -3060,9 +3074,9 @@ checksum = "1f3ccbac311fea05f86f61904b462b55fb3df8837a366dfc601a0161d0532f20" [[package]] name = "tokio" -version = "1.39.2" +version = "1.40.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "daa4fb1bc778bd6f04cbfc4bb2d06a7396a8f299dc33ea1900cedaa316f467b1" +checksum = "e2b070231665d27ad9ec9b8df639893f46727666c6767db40317fbe920a5d998" dependencies = [ "backtrace", "bytes", @@ -3084,7 +3098,7 @@ checksum = "693d596312e88961bc67d7f1f97af8a70227d9f90c31bba5806eec004978d752" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -3145,9 +3159,9 @@ dependencies = [ [[package]] name = "tonic" -version = "0.12.1" +version = "0.12.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "38659f4a91aba8598d27821589f5db7dddd94601e7a01b1e485a50e5484c7401" +checksum = "c6f6ba989e4b2c58ae83d862d3a3e27690b6e3ae630d0deb59f3697f32aa88ad" dependencies = [ "async-stream", "async-trait", @@ -3155,7 +3169,7 @@ dependencies = [ "base64 0.22.1", "bytes", "flate2", - "h2 0.4.5", + "h2 0.4.6", "http 1.1.0", "http-body 1.0.1", "http-body-util", @@ -3178,15 +3192,15 @@ dependencies = [ [[package]] name = "tonic-build" -version = "0.12.1" +version = "0.12.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "568392c5a2bd0020723e3f387891176aabafe36fd9fcd074ad309dfa0c8eb964" +checksum = "fe4ee8877250136bd7e3d2331632810a4df4ea5e004656990d8d66d2f5ee8a67" dependencies = [ "prettyplease", "proc-macro2", "prost-build", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -3211,15 +3225,15 @@ dependencies = [ [[package]] name = "tower-layer" -version = "0.3.2" +version = "0.3.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c20c8dbed6283a09604c3e69b4b7eeb54e298b8a600d4d5ecb5ad39de609f1d0" +checksum = "121c2a6cda46980bb0fcd1647ffaf6cd3fc79a013de288782836f6df9c48780e" [[package]] name = "tower-service" -version = "0.3.2" +version = "0.3.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "b6bc1c9ce2b5135ac7f93c72918fc37feb872bdc6a5533a8b85eb4b86bfdae52" +checksum = "8df9b6e13f2d32c91b9bd719c00d1958837bc7dec474d94952798cc8e69eeec3" [[package]] name = "tracing" @@ -3240,7 +3254,7 @@ checksum = "34704c8d6ebcbc939824180af020566b01a7c01f80641264eba0999f6c2b6be7" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] @@ -3414,34 +3428,35 @@ checksum = "9c8d87e72b64a3b4db28d11ce29237c246188f4f51057d65a7eab63b7987e423" [[package]] name = "wasm-bindgen" -version = "0.2.92" +version = "0.2.93" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "4be2531df63900aeb2bca0daaaddec08491ee64ceecbee5076636a3b026795a8" +checksum = "a82edfc16a6c469f5f44dc7b571814045d60404b55a0ee849f9bcfa2e63dd9b5" dependencies = [ "cfg-if", + "once_cell", "wasm-bindgen-macro", ] [[package]] name = "wasm-bindgen-backend" -version = "0.2.92" +version = "0.2.93" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "614d787b966d3989fa7bb98a654e369c762374fd3213d212cfc0251257e747da" +checksum = "9de396da306523044d3302746f1208fa71d7532227f15e347e2d93e4145dd77b" dependencies = [ "bumpalo", "log", "once_cell", "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", "wasm-bindgen-shared", ] [[package]] name = "wasm-bindgen-macro" -version = "0.2.92" +version = "0.2.93" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a1f8823de937b71b9460c0c34e25f3da88250760bec0ebac694b49997550d726" +checksum = "585c4c91a46b072c92e908d99cb1dcdf95c5218eeb6f3bf1efa991ee7a68cccf" dependencies = [ "quote", "wasm-bindgen-macro-support", @@ -3449,22 +3464,22 @@ dependencies = [ [[package]] name = "wasm-bindgen-macro-support" -version = "0.2.92" +version = "0.2.93" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "e94f17b526d0a461a191c78ea52bbce64071ed5c04c9ffe424dcb38f74171bb7" +checksum = "afc340c74d9005395cf9dd098506f7f44e38f2b4a21c6aaacf9a105ea5e1e836" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", "wasm-bindgen-backend", "wasm-bindgen-shared", ] [[package]] name = "wasm-bindgen-shared" -version = "0.2.92" +version = "0.2.93" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "af190c94f2773fdb3729c55b007a722abb5384da03bc0986df4c289bf5567e96" +checksum = "c62a0a307cb4a311d3a07867860911ca130c3494e8c2719593806c08bc5d0484" [[package]] name = "webpki-roots" @@ -3606,7 +3621,7 @@ checksum = "fa4f8080344d4671fb4e831a13ad1e68092748387dfc4f55e356242fae12ce3e" dependencies = [ "proc-macro2", "quote", - "syn 2.0.72", + "syn 2.0.77", ] [[package]] diff --git a/nativelink-proto/genproto/build.bazel.remote.execution.v2.pb.rs b/nativelink-proto/genproto/build.bazel.remote.execution.v2.pb.rs index 1b8f8f211..3054f22ca 100644 --- a/nativelink-proto/genproto/build.bazel.remote.execution.v2.pb.rs +++ b/nativelink-proto/genproto/build.bazel.remote.execution.v2.pb.rs @@ -34,7 +34,6 @@ /// to understand the caching behaviour. Ideally, all `Action`s will be /// reproducible so that serving a result from cache is always desirable and /// correct. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Action { /// The digest of the [Command][build.bazel.remote.execution.v2.Command] @@ -107,7 +106,6 @@ pub struct Action { /// Except as otherwise required, the environment (such as which system /// libraries or binaries are available, and what filesystems are mounted where) /// is defined by and specific to the implementation of the remote execution API. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Command { /// The arguments to the command. @@ -262,7 +260,6 @@ pub struct Command { pub mod command { /// An `EnvironmentVariable` is one variable to set in the running program's /// environment. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct EnvironmentVariable { /// The variable name. @@ -278,7 +275,6 @@ pub mod command { /// [Action][build.bazel.remote.execution.v2.Action]'s execution /// environment. A `Platform` is represented as a series of key-value pairs /// representing the properties that are required of the platform. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Platform { /// The properties that make up this platform. In order to ensure that @@ -312,7 +308,6 @@ pub mod platform { /// is implicitly part of the action digest, so even tiny changes in the names /// or values (like changing case) may result in different action cache /// entries. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Property { /// The property name. @@ -399,7 +394,6 @@ pub mod platform { /// ] /// } /// ``` -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Directory { /// The files in the directory. @@ -419,7 +413,6 @@ pub struct Directory { /// [SymlinkNodes][build.bazel.remote.execution.v2.SymlinkNode]. The server is /// responsible for specifying the property `name`s that it accepts. If /// permitted by the server, the same `name` may occur multiple times. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct NodeProperty { /// The property name. @@ -434,7 +427,6 @@ pub struct NodeProperty { /// [SymlinkNodes][build.bazel.remote.execution.v2.SymlinkNode]. The server is /// responsible for specifying the properties that it accepts. /// -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct NodeProperties { /// A list of string-based @@ -449,7 +441,6 @@ pub struct NodeProperties { pub unix_mode: ::core::option::Option, } /// A `FileNode` represents a single file and associated metadata. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct FileNode { /// The name of the file. @@ -467,7 +458,6 @@ pub struct FileNode { /// A `DirectoryNode` represents a child of a /// [Directory][build.bazel.remote.execution.v2.Directory] which is itself /// a `Directory` and its associated metadata. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct DirectoryNode { /// The name of the directory. @@ -481,7 +471,6 @@ pub struct DirectoryNode { pub digest: ::core::option::Option, } /// A `SymlinkNode` represents a symbolic link. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct SymlinkNode { /// The name of the symlink. @@ -532,7 +521,6 @@ pub struct SymlinkNode { /// Most protocol buffer implementations will always follow these rules when /// serializing, but care should be taken to avoid shortcuts. For instance, /// concatenating two messages to merge them may produce duplicate fields. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Digest { /// The hash. In the case of SHA-256, it will always be a lowercase hex string @@ -544,7 +532,6 @@ pub struct Digest { pub size_bytes: i64, } /// ExecutedActionMetadata contains details about a completed execution. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ExecutedActionMetadata { /// The name of the worker which ran the execution. @@ -613,7 +600,6 @@ pub struct ExecutedActionMetadata { /// `ActionResult.execution_metadata.Worker`) have a non-default value, to /// ensure that the serialized value is non-empty, which can then be used /// as a basic data sanity check. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ActionResult { /// The output files of the action. For each output file requested in the @@ -790,7 +776,6 @@ pub struct ActionResult { /// [FileNode][build.bazel.remote.execution.v2.FileNode], but it is used as an /// output in an `ActionResult`. It allows a full file path rather than /// only a name. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct OutputFile { /// The full path of the file relative to the working directory, including the @@ -818,7 +803,6 @@ pub struct OutputFile { /// A `Tree` contains all the /// [Directory][build.bazel.remote.execution.v2.Directory] protos in a /// single directory Merkle tree, compressed into one message. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Tree { /// The root directory in the tree. @@ -836,7 +820,6 @@ pub struct Tree { } /// An `OutputDirectory` is the output in an `ActionResult` corresponding to a /// directory's full contents rather than a single file. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct OutputDirectory { /// The full path of the directory relative to the working directory. The path @@ -893,7 +876,6 @@ pub struct OutputDirectory { /// output in an `ActionResult`. /// /// `OutputSymlink` is binary-compatible with `SymlinkNode`. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct OutputSymlink { /// The full path of the symlink relative to the working directory, including the @@ -912,7 +894,6 @@ pub struct OutputSymlink { pub node_properties: ::core::option::Option, } /// An `ExecutionPolicy` can be used to control the scheduling of the action. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct ExecutionPolicy { /// The priority (relative importance) of this action. Generally, a lower value @@ -929,7 +910,6 @@ pub struct ExecutionPolicy { } /// A `ResultsCachePolicy` is used for fine-grained control over how action /// outputs are stored in the CAS and Action Cache. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct ResultsCachePolicy { /// The priority (relative importance) of this content in the overall cache. @@ -945,7 +925,6 @@ pub struct ResultsCachePolicy { } /// A request message for /// [Execution.Execute][build.bazel.remote.execution.v2.Execution.Execute]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ExecuteRequest { /// The instance of the execution system to operate against. A server may @@ -994,7 +973,6 @@ pub struct ExecuteRequest { pub digest_function: i32, } /// A `LogFile` is a log stored in the CAS. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct LogFile { /// The digest of the log contents. @@ -1013,7 +991,6 @@ pub struct LogFile { /// which will be contained in the [response /// field][google.longrunning.Operation.response] of the /// [Operation][google.longrunning.Operation]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ExecuteResponse { /// The result of the action. @@ -1065,7 +1042,6 @@ pub struct ExecuteResponse { /// has reached the COMPLETED stage, it MUST set the [done /// field][google.longrunning.Operation.done] of the /// [Operation][google.longrunning.Operation] and terminate the stream. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct ExecutionStage {} /// Nested message and enum types in `ExecutionStage`. @@ -1126,7 +1102,6 @@ pub mod execution_stage { /// will be contained in the [metadata /// field][google.longrunning.Operation.response] of the /// [Operation][google.longrunning.Operation]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ExecuteOperationMetadata { /// The current stage of execution. @@ -1153,7 +1128,6 @@ pub struct ExecuteOperationMetadata { } /// A request message for /// [WaitExecution][build.bazel.remote.execution.v2.Execution.WaitExecution]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct WaitExecutionRequest { /// The name of the [Operation][google.longrunning.Operation] @@ -1163,7 +1137,6 @@ pub struct WaitExecutionRequest { } /// A request message for /// [ActionCache.GetActionResult][build.bazel.remote.execution.v2.ActionCache.GetActionResult]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GetActionResultRequest { /// The instance of the execution system to operate against. A server may @@ -1203,7 +1176,6 @@ pub struct GetActionResultRequest { } /// A request message for /// [ActionCache.UpdateActionResult][build.bazel.remote.execution.v2.ActionCache.UpdateActionResult]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct UpdateActionResultRequest { /// The instance of the execution system to operate against. A server may @@ -1238,7 +1210,6 @@ pub struct UpdateActionResultRequest { } /// A request message for /// [ContentAddressableStorage.FindMissingBlobs][build.bazel.remote.execution.v2.ContentAddressableStorage.FindMissingBlobs]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct FindMissingBlobsRequest { /// The instance of the execution system to operate against. A server may @@ -1264,7 +1235,6 @@ pub struct FindMissingBlobsRequest { } /// A response message for /// [ContentAddressableStorage.FindMissingBlobs][build.bazel.remote.execution.v2.ContentAddressableStorage.FindMissingBlobs]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct FindMissingBlobsResponse { /// A list of the blobs requested *not* present in the storage. @@ -1273,7 +1243,6 @@ pub struct FindMissingBlobsResponse { } /// A request message for /// [ContentAddressableStorage.BatchUpdateBlobs][build.bazel.remote.execution.v2.ContentAddressableStorage.BatchUpdateBlobs]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct BatchUpdateBlobsRequest { /// The instance of the execution system to operate against. A server may @@ -1300,7 +1269,6 @@ pub struct BatchUpdateBlobsRequest { /// Nested message and enum types in `BatchUpdateBlobsRequest`. pub mod batch_update_blobs_request { /// A request corresponding to a single blob that the client wants to upload. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Request { /// The digest of the blob. This MUST be the digest of `data`. All @@ -1320,7 +1288,6 @@ pub mod batch_update_blobs_request { } /// A response message for /// [ContentAddressableStorage.BatchUpdateBlobs][build.bazel.remote.execution.v2.ContentAddressableStorage.BatchUpdateBlobs]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct BatchUpdateBlobsResponse { /// The responses to the requests. @@ -1330,7 +1297,6 @@ pub struct BatchUpdateBlobsResponse { /// Nested message and enum types in `BatchUpdateBlobsResponse`. pub mod batch_update_blobs_response { /// A response corresponding to a single blob that the client tried to upload. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Response { /// The blob digest to which this response corresponds. @@ -1345,7 +1311,6 @@ pub mod batch_update_blobs_response { } /// A request message for /// [ContentAddressableStorage.BatchReadBlobs][build.bazel.remote.execution.v2.ContentAddressableStorage.BatchReadBlobs]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct BatchReadBlobsRequest { /// The instance of the execution system to operate against. A server may @@ -1375,7 +1340,6 @@ pub struct BatchReadBlobsRequest { } /// A response message for /// [ContentAddressableStorage.BatchReadBlobs][build.bazel.remote.execution.v2.ContentAddressableStorage.BatchReadBlobs]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct BatchReadBlobsResponse { /// The responses to the requests. @@ -1385,7 +1349,6 @@ pub struct BatchReadBlobsResponse { /// Nested message and enum types in `BatchReadBlobsResponse`. pub mod batch_read_blobs_response { /// A response corresponding to a single blob that the client tried to download. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Response { /// The digest to which this response corresponds. @@ -1407,7 +1370,6 @@ pub mod batch_read_blobs_response { } /// A request message for /// [ContentAddressableStorage.GetTree][build.bazel.remote.execution.v2.ContentAddressableStorage.GetTree]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GetTreeRequest { /// The instance of the execution system to operate against. A server may @@ -1448,7 +1410,6 @@ pub struct GetTreeRequest { } /// A response message for /// [ContentAddressableStorage.GetTree][build.bazel.remote.execution.v2.ContentAddressableStorage.GetTree]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GetTreeResponse { /// The directories descended from the requested root. @@ -1463,7 +1424,6 @@ pub struct GetTreeResponse { } /// A request message for /// [Capabilities.GetCapabilities][build.bazel.remote.execution.v2.Capabilities.GetCapabilities]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GetCapabilitiesRequest { /// The instance of the execution system to operate against. A server may @@ -1476,7 +1436,6 @@ pub struct GetCapabilitiesRequest { } /// A response message for /// [Capabilities.GetCapabilities][build.bazel.remote.execution.v2.Capabilities.GetCapabilities]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ServerCapabilities { /// Capabilities of the remote cache system. @@ -1499,7 +1458,6 @@ pub struct ServerCapabilities { } /// The digest function used for converting values into keys for CAS and Action /// Cache. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct DigestFunction {} /// Nested message and enum types in `DigestFunction`. @@ -1637,7 +1595,6 @@ pub mod digest_function { } } /// Describes the server/instance capabilities for updating the action cache. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct ActionCacheUpdateCapabilities { #[prost(bool, tag = "1")] @@ -1647,7 +1604,6 @@ pub struct ActionCacheUpdateCapabilities { /// [ResultsCachePolicy][build.bazel.remoteexecution.v2.ResultsCachePolicy] and /// [ExecutionPolicy][build.bazel.remoteexecution.v2.ResultsCachePolicy] /// Used for querying both cache and execution valid priority ranges. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct PriorityCapabilities { #[prost(message, repeated, tag = "1")] @@ -1656,7 +1612,6 @@ pub struct PriorityCapabilities { /// Nested message and enum types in `PriorityCapabilities`. pub mod priority_capabilities { /// Supported range of priorities, including boundaries. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct PriorityRange { /// The minimum numeric value for this priority range, which represents the @@ -1670,7 +1625,6 @@ pub mod priority_capabilities { } } /// Describes how the server treats absolute symlink targets. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct SymlinkAbsolutePathStrategy {} /// Nested message and enum types in `SymlinkAbsolutePathStrategy`. @@ -1723,7 +1677,6 @@ pub mod symlink_absolute_path_strategy { } } /// Compression formats which may be supported. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct Compressor {} /// Nested message and enum types in `Compressor`. @@ -1782,7 +1735,6 @@ pub mod compressor { } } /// Capabilities of the remote cache system. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct CacheCapabilities { /// All the digest functions supported by the remote cache. @@ -1821,7 +1773,6 @@ pub struct CacheCapabilities { pub supported_batch_update_compressors: ::prost::alloc::vec::Vec, } /// Capabilities of the remote execution system. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ExecutionCapabilities { /// Legacy field for indicating which digest function is supported by the @@ -1857,7 +1808,6 @@ pub struct ExecutionCapabilities { pub digest_functions: ::prost::alloc::vec::Vec, } /// Details for the tool used to call the API. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ToolDetails { /// Name of the tool, e.g. bazel. @@ -1880,7 +1830,6 @@ pub struct ToolDetails { /// Therefore, if the gRPC library is used to pass/retrieve this /// metadata, the user may ignore the base64 encoding and assume it is simply /// serialized as a binary message. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct RequestMetadata { /// The details for the tool invoking the requests. @@ -1935,8 +1884,8 @@ pub mod execution_client { where T: tonic::client::GrpcService, T::Error: Into, - T::ResponseBody: Body + Send + 'static, - ::Error: Into + Send, + T::ResponseBody: Body + std::marker::Send + 'static, + ::Error: Into + std::marker::Send, { pub fn new(inner: T) -> Self { let inner = tonic::client::Grpc::new(inner); @@ -1961,7 +1910,7 @@ pub mod execution_client { >, , - >>::Error: Into + Send + Sync, + >>::Error: Into + std::marker::Send + std::marker::Sync, { ExecutionClient::new(InterceptedService::new(inner, interceptor)) } @@ -2182,8 +2131,8 @@ pub mod action_cache_client { where T: tonic::client::GrpcService, T::Error: Into, - T::ResponseBody: Body + Send + 'static, - ::Error: Into + Send, + T::ResponseBody: Body + std::marker::Send + 'static, + ::Error: Into + std::marker::Send, { pub fn new(inner: T) -> Self { let inner = tonic::client::Grpc::new(inner); @@ -2208,7 +2157,7 @@ pub mod action_cache_client { >, , - >>::Error: Into + Send + Sync, + >>::Error: Into + std::marker::Send + std::marker::Sync, { ActionCacheClient::new(InterceptedService::new(inner, interceptor)) } @@ -2486,8 +2435,8 @@ pub mod content_addressable_storage_client { where T: tonic::client::GrpcService, T::Error: Into, - T::ResponseBody: Body + Send + 'static, - ::Error: Into + Send, + T::ResponseBody: Body + std::marker::Send + 'static, + ::Error: Into + std::marker::Send, { pub fn new(inner: T) -> Self { let inner = tonic::client::Grpc::new(inner); @@ -2512,7 +2461,7 @@ pub mod content_addressable_storage_client { >, , - >>::Error: Into + Send + Sync, + >>::Error: Into + std::marker::Send + std::marker::Sync, { ContentAddressableStorageClient::new( InterceptedService::new(inner, interceptor), @@ -2765,8 +2714,8 @@ pub mod capabilities_client { where T: tonic::client::GrpcService, T::Error: Into, - T::ResponseBody: Body + Send + 'static, - ::Error: Into + Send, + T::ResponseBody: Body + std::marker::Send + 'static, + ::Error: Into + std::marker::Send, { pub fn new(inner: T) -> Self { let inner = tonic::client::Grpc::new(inner); @@ -2791,7 +2740,7 @@ pub mod capabilities_client { >, , - >>::Error: Into + Send + Sync, + >>::Error: Into + std::marker::Send + std::marker::Sync, { CapabilitiesClient::new(InterceptedService::new(inner, interceptor)) } @@ -2874,7 +2823,7 @@ pub mod execution_server { use tonic::codegen::*; /// Generated trait containing gRPC methods that should be implemented for use with ExecutionServer. #[async_trait] - pub trait Execution: Send + Sync + 'static { + pub trait Execution: std::marker::Send + std::marker::Sync + 'static { /// Server streaming response type for the Execute method. type ExecuteStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< @@ -2882,7 +2831,7 @@ pub mod execution_server { tonic::Status, >, > - + Send + + std::marker::Send + 'static; /// Execute an action remotely. /// @@ -2968,7 +2917,7 @@ pub mod execution_server { tonic::Status, >, > - + Send + + std::marker::Send + 'static; /// Wait for an execution operation to complete. When the client initially /// makes the request, the server immediately responds with the current status @@ -3001,14 +2950,14 @@ pub mod execution_server { /// information about when the client should retry the request; clients SHOULD /// respect the information provided. #[derive(Debug)] - pub struct ExecutionServer { + pub struct ExecutionServer { inner: Arc, accept_compression_encodings: EnabledCompressionEncodings, send_compression_encodings: EnabledCompressionEncodings, max_decoding_message_size: Option, max_encoding_message_size: Option, } - impl ExecutionServer { + impl ExecutionServer { pub fn new(inner: T) -> Self { Self::from_arc(Arc::new(inner)) } @@ -3062,8 +3011,8 @@ pub mod execution_server { impl tonic::codegen::Service> for ExecutionServer where T: Execution, - B: Body + Send + 'static, - B::Error: Into + Send + 'static, + B: Body + std::marker::Send + 'static, + B::Error: Into + std::marker::Send + 'static, { type Response = http::Response; type Error = std::convert::Infallible; @@ -3186,7 +3135,7 @@ pub mod execution_server { } } } - impl Clone for ExecutionServer { + impl Clone for ExecutionServer { fn clone(&self) -> Self { let inner = self.inner.clone(); Self { @@ -3198,8 +3147,10 @@ pub mod execution_server { } } } - impl tonic::server::NamedService for ExecutionServer { - const NAME: &'static str = "build.bazel.remote.execution.v2.Execution"; + /// Generated gRPC service name + pub const SERVICE_NAME: &str = "build.bazel.remote.execution.v2.Execution"; + impl tonic::server::NamedService for ExecutionServer { + const NAME: &'static str = SERVICE_NAME; } } /// Generated server implementations. @@ -3208,7 +3159,7 @@ pub mod action_cache_server { use tonic::codegen::*; /// Generated trait containing gRPC methods that should be implemented for use with ActionCacheServer. #[async_trait] - pub trait ActionCache: Send + Sync + 'static { + pub trait ActionCache: std::marker::Send + std::marker::Sync + 'static { /// Retrieve a cached execution result. /// /// Implementations SHOULD ensure that any blobs referenced from the @@ -3266,14 +3217,14 @@ pub mod action_cache_server { /// information about when the client should retry the request; clients SHOULD /// respect the information provided. #[derive(Debug)] - pub struct ActionCacheServer { + pub struct ActionCacheServer { inner: Arc, accept_compression_encodings: EnabledCompressionEncodings, send_compression_encodings: EnabledCompressionEncodings, max_decoding_message_size: Option, max_encoding_message_size: Option, } - impl ActionCacheServer { + impl ActionCacheServer { pub fn new(inner: T) -> Self { Self::from_arc(Arc::new(inner)) } @@ -3327,8 +3278,8 @@ pub mod action_cache_server { impl tonic::codegen::Service> for ActionCacheServer where T: ActionCache, - B: Body + Send + 'static, - B::Error: Into + Send + 'static, + B: Body + std::marker::Send + 'static, + B::Error: Into + std::marker::Send + 'static, { type Response = http::Response; type Error = std::convert::Infallible; @@ -3450,7 +3401,7 @@ pub mod action_cache_server { } } } - impl Clone for ActionCacheServer { + impl Clone for ActionCacheServer { fn clone(&self) -> Self { let inner = self.inner.clone(); Self { @@ -3462,8 +3413,10 @@ pub mod action_cache_server { } } } - impl tonic::server::NamedService for ActionCacheServer { - const NAME: &'static str = "build.bazel.remote.execution.v2.ActionCache"; + /// Generated gRPC service name + pub const SERVICE_NAME: &str = "build.bazel.remote.execution.v2.ActionCache"; + impl tonic::server::NamedService for ActionCacheServer { + const NAME: &'static str = SERVICE_NAME; } } /// Generated server implementations. @@ -3472,7 +3425,7 @@ pub mod content_addressable_storage_server { use tonic::codegen::*; /// Generated trait containing gRPC methods that should be implemented for use with ContentAddressableStorageServer. #[async_trait] - pub trait ContentAddressableStorage: Send + Sync + 'static { + pub trait ContentAddressableStorage: std::marker::Send + std::marker::Sync + 'static { /// Determine if blobs are present in the CAS. /// /// Clients can use this API before uploading blobs to determine which ones are @@ -3550,7 +3503,7 @@ pub mod content_addressable_storage_server { type GetTreeStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result, > - + Send + + std::marker::Send + 'static; /// Fetch the entire directory tree rooted at a node. /// @@ -3724,14 +3677,14 @@ pub mod content_addressable_storage_server { /// information about when the client should retry the request; clients SHOULD /// respect the information provided. #[derive(Debug)] - pub struct ContentAddressableStorageServer { + pub struct ContentAddressableStorageServer { inner: Arc, accept_compression_encodings: EnabledCompressionEncodings, send_compression_encodings: EnabledCompressionEncodings, max_decoding_message_size: Option, max_encoding_message_size: Option, } - impl ContentAddressableStorageServer { + impl ContentAddressableStorageServer { pub fn new(inner: T) -> Self { Self::from_arc(Arc::new(inner)) } @@ -3786,8 +3739,8 @@ pub mod content_addressable_storage_server { for ContentAddressableStorageServer where T: ContentAddressableStorage, - B: Body + Send + 'static, - B::Error: Into + Send + 'static, + B: Body + std::marker::Send + 'static, + B::Error: Into + std::marker::Send + 'static, { type Response = http::Response; type Error = std::convert::Infallible; @@ -4012,7 +3965,7 @@ pub mod content_addressable_storage_server { } } } - impl Clone for ContentAddressableStorageServer { + impl Clone for ContentAddressableStorageServer { fn clone(&self) -> Self { let inner = self.inner.clone(); Self { @@ -4024,9 +3977,10 @@ pub mod content_addressable_storage_server { } } } - impl tonic::server::NamedService - for ContentAddressableStorageServer { - const NAME: &'static str = "build.bazel.remote.execution.v2.ContentAddressableStorage"; + /// Generated gRPC service name + pub const SERVICE_NAME: &str = "build.bazel.remote.execution.v2.ContentAddressableStorage"; + impl tonic::server::NamedService for ContentAddressableStorageServer { + const NAME: &'static str = SERVICE_NAME; } } /// Generated server implementations. @@ -4035,7 +3989,7 @@ pub mod capabilities_server { use tonic::codegen::*; /// Generated trait containing gRPC methods that should be implemented for use with CapabilitiesServer. #[async_trait] - pub trait Capabilities: Send + Sync + 'static { + pub trait Capabilities: std::marker::Send + std::marker::Sync + 'static { /// GetCapabilities returns the server capabilities configuration of the /// remote endpoint. /// Only the capabilities of the services supported by the endpoint will @@ -4061,14 +4015,14 @@ pub mod capabilities_server { /// The query may include a particular `instance_name`, in which case the values /// returned will pertain to that instance. #[derive(Debug)] - pub struct CapabilitiesServer { + pub struct CapabilitiesServer { inner: Arc, accept_compression_encodings: EnabledCompressionEncodings, send_compression_encodings: EnabledCompressionEncodings, max_decoding_message_size: Option, max_encoding_message_size: Option, } - impl CapabilitiesServer { + impl CapabilitiesServer { pub fn new(inner: T) -> Self { Self::from_arc(Arc::new(inner)) } @@ -4122,8 +4076,8 @@ pub mod capabilities_server { impl tonic::codegen::Service> for CapabilitiesServer where T: Capabilities, - B: Body + Send + 'static, - B::Error: Into + Send + 'static, + B: Body + std::marker::Send + 'static, + B::Error: Into + std::marker::Send + 'static, { type Response = http::Response; type Error = std::convert::Infallible; @@ -4199,7 +4153,7 @@ pub mod capabilities_server { } } } - impl Clone for CapabilitiesServer { + impl Clone for CapabilitiesServer { fn clone(&self) -> Self { let inner = self.inner.clone(); Self { @@ -4211,7 +4165,9 @@ pub mod capabilities_server { } } } - impl tonic::server::NamedService for CapabilitiesServer { - const NAME: &'static str = "build.bazel.remote.execution.v2.Capabilities"; + /// Generated gRPC service name + pub const SERVICE_NAME: &str = "build.bazel.remote.execution.v2.Capabilities"; + impl tonic::server::NamedService for CapabilitiesServer { + const NAME: &'static str = SERVICE_NAME; } } diff --git a/nativelink-proto/genproto/build.bazel.semver.pb.rs b/nativelink-proto/genproto/build.bazel.semver.pb.rs index 732c9e991..a4e390231 100644 --- a/nativelink-proto/genproto/build.bazel.semver.pb.rs +++ b/nativelink-proto/genproto/build.bazel.semver.pb.rs @@ -14,7 +14,6 @@ // This file is @generated by prost-build. /// The full version of a given tool. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct SemVer { /// The major version, e.g 10 for 10.2.3. diff --git a/nativelink-proto/genproto/com.github.trace_machina.nativelink.remote_execution.pb.rs b/nativelink-proto/genproto/com.github.trace_machina.nativelink.remote_execution.pb.rs index f7b777d27..964a01eca 100644 --- a/nativelink-proto/genproto/com.github.trace_machina.nativelink.remote_execution.pb.rs +++ b/nativelink-proto/genproto/com.github.trace_machina.nativelink.remote_execution.pb.rs @@ -14,7 +14,6 @@ // This file is @generated by prost-build. /// / Request object for keep alive requests. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct KeepAliveRequest { /// / ID of the worker making the request. @@ -22,7 +21,6 @@ pub struct KeepAliveRequest { pub worker_id: ::prost::alloc::string::String, } /// / Request object for going away requests. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GoingAwayRequest { /// / ID of the worker making the request. @@ -31,7 +29,6 @@ pub struct GoingAwayRequest { } /// / Represents the initial request sent to the scheduler informing the /// / scheduler about this worker's capabilities. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct SupportedProperties { /// / The list of properties this worker can support. The exact @@ -50,7 +47,6 @@ pub struct SupportedProperties { >, } /// / The result of an ExecutionRequest. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ExecuteResult { /// / ID of the worker making the request. @@ -70,7 +66,6 @@ pub struct ExecuteResult { /// Nested message and enum types in `ExecuteResult`. pub mod execute_result { /// / The actual response data. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { /// / Result of the execution. See `build.bazel.remote.execution.v2.ExecuteResponse` @@ -87,7 +82,6 @@ pub mod execute_result { } } /// / Result sent back from the server when a node connects. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ConnectionResult { /// / The internal ID given to the newly connected node. @@ -95,7 +89,6 @@ pub struct ConnectionResult { pub worker_id: ::prost::alloc::string::String, } /// / Request to kill a running operation sent from the scheduler to a worker. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct KillOperationRequest { /// / The the operation id for the operation to be killed. @@ -103,7 +96,6 @@ pub struct KillOperationRequest { pub operation_id: ::prost::alloc::string::String, } /// / Communication from the scheduler to the worker. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct UpdateForWorker { #[prost(oneof = "update_for_worker::Update", tags = "1, 2, 3, 4, 5")] @@ -111,7 +103,6 @@ pub struct UpdateForWorker { } /// Nested message and enum types in `UpdateForWorker`. pub mod update_for_worker { - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Update { /// / This will be sent only as the first item in the stream after the node @@ -138,7 +129,6 @@ pub mod update_for_worker { KillOperationRequest(super::KillOperationRequest), } } -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct StartExecute { /// / The action information used to execute job. @@ -158,7 +148,6 @@ pub struct StartExecute { /// / by programs like bb_browswer to inspect the history of a build. /// / Note: Ensure this is always compatible with: /// / -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct HistoricalExecuteResponse { #[prost(message, optional, tag = "1")] @@ -190,8 +179,8 @@ pub mod worker_api_client { where T: tonic::client::GrpcService, T::Error: Into, - T::ResponseBody: Body + Send + 'static, - ::Error: Into + Send, + T::ResponseBody: Body + std::marker::Send + 'static, + ::Error: Into + std::marker::Send, { pub fn new(inner: T) -> Self { let inner = tonic::client::Grpc::new(inner); @@ -216,7 +205,7 @@ pub mod worker_api_client { >, , - >>::Error: Into + Send + Sync, + >>::Error: Into + std::marker::Send + std::marker::Sync, { WorkerApiClient::new(InterceptedService::new(inner, interceptor)) } @@ -391,12 +380,12 @@ pub mod worker_api_server { use tonic::codegen::*; /// Generated trait containing gRPC methods that should be implemented for use with WorkerApiServer. #[async_trait] - pub trait WorkerApi: Send + Sync + 'static { + pub trait WorkerApi: std::marker::Send + std::marker::Sync + 'static { /// Server streaming response type for the ConnectWorker method. type ConnectWorkerStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result, > - + Send + + std::marker::Send + 'static; /// / Registers this worker and informs the scheduler what properties /// / this worker supports. The response must be listened on the client @@ -447,14 +436,14 @@ pub mod worker_api_server { /// / command to the scheduler. The scheduler will then use this information /// / to determine which jobs the worker can process. #[derive(Debug)] - pub struct WorkerApiServer { + pub struct WorkerApiServer { inner: Arc, accept_compression_encodings: EnabledCompressionEncodings, send_compression_encodings: EnabledCompressionEncodings, max_decoding_message_size: Option, max_encoding_message_size: Option, } - impl WorkerApiServer { + impl WorkerApiServer { pub fn new(inner: T) -> Self { Self::from_arc(Arc::new(inner)) } @@ -508,8 +497,8 @@ pub mod worker_api_server { impl tonic::codegen::Service> for WorkerApiServer where T: WorkerApi, - B: Body + Send + 'static, - B::Error: Into + Send + 'static, + B: Body + std::marker::Send + 'static, + B::Error: Into + std::marker::Send + 'static, { type Response = http::Response; type Error = std::convert::Infallible; @@ -719,7 +708,7 @@ pub mod worker_api_server { } } } - impl Clone for WorkerApiServer { + impl Clone for WorkerApiServer { fn clone(&self) -> Self { let inner = self.inner.clone(); Self { @@ -731,7 +720,9 @@ pub mod worker_api_server { } } } - impl tonic::server::NamedService for WorkerApiServer { - const NAME: &'static str = "com.github.trace_machina.nativelink.remote_execution.WorkerApi"; + /// Generated gRPC service name + pub const SERVICE_NAME: &str = "com.github.trace_machina.nativelink.remote_execution.WorkerApi"; + impl tonic::server::NamedService for WorkerApiServer { + const NAME: &'static str = SERVICE_NAME; } } diff --git a/nativelink-proto/genproto/google.api.pb.rs b/nativelink-proto/genproto/google.api.pb.rs index ad80d4194..8f284ba50 100644 --- a/nativelink-proto/genproto/google.api.pb.rs +++ b/nativelink-proto/genproto/google.api.pb.rs @@ -16,7 +16,6 @@ /// Defines the HTTP configuration for an API service. It contains a list of /// [HttpRule][google.api.HttpRule], each specifying the mapping of an RPC method /// to one or more HTTP REST API methods. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Http { /// A list of HTTP configuration rules that apply to individual API methods. @@ -315,7 +314,6 @@ pub struct Http { /// If an API needs to use a JSON array for request or response body, it can map /// the request or response body to a repeated field. However, some gRPC /// Transcoding implementations may not support this feature. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct HttpRule { /// Selects a method to which this rule applies. @@ -355,7 +353,6 @@ pub mod http_rule { /// Determines the URL pattern is matched by this rules. This pattern can be /// used with any of the {get|put|post|delete|patch} methods. A custom method /// can be defined using the 'custom' field. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Pattern { /// Maps to HTTP GET. Used for listing and getting information about @@ -383,7 +380,6 @@ pub mod http_rule { } } /// A custom pattern is used for defining custom HTTP verb. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct CustomHttpPattern { /// The name of this custom HTTP verb. diff --git a/nativelink-proto/genproto/google.bytestream.pb.rs b/nativelink-proto/genproto/google.bytestream.pb.rs index 530dbad35..77db57476 100644 --- a/nativelink-proto/genproto/google.bytestream.pb.rs +++ b/nativelink-proto/genproto/google.bytestream.pb.rs @@ -14,7 +14,6 @@ // This file is @generated by prost-build. /// Request object for ByteStream.Read. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ReadRequest { /// The name of the resource to read. @@ -38,7 +37,6 @@ pub struct ReadRequest { pub read_limit: i64, } /// Response object for ByteStream.Read. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ReadResponse { /// A portion of the data for the resource. The service **may** leave `data` @@ -49,7 +47,6 @@ pub struct ReadResponse { pub data: ::prost::bytes::Bytes, } /// Request object for ByteStream.Write. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct WriteRequest { /// The name of the resource to write. This **must** be set on the first @@ -84,7 +81,6 @@ pub struct WriteRequest { pub data: ::prost::bytes::Bytes, } /// Response object for ByteStream.Write. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct WriteResponse { /// The number of bytes that have been processed for the given resource. @@ -92,7 +88,6 @@ pub struct WriteResponse { pub committed_size: i64, } /// Request object for ByteStream.QueryWriteStatus. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct QueryWriteStatusRequest { /// The name of the resource whose write status is being requested. @@ -100,7 +95,6 @@ pub struct QueryWriteStatusRequest { pub resource_name: ::prost::alloc::string::String, } /// Response object for ByteStream.QueryWriteStatus. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct QueryWriteStatusResponse { /// The number of bytes that have been processed for the given resource. @@ -147,8 +141,8 @@ pub mod byte_stream_client { where T: tonic::client::GrpcService, T::Error: Into, - T::ResponseBody: Body + Send + 'static, - ::Error: Into + Send, + T::ResponseBody: Body + std::marker::Send + 'static, + ::Error: Into + std::marker::Send, { pub fn new(inner: T) -> Self { let inner = tonic::client::Grpc::new(inner); @@ -173,7 +167,7 @@ pub mod byte_stream_client { >, , - >>::Error: Into + Send + Sync, + >>::Error: Into + std::marker::Send + std::marker::Sync, { ByteStreamClient::new(InterceptedService::new(inner, interceptor)) } @@ -329,12 +323,12 @@ pub mod byte_stream_server { use tonic::codegen::*; /// Generated trait containing gRPC methods that should be implemented for use with ByteStreamServer. #[async_trait] - pub trait ByteStream: Send + Sync + 'static { + pub trait ByteStream: std::marker::Send + std::marker::Sync + 'static { /// Server streaming response type for the Read method. type ReadStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result, > - + Send + + std::marker::Send + 'static; /// `Read()` is used to retrieve the contents of a resource as a sequence /// of bytes. The bytes are returned in a sequence of responses, and the @@ -415,14 +409,14 @@ pub mod byte_stream_server { /// /// The errors returned by the service are in the Google canonical error space. #[derive(Debug)] - pub struct ByteStreamServer { + pub struct ByteStreamServer { inner: Arc, accept_compression_encodings: EnabledCompressionEncodings, send_compression_encodings: EnabledCompressionEncodings, max_decoding_message_size: Option, max_encoding_message_size: Option, } - impl ByteStreamServer { + impl ByteStreamServer { pub fn new(inner: T) -> Self { Self::from_arc(Arc::new(inner)) } @@ -476,8 +470,8 @@ pub mod byte_stream_server { impl tonic::codegen::Service> for ByteStreamServer where T: ByteStream, - B: Body + Send + 'static, - B::Error: Into + Send + 'static, + B: Body + std::marker::Send + 'static, + B::Error: Into + std::marker::Send + 'static, { type Response = http::Response; type Error = std::convert::Infallible; @@ -646,7 +640,7 @@ pub mod byte_stream_server { } } } - impl Clone for ByteStreamServer { + impl Clone for ByteStreamServer { fn clone(&self) -> Self { let inner = self.inner.clone(); Self { @@ -658,7 +652,9 @@ pub mod byte_stream_server { } } } - impl tonic::server::NamedService for ByteStreamServer { - const NAME: &'static str = "google.bytestream.ByteStream"; + /// Generated gRPC service name + pub const SERVICE_NAME: &str = "google.bytestream.ByteStream"; + impl tonic::server::NamedService for ByteStreamServer { + const NAME: &'static str = SERVICE_NAME; } } diff --git a/nativelink-proto/genproto/google.devtools.build.v1.pb.rs b/nativelink-proto/genproto/google.devtools.build.v1.pb.rs index 999e9d3ae..501867421 100644 --- a/nativelink-proto/genproto/google.devtools.build.v1.pb.rs +++ b/nativelink-proto/genproto/google.devtools.build.v1.pb.rs @@ -14,7 +14,6 @@ // This file is @generated by prost-build. /// Status used for both invocation attempt and overall build completion. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct BuildStatus { /// The end result. @@ -107,7 +106,6 @@ pub mod build_status { } /// An event representing some state change that occurred in the build. This /// message does not include field for uniquely identifying an event. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct BuildEvent { /// This should be precisely the time when this event happened, and not when @@ -123,7 +121,6 @@ pub struct BuildEvent { /// Nested message and enum types in `BuildEvent`. pub mod build_event { /// Notification that the build system has attempted to run the build tool. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct InvocationAttemptStarted { /// The number of the invocation attempt, starting at 1 and increasing by 1 @@ -136,7 +133,6 @@ pub mod build_event { pub details: ::core::option::Option<::prost_types::Any>, } /// Notification that an invocation attempt has finished. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct InvocationAttemptFinished { /// Final status of the invocation. @@ -147,7 +143,6 @@ pub mod build_event { pub details: ::core::option::Option<::prost_types::Any>, } /// Notification that the build request is enqueued. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct BuildEnqueued { /// Additional details about the Build. @@ -157,7 +152,6 @@ pub mod build_event { /// Notification that the build request has finished, and no further /// invocations will occur. Note that this applies to the entire Build. /// Individual invocations trigger InvocationFinished when they finish. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct BuildFinished { /// Final status of the build. @@ -168,7 +162,6 @@ pub mod build_event { pub details: ::core::option::Option<::prost_types::Any>, } /// Textual output written to standard output or standard error. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ConsoleOutput { /// The output stream type. @@ -181,7 +174,6 @@ pub mod build_event { /// Nested message and enum types in `ConsoleOutput`. pub mod console_output { /// The output stream content. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Output { /// Regular UTF-8 output; normal text. @@ -194,7 +186,6 @@ pub mod build_event { } /// Notification of the end of a build event stream published by a build /// component other than CONTROLLER (See StreamId.BuildComponents). - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, Copy, PartialEq, ::prost::Message)] pub struct BuildComponentStreamFinished { /// How the event stream finished. @@ -253,7 +244,6 @@ pub mod build_event { /// ////////////////////////////////////////////////////////////////////////// /// Events that indicate a state change of a build request in the build /// queue. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Event { /// An invocation attempt has started. @@ -290,7 +280,6 @@ pub mod build_event { } } /// Unique identifier for a build event stream. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct StreamId { /// The id of a Build message. @@ -394,7 +383,6 @@ impl ConsoleOutputStream { /// multiple invocations for a build (e.g. retries). /// - InvocationAttemptCompleted: When work for a build finishes. /// - BuildFinished: When a build is finished. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct PublishLifecycleEventRequest { /// The interactivity of this build. @@ -478,7 +466,6 @@ pub mod publish_lifecycle_event_request { } /// States which event has been committed. Any failure to commit will cause /// RPC errors, hence not recorded by this proto. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct PublishBuildToolEventStreamResponse { /// The stream that contains this event. @@ -490,7 +477,6 @@ pub struct PublishBuildToolEventStreamResponse { } /// Build event with contextual information about the stream it belongs to and /// its position in that stream. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct OrderedBuildEvent { /// Which build event stream this event belongs to. @@ -506,7 +492,6 @@ pub struct OrderedBuildEvent { pub event: ::core::option::Option, } /// Streaming request message for PublishBuildToolEventStream. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct PublishBuildToolEventStreamRequest { /// Required. The build event with position info. @@ -559,8 +544,8 @@ pub mod publish_build_event_client { where T: tonic::client::GrpcService, T::Error: Into, - T::ResponseBody: Body + Send + 'static, - ::Error: Into + Send, + T::ResponseBody: Body + std::marker::Send + 'static, + ::Error: Into + std::marker::Send, { pub fn new(inner: T) -> Self { let inner = tonic::client::Grpc::new(inner); @@ -585,7 +570,7 @@ pub mod publish_build_event_client { >, , - >>::Error: Into + Send + Sync, + >>::Error: Into + std::marker::Send + std::marker::Sync, { PublishBuildEventClient::new(InterceptedService::new(inner, interceptor)) } @@ -701,7 +686,7 @@ pub mod publish_build_event_server { use tonic::codegen::*; /// Generated trait containing gRPC methods that should be implemented for use with PublishBuildEventServer. #[async_trait] - pub trait PublishBuildEvent: Send + Sync + 'static { + pub trait PublishBuildEvent: std::marker::Send + std::marker::Sync + 'static { /// Publish a build event stating the new state of a build (typically from the /// build queue). The BuildEnqueued event must be published before all other /// events for the same build ID. @@ -723,7 +708,7 @@ pub mod publish_build_event_server { tonic::Status, >, > - + Send + + std::marker::Send + 'static; /// Publish build tool events belonging to the same stream to a backend job /// using bidirectional streaming. @@ -753,14 +738,14 @@ pub mod publish_build_event_server { /// target objects produced via compilation, tests run, et cetera. There could be /// more than one build tool stream for an invocation attempt of a build. #[derive(Debug)] - pub struct PublishBuildEventServer { + pub struct PublishBuildEventServer { inner: Arc, accept_compression_encodings: EnabledCompressionEncodings, send_compression_encodings: EnabledCompressionEncodings, max_decoding_message_size: Option, max_encoding_message_size: Option, } - impl PublishBuildEventServer { + impl PublishBuildEventServer { pub fn new(inner: T) -> Self { Self::from_arc(Arc::new(inner)) } @@ -814,8 +799,8 @@ pub mod publish_build_event_server { impl tonic::codegen::Service> for PublishBuildEventServer where T: PublishBuildEvent, - B: Body + Send + 'static, - B::Error: Into + Send + 'static, + B: Body + std::marker::Send + 'static, + B::Error: Into + std::marker::Send + 'static, { type Response = http::Response; type Error = std::convert::Infallible; @@ -950,7 +935,7 @@ pub mod publish_build_event_server { } } } - impl Clone for PublishBuildEventServer { + impl Clone for PublishBuildEventServer { fn clone(&self) -> Self { let inner = self.inner.clone(); Self { @@ -962,8 +947,9 @@ pub mod publish_build_event_server { } } } - impl tonic::server::NamedService - for PublishBuildEventServer { - const NAME: &'static str = "google.devtools.build.v1.PublishBuildEvent"; + /// Generated gRPC service name + pub const SERVICE_NAME: &str = "google.devtools.build.v1.PublishBuildEvent"; + impl tonic::server::NamedService for PublishBuildEventServer { + const NAME: &'static str = SERVICE_NAME; } } diff --git a/nativelink-proto/genproto/google.longrunning.pb.rs b/nativelink-proto/genproto/google.longrunning.pb.rs index b99606b86..63247445d 100644 --- a/nativelink-proto/genproto/google.longrunning.pb.rs +++ b/nativelink-proto/genproto/google.longrunning.pb.rs @@ -15,7 +15,6 @@ // This file is @generated by prost-build. /// This resource represents a long-running operation that is the result of a /// network API call. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Operation { /// The server-assigned name, which is only unique within the same service that @@ -45,7 +44,6 @@ pub mod operation { /// The operation result, which can be either an `error` or a valid `response`. /// If `done` == `false`, neither `error` nor `response` is set. /// If `done` == `true`, exactly one of `error` or `response` is set. - #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Oneof)] pub enum Result { /// The error result of the operation in case of failure or cancellation. @@ -64,7 +62,6 @@ pub mod operation { } } /// The request message for [Operations.GetOperation][google.longrunning.Operations.GetOperation]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GetOperationRequest { /// The name of the operation resource. @@ -72,7 +69,6 @@ pub struct GetOperationRequest { pub name: ::prost::alloc::string::String, } /// The request message for [Operations.ListOperations][google.longrunning.Operations.ListOperations]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ListOperationsRequest { /// The name of the operation's parent resource. @@ -89,7 +85,6 @@ pub struct ListOperationsRequest { pub page_token: ::prost::alloc::string::String, } /// The response message for [Operations.ListOperations][google.longrunning.Operations.ListOperations]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct ListOperationsResponse { /// A list of operations that matches the specified filter in the request. @@ -100,7 +95,6 @@ pub struct ListOperationsResponse { pub next_page_token: ::prost::alloc::string::String, } /// The request message for [Operations.CancelOperation][google.longrunning.Operations.CancelOperation]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct CancelOperationRequest { /// The name of the operation resource to be cancelled. @@ -108,7 +102,6 @@ pub struct CancelOperationRequest { pub name: ::prost::alloc::string::String, } /// The request message for [Operations.DeleteOperation][google.longrunning.Operations.DeleteOperation]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct DeleteOperationRequest { /// The name of the operation resource to be deleted. @@ -116,7 +109,6 @@ pub struct DeleteOperationRequest { pub name: ::prost::alloc::string::String, } /// The request message for [Operations.WaitOperation][google.longrunning.Operations.WaitOperation]. -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct WaitOperationRequest { /// The name of the operation resource to wait on. @@ -139,7 +131,6 @@ pub struct WaitOperationRequest { /// metadata_type: "LongRunningRecognizeMetadata" /// }; /// } -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct OperationInfo { /// Required. The message name of the primary return type for this @@ -184,8 +175,8 @@ pub mod operations_client { where T: tonic::client::GrpcService, T::Error: Into, - T::ResponseBody: Body + Send + 'static, - ::Error: Into + Send, + T::ResponseBody: Body + std::marker::Send + 'static, + ::Error: Into + std::marker::Send, { pub fn new(inner: T) -> Self { let inner = tonic::client::Grpc::new(inner); @@ -210,7 +201,7 @@ pub mod operations_client { >, , - >>::Error: Into + Send + Sync, + >>::Error: Into + std::marker::Send + std::marker::Sync, { OperationsClient::new(InterceptedService::new(inner, interceptor)) } @@ -412,7 +403,7 @@ pub mod operations_server { use tonic::codegen::*; /// Generated trait containing gRPC methods that should be implemented for use with OperationsServer. #[async_trait] - pub trait Operations: Send + Sync + 'static { + pub trait Operations: std::marker::Send + std::marker::Sync + 'static { /// Lists operations that match the specified filter in the request. If the /// server doesn't support this method, it returns `UNIMPLEMENTED`. /// @@ -483,14 +474,14 @@ pub mod operations_server { /// returns long-running operations should implement the `Operations` interface /// so developers can have a consistent client experience. #[derive(Debug)] - pub struct OperationsServer { + pub struct OperationsServer { inner: Arc, accept_compression_encodings: EnabledCompressionEncodings, send_compression_encodings: EnabledCompressionEncodings, max_decoding_message_size: Option, max_encoding_message_size: Option, } - impl OperationsServer { + impl OperationsServer { pub fn new(inner: T) -> Self { Self::from_arc(Arc::new(inner)) } @@ -544,8 +535,8 @@ pub mod operations_server { impl tonic::codegen::Service> for OperationsServer where T: Operations, - B: Body + Send + 'static, - B::Error: Into + Send + 'static, + B: Body + std::marker::Send + 'static, + B::Error: Into + std::marker::Send + 'static, { type Response = http::Response; type Error = std::convert::Infallible; @@ -801,7 +792,7 @@ pub mod operations_server { } } } - impl Clone for OperationsServer { + impl Clone for OperationsServer { fn clone(&self) -> Self { let inner = self.inner.clone(); Self { @@ -813,7 +804,9 @@ pub mod operations_server { } } } - impl tonic::server::NamedService for OperationsServer { - const NAME: &'static str = "google.longrunning.Operations"; + /// Generated gRPC service name + pub const SERVICE_NAME: &str = "google.longrunning.Operations"; + impl tonic::server::NamedService for OperationsServer { + const NAME: &'static str = SERVICE_NAME; } } diff --git a/nativelink-proto/genproto/google.rpc.pb.rs b/nativelink-proto/genproto/google.rpc.pb.rs index 0ee6acb3f..a901e45d7 100644 --- a/nativelink-proto/genproto/google.rpc.pb.rs +++ b/nativelink-proto/genproto/google.rpc.pb.rs @@ -20,7 +20,6 @@ /// /// You can find out more about this error model and how to work with it in the /// [API Design Guide](). -#[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct Status { /// The status code, which should be an enum value of [google.rpc.Code][google.rpc.Code]. diff --git a/nativelink-store/Cargo.toml b/nativelink-store/Cargo.toml index 8a711065a..6f5676ac2 100644 --- a/nativelink-store/Cargo.toml +++ b/nativelink-store/Cargo.toml @@ -14,7 +14,7 @@ async-trait = "0.1.80" aws-config = { version = "1.5.4", default-features = false, features = [ "rustls", ] } -aws-sdk-s3 = { version = "1.41.0", features = [ +aws-sdk-s3 = { version = "=1.42.0", features = [ "rt-tokio", ], default-features = false } aws-smithy-runtime = { version = "1.6.2" } @@ -61,13 +61,13 @@ once_cell = { version = "1.19.0", default-features = false } sha2 = { version = "0.10.8", default-features = false } http = { version = "1.1.0", default-features = false } aws-smithy-types = "1.2.0" -aws-smithy-runtime = { version = "1.6.2", features = [ +aws-smithy-runtime = { version = "=1.6.2", features = [ "test-util", ], default-features = false } aws-sdk-s3 = { version = "1.41.0", features = [ "rt-tokio", ], default-features = false } -aws-smithy-runtime-api = "1.7.1" +aws-smithy-runtime-api = "=1.7.1" serial_test = { version = "3.1.1", features = [ "async", ], default-features = false } diff --git a/src/bin/nativelink.rs b/src/bin/nativelink.rs index 874f02b5a..20ac7f26f 100644 --- a/src/bin/nativelink.rs +++ b/src/bin/nativelink.rs @@ -442,7 +442,7 @@ async fn inner_main( let health_registry = health_registry_builder.lock().await.build(); let mut svc = Router::new() - .merge(tonic_services.into_router()) + .merge(tonic_services.into_service().into_axum_router()) // This is the default service that executes if no other endpoint matches. .fallback((StatusCode::NOT_FOUND, "Not Found"));