diff --git a/quickwit/Cargo.lock b/quickwit/Cargo.lock index 1662803ed0b..7f142b837c7 100644 --- a/quickwit/Cargo.lock +++ b/quickwit/Cargo.lock @@ -104,9 +104,9 @@ dependencies = [ [[package]] name = "allocator-api2" -version = "0.2.20" +version = "0.2.21" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "45862d1c77f2228b9e10bc609d5bc203d86ebc9b87ad8d5d5167a6c9abf739d9" +checksum = "683d7910e743518b0e34f1186f92494becacb047c7b6bf616c96772180fef923" [[package]] name = "android-tzdata" @@ -199,9 +199,9 @@ dependencies = [ [[package]] name = "anyhow" -version = "1.0.93" +version = "1.0.94" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "4c95c10ba0b00a02636238b814946408b1322d5ac4760326e6fb8ec956d85775" +checksum = "c1fd03a028ef38ba2276dce7e33fcd6369c158a1bca17946c4b1b701891c1ff7" [[package]] name = "arc-swap" @@ -264,9 +264,9 @@ dependencies = [ [[package]] name = "async-compression" -version = "0.4.17" +version = "0.4.18" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "0cb8f1d480b0ea3783ab015936d2a55c87e219676f0c0b7dec61494043f21857" +checksum = "df895a515f70646414f4b45c0b79082783b80552b373a68283012928df56f522" dependencies = [ "flate2", "futures-core", @@ -319,7 +319,7 @@ checksum = "c7c24de15d275a1ecfd47a380fb4d5ec9bfe0933f309ed5e705b775596a3574d" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -330,7 +330,7 @@ checksum = "721cae7de5c34fbb2acd27e21e6d2cf7b886dce0c27388d46c4e6c47ea4318dd" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -361,13 +361,13 @@ dependencies = [ "aws-sdk-sts", "aws-smithy-async", "aws-smithy-http", - "aws-smithy-json", + "aws-smithy-json 0.60.7", "aws-smithy-runtime", "aws-smithy-runtime-api", "aws-smithy-types", "aws-types", "bytes", - "fastrand 2.2.0", + "fastrand 2.3.0", "hex", "http 0.2.12", "ring 0.17.8", @@ -392,9 +392,9 @@ dependencies = [ [[package]] name = "aws-runtime" -version = "1.4.3" +version = "1.4.4" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a10d5c055aa540164d9561a0e2e74ad30f0dcf7393c3a92f6733ddf9c5762468" +checksum = "b5ac934720fbb46206292d2c75b57e67acfc56fe7dfd34fb9a02334af08409ea" dependencies = [ "aws-credential-types", "aws-sigv4", @@ -406,7 +406,7 @@ dependencies = [ "aws-smithy-types", "aws-types", "bytes", - "fastrand 2.2.0", + "fastrand 2.3.0", "http 0.2.12", "http-body 0.4.6", "once_cell", @@ -418,15 +418,15 @@ dependencies = [ [[package]] name = "aws-sdk-kinesis" -version = "1.51.0" +version = "1.52.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ad48026d3d53881146469b36358d633f1b8c9ad6eb3033f348600f981f2f449b" +checksum = "3e5d4932ecd8754ec808b57c13b5ab4965d2b568ae1c1984d1823a4e2aa3e7bc" dependencies = [ "aws-credential-types", "aws-runtime", "aws-smithy-async", "aws-smithy-http", - "aws-smithy-json", + "aws-smithy-json 0.61.1", "aws-smithy-runtime", "aws-smithy-runtime-api", "aws-smithy-types", @@ -440,9 +440,9 @@ dependencies = [ [[package]] name = "aws-sdk-s3" -version = "1.62.0" +version = "1.65.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "83d3a2854c7490b4c63d2b0e8c3976d628c80afa3045d078a715b2edb2ee4e0a" +checksum = "d3ba2c5c0f2618937ce3d4a5ad574b86775576fa24006bcb3128c6e2cbf3c34e" dependencies = [ "aws-credential-types", "aws-runtime", @@ -451,14 +451,14 @@ dependencies = [ "aws-smithy-checksums", "aws-smithy-eventstream", "aws-smithy-http", - "aws-smithy-json", + "aws-smithy-json 0.61.1", "aws-smithy-runtime", "aws-smithy-runtime-api", "aws-smithy-types", "aws-smithy-xml", "aws-types", "bytes", - "fastrand 2.2.0", + "fastrand 2.3.0", "hex", "hmac", "http 0.2.12", @@ -474,15 +474,15 @@ dependencies = [ [[package]] name = "aws-sdk-sqs" -version = "1.49.0" +version = "1.50.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "073df10a6d1dbbfdb06c5a6a6d1ebf5bf799afe64586e0688bae08a3b1be553f" +checksum = "1d0a1bb53c15b172e67d1ed2576514a998397f91205c475e3278125a98134732" dependencies = [ "aws-credential-types", "aws-runtime", "aws-smithy-async", "aws-smithy-http", - "aws-smithy-json", + "aws-smithy-json 0.61.1", "aws-smithy-runtime", "aws-smithy-runtime-api", "aws-smithy-types", @@ -496,15 +496,15 @@ dependencies = [ [[package]] name = "aws-sdk-sso" -version = "1.49.0" +version = "1.50.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "09677244a9da92172c8dc60109b4a9658597d4d298b188dd0018b6a66b410ca4" +checksum = "05ca43a4ef210894f93096039ef1d6fa4ad3edfabb3be92b80908b9f2e4b4eab" dependencies = [ "aws-credential-types", "aws-runtime", "aws-smithy-async", "aws-smithy-http", - "aws-smithy-json", + "aws-smithy-json 0.61.1", "aws-smithy-runtime", "aws-smithy-runtime-api", "aws-smithy-types", @@ -518,15 +518,15 @@ dependencies = [ [[package]] name = "aws-sdk-ssooidc" -version = "1.50.0" +version = "1.51.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "81fea2f3a8bb3bd10932ae7ad59cc59f65f270fc9183a7e91f501dc5efbef7ee" +checksum = "abaf490c2e48eed0bb8e2da2fb08405647bd7f253996e0f93b981958ea0f73b0" dependencies = [ "aws-credential-types", "aws-runtime", "aws-smithy-async", "aws-smithy-http", - "aws-smithy-json", + "aws-smithy-json 0.61.1", "aws-smithy-runtime", "aws-smithy-runtime-api", "aws-smithy-types", @@ -540,15 +540,15 @@ dependencies = [ [[package]] name = "aws-sdk-sts" -version = "1.50.0" +version = "1.51.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6ada54e5f26ac246dc79727def52f7f8ed38915cb47781e2a72213957dc3a7d5" +checksum = "b68fde0d69c8bfdc1060ea7da21df3e39f6014da316783336deff0a9ec28f4bf" dependencies = [ "aws-credential-types", "aws-runtime", "aws-smithy-async", "aws-smithy-http", - "aws-smithy-json", + "aws-smithy-json 0.61.1", "aws-smithy-query", "aws-smithy-runtime", "aws-smithy-runtime-api", @@ -563,9 +563,9 @@ dependencies = [ [[package]] name = "aws-sigv4" -version = "1.2.5" +version = "1.2.6" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5619742a0d8f253be760bfbb8e8e8368c69e3587e4637af5754e488a611499b1" +checksum = "7d3820e0c08d0737872ff3c7c1f21ebbb6693d832312d6152bf18ef50a5471c2" dependencies = [ "aws-credential-types", "aws-smithy-eventstream", @@ -578,7 +578,7 @@ dependencies = [ "hex", "hmac", "http 0.2.12", - "http 1.1.0", + "http 1.2.0", "once_cell", "p256", "percent-encoding", @@ -663,6 +663,15 @@ dependencies = [ "aws-smithy-types", ] +[[package]] +name = "aws-smithy-json" +version = "0.61.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ee4e69cc50921eb913c6b662f8d909131bb3e6ad6cb6090d3a39b66fc5c52095" +dependencies = [ + "aws-smithy-types", +] + [[package]] name = "aws-smithy-protocol-test" version = "0.63.0" @@ -679,7 +688,7 @@ dependencies = [ "regex-lite", "roxmltree 0.14.1", "serde_json", - "thiserror", + "thiserror 1.0.69", ] [[package]] @@ -694,9 +703,9 @@ dependencies = [ [[package]] name = "aws-smithy-runtime" -version = "1.7.3" +version = "1.7.4" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "be28bd063fa91fd871d131fc8b68d7cd4c5fa0869bea68daca50dcb1cbd76be2" +checksum = "9f20685047ca9d6f17b994a07f629c813f08b5bce65523e47124879e60103d45" dependencies = [ "aws-smithy-async", "aws-smithy-http", @@ -704,7 +713,7 @@ dependencies = [ "aws-smithy-runtime-api", "aws-smithy-types", "bytes", - "fastrand 2.2.0", + "fastrand 2.3.0", "h2", "http 0.2.12", "http-body 0.4.6", @@ -712,7 +721,7 @@ dependencies = [ "httparse", "hyper 0.14.31", "hyper-rustls", - "indexmap 2.6.0", + "indexmap 2.7.0", "once_cell", "pin-project-lite", "pin-utils", @@ -734,7 +743,7 @@ dependencies = [ "aws-smithy-types", "bytes", "http 0.2.12", - "http 1.1.0", + "http 1.2.0", "pin-project-lite", "tokio", "tracing", @@ -752,7 +761,7 @@ dependencies = [ "bytes-utils", "futures-core", "http 0.2.12", - "http 1.1.0", + "http 1.2.0", "http-body 0.4.6", "http-body 1.0.1", "http-body-util", @@ -816,7 +825,7 @@ dependencies = [ "bytes", "chrono", "flate2", - "http 1.1.0", + "http 1.2.0", "http-body 1.0.1", "http-serde 2.1.1", "query_map", @@ -947,7 +956,7 @@ version = "0.4.4" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "d67782c3f868daa71d3533538e98a8e13713231969def7536e8039606fc46bf0" dependencies = [ - "fastrand 2.2.0", + "fastrand 2.3.0", "futures-core", "pin-project", "tokio", @@ -1046,7 +1055,7 @@ dependencies = [ "miniserde", "peakmem-alloc", "perf-event", - "rustc-hash 2.0.0", + "rustc-hash 2.1.0", "rustop", "unicode-width 0.1.14", "yansi", @@ -1141,7 +1150,7 @@ dependencies = [ "proc-macro-crate 3.2.0", "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -1210,9 +1219,9 @@ checksum = "1fd0f2584146f6f2ef48085050886acf353beff7305ebd1ae69500e27c67f64b" [[package]] name = "bytes" -version = "1.8.0" +version = "1.9.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "9ac0150caa2ae65ca5bd83f25c7de183dea78d4d366469f148435e2acfbad0da" +checksum = "325918d6fe32f23b19878fe4b34794ae41fc19ddbe53b10571a4874d44ffd39b" dependencies = [ "serde", ] @@ -1238,9 +1247,9 @@ dependencies = [ [[package]] name = "bytestring" -version = "1.3.1" +version = "1.4.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "74d80203ea6b29df88012294f62733de21cfeab47f17b41af3a38bc30a03ee72" +checksum = "e465647ae23b2823b0753f50decb2d5a86d2bb2cac04788fafd1f80e45378e5f" dependencies = [ "bytes", ] @@ -1302,9 +1311,9 @@ dependencies = [ [[package]] name = "cc" -version = "1.2.1" +version = "1.2.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "fd9de9f2205d5ef3fd67e685b0df337994ddd4495e2a28d185500d0e1edfea47" +checksum = "27f657647bcff5394bf56c7317665bbf790a137a50eaaa5c6bfbb9e27a518f2d" dependencies = [ "jobserver", "libc", @@ -1391,9 +1400,9 @@ dependencies = [ [[package]] name = "chrono" -version = "0.4.38" +version = "0.4.39" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a21f936df1771bf62b77f047b726c4625ff2e8aa607c01ec06e5a05bd8463401" +checksum = "7e36cc9d416881d2e24f9a963be5fb1cd90966419ac844274161d10488b3e825" dependencies = [ "android-tzdata", "iana-time-zone", @@ -1482,18 +1491,18 @@ dependencies = [ [[package]] name = "clap" -version = "4.5.21" +version = "4.5.23" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "fb3b4b9e5a7c7514dfa52869339ee98b3156b0bfb4e8a77c4ff4babb64b1604f" +checksum = "3135e7ec2ef7b10c6ed8950f0f792ed96ee093fa088608f1c76e569722700c84" dependencies = [ "clap_builder", ] [[package]] name = "clap_builder" -version = "4.5.21" +version = "4.5.23" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "b17a95aa67cc7b5ebd32aa5370189aa0d79069ef1c64ce893bd30fb24bff20ec" +checksum = "30582fc632330df2bd26877bde0c1f4470d57c582bbc070376afcd04d8cb4838" dependencies = [ "anstream", "anstyle", @@ -1503,24 +1512,24 @@ dependencies = [ [[package]] name = "clap_lex" -version = "0.7.3" +version = "0.7.4" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "afb84c814227b90d6895e01398aee0d8033c00e7466aca416fb6a8e0eb19d8a7" +checksum = "f46ad14479a25103f283c0f10005961cf086d8dc42205bb44c46ac563475dca6" [[package]] name = "cmake" -version = "0.1.51" +version = "0.1.52" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "fb1e43aa7fd152b1f968787f7dbcdeb306d1867ff373c69955211876c053f91a" +checksum = "c682c223677e0e5b6b7f63a64b9351844c3f1b1678a68b7ee617e30fb082620e" dependencies = [ "cc", ] [[package]] name = "coarsetime" -version = "0.1.34" +version = "0.1.35" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "13b3839cf01bb7960114be3ccf2340f541b6d0c81f8690b007b2b39f750f7e5d" +checksum = "4252bf230cb600c19826a575b31c8c9c84c6f11acfab6dfcad2e941b10b6f8e2" dependencies = [ "libc", "wasix", @@ -1603,7 +1612,7 @@ checksum = "c2895653b4d9f1538a83970077cb01dfc77a4810524e51a110944688e916b18e" dependencies = [ "prost 0.11.9", "prost-types 0.11.9", - "tonic", + "tonic 0.9.2", "tracing-core", ] @@ -1625,7 +1634,7 @@ dependencies = [ "thread_local", "tokio", "tokio-stream", - "tonic", + "tonic 0.9.2", "tracing", "tracing-core", "tracing-subscriber", @@ -1946,7 +1955,7 @@ dependencies = [ "proc-macro2", "quote", "strsim 0.11.1", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -1968,7 +1977,7 @@ checksum = "d336a2a514f6ccccaa3e09b02d41d35330c07ddf03a62165fcec10bb561c7806" dependencies = [ "darling_core 0.20.10", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -2052,7 +2061,7 @@ dependencies = [ "proc-macro2", "quote", "rustc_version", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -2120,7 +2129,7 @@ checksum = "97369cbbc041bc366949bc74d34658d6cda5621039731c6310521892a3a20ae0" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -2380,7 +2389,7 @@ checksum = "a1ab991c1362ac86c61ab6f556cff143daa22e5a15e4e189df818b2fd19fe65b" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -2404,12 +2413,12 @@ checksum = "5443807d6dff69373d433ab9ef5378ad8df50ca6298caf15de6e52e24aaf54d5" [[package]] name = "errno" -version = "0.3.9" +version = "0.3.10" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "534c5cf6194dfab3db3242765c03bbe257cf92f22b38f6bc0c58d59108a820ba" +checksum = "33d852cb9b869c2a9b3df2f71a3074817f01e1844f839a144f5fcef059a4eb5d" dependencies = [ "libc", - "windows-sys 0.52.0", + "windows-sys 0.59.0", ] [[package]] @@ -2442,9 +2451,9 @@ dependencies = [ [[package]] name = "event-listener-strategy" -version = "0.5.2" +version = "0.5.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "0f214dc438f977e6d4e3500aaa277f5ad94ca83fbbd9b1a15713ce2344ccc5a1" +checksum = "3c3e4e0dd3673c1139bf041f3008816d9cf2946bbfac2945c09e523b8d7b05b2" dependencies = [ "event-listener 5.3.1", "pin-project-lite", @@ -2501,9 +2510,9 @@ dependencies = [ [[package]] name = "fastrand" -version = "2.2.0" +version = "2.3.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "486f806e73c5707928240ddc295403b1b93c96a02038563881c4a2fd84b81ac4" +checksum = "37909eebbb50d72f9059c3b6d82c0463f2ff062c9e95845c43a6c9c0355411be" [[package]] name = "ff" @@ -2732,7 +2741,7 @@ checksum = "162ee34ebcb7c64a8abebc059ce0fee27c2262618d7b60ed8faf72fef13c3650" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -2833,7 +2842,7 @@ dependencies = [ "reqwest", "serde", "serde_json", - "thiserror", + "thiserror 1.0.69", "time", "tokio", "tracing", @@ -2848,10 +2857,10 @@ checksum = "f8bdaaa4bc036e8318274d1b25f0f2265b3e95418b765fd1ea1c7ef938fd69bd" dependencies = [ "google-cloud-token", "http 0.2.12", - "thiserror", + "thiserror 1.0.69", "tokio", "tokio-retry", - "tonic", + "tonic 0.9.2", "tower", "tracing", ] @@ -2864,7 +2873,7 @@ checksum = "2a3b24a3f57be08afc02344e693afb55e48172c9c2ab86ff3fdb8efff550e4b9" dependencies = [ "prost 0.11.9", "prost-types 0.11.9", - "tonic", + "tonic 0.9.2", ] [[package]] @@ -2874,7 +2883,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "96e4ad0802d3f416f62e7ce01ac1460898ee0efc98f8b45cd4aab7611607012f" dependencies = [ "reqwest", - "thiserror", + "thiserror 1.0.69", "tokio", ] @@ -2891,7 +2900,7 @@ dependencies = [ "google-cloud-googleapis", "google-cloud-token", "prost-types 0.11.9", - "thiserror", + "thiserror 1.0.69", "tokio", "tokio-util", "tracing", @@ -2939,7 +2948,7 @@ dependencies = [ "futures-sink", "futures-util", "http 0.2.12", - "indexmap 2.6.0", + "indexmap 2.7.0", "slab", "tokio", "tokio-util", @@ -2977,9 +2986,9 @@ dependencies = [ [[package]] name = "hashbrown" -version = "0.15.1" +version = "0.15.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3a9bfc1af68b1726ea47d3d5109de126281def866b33970e10fbab11b5dafab3" +checksum = "bf151400ff0baff5465007dd2f3e717f3fe502074ca563069ce3a6629d07b289" dependencies = [ "allocator-api2", "equivalent", @@ -3092,17 +3101,6 @@ dependencies = [ "windows-sys 0.52.0", ] -[[package]] -name = "hostname" -version = "0.3.1" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3c731c3e10504cc8ed35cfe2f1db4c9274c3d35fa486e3b31df46f068ef3e867" -dependencies = [ - "libc", - "match_cfg", - "winapi 0.3.9", -] - [[package]] name = "hostname" version = "0.4.0" @@ -3133,9 +3131,9 @@ dependencies = [ [[package]] name = "http" -version = "1.1.0" +version = "1.2.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "21b9ddb458710bc376481b842f5da65cdf31522de232c1ca8146abce2a358258" +checksum = "f16ca2af56261c99fba8bac40a10251ce8188205a4c448fbb745a2e4daa76fea" dependencies = [ "bytes", "fnv", @@ -3160,7 +3158,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "1efedce1fb8e6913f23e0c92de8e62cd5b772a67e7b3946df930a62566c93184" dependencies = [ "bytes", - "http 1.1.0", + "http 1.2.0", ] [[package]] @@ -3171,7 +3169,7 @@ checksum = "793429d76616a256bcb62c2a2ec2bed781c8307e797e2598c50010f2bee2544f" dependencies = [ "bytes", "futures-util", - "http 1.1.0", + "http 1.2.0", "http-body 1.0.1", "pin-project-lite", ] @@ -3198,7 +3196,7 @@ version = "2.1.1" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "0f056c8559e3757392c8d091e796416e4649d8e49e88b8d76df6c002f05027fd" dependencies = [ - "http 1.1.0", + "http 1.2.0", "serde", ] @@ -3274,7 +3272,7 @@ dependencies = [ "bytes", "futures-channel", "futures-util", - "http 1.1.0", + "http 1.2.0", "http-body 1.0.1", "httparse", "itoa", @@ -3334,7 +3332,7 @@ dependencies = [ "bytes", "futures-channel", "futures-util", - "http 1.1.0", + "http 1.2.0", "http-body 1.0.1", "hyper 1.5.1", "pin-project-lite", @@ -3491,7 +3489,7 @@ checksum = "1ec89e9337638ecdc08744df490b221a7399bf8d164eb52a665454e60e075ad6" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -3544,12 +3542,12 @@ dependencies = [ [[package]] name = "indexmap" -version = "2.6.0" +version = "2.7.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "707907fe3c25f5424cce2cb7e1cbcafee6bdbe735ca90ef77c29e84591e5b9da" +checksum = "62f822373a4fe84d4bb149bf54e584a7f4abec90e072ed49cda0edea5b95471f" dependencies = [ "equivalent", - "hashbrown 0.15.1", + "hashbrown 0.15.2", "serde", ] @@ -3585,7 +3583,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "232929e1d75fe899576a3d5c7416ad0d88dbfbb3c3d6aa00873a7408a50ddb88" dependencies = [ "ahash 0.8.11", - "indexmap 2.6.0", + "indexmap 2.7.0", "is-terminal", "itoa", "log", @@ -3617,7 +3615,7 @@ checksum = "0122b7114117e64a63ac49f752a5ca4624d534c7b1c7de796ac196381cd2d947" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -3712,9 +3710,9 @@ dependencies = [ [[package]] name = "itoa" -version = "1.0.13" +version = "1.0.14" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "540654e97a3f4470a492cd30ff187bc95d89557a903a2bbf112e2fae98104ef2" +checksum = "d75a2a4b1b190afb6f5425f10f6a8f959d2ea0b9c2b1d79553551850539e4674" [[package]] name = "jobserver" @@ -3727,10 +3725,11 @@ dependencies = [ [[package]] name = "js-sys" -version = "0.3.72" +version = "0.3.76" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6a88f1bda2bd75b0452a14784937d796722fdebfe50df998aeb3f0b7603019a9" +checksum = "6717b6b5b077764fb5966237269cb3c64edddde4b14ce42647430a78ced9e7b7" dependencies = [ + "once_cell", "wasm-bindgen", ] @@ -3881,7 +3880,7 @@ dependencies = [ "base64 0.22.1", "bytes", "futures", - "http 1.1.0", + "http 1.2.0", "http-body 1.0.1", "http-body-util", "http-serde 2.1.1", @@ -3920,7 +3919,7 @@ dependencies = [ "bytes", "futures-channel", "futures-util", - "http 1.1.0", + "http 1.2.0", "http-body 1.0.1", "http-body-util", "hyper 1.5.1", @@ -3949,9 +3948,9 @@ checksum = "0c2cdeb66e45e9f36bfad5bbdb4d2384e70936afbee843c6f6543f0c551ebb25" [[package]] name = "libc" -version = "0.2.164" +version = "0.2.168" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "433bfe06b8c75da9b2e3fbea6e5329ff87748f0b144ef75306e674c3f6f7c13f" +checksum = "5aaeb2981e0606ca11d79718f8bb01164f1d6ed75080182d3abf017e6d244b6d" [[package]] name = "libm" @@ -4053,7 +4052,7 @@ dependencies = [ "log", "once_cell", "serde", - "thiserror", + "thiserror 1.0.69", "yada", ] @@ -4234,9 +4233,9 @@ checksum = "78b3ae25bc7c8c38cec158d1f2757ee79e9b3740fbc7ccf0e59e4b08d793fa89" [[package]] name = "litemap" -version = "0.7.3" +version = "0.7.4" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "643cb0b8d4fcc284004d5fd0d67ccf61dfffadb7f75e1e71bc420f4688a3a704" +checksum = "4ee93343901ab17bd981295f2cf0026d4ad018c7c31ba84549a4ddbb47a45104" [[package]] name = "lock_api" @@ -4260,7 +4259,7 @@ version = "0.12.5" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "234cf4f4a04dc1f57e24b96cc0cd600cf2af460d4161ac5ecdd0af8e1f3b2a38" dependencies = [ - "hashbrown 0.15.1", + "hashbrown 0.15.2", ] [[package]] @@ -4288,12 +4287,6 @@ version = "0.11.3" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "75761162ae2b0e580d7e7c390558127e5f01b4194debd6221fd8c207fc80e3f5" -[[package]] -name = "match_cfg" -version = "0.1.0" -source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ffbee8634e0d45d258acb448e7eaab3fce7a0a467395d4d9f228e3c1f01fb2e4" - [[package]] name = "matchers" version = "0.1.0" @@ -4374,13 +4367,13 @@ dependencies = [ [[package]] name = "mini-internal" -version = "0.1.40" +version = "0.1.41" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f3cd9f9bbedc1b92683a9847b8db12f3203cf32af6a11db085fa007708dc9555" +checksum = "07b7f1340a7f0d2f89755aac4096f1c55352bfcb95cb8f351d6fcefa18df474f" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -4391,9 +4384,9 @@ checksum = "68354c5c6bd36d73ff3feceb05efa59b6acb7626617f4962be322a825e61f79a" [[package]] name = "miniserde" -version = "0.1.40" +version = "0.1.41" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "e9b650e926368ad21aaabe6055341d1874df696178f47d70b6d9a691f616274e" +checksum = "625208b7bc90255fe6d99338041880bf48a3049166f46fbefbd4e9b0478c0b66" dependencies = [ "itoa", "mini-internal", @@ -4411,11 +4404,10 @@ dependencies = [ [[package]] name = "mio" -version = "1.0.2" +version = "1.0.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "80e04d1dcff3aae0704555fe5fee3bcfaf3d1fdf8a7e521d5b9d2b42acb52cec" +checksum = "2886843bf800fba2e3377cff24abf6379b4c4d5c6681eaf9ea5b0d15090450bd" dependencies = [ - "hermit-abi 0.3.9", "libc", "wasi 0.11.0+wasi-snapshot-preview1", "windows-sys 0.52.0", @@ -4467,7 +4459,7 @@ dependencies = [ "rustc_version", "smallvec", "tagptr", - "thiserror", + "thiserror 1.0.69", "triomphe", "uuid", ] @@ -4481,7 +4473,7 @@ dependencies = [ "crc32fast", "serde", "serde_json", - "thiserror", + "thiserror 1.0.69", "tracing", ] @@ -4509,6 +4501,12 @@ version = "0.8.3" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "e5ce46fe64a9d73be07dcbe690a38ce1b293be448fd8ce1e6c1b8062c9f72c6a" +[[package]] +name = "multimap" +version = "0.10.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "defc4c55412d89136f966bbb339008b474350e5e6e78d2714439c386b3137a03" + [[package]] name = "murmurhash32" version = "0.3.1" @@ -4696,44 +4694,44 @@ dependencies = [ [[package]] name = "num_enum" -version = "0.5.11" +version = "0.6.1" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "1f646caf906c20226733ed5b1374287eb97e3c2a5c227ce668c1f2ce20ae57c9" +checksum = "7a015b430d3c108a207fd776d2e2196aaf8b1cf8cf93253e3a097ff3085076a1" dependencies = [ - "num_enum_derive 0.5.11", + "num_enum_derive 0.6.1", ] [[package]] name = "num_enum" -version = "0.6.1" +version = "0.7.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "7a015b430d3c108a207fd776d2e2196aaf8b1cf8cf93253e3a097ff3085076a1" +checksum = "4e613fc340b2220f734a8595782c551f1250e969d87d3be1ae0579e8d4065179" dependencies = [ - "num_enum_derive 0.6.1", + "num_enum_derive 0.7.3", ] [[package]] name = "num_enum_derive" -version = "0.5.11" +version = "0.6.1" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "dcbff9bc912032c62bf65ef1d5aea88983b420f4f839db1e9b0c281a25c9c799" +checksum = "96667db765a921f7b295ffee8b60472b686a51d4f21c2ee4ffdb94c7013b65a6" dependencies = [ "proc-macro-crate 1.3.1", "proc-macro2", "quote", - "syn 1.0.109", + "syn 2.0.90", ] [[package]] name = "num_enum_derive" -version = "0.6.1" +version = "0.7.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "96667db765a921f7b295ffee8b60472b686a51d4f21c2ee4ffdb94c7013b65a6" +checksum = "af1844ef2428cc3e1cb900be36181049ef3d3193c63e43026cfe202983b27a56" dependencies = [ - "proc-macro-crate 1.3.1", + "proc-macro-crate 3.2.0", "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -4777,7 +4775,7 @@ dependencies = [ "serde_json", "serde_path_to_error", "sha2", - "thiserror", + "thiserror 1.0.69", "url", ] @@ -4908,7 +4906,7 @@ dependencies = [ "serde_plain", "serde_with 1.14.0", "subtle", - "thiserror", + "thiserror 1.0.69", "url", ] @@ -4935,7 +4933,7 @@ checksum = "a948666b637a0f465e8564c73e89d4dde00d72d4d473cc972f390fc3dcee7d9c" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -5005,9 +5003,9 @@ dependencies = [ "opentelemetry_sdk", "prost 0.11.9", "reqwest", - "thiserror", + "thiserror 1.0.69", "tokio", - "tonic", + "tonic 0.9.2", ] [[package]] @@ -5019,7 +5017,7 @@ dependencies = [ "opentelemetry_api", "opentelemetry_sdk", "prost 0.11.9", - "tonic", + "tonic 0.9.2", ] [[package]] @@ -5043,7 +5041,7 @@ dependencies = [ "js-sys", "once_cell", "pin-project-lite", - "thiserror", + "thiserror 1.0.69", "urlencoding", ] @@ -5065,7 +5063,7 @@ dependencies = [ "rand 0.8.5", "regex", "serde_json", - "thiserror", + "thiserror 1.0.69", "tokio", "tokio-stream", ] @@ -5129,7 +5127,7 @@ dependencies = [ "proc-macro2", "proc-macro2-diagnostics", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -5320,20 +5318,20 @@ dependencies = [ [[package]] name = "pest" -version = "2.7.14" +version = "2.7.15" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "879952a81a83930934cbf1786752d6dedc3b1f29e8f8fb2ad1d0a36f377cf442" +checksum = "8b7cafe60d6cf8e62e1b9b2ea516a089c008945bb5a275416789e7db0bc199dc" dependencies = [ "memchr", - "thiserror", + "thiserror 2.0.6", "ucd-trie", ] [[package]] name = "pest_derive" -version = "2.7.14" +version = "2.7.15" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "d214365f632b123a47fd913301e14c946c61d1c183ee245fa76eb752e59a02dd" +checksum = "816518421cfc6887a0d62bf441b6ffb4536fcc926395a69e1a85852d4363f57e" dependencies = [ "pest", "pest_generator", @@ -5341,22 +5339,22 @@ dependencies = [ [[package]] name = "pest_generator" -version = "2.7.14" +version = "2.7.15" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "eb55586734301717aea2ac313f50b2eb8f60d2fc3dc01d190eefa2e625f60c4e" +checksum = "7d1396fd3a870fc7838768d171b4616d5c91f6cc25e377b673d714567d99377b" dependencies = [ "pest", "pest_meta", "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] name = "pest_meta" -version = "2.7.14" +version = "2.7.15" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "b75da2a70cf4d9cb76833c990ac9cd3923c9a8905a8929789ce347c84564d03d" +checksum = "e1e58089ea25d717bfd31fb534e4f3afcc2cc569c70de3e239778991ea3b7dea" dependencies = [ "once_cell", "pest", @@ -5370,7 +5368,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "b4c5cc86750666a3ed20bdaf5ca2a0344f9c67674cae0515bec2da16fbaa47db" dependencies = [ "fixedbitset", - "indexmap 2.6.0", + "indexmap 2.7.0", ] [[package]] @@ -5437,7 +5435,7 @@ checksum = "3c0f5fad0874fc7abcd4d750e76917eaebbecaa2c20bde22e1dbeeba8beb758c" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -5638,15 +5636,15 @@ dependencies = [ [[package]] name = "portable-atomic" -version = "1.9.0" +version = "1.10.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "cc9c68a3f6da06753e9335d63e27f6b9754dd1920d941135b7ea8224f141adb2" +checksum = "280dc24453071f1b63954171985a0b0d30058d287960968b9b2aca264c8d4ee6" [[package]] name = "postcard" -version = "1.0.10" +version = "1.1.1" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5f7f0a8d620d71c457dd1d47df76bb18960378da56af4527aaa10f515eee732e" +checksum = "170a2601f67cc9dba8edd8c4870b15f71a6a2dc196daec8c83f72b59dff628a8" dependencies = [ "cobs", "embedded-io 0.4.0", @@ -5678,7 +5676,7 @@ dependencies = [ "smallvec", "symbolic-demangle", "tempfile", - "thiserror", + "thiserror 1.0.69", ] [[package]] @@ -5767,7 +5765,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "64d1ec885c64d0457d564db4ec299b2dae3f9c02808b8ad9c3a089c591b18033" dependencies = [ "proc-macro2", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -5830,7 +5828,7 @@ checksum = "af066a9c399a26e020ada66a034357a868728e72cd426f3adcd35f80d88d88c8" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", "version_check", "yansi", ] @@ -5872,7 +5870,7 @@ dependencies = [ "parking_lot", "procfs", "protobuf", - "thiserror", + "thiserror 1.0.69", ] [[package]] @@ -5907,12 +5905,22 @@ dependencies = [ [[package]] name = "prost" -version = "0.13.3" +version = "0.12.6" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "7b0487d90e047de87f984913713b85c601c05609aad5b0df4b4573fbf69aa13f" +checksum = "deb1435c188b76130da55f17a466d252ff7b1418b2ad3e037d127b94e3411f29" dependencies = [ "bytes", - "prost-derive 0.13.3", + "prost-derive 0.12.6", +] + +[[package]] +name = "prost" +version = "0.13.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2c0fef6c4230e4ccf618a35c59d7ede15dea37de8427500f50aff708806e42ec" +dependencies = [ + "bytes", + "prost-derive 0.13.4", ] [[package]] @@ -5926,7 +5934,7 @@ dependencies = [ "itertools 0.10.5", "lazy_static", "log", - "multimap", + "multimap 0.8.3", "petgraph", "prettyplease 0.1.25", "prost 0.11.9", @@ -5937,6 +5945,27 @@ dependencies = [ "which", ] +[[package]] +name = "prost-build" +version = "0.12.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "22505a5c94da8e3b7c2996394d1c933236c4d743e81a410bcca4e6989fc066a4" +dependencies = [ + "bytes", + "heck 0.5.0", + "itertools 0.12.1", + "log", + "multimap 0.10.0", + "once_cell", + "petgraph", + "prettyplease 0.2.25", + "prost 0.12.6", + "prost-types 0.12.6", + "regex", + "syn 2.0.90", + "tempfile", +] + [[package]] name = "prost-derive" version = "0.11.9" @@ -5952,26 +5981,39 @@ dependencies = [ [[package]] name = "prost-derive" -version = "0.13.3" +version = "0.12.6" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "e9552f850d5f0964a4e4d0bf306459ac29323ddfbae05e35a7c0d35cb0803cc5" +checksum = "81bddcdb20abf9501610992b6759a4c888aef7d1a7247ef75e2404275ac24af1" +dependencies = [ + "anyhow", + "itertools 0.12.1", + "proc-macro2", + "quote", + "syn 2.0.90", +] + +[[package]] +name = "prost-derive" +version = "0.13.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "157c5a9d7ea5c2ed2d9fb8f495b64759f7816c7eaea54ba3978f0d63000162e3" dependencies = [ "anyhow", "itertools 0.13.0", "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] name = "prost-reflect" -version = "0.14.2" +version = "0.14.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "4b7535b02f0e5efe3e1dbfcb428be152226ed0c66cad9541f2274c8ba8d4cd40" +checksum = "20ae544fca2892fd4b7e9ff26cba1090cedf1d4d95c2aded1af15d2f93f270b8" dependencies = [ "once_cell", - "prost 0.13.3", - "prost-types 0.13.3", + "prost 0.13.4", + "prost-types 0.13.4", ] [[package]] @@ -5985,11 +6027,20 @@ dependencies = [ [[package]] name = "prost-types" -version = "0.13.3" +version = "0.12.6" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "4759aa0d3a6232fb8dbdb97b61de2c20047c68aca932c7ed76da9d788508d670" +checksum = "9091c90b0a32608e984ff2fa4091273cbdd755d54935c51d520887f4a1dbd5b0" dependencies = [ - "prost 0.13.3", + "prost 0.12.6", +] + +[[package]] +name = "prost-types" +version = "0.13.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cc2f1e56baa61e93533aebc21af4d2134b70f66275e0fcdf3cbe43d77ff7e8fc" +dependencies = [ + "prost 0.13.4", ] [[package]] @@ -6000,9 +6051,9 @@ checksum = "106dd99e98437432fed6519dedecfade6a06a73bb7b2a1e019fdd2bee5778d94" [[package]] name = "psl" -version = "2.1.59" +version = "2.1.66" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f9b9bc1071e59efa5b4972b584daa069e80d5262ce1309718a2ab20dae5f84ca" +checksum = "59bbcf24d16c12896265cdc98f2b98afb1e62223bc0c396565eaf1c2b6278170" dependencies = [ "psl-types", ] @@ -6067,7 +6118,7 @@ dependencies = [ "openidconnect", "pem 1.1.1", "prost 0.11.9", - "prost-build", + "prost-build 0.11.9", "prost-derive 0.11.9", "rand 0.8.5", "regex", @@ -6158,7 +6209,7 @@ dependencies = [ "serde", "serde_json", "sync_wrapper", - "thiserror", + "thiserror 1.0.69", "tokio", "tracing", ] @@ -6222,7 +6273,7 @@ dependencies = [ "serde_json", "tabled", "tempfile", - "thiserror", + "thiserror 1.0.69", "thousands", "tikv-jemalloc-ctl", "tikv-jemallocator", @@ -6255,7 +6306,7 @@ dependencies = [ "time", "tokio", "tokio-stream", - "tonic", + "tonic 0.11.0", "tracing", "utoipa", ] @@ -6266,13 +6317,13 @@ version = "0.8.0" dependencies = [ "anyhow", "futures", - "heck 0.4.1", + "heck 0.5.0", "prettyplease 0.2.25", "proc-macro2", - "prost-build", + "prost-build 0.12.6", "quote", "serde", - "syn 2.0.89", + "syn 2.0.90", "tonic-build", ] @@ -6286,16 +6337,16 @@ dependencies = [ "futures", "http 0.2.12", "mockall", - "prost 0.11.9", + "prost 0.12.6", "quickwit-actors", "quickwit-codegen", "quickwit-common", "quickwit-proto", "serde", - "thiserror", + "thiserror 1.0.69", "tokio", "tokio-stream", - "tonic", + "tonic 0.11.0", "tower", "utoipa", ] @@ -6314,7 +6365,7 @@ dependencies = [ "fnv", "futures", "home", - "hostname 0.3.1", + "hostname", "http 0.2.12", "hyper 0.14.31", "itertools 0.13.0", @@ -6330,11 +6381,11 @@ dependencies = [ "serde_json", "siphasher", "tempfile", - "thiserror", + "thiserror 1.0.69", "tokio", "tokio-metrics", "tokio-stream", - "tonic", + "tonic 0.11.0", "tower", "tracing", ] @@ -6444,7 +6495,7 @@ dependencies = [ "binggan", "fnv", "hex", - "indexmap 2.6.0", + "indexmap 2.7.0", "itertools 0.13.0", "matches", "nom", @@ -6461,7 +6512,7 @@ dependencies = [ "serde_yaml", "siphasher", "tantivy", - "thiserror", + "thiserror 1.0.69", "time", "tracing", "utoipa", @@ -6481,7 +6532,7 @@ dependencies = [ "quickwit-metastore", "quickwit-proto", "quickwit-storage", - "thiserror", + "thiserror 1.0.69", "time", "tokio", "tracing", @@ -6515,7 +6566,7 @@ dependencies = [ "oneshot", "openssl", "proptest", - "prost 0.11.9", + "prost 0.12.6", "pulsar", "quickwit-actors", "quickwit-aws", @@ -6539,7 +6590,7 @@ dependencies = [ "serde_json", "tantivy", "tempfile", - "thiserror", + "thiserror 1.0.69", "time", "tokio", "tracing", @@ -6563,7 +6614,7 @@ dependencies = [ "mockall", "mrecordlog", "once_cell", - "prost 0.11.9", + "prost 0.12.6", "quickwit-actors", "quickwit-cluster", "quickwit-codegen", @@ -6577,9 +6628,9 @@ dependencies = [ "serde_json", "serde_json_borrow", "tempfile", - "thiserror", + "thiserror 1.0.69", "tokio", - "tonic", + "tonic 0.11.0", "tower", "tracing", "ulid", @@ -6610,7 +6661,7 @@ dependencies = [ "serde_json", "tempfile", "tokio", - "tonic", + "tonic 0.11.0", "tracing", "tracing-subscriber", ] @@ -6622,8 +6673,8 @@ dependencies = [ "async-trait", "itertools 0.13.0", "once_cell", - "prost 0.11.9", - "prost-types 0.11.9", + "prost 0.12.6", + "prost-types 0.12.6", "quickwit-actors", "quickwit-cluster", "quickwit-common", @@ -6643,7 +6694,7 @@ dependencies = [ "time", "tokio", "tokio-stream", - "tonic", + "tonic 0.11.0", "tracing", ] @@ -6672,7 +6723,7 @@ dependencies = [ "serde_json", "tantivy", "tempfile", - "thiserror", + "thiserror 1.0.69", "time", "tokio", "tracing", @@ -6730,7 +6781,7 @@ version = "0.8.0" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -6766,7 +6817,7 @@ dependencies = [ "serial_test", "sqlx", "tempfile", - "thiserror", + "thiserror 1.0.69", "time", "tokio", "tokio-stream", @@ -6785,7 +6836,7 @@ dependencies = [ "async-trait", "hex", "once_cell", - "prost 0.11.9", + "prost 0.12.6", "quickwit-common", "quickwit-config", "quickwit-ingest", @@ -6793,10 +6844,10 @@ dependencies = [ "quickwit-proto", "serde", "serde_json", - "thiserror", + "thiserror 1.0.69", "time", "tokio", - "tonic", + "tonic 0.11.0", "tracing", ] @@ -6814,9 +6865,9 @@ dependencies = [ "http 0.2.12", "mockall", "opentelemetry", - "prost 0.11.9", - "prost-build", - "prost-types 0.11.9", + "prost 0.12.6", + "prost-build 0.12.6", + "prost-types 0.12.6", "quickwit-actors", "quickwit-codegen", "quickwit-common", @@ -6824,9 +6875,9 @@ dependencies = [ "serde", "serde_json", "sqlx", - "thiserror", + "thiserror 1.0.69", "tokio", - "tonic", + "tonic 0.11.0", "tonic-build", "tower", "tracing", @@ -6855,7 +6906,7 @@ dependencies = [ "serde_json", "serde_with 3.11.0", "tantivy", - "thiserror", + "thiserror 1.0.69", "time", "whichlang", ] @@ -6877,7 +6928,7 @@ dependencies = [ "reqwest", "serde", "serde_json", - "thiserror", + "thiserror 1.0.69", "tokio", "tracing", "wiremock", @@ -6901,7 +6952,7 @@ dependencies = [ "once_cell", "postcard", "proptest", - "prost 0.11.9", + "prost 0.12.6", "quickwit-common", "quickwit-config", "quickwit-directories", @@ -6917,7 +6968,7 @@ dependencies = [ "serde", "serde_json", "tantivy", - "thiserror", + "thiserror 1.0.69", "tokio", "tokio-stream", "tower", @@ -6953,8 +7004,8 @@ dependencies = [ "opentelemetry", "percent-encoding", "pprof", - "prost 0.11.9", - "prost-types 0.11.9", + "prost 0.12.6", + "prost-types 0.12.6", "quickwit-actors", "quickwit-cluster", "quickwit-common", @@ -6980,11 +7031,11 @@ dependencies = [ "serde_qs 0.12.0", "serde_with 3.11.0", "tempfile", - "thiserror", + "thiserror 1.0.69", "time", "tokio", "tokio-stream", - "tonic", + "tonic 0.11.0", "tower", "tower-http", "tracing", @@ -7032,7 +7083,7 @@ dependencies = [ "serde_json", "tantivy", "tempfile", - "thiserror", + "thiserror 1.0.69", "tokio", "tokio-stream", "tokio-util", @@ -7047,7 +7098,7 @@ version = "0.8.0" dependencies = [ "async-trait", "encoding_rs", - "hostname 0.3.1", + "hostname", "md5", "once_cell", "quickwit-common", @@ -7220,14 +7271,14 @@ dependencies = [ [[package]] name = "rdkafka-sys" -version = "4.7.0+2.3.0" +version = "4.8.0+2.3.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "55e0d2f9ba6253f6ec72385e453294f8618e9e15c2c6aba2a5c01ccf9622d615" +checksum = "ced38182dc436b3d9df0c77976f37a67134df26b050df1f0006688e46fc4c8be" dependencies = [ "cmake", "libc", "libz-sys", - "num_enum 0.5.11", + "num_enum 0.7.3", "openssl-sys", "pkg-config", "sasl2-sys", @@ -7251,7 +7302,7 @@ checksum = "ba009ff324d1fc1b900bd1fdb31564febe58a8ccc8a6fdbb93b543d33b13ca43" dependencies = [ "getrandom 0.2.15", "libredox", - "thiserror", + "thiserror 1.0.69", ] [[package]] @@ -7490,9 +7541,9 @@ checksum = "6c20b6793b5c2fa6553b250154b78d6d0db37e72700ae35fad9387a46f487c97" [[package]] name = "rsa" -version = "0.9.6" +version = "0.9.7" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5d0e5124fcb30e76a7e79bfee683a2746db83784b86289f6251b54b7950a0dfc" +checksum = "47c75d7c5c6b673e58bf54d8544a9f432e3a925b0e80f7cd3602ab5c50c55519" dependencies = [ "const-oid", "digest", @@ -7529,7 +7580,7 @@ dependencies = [ "proc-macro2", "quote", "rust-embed-utils", - "syn 2.0.89", + "syn 2.0.90", "walkdir", ] @@ -7583,9 +7634,9 @@ checksum = "08d43f7aa6b08d49f382cde6a7982047c3426db949b1424bc4b7ec9ae12c6ce2" [[package]] name = "rustc-hash" -version = "2.0.0" +version = "2.1.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "583034fd73374156e66797ed8e5b0d5690409c9226b22d87cb7f19821c05d152" +checksum = "c7fb8039b3032c191086b10f11f319a6e99e1e82889c5cc6046f515c9db1d497" [[package]] name = "rustc_version" @@ -7598,15 +7649,15 @@ dependencies = [ [[package]] name = "rustix" -version = "0.38.41" +version = "0.38.42" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "d7f649912bc1495e167a6edee79151c84b1bad49748cb4f1f1167f459f6224f6" +checksum = "f93dc38ecbab2eb790ff964bb77fa94faf256fd3e73285fd7ba0903b76bedb85" dependencies = [ "bitflags 2.6.0", "errno", "libc", "linux-raw-sys", - "windows-sys 0.52.0", + "windows-sys 0.59.0", ] [[package]] @@ -7809,8 +7860,8 @@ dependencies = [ "heck 0.4.1", "proc-macro2", "quote", - "syn 2.0.89", - "thiserror", + "syn 2.0.90", + "thiserror 1.0.69", ] [[package]] @@ -7895,7 +7946,7 @@ checksum = "ad1e866f866923f252f05c889987993144fb74e722403468a4ebd70c3cd756c0" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -7914,7 +7965,7 @@ version = "1.0.133" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "c7fceb2473b9166b2294ef05efcb65a3db80803f0b03ef86a5fc88a2b85ee377" dependencies = [ - "indexmap 2.6.0", + "indexmap 2.7.0", "itoa", "memchr", "ryu", @@ -7958,7 +8009,7 @@ checksum = "c7715380eec75f029a4ef7de39a9200e0a63823176b759d055b613f5a87df6a6" dependencies = [ "percent-encoding", "serde", - "thiserror", + "thiserror 1.0.69", ] [[package]] @@ -7970,7 +8021,7 @@ dependencies = [ "futures", "percent-encoding", "serde", - "thiserror", + "thiserror 1.0.69", "tracing", "warp", ] @@ -8016,7 +8067,7 @@ dependencies = [ "chrono", "hex", "indexmap 1.9.3", - "indexmap 2.6.0", + "indexmap 2.7.0", "serde", "serde_derive", "serde_json", @@ -8045,7 +8096,7 @@ dependencies = [ "darling 0.20.10", "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -8054,7 +8105,7 @@ version = "0.9.34+deprecated" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "6a8b1a1a2ebf674015cc02edccce75287f1a0130d394307b36743c2f5d504b47" dependencies = [ - "indexmap 2.6.0", + "indexmap 2.7.0", "itoa", "ryu", "serde", @@ -8084,7 +8135,7 @@ checksum = "5d69265a08751de7844521fd15003ae0a888e035773ba05695c5c759a6f89eef" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -8204,7 +8255,7 @@ checksum = "adc4e5204eb1910f40f9cfa375f6f05b68c3abac4b6fd879c8ff5e7ae8a0a085" dependencies = [ "num-bigint", "num-traits", - "thiserror", + "thiserror 1.0.69", "time", ] @@ -8278,7 +8329,7 @@ dependencies = [ "heck 0.5.0", "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -8289,9 +8340,9 @@ checksum = "1b6b67fb9a61334225b5b790716f609cd58395f895b3fe8b328786812a40bc3b" [[package]] name = "socket2" -version = "0.5.7" +version = "0.5.8" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ce305eb0b4296696835b71df73eb912e0f1ffd2556a501fcede6e0c50349191c" +checksum = "c970269d99b64e60ec3bd6ad27270092a5394c4e309314b18ae3fe575695fbe8" dependencies = [ "libc", "windows-sys 0.52.0", @@ -8376,7 +8427,7 @@ dependencies = [ "futures-util", "hashlink", "hex", - "indexmap 2.6.0", + "indexmap 2.7.0", "log", "memchr", "once_cell", @@ -8389,7 +8440,7 @@ dependencies = [ "sha2", "smallvec", "sqlformat", - "thiserror", + "thiserror 1.0.69", "time", "tokio", "tokio-stream", @@ -8474,7 +8525,7 @@ dependencies = [ "smallvec", "sqlx-core", "stringprep", - "thiserror", + "thiserror 1.0.69", "time", "tracing", "whoami", @@ -8513,7 +8564,7 @@ dependencies = [ "smallvec", "sqlx-core", "stringprep", - "thiserror", + "thiserror 1.0.69", "time", "tracing", "whoami", @@ -8614,9 +8665,9 @@ checksum = "13c2bddecc57b384dee18652358fb23172facb8a2c51ccc10d74c157bdea3292" [[package]] name = "symbolic-common" -version = "12.12.1" +version = "12.12.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3d4d73159efebfb389d819fd479afb2dbd57dcb3e3f4b7fcfa0e675f5a46c1cb" +checksum = "e5ba5365997a4e375660bed52f5b42766475d5bc8ceb1bb13fea09c469ea0f49" dependencies = [ "debugid", "memmap2", @@ -8626,9 +8677,9 @@ dependencies = [ [[package]] name = "symbolic-demangle" -version = "12.12.1" +version = "12.12.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a767859f6549c665011970874c3f541838b4835d5aaaa493d3ee383918be9f10" +checksum = "beff338b2788519120f38c59ff4bb15174f52a183e547bac3d6072c2c0aa48aa" dependencies = [ "cpp_demangle", "rustc-demangle", @@ -8648,9 +8699,9 @@ dependencies = [ [[package]] name = "syn" -version = "2.0.89" +version = "2.0.90" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "44d46482f1c1c87acd84dea20c1bf5ebff4c757009ed6bf19cfd36fb10e92c4e" +checksum = "919d3b74a5dd0ccd15aeb8f93e7006bd9e14c295087c9896a110f490752bcf31" dependencies = [ "proc-macro2", "quote", @@ -8671,7 +8722,7 @@ checksum = "c8af7666ab7b6390ab78131fb5b0fce11d6b7a6951602017c35fa82800708971" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -8783,7 +8834,7 @@ dependencies = [ "tantivy-stacker", "tantivy-tokenizer-api", "tempfile", - "thiserror", + "thiserror 1.0.69", "time", "uuid", "winapi 0.3.9", @@ -8897,7 +8948,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "28cce251fcbc87fac86a866eeb0d6c2d536fc16d06f184bb61aeae11aa4cee0c" dependencies = [ "cfg-if", - "fastrand 2.2.0", + "fastrand 2.3.0", "once_cell", "rustix", "windows-sys 0.59.0", @@ -8935,7 +8986,16 @@ version = "1.0.69" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "b6aaf5339b578ea85b50e080feb250a3e8ae8cfcdff9a461c9ec2904bc923f52" dependencies = [ - "thiserror-impl", + "thiserror-impl 1.0.69", +] + +[[package]] +name = "thiserror" +version = "2.0.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "8fec2a1820ebd077e2b90c4df007bebf344cd394098a13c563957d0afc83ea47" +dependencies = [ + "thiserror-impl 2.0.6", ] [[package]] @@ -8946,7 +9006,18 @@ checksum = "4fee6c4efc90059e10f81e6d42c60a18f76588c3d74cb83a0b242a2b6c7504c1" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", +] + +[[package]] +name = "thiserror-impl" +version = "2.0.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d65750cab40f4ff1929fb1ba509e9914eb756131cef4210da8d5d700d26f6312" +dependencies = [ + "proc-macro2", + "quote", + "syn 2.0.90", ] [[package]] @@ -8998,9 +9069,9 @@ dependencies = [ [[package]] name = "time" -version = "0.3.36" +version = "0.3.37" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5dfd88e563464686c916c7e46e623e520ddc6d79fa6641390f2e3fa86e83e885" +checksum = "35e7868883861bd0e56d9ac6efcaaca0d6d5d82a2a7ec8209ff492c07cf37b21" dependencies = [ "deranged", "itoa", @@ -9025,15 +9096,15 @@ version = "0.3.8" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "78bfd61bca99323ce96911bd2c443259115460615e44f1d449cee8cb3831a1dd" dependencies = [ - "thiserror", + "thiserror 1.0.69", "time", ] [[package]] name = "time-macros" -version = "0.2.18" +version = "0.2.19" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "3f252a68540fde3a3877aeea552b832b40ab9a69e318efd078774a01ddee1ccf" +checksum = "2834e6017e3e5e4b9834939793b282bc03b37a3336245fa820e35e233e2a85de" dependencies = [ "num-conv", "time-core", @@ -9085,9 +9156,9 @@ checksum = "1f3ccbac311fea05f86f61904b462b55fb3df8837a366dfc601a0161d0532f20" [[package]] name = "tokio" -version = "1.41.1" +version = "1.42.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "22cfb5bee7a6a52939ca9224d6ac897bb669134078daa8735560897f69de4d33" +checksum = "5cec9b21b0450273377fc97bd4c33a8acffc8c996c987a7c5b319a0083707551" dependencies = [ "backtrace", "bytes", @@ -9120,7 +9191,7 @@ checksum = "693d596312e88961bc67d7f1f97af8a70227d9f90c31bba5806eec004978d752" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] @@ -9168,9 +9239,9 @@ dependencies = [ [[package]] name = "tokio-stream" -version = "0.1.16" +version = "0.1.17" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "4f4e6ce100d0eb49a2734f8c0812bcd324cf357d21810932c5df6b96ef2b86f1" +checksum = "eca58d7bba4a75707817a2c44174253f9236b2d5fbd055602e9d5c07c139a047" dependencies = [ "futures-core", "pin-project-lite", @@ -9192,9 +9263,9 @@ dependencies = [ [[package]] name = "tokio-util" -version = "0.7.12" +version = "0.7.13" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "61e7c3654c13bcd040d4a03abee2c75b1d14a37b423cf5a813ceae1cc903ec6a" +checksum = "d7fcaa8d55a2bdd6b83ace262b016eca0d79ee02818c5c1bcdf0305114081078" dependencies = [ "bytes", "futures-core", @@ -9234,7 +9305,7 @@ version = "0.19.15" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "1b5bb770da30e5cbfde35a2d7b9b8a2c4b8ef89548a7a6aeab5c9a576e3e7421" dependencies = [ - "indexmap 2.6.0", + "indexmap 2.7.0", "serde", "serde_spanned", "toml_datetime", @@ -9247,7 +9318,7 @@ version = "0.22.22" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "4ae48d6208a266e853d946088ed816055e556cc6028c5e8e2b84d9fa5dd7c7f5" dependencies = [ - "indexmap 2.6.0", + "indexmap 2.7.0", "toml_datetime", "winnow 0.6.20", ] @@ -9285,17 +9356,45 @@ dependencies = [ "webpki-roots 0.23.1", ] +[[package]] +name = "tonic" +version = "0.11.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "76c4eb7a4e9ef9d4763600161f12f5070b92a578e1b634db88a6887844c91a13" +dependencies = [ + "async-stream", + "async-trait", + "axum", + "base64 0.21.7", + "bytes", + "flate2", + "h2", + "http 0.2.12", + "http-body 0.4.6", + "hyper 0.14.31", + "hyper-timeout", + "percent-encoding", + "pin-project", + "prost 0.12.6", + "tokio", + "tokio-stream", + "tower", + "tower-layer", + "tower-service", + "tracing", +] + [[package]] name = "tonic-build" -version = "0.9.2" +version = "0.11.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "a6fdaae4c2c638bb70fe42803a26fbd6fc6ac8c72f5c59f67ecc2a2dcabf4b07" +checksum = "be4ef6dd70a610078cb4e338a0f79d06bc759ff1b22d2120c2ff02ae264ba9c2" dependencies = [ - "prettyplease 0.1.25", + "prettyplease 0.2.25", "proc-macro2", - "prost-build", + "prost-build 0.12.6", "quote", - "syn 1.0.109", + "syn 2.0.90", ] [[package]] @@ -9353,9 +9452,9 @@ checksum = "8df9b6e13f2d32c91b9bd719c00d1958837bc7dec474d94952798cc8e69eeec3" [[package]] name = "tracing" -version = "0.1.40" +version = "0.1.41" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c3523ab5a71916ccf420eebdf5521fcef02141234bbc0b8a49f2fdc4544364ef" +checksum = "784e0ac535deb450455cbfa28a6f0df145ea1bb7ae51b821cf5e7927fdcfbdd0" dependencies = [ "log", "pin-project-lite", @@ -9365,20 +9464,20 @@ dependencies = [ [[package]] name = "tracing-attributes" -version = "0.1.27" +version = "0.1.28" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "34704c8d6ebcbc939824180af020566b01a7c01f80641264eba0999f6c2b6be7" +checksum = "395ae124c09f9e6918a2310af6038fba074bcf474ac352496d5910dd59a2226d" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] name = "tracing-core" -version = "0.1.32" +version = "0.1.33" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c06d3da6113f116aaee68e4d601191614c9053067f9ab7f6edbcb161237daa54" +checksum = "e672c95779cf947c5311f83787af4fa8fffd12fb27e4993211a84bdfd9610f9c" dependencies = [ "once_cell", "valuable", @@ -9422,9 +9521,9 @@ dependencies = [ [[package]] name = "tracing-serde" -version = "0.1.3" +version = "0.2.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "bc6b213177105856957181934e4920de57730fc69bf42c37ee5bb664d406d9e1" +checksum = "704b1aeb7be0d0a84fc9828cae51dab5970fee5088f83d1dd7ee6f6246fc6ff1" dependencies = [ "serde", "tracing-core", @@ -9432,9 +9531,9 @@ dependencies = [ [[package]] name = "tracing-subscriber" -version = "0.3.18" +version = "0.3.19" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ad0f048c97dbd9faa9b7df56362b8ebcaa52adb06b498c050d2f4e32f90a7a8b" +checksum = "e8189decb5ac0fa7bc8b96b7cb9b2701d60d48805aca84a238004d665fcc4008" dependencies = [ "matchers", "nu-ansi-term", @@ -9482,12 +9581,12 @@ dependencies = [ "byteorder", "bytes", "data-encoding", - "http 1.1.0", + "http 1.2.0", "httparse", "log", "rand 0.8.5", "sha1", - "thiserror", + "thiserror 1.0.69", "url", "utf-8", ] @@ -9697,7 +9796,7 @@ version = "4.2.3" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "c5afb1a60e207dca502682537fefcfd9921e71d0b83e9576060f09abc6efab23" dependencies = [ - "indexmap 2.6.0", + "indexmap 2.7.0", "serde", "serde_json", "utoipa-gen", @@ -9712,7 +9811,7 @@ dependencies = [ "proc-macro-error", "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", "ulid", ] @@ -9781,10 +9880,10 @@ dependencies = [ "grok", "hex", "hmac", - "hostname 0.4.0", + "hostname", "iana-time-zone", "idna 0.5.0", - "indexmap 2.6.0", + "indexmap 2.7.0", "indoc", "influxdb-line-protocol", "itertools 0.13.0", @@ -9801,7 +9900,7 @@ dependencies = [ "percent-encoding", "pest", "pest_derive", - "prost 0.13.3", + "prost 0.13.4", "prost-reflect", "psl", "psl-types", @@ -9822,7 +9921,7 @@ dependencies = [ "strip-ansi-escapes", "syslog_loose", "termcolor", - "thiserror", + "thiserror 1.0.69", "tokio", "tracing", "uaparser", @@ -9963,9 +10062,9 @@ dependencies = [ [[package]] name = "wasm-bindgen" -version = "0.2.95" +version = "0.2.99" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "128d1e363af62632b8eb57219c8fd7877144af57558fb2ef0368d0087bddeb2e" +checksum = "a474f6281d1d70c17ae7aa6a613c87fce69a127e2624002df63dcb39d6cf6396" dependencies = [ "cfg-if", "once_cell", @@ -9974,36 +10073,36 @@ dependencies = [ [[package]] name = "wasm-bindgen-backend" -version = "0.2.95" +version = "0.2.99" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "cb6dd4d3ca0ddffd1dd1c9c04f94b868c37ff5fac97c30b97cff2d74fce3a358" +checksum = "5f89bb38646b4f81674e8f5c3fb81b562be1fd936d84320f3264486418519c79" dependencies = [ "bumpalo", "log", - "once_cell", "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", "wasm-bindgen-shared", ] [[package]] name = "wasm-bindgen-futures" -version = "0.4.45" +version = "0.4.49" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "cc7ec4f8827a71586374db3e87abdb5a2bb3a15afed140221307c3ec06b1f63b" +checksum = "38176d9b44ea84e9184eff0bc34cc167ed044f816accfe5922e54d84cf48eca2" dependencies = [ "cfg-if", "js-sys", + "once_cell", "wasm-bindgen", "web-sys", ] [[package]] name = "wasm-bindgen-macro" -version = "0.2.95" +version = "0.2.99" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "e79384be7f8f5a9dd5d7167216f022090cf1f9ec128e6e6a482a2cb5c5422c56" +checksum = "2cc6181fd9a7492eef6fef1f33961e3695e4579b9872a6f7c83aee556666d4fe" dependencies = [ "quote", "wasm-bindgen-macro-support", @@ -10011,22 +10110,22 @@ dependencies = [ [[package]] name = "wasm-bindgen-macro-support" -version = "0.2.95" +version = "0.2.99" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "26c6ab57572f7a24a4985830b120de1594465e5d500f24afe89e16b4e833ef68" +checksum = "30d7a95b763d3c45903ed6c81f156801839e5ee968bb07e534c44df0fcd330c2" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", "wasm-bindgen-backend", "wasm-bindgen-shared", ] [[package]] name = "wasm-bindgen-shared" -version = "0.2.95" +version = "0.2.99" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "65fc09f10666a9f147042251e0dda9c18f166ff7de300607007e96bdebc1068d" +checksum = "943aab3fdaaa029a6e0271b35ea10b72b943135afe9bffca82384098ad0e06a6" [[package]] name = "wasm-streams" @@ -10043,9 +10142,9 @@ dependencies = [ [[package]] name = "web-sys" -version = "0.3.72" +version = "0.3.76" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "f6488b90108c040df0fe62fa815cbdee25124641df01814dd7282749234c6112" +checksum = "04dd7223427d52553d3702c004d3b2fe07c148165faa56313cb00211e31c12bc" dependencies = [ "js-sys", "wasm-bindgen", @@ -10428,9 +10527,9 @@ dependencies = [ [[package]] name = "yoke" -version = "0.7.4" +version = "0.7.5" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6c5b1314b079b0930c31e3af543d8ee1757b1951ae1e1565ec704403a7240ca5" +checksum = "120e6aef9aa629e3d4f52dc8cc43a015c7724194c97dfaf45180d2daf2b77f40" dependencies = [ "serde", "stable_deref_trait", @@ -10440,13 +10539,13 @@ dependencies = [ [[package]] name = "yoke-derive" -version = "0.7.4" +version = "0.7.5" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "28cc31741b18cb6f1d5ff12f5b7523e3d6eb0852bbbad19d73905511d9849b95" +checksum = "2380878cad4ac9aac1e2435f3eb4020e8374b5f13c296cb75b4620ff8e229154" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", "synstructure", ] @@ -10468,27 +10567,27 @@ checksum = "fa4f8080344d4671fb4e831a13ad1e68092748387dfc4f55e356242fae12ce3e" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] name = "zerofrom" -version = "0.1.4" +version = "0.1.5" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "91ec111ce797d0e0784a1116d0ddcdbea84322cd79e5d5ad173daeba4f93ab55" +checksum = "cff3ee08c995dee1859d998dea82f7374f2826091dd9cd47def953cae446cd2e" dependencies = [ "zerofrom-derive", ] [[package]] name = "zerofrom-derive" -version = "0.1.4" +version = "0.1.5" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "0ea7b4a3637ea8669cedf0f1fd5c286a17f3de97b8dd5a70a6c167a1730e63a5" +checksum = "595eed982f7d355beb85837f651fa22e90b3c044842dc7f2c2842c086f295808" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", "synstructure", ] @@ -10517,7 +10616,7 @@ checksum = "6eafa6dfb17584ea3e2bd6e76e0cc15ad7af12b09abdd1ca55961bed9b1063c6" dependencies = [ "proc-macro2", "quote", - "syn 2.0.89", + "syn 2.0.90", ] [[package]] diff --git a/quickwit/Cargo.toml b/quickwit/Cargo.toml index c3e3051470c..3ad92866f15 100644 --- a/quickwit/Cargo.toml +++ b/quickwit/Cargo.toml @@ -89,7 +89,7 @@ base64 = "0.22" binggan = { version = "0.14" } bytes = { version = "1", features = ["serde"] } bytesize = { version = "1.3.0", features = ["serde"] } -bytestring = "1.3.0" +bytestring = "1.4" chitchat = { git = "https://github.com/quickwit-oss/chitchat.git", rev = "54cbc70" } chrono = { version = "0.4", default-features = false, features = [ "clock", @@ -117,12 +117,12 @@ google-cloud-auth = "0.12.0" google-cloud-gax = "0.15.0" google-cloud-googleapis = { version = "0.10.0", features = ["pubsub"] } google-cloud-pubsub = "0.18.0" -heck = "0.4.1" +heck = "0.5" hex = "0.4.3" home = "0.5.4" -hostname = "0.3" -http = "0.2.9" -http-serde = "1.1.2" +hostname = "0.4" +http = "0.2" +http-serde = "1.1" humantime = "2.1.0" hyper = { version = "0.14", features = [ "client", @@ -133,7 +133,7 @@ hyper = { version = "0.14", features = [ "tcp", ] } hyper-rustls = "0.24" -indexmap = { version = "2.1.0", features = ["serde"] } +indexmap = { version = "2.7", features = ["serde"] } indicatif = "0.17.3" itertools = "0.13" json_comments = "0.2" @@ -167,7 +167,7 @@ ouroboros = "0.18.0" percent-encoding = "2.3.1" pin-project = "1.1.0" pnet = { version = "0.33.0", features = ["std"] } -postcard = { version = "1.0.4", features = [ +postcard = { version = "1.1", features = [ "use-std", ], default-features = false } predicates = "3" @@ -176,11 +176,11 @@ pprof = { version = "0.13", features = ["flamegraph"] } proc-macro2 = "1.0.50" prometheus = { version = "0.13", features = ["process"] } proptest = "1" -prost = { version = "0.11.6", default-features = false, features = [ +prost = { version = "0.12", default-features = false, features = [ "prost-derive", ] } -prost-build = "0.11.6" -prost-types = "0.11.6" +prost-build = "0.12" +prost-types = "0.12" pulsar = { version = "5.1.1", default-features = false, features = [ "auth-oauth2", "compression", @@ -216,7 +216,7 @@ serde_json_borrow = "0.5" serde_qs = { version = "0.12", features = ["warp"] } serde_with = "3.9.0" serde_yaml = "0.9" -serial_test = { version = "3.1.1", features = ["file_locks"] } +serial_test = { version = "3.2", features = ["file_locks"] } siphasher = "0.3" smallvec = "1" sqlx = { version = "0.7", features = [ @@ -239,8 +239,8 @@ tokio-metrics = { version = "0.3.1", features = ["rt"] } tokio-stream = { version = "0.1", features = ["sync"] } tokio-util = { version = "0.7", features = ["full"] } toml = "0.7.6" -tonic = { version = "0.9.0", features = ["gzip"] } -tonic-build = "0.9.0" +tonic = { version = "0.11", features = ["gzip"] } +tonic-build = "0.11" tower = { version = "0.4.13", features = [ "balance", "buffer", @@ -281,7 +281,7 @@ aws-config = "1.5.4" aws-credential-types = { version = "1.2", features = ["hardcoded-credentials"] } aws-runtime = "1.3.1" aws-sdk-kinesis = "1.37" -aws-sdk-s3 = "1.42" +aws-sdk-s3 = "1.64" aws-sdk-sqs = "1.36" aws-smithy-async = "1.2" aws-smithy-runtime = "1.6.2" diff --git a/quickwit/quickwit-codegen/example/src/codegen/hello.rs b/quickwit/quickwit-codegen/example/src/codegen/hello.rs index 93b9b634ce7..9b2609a0f03 100644 --- a/quickwit/quickwit-codegen/example/src/codegen/hello.rs +++ b/quickwit/quickwit-codegen/example/src/codegen/hello.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize, utoipa::ToSchema)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -1012,7 +1013,7 @@ pub mod hello_grpc_server { request: tonic::Request, ) -> std::result::Result, tonic::Status>; /// Server streaming response type for the Ping method. - type PingStream: futures_core::Stream< + type PingStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result, > + Send @@ -1117,7 +1118,9 @@ pub mod hello_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).hello(request).await }; + let fut = async move { + ::hello(&inner, request).await + }; Box::pin(fut) } } @@ -1159,7 +1162,9 @@ pub mod hello_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).goodbye(request).await }; + let fut = async move { + ::goodbye(&inner, request).await + }; Box::pin(fut) } } @@ -1204,7 +1209,9 @@ pub mod hello_grpc_server { request: tonic::Request>, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).ping(request).await }; + let fut = async move { + ::ping(&inner, request).await + }; Box::pin(fut) } } diff --git a/quickwit/quickwit-common/src/net.rs b/quickwit/quickwit-common/src/net.rs index cea456e8cb8..ab38cb37e7d 100644 --- a/quickwit/quickwit-common/src/net.rs +++ b/quickwit/quickwit-common/src/net.rs @@ -171,10 +171,7 @@ impl HostAddr { (host_addr, default_port) }; if !is_valid_hostname(hostname) { - bail!( - "failed to parse address `{}`: hostname is invalid", - host_addr - ) + bail!("failed to parse address `{host_addr}`: hostname is invalid") } Ok(Self { host: Host::Hostname(hostname.to_string()), diff --git a/quickwit/quickwit-ingest/src/codegen/ingest_service.rs b/quickwit/quickwit-ingest/src/codegen/ingest_service.rs index ac03fd52faf..6658d8bc0e0 100644 --- a/quickwit/quickwit-ingest/src/codegen/ingest_service.rs +++ b/quickwit/quickwit-ingest/src/codegen/ingest_service.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize, utoipa::ToSchema)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -1215,7 +1216,9 @@ pub mod ingest_service_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).ingest(request).await }; + let fut = async move { + ::ingest(&inner, request).await + }; Box::pin(fut) } } @@ -1258,7 +1261,9 @@ pub mod ingest_service_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).fetch(request).await }; + let fut = async move { + ::fetch(&inner, request).await + }; Box::pin(fut) } } @@ -1301,7 +1306,9 @@ pub mod ingest_service_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).tail(request).await }; + let fut = async move { + ::tail(&inner, request).await + }; Box::pin(fut) } } diff --git a/quickwit/quickwit-proto/src/codegen/jaeger/jaeger.api_v2.rs b/quickwit/quickwit-proto/src/codegen/jaeger/jaeger.api_v2.rs index b34d2868413..9ff27c0fda5 100644 --- a/quickwit/quickwit-proto/src/codegen/jaeger/jaeger.api_v2.rs +++ b/quickwit/quickwit-proto/src/codegen/jaeger/jaeger.api_v2.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct KeyValue { diff --git a/quickwit/quickwit-proto/src/codegen/jaeger/jaeger.storage.v1.rs b/quickwit/quickwit-proto/src/codegen/jaeger/jaeger.storage.v1.rs index 71850d64a7f..60f0ac3e1d9 100644 --- a/quickwit/quickwit-proto/src/codegen/jaeger/jaeger.storage.v1.rs +++ b/quickwit/quickwit-proto/src/codegen/jaeger/jaeger.storage.v1.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] pub struct GetDependenciesRequest { @@ -1213,7 +1214,9 @@ pub mod span_writer_plugin_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).write_span(request).await }; + let fut = async move { + ::write_span(&inner, request).await + }; Box::pin(fut) } } @@ -1257,7 +1260,9 @@ pub mod span_writer_plugin_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).close(request).await }; + let fut = async move { + ::close(&inner, request).await + }; Box::pin(fut) } } @@ -1440,7 +1445,11 @@ pub mod streaming_span_writer_plugin_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).write_span_stream(request).await + ::write_span_stream( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -1518,7 +1527,7 @@ pub mod span_reader_plugin_server { #[async_trait] pub trait SpanReaderPlugin: Send + Sync + 'static { /// Server streaming response type for the GetTrace method. - type GetTraceStream: futures_core::Stream< + type GetTraceStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result, > + Send @@ -1543,7 +1552,7 @@ pub mod span_reader_plugin_server { tonic::Status, >; /// Server streaming response type for the FindTraces method. - type FindTracesStream: futures_core::Stream< + type FindTracesStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result, > + Send @@ -1657,7 +1666,9 @@ pub mod span_reader_plugin_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).get_trace(request).await }; + let fut = async move { + ::get_trace(&inner, request).await + }; Box::pin(fut) } } @@ -1702,7 +1713,7 @@ pub mod span_reader_plugin_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).get_services(request).await + ::get_services(&inner, request).await }; Box::pin(fut) } @@ -1748,7 +1759,8 @@ pub mod span_reader_plugin_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).get_operations(request).await + ::get_operations(&inner, request) + .await }; Box::pin(fut) } @@ -1794,7 +1806,9 @@ pub mod span_reader_plugin_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).find_traces(request).await }; + let fut = async move { + ::find_traces(&inner, request).await + }; Box::pin(fut) } } @@ -1839,7 +1853,8 @@ pub mod span_reader_plugin_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).find_trace_i_ds(request).await + ::find_trace_i_ds(&inner, request) + .await }; Box::pin(fut) } @@ -2022,7 +2037,11 @@ pub mod archive_span_writer_plugin_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).write_archive_span(request).await + ::write_archive_span( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -2100,7 +2119,7 @@ pub mod archive_span_reader_plugin_server { #[async_trait] pub trait ArchiveSpanReaderPlugin: Send + Sync + 'static { /// Server streaming response type for the GetArchiveTrace method. - type GetArchiveTraceStream: futures_core::Stream< + type GetArchiveTraceStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result, > + Send @@ -2213,7 +2232,11 @@ pub mod archive_span_reader_plugin_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).get_archive_trace(request).await + ::get_archive_trace( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -2397,7 +2420,11 @@ pub mod dependencies_reader_plugin_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).get_dependencies(request).await + ::get_dependencies( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -2579,7 +2606,8 @@ pub mod plugin_capabilities_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).capabilities(request).await + ::capabilities(&inner, request) + .await }; Box::pin(fut) } diff --git a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.logs.v1.rs b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.logs.v1.rs index 7c35915e03c..60174e2412c 100644 --- a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.logs.v1.rs +++ b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.logs.v1.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -293,7 +294,9 @@ pub mod logs_service_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).export(request).await }; + let fut = async move { + ::export(&inner, request).await + }; Box::pin(fut) } } diff --git a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.metrics.v1.rs b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.metrics.v1.rs index 53bbe9793cd..25ab3667c77 100644 --- a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.metrics.v1.rs +++ b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.metrics.v1.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -292,7 +293,9 @@ pub mod metrics_service_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).export(request).await }; + let fut = async move { + ::export(&inner, request).await + }; Box::pin(fut) } } diff --git a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.trace.v1.rs b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.trace.v1.rs index b667cb51d41..6696dc648cd 100644 --- a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.trace.v1.rs +++ b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.collector.trace.v1.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -292,7 +293,9 @@ pub mod trace_service_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).export(request).await }; + let fut = async move { + ::export(&inner, request).await + }; Box::pin(fut) } } diff --git a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.common.v1.rs b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.common.v1.rs index abc40cf30e7..739111ffb0a 100644 --- a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.common.v1.rs +++ b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.common.v1.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. /// AnyValue is used to represent any type of attribute value. AnyValue may contain a /// primitive value such as a string or integer or it may contain an arbitrary nested /// object containing arrays, key-value lists and primitives. diff --git a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.logs.v1.rs b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.logs.v1.rs index ba30bf10a0d..f77102438a4 100644 --- a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.logs.v1.rs +++ b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.logs.v1.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. /// LogsData represents the logs data that can be stored in a persistent storage, /// OR can be embedded by other protocols that transfer OTLP logs data but do not /// implement the OTLP protocol. diff --git a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.metrics.v1.rs b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.metrics.v1.rs index 0c2da7bda93..b4e3235bba3 100644 --- a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.metrics.v1.rs +++ b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.metrics.v1.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. /// MetricsData represents the metrics data that can be stored in a persistent /// storage, OR can be embedded by other protocols that transfer OTLP metrics /// data but do not implement the OTLP protocol. @@ -79,7 +80,7 @@ pub struct ScopeMetrics { /// |data |---> |Gauge, Sum, Histogram, Summary, ... | /// +------------+ +------------------------------------+ /// -/// Data [One of Gauge, Sum, Histogram, Summary, ...] +/// Data \[One of Gauge, Sum, Histogram, Summary, ...\] /// +-----------+ /// |... | // Metadata about the Data. /// |points |--+ @@ -569,7 +570,7 @@ pub mod summary_data_point { #[derive(Clone, PartialEq, ::prost::Message)] pub struct ValueAtQuantile { /// The quantile of a distribution. Must be in the interval - /// [0.0, 1.0]. + /// \[0.0, 1.0\]. #[prost(double, tag = "1")] pub quantile: f64, /// The value at the given quantile of a distribution. diff --git a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.resource.v1.rs b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.resource.v1.rs index cca43e3c694..62ef899aa28 100644 --- a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.resource.v1.rs +++ b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.resource.v1.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. /// Resource information. #[derive(serde::Serialize, serde::Deserialize)] #[allow(clippy::derive_partial_eq_without_eq)] diff --git a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.trace.v1.rs b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.trace.v1.rs index abb6ab679e9..77ec7c54a37 100644 --- a/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.trace.v1.rs +++ b/quickwit/quickwit-proto/src/codegen/opentelemetry/opentelemetry.proto.trace.v1.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. /// TracesData represents the traces data that can be stored in a persistent storage, /// OR can be embedded by other protocols that transfer OTLP traces data but do /// not implement the OTLP protocol. diff --git a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.cluster.rs b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.cluster.rs index 38471f0ad7b..ae937267bad 100644 --- a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.cluster.rs +++ b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.cluster.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize, utoipa::ToSchema)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -779,7 +780,11 @@ pub mod cluster_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).fetch_cluster_state(request).await + ::fetch_cluster_state( + &inner, + request, + ) + .await }; Box::pin(fut) } diff --git a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.common.rs b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.common.rs index d33e5dc658c..bedfe7c3503 100644 --- a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.common.rs +++ b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.common.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. /// The corresponding Rust struct \[`crate::types::DocUid`\] is defined manually and /// externally provided during code generation (see `build.rs`). /// diff --git a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.control_plane.rs b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.control_plane.rs index c14ef724de0..c0e480e7db7 100644 --- a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.control_plane.rs +++ b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.control_plane.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize, utoipa::ToSchema)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -2433,7 +2434,11 @@ pub mod control_plane_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).create_index(request).await + ::create_index( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -2482,7 +2487,11 @@ pub mod control_plane_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).update_index(request).await + ::update_index( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -2531,7 +2540,11 @@ pub mod control_plane_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).delete_index(request).await + ::delete_index( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -2579,7 +2592,10 @@ pub mod control_plane_service_grpc_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).add_source(request).await }; + let fut = async move { + ::add_source(&inner, request) + .await + }; Box::pin(fut) } } @@ -2627,7 +2643,11 @@ pub mod control_plane_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).toggle_source(request).await + ::toggle_source( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -2676,7 +2696,11 @@ pub mod control_plane_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).delete_source(request).await + ::delete_source( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -2724,7 +2748,11 @@ pub mod control_plane_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).get_or_create_open_shards(request).await + ::get_or_create_open_shards( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -2770,7 +2798,11 @@ pub mod control_plane_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).advise_reset_shards(request).await + ::advise_reset_shards( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -2819,7 +2851,11 @@ pub mod control_plane_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).prune_shards(request).await + ::prune_shards( + &inner, + request, + ) + .await }; Box::pin(fut) } diff --git a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.developer.rs b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.developer.rs index b05cc01aef8..f39d3712ec3 100644 --- a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.developer.rs +++ b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.developer.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize, utoipa::ToSchema)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -716,7 +717,8 @@ pub mod developer_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).get_debug_info(request).await + ::get_debug_info(&inner, request) + .await }; Box::pin(fut) } diff --git a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.indexing.rs b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.indexing.rs index ae0ef465968..b6665636072 100644 --- a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.indexing.rs +++ b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.indexing.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize, utoipa::ToSchema)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -730,7 +731,11 @@ pub mod indexing_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).apply_indexing_plan(request).await + ::apply_indexing_plan( + &inner, + request, + ) + .await }; Box::pin(fut) } diff --git a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.ingester.rs b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.ingester.rs index ccb13a5e44d..7f9e99013d0 100644 --- a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.ingester.rs +++ b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.ingester.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize, utoipa::ToSchema)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -2706,7 +2707,7 @@ pub mod ingester_service_grpc_server { request: tonic::Request, ) -> std::result::Result, tonic::Status>; /// Server streaming response type for the OpenReplicationStream method. - type OpenReplicationStreamStream: futures_core::Stream< + type OpenReplicationStreamStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result, > + Send @@ -2720,7 +2721,7 @@ pub mod ingester_service_grpc_server { tonic::Status, >; /// Server streaming response type for the OpenFetchStream method. - type OpenFetchStreamStream: futures_core::Stream< + type OpenFetchStreamStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result, > + Send @@ -2735,7 +2736,7 @@ pub mod ingester_service_grpc_server { tonic::Status, >; /// Server streaming response type for the OpenObservationStream method. - type OpenObservationStreamStream: futures_core::Stream< + type OpenObservationStreamStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result, > + Send @@ -2886,7 +2887,9 @@ pub mod ingester_service_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).persist(request).await }; + let fut = async move { + ::persist(&inner, request).await + }; Box::pin(fut) } } @@ -2934,7 +2937,11 @@ pub mod ingester_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).open_replication_stream(request).await + ::open_replication_stream( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -2982,7 +2989,11 @@ pub mod ingester_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).open_fetch_stream(request).await + ::open_fetch_stream( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -3030,7 +3041,11 @@ pub mod ingester_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).open_observation_stream(request).await + ::open_observation_stream( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -3075,7 +3090,10 @@ pub mod ingester_service_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).init_shards(request).await }; + let fut = async move { + ::init_shards(&inner, request) + .await + }; Box::pin(fut) } } @@ -3120,7 +3138,8 @@ pub mod ingester_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).retain_shards(request).await + ::retain_shards(&inner, request) + .await }; Box::pin(fut) } @@ -3166,7 +3185,8 @@ pub mod ingester_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).truncate_shards(request).await + ::truncate_shards(&inner, request) + .await }; Box::pin(fut) } @@ -3212,7 +3232,8 @@ pub mod ingester_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).close_shards(request).await + ::close_shards(&inner, request) + .await }; Box::pin(fut) } @@ -3258,7 +3279,8 @@ pub mod ingester_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).decommission(request).await + ::decommission(&inner, request) + .await }; Box::pin(fut) } diff --git a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.router.rs b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.router.rs index 1f43bd342ca..8a6480ab69b 100644 --- a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.router.rs +++ b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.router.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize, utoipa::ToSchema)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -844,7 +845,10 @@ pub mod ingest_router_service_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).ingest(request).await }; + let fut = async move { + ::ingest(&inner, request) + .await + }; Box::pin(fut) } } diff --git a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.rs b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.rs index 0790c8a7416..d924012aa9e 100644 --- a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.rs +++ b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.ingest.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. /// Shard primary key. #[derive(serde::Serialize, serde::Deserialize, utoipa::ToSchema)] #[allow(clippy::derive_partial_eq_without_eq)] diff --git a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.metastore.rs b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.metastore.rs index 08b12006db3..451eb35e5d3 100644 --- a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.metastore.rs +++ b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.metastore.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. #[derive(serde::Serialize, serde::Deserialize, utoipa::ToSchema)] #[allow(clippy::derive_partial_eq_without_eq)] #[derive(Clone, PartialEq, ::prost::Message)] @@ -6728,7 +6729,7 @@ pub mod metastore_service_grpc_server { request: tonic::Request, ) -> std::result::Result, tonic::Status>; /// Server streaming response type for the ListSplits method. - type ListSplitsStream: futures_core::Stream< + type ListSplitsStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result, > + Send @@ -7044,7 +7045,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).create_index(request).await + ::create_index(&inner, request) + .await }; Box::pin(fut) } @@ -7090,7 +7092,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).update_index(request).await + ::update_index(&inner, request) + .await }; Box::pin(fut) } @@ -7136,7 +7139,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).index_metadata(request).await + ::index_metadata(&inner, request) + .await }; Box::pin(fut) } @@ -7182,7 +7186,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).indexes_metadata(request).await + ::indexes_metadata( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -7228,7 +7236,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).list_indexes_metadata(request).await + ::list_indexes_metadata( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -7274,7 +7286,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).delete_index(request).await + ::delete_index(&inner, request) + .await }; Box::pin(fut) } @@ -7320,7 +7333,10 @@ pub mod metastore_service_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).list_splits(request).await }; + let fut = async move { + ::list_splits(&inner, request) + .await + }; Box::pin(fut) } } @@ -7365,7 +7381,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stage_splits(request).await + ::stage_splits(&inner, request) + .await }; Box::pin(fut) } @@ -7411,7 +7428,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).publish_splits(request).await + ::publish_splits(&inner, request) + .await }; Box::pin(fut) } @@ -7457,7 +7475,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).mark_splits_for_deletion(request).await + ::mark_splits_for_deletion( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -7503,7 +7525,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).delete_splits(request).await + ::delete_splits(&inner, request) + .await }; Box::pin(fut) } @@ -7548,7 +7571,10 @@ pub mod metastore_service_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).add_source(request).await }; + let fut = async move { + ::add_source(&inner, request) + .await + }; Box::pin(fut) } } @@ -7593,7 +7619,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).toggle_source(request).await + ::toggle_source(&inner, request) + .await }; Box::pin(fut) } @@ -7639,7 +7666,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).delete_source(request).await + ::delete_source(&inner, request) + .await }; Box::pin(fut) } @@ -7685,7 +7713,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).reset_source_checkpoint(request).await + ::reset_source_checkpoint( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -7731,7 +7763,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).last_delete_opstamp(request).await + ::last_delete_opstamp( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -7777,7 +7813,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).create_delete_task(request).await + ::create_delete_task( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -7828,7 +7868,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).update_splits_delete_opstamp(request).await + ::update_splits_delete_opstamp( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -7874,7 +7918,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).list_delete_tasks(request).await + ::list_delete_tasks( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -7920,7 +7968,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).list_stale_splits(request).await + ::list_stale_splits( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -7965,7 +8017,10 @@ pub mod metastore_service_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).open_shards(request).await }; + let fut = async move { + ::open_shards(&inner, request) + .await + }; Box::pin(fut) } } @@ -8010,7 +8065,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).acquire_shards(request).await + ::acquire_shards(&inner, request) + .await }; Box::pin(fut) } @@ -8056,7 +8112,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).delete_shards(request).await + ::delete_shards(&inner, request) + .await }; Box::pin(fut) } @@ -8102,7 +8159,8 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).prune_shards(request).await + ::prune_shards(&inner, request) + .await }; Box::pin(fut) } @@ -8147,7 +8205,10 @@ pub mod metastore_service_grpc_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).list_shards(request).await }; + let fut = async move { + ::list_shards(&inner, request) + .await + }; Box::pin(fut) } } @@ -8192,7 +8253,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).create_index_template(request).await + ::create_index_template( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -8238,7 +8303,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).get_index_template(request).await + ::get_index_template( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -8288,7 +8357,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).find_index_template_matches(request).await + ::find_index_template_matches( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -8334,7 +8407,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).list_index_templates(request).await + ::list_index_templates( + &inner, + request, + ) + .await }; Box::pin(fut) } @@ -8380,7 +8457,11 @@ pub mod metastore_service_grpc_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).delete_index_templates(request).await + ::delete_index_templates( + &inner, + request, + ) + .await }; Box::pin(fut) } diff --git a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.search.rs b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.search.rs index 3fc4d5bdcaa..0e12fa7cbd1 100644 --- a/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.search.rs +++ b/quickwit/quickwit-proto/src/codegen/quickwit/quickwit.search.rs @@ -1,3 +1,4 @@ +// This file is @generated by prost-build. /// / Scroll Request #[derive(serde::Serialize, serde::Deserialize, utoipa::ToSchema)] #[allow(clippy::derive_partial_eq_without_eq)] @@ -1293,7 +1294,7 @@ pub mod search_service_server { tonic::Status, >; /// Server streaming response type for the LeafSearchStream method. - type LeafSearchStreamStream: futures_core::Stream< + type LeafSearchStreamStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::LeafSearchStreamResponse, tonic::Status, @@ -1477,7 +1478,9 @@ pub mod search_service_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).root_search(request).await }; + let fut = async move { + ::root_search(&inner, request).await + }; Box::pin(fut) } } @@ -1521,7 +1524,9 @@ pub mod search_service_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).leaf_search(request).await }; + let fut = async move { + ::leaf_search(&inner, request).await + }; Box::pin(fut) } } @@ -1565,7 +1570,9 @@ pub mod search_service_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).fetch_docs(request).await }; + let fut = async move { + ::fetch_docs(&inner, request).await + }; Box::pin(fut) } } @@ -1612,7 +1619,8 @@ pub mod search_service_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).leaf_search_stream(request).await + ::leaf_search_stream(&inner, request) + .await }; Box::pin(fut) } @@ -1658,7 +1666,7 @@ pub mod search_service_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).root_list_terms(request).await + ::root_list_terms(&inner, request).await }; Box::pin(fut) } @@ -1704,7 +1712,7 @@ pub mod search_service_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).leaf_list_terms(request).await + ::leaf_list_terms(&inner, request).await }; Box::pin(fut) } @@ -1749,7 +1757,9 @@ pub mod search_service_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).scroll(request).await }; + let fut = async move { + ::scroll(&inner, request).await + }; Box::pin(fut) } } @@ -1792,7 +1802,9 @@ pub mod search_service_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).put_kv(request).await }; + let fut = async move { + ::put_kv(&inner, request).await + }; Box::pin(fut) } } @@ -1835,7 +1847,9 @@ pub mod search_service_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).get_kv(request).await }; + let fut = async move { + ::get_kv(&inner, request).await + }; Box::pin(fut) } } @@ -1880,7 +1894,7 @@ pub mod search_service_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).report_splits(request).await + ::report_splits(&inner, request).await }; Box::pin(fut) } @@ -1925,7 +1939,9 @@ pub mod search_service_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).list_fields(request).await }; + let fut = async move { + ::list_fields(&inner, request).await + }; Box::pin(fut) } } @@ -1970,7 +1986,8 @@ pub mod search_service_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).leaf_list_fields(request).await + ::leaf_list_fields(&inner, request) + .await }; Box::pin(fut) } @@ -2015,7 +2032,9 @@ pub mod search_service_server { request: tonic::Request, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).search_plan(request).await }; + let fut = async move { + ::search_plan(&inner, request).await + }; Box::pin(fut) } }