Fuzz introspector: fuzz_from_uri
For issues and ideas: https://github.com/ossf/fuzz-introspector/issues

Fuzz blockers

The following nodes represent call sites where fuzz blockers occur.

Amount of callsites blocked Calltree index Parent function Callsite Largest blocked function
2107 92 Operator::from_parts call site: 00092 BytesRange::from_str
142 2277 oio::PooledBuf::new call site: 02277 tests::test_copy_and_rename_route_by_from
85 0 EP call site: 00000 tests::from_uri_with_all_components
72 2203 Operator::from_parts call site: 02203 OperationLabels::encode
1 86 Operator::from_parts call site: 00086
1 88 Operator::from_parts call site: 00088
1 90 Operator::from_parts call site: 00090

Fuzzer calltree

0 fuzz_target [function] [call site] 00000
1 logforth::starter_log::stderr [function] [call site] 00001
1 CapabilityOverrides::try_apply [function] [call site] 00002
2 serde_json::to_value [function] [call site] 00003
2 map_err [function] [call site] 00004
2 Error::new [function] [call site] 00005
3 Reader::read_into [function] [call site] 00006
4 RetryLayer::clone [function] [call site] 00007
5 RetryLayer::clone [function] [call site] 00008
6 RetryLayer::clone [function] [call site] 00009
4 Reader::into_stream [function] [call site] 00010
5 BufferStream::create [function] [call site] 00011
6 Reader::read_into [function] [call site] 00012
7 RetryLayer::clone [function] [call site] 00013
7 Reader::into_stream [function] [call site] 00014
7 Result::try_next [function] [call site] 00015
7 Ok [function] [call site] 00016
7 Buffer::len [function] [call site] 00017
8 Buffer::remaining [function] [call site] 00018
9 Buffer::len [function] [call site] 00019
10 Buffer::remaining [function] [call site] 00020
7 io::Result::put [function] [call site] 00021
6 Operator::presign_stat_options [function] [call site] 00022
7 normalize_path [function] [call site] 00023
8 std::fs::canonicalize [function] [call site] 00024
8 unwrap_or_else [function] [call site] 00025
8 lexical_normalize [function] [call site] 00026
9 Fixture::new [function] [call site] 00027
10 Fixture::new [function] [call site] 00028
11 Fixture::new [function] [call site] 00029
9 tests::from_uri_with_all_components [function] [call site] 00030
10 OperatorUri::new [function] [call site] 00031
11 into_iter [function] [call site] 00032
11 ConfigDeserializer::deserialize_map [function] [call site] 00033
12 V::visit_map [function] [call site] 00034
11 Result::to_ascii_lowercase [function] [call site] 00035
11 into_iter() [call site] 00036
6 .map(|(k, [call site] 00037
6 .collect::<Vec<_>> [function] [call site] 00038
11 HashMap::<String, [call site] 00039
12 Fixture::new [function] [call site] 00040
11 SizeBucket::contains [function] [call site] 00041
12 is_none_or [function] [call site] 00042
11 ImmutableIndexLayer::insert [function] [call site] 00043
12 QueryPairsWriter::push [function] [call site] 00044
13 QueryPairsWriter::push [function] [call site] 00045
13 QueryPairsWriter::push [function] [call site] 00046
13 push_str [function] [call site] 00047
13 Buffer::is_empty [function] [call site] 00048
14 Buffer::len [function] [call site] 00049
13 QueryPairsWriter::push [function] [call site] 00050
13 push_str [function] [call site] 00051
11 RetryLayer::clone [function] [call site] 00052
12 RetryLayer::clone [function] [call site] 00053
11 RetryLayer::clone [function] [call site] 00054
12 RetryLayer::clone [function] [call site] 00055
11 Ok [function] [call site] 00056
11 Self::to_ascii_lowercase [function] [call site] 00057
11 CapabilityOverrides::parse [function] [call site] 00058
12 Fixture::default [function] [call site] 00059
13 Fixture::new [function] [call site] 00060
14 Fixture::new [function] [call site] 00061
12 DeleteInput::split [function] [call site] 00062
12 ConfigDeserializer::deserialize_map [function] [call site] 00063
12 filter [function] [call site] 00064
12 Buffer::is_empty [function] [call site] 00065
13 Buffer::len [function] [call site] 00066
12 parse_capability_override [function] [call site] 00067
13 Self::split_once [function] [call site] 00068
13 Err [function] [call site] 00069
13 invalid_capability_override [function] [call site] 00070
14 Error::new [function] [call site] 00071
13 Ok [function] [call site] 00072
13 Result::trim [function] [call site] 00073
13 parse_capability_value [function] [call site] 00074
14 Ok [function] [call site] 00075
14 Value::Bool [function] [call site] 00076
14 Ok [function] [call site] 00077
14 Value::Bool [function] [call site] 00078
14 Ok [function] [call site] 00079
14 parse::<usize> [function] [call site] 00080
14 ConfigDeserializer::deserialize_map [function] [call site] 00081
14 Value::Number [function] [call site] 00082
14 tests::test_copy_and_rename_route_by_from [function] [call site] 00083
15 tests::build_mock_operator [function] [call site] 00084
16 Operator::from_parts [function] [call site] 00085
17 RetryLayer::clone [function] [call site] 00086
18 RetryLayer::clone [function] [call site] 00087
17 RetryLayer::clone [function] [call site] 00088
18 RetryLayer::clone [function] [call site] 00089
17 Fixture::new [function] [call site] 00090
18 Fixture::new [function] [call site] 00091
17 Fixture::new [function] [call site] 00092
18 Fixture::new [function] [call site] 00093
16 OperationContext::default [function] [call site] 00094
17 Fixture::new [function] [call site] 00095
16 Fixture::new [function] [call site] 00096
16 ServiceInfo::new [function] [call site] 00097
17 tests::test_copy_and_rename_route_by_from [function] [call site] 00098
18 tests::build_mock_operator [function] [call site] 00099
18 tests::build_mock_operator [function] [call site] 00100
18 RetryLayer::clone [function] [call site] 00101
19 RetryLayer::clone [function] [call site] 00102
18 ThrottleLayer::layer [function] [call site] 00103
19 RetryLayer::clone [function] [call site] 00104
18 RouteLayer::builder [function] [call site] 00105
19 Fixture::default [function] [call site] 00106
20 Fixture::new [function] [call site] 00107
18 RouteLayerBuilder::route [function] [call site] 00108
19 Entry::into_parts [function] [call site] 00109
19 QueryPairsWriter::push [function] [call site] 00110
19 OperationLabelNames::as_ref [function] [call site] 00111
19 tests::test_bytes_range_to_string [function] [call site] 00112
20 BytesRange::new [function] [call site] 00113
20 Some [function] [call site] 00114
20 BytesRange::new [function] [call site] 00115
20 BytesRange::new [function] [call site] 00116
20 Some [function] [call site] 00117
20 BytesRange::suffix [function] [call site] 00118
18 RetryLayer::clone [function] [call site] 00119
18 RouteLayerBuilder::build [function] [call site] 00120
19 Fixture::new [function] [call site] 00121
20 Fixture::new [function] [call site] 00122
19 Vec::with_capacity [function] [call site] 00123
19 Buffer::len [function] [call site] 00124
20 Buffer::remaining [function] [call site] 00125
19 Fixture::new [function] [call site] 00126
20 Fixture::new [function] [call site] 00127
19 Self::map_err [function] [call site] 00128
19 Error::new [function] [call site] 00129
19 Error::with_context [function] [call site] 00130
20 QueryPairsWriter::push [function] [call site] 00131
20 tests::test_bytes_range_to_string [function] [call site] 00132
21 BytesRange::new [function] [call site] 00133
21 Some [function] [call site] 00134
21 BytesRange::new [function] [call site] 00135
21 BytesRange::new [function] [call site] 00136
21 Some [function] [call site] 00137
21 BytesRange::suffix [function] [call site] 00138
19 RetryLayer::clone [function] [call site] 00139
19 Error::with_context [function] [call site] 00140
19 tests::test_bytes_range_to_string [function] [call site] 00141
20 BytesRange::new [function] [call site] 00142
20 Some [function] [call site] 00143
20 BytesRange::new [function] [call site] 00144
20 BytesRange::new [function] [call site] 00145
20 Some [function] [call site] 00146
20 BytesRange::suffix [function] [call site] 00147
19 Timestamp::add [function] [call site] 00148
20 checked_add [function] [call site] 00149
20 expect [function] [call site] 00150
20 Timestamp [function] [call site] 00151
19 QueryPairsWriter::push [function] [call site] 00152
19 RouteLayerBuilder::build [function] [call site] 00153
20 Fixture::new [function] [call site] 00154
20 Vec::with_capacity [function] [call site] 00155
20 Buffer::len [function] [call site] 00156
20 Fixture::new [function] [call site] 00157
20 Self::map_err [function] [call site] 00158
20 Error::new [function] [call site] 00159
20 Error::with_context [function] [call site] 00160
20 RetryLayer::clone [function] [call site] 00161
20 Error::with_context [function] [call site] 00162
20 tests::test_bytes_range_to_string [function] [call site] 00163
20 Timestamp::add [function] [call site] 00164
20 QueryPairsWriter::push [function] [call site] 00165
20 RouteLayerBuilder::build [function] [call site] 00166
20 Result::map_err [function] [call site] 00167
20 Error::new [function] [call site] 00168
20 Error::with_context [function] [call site] 00169
20 tests::test_bytes_range_to_string [function] [call site] 00170
20 Ok [function] [call site] 00171
20 Fixture::new [function] [call site] 00172
19 Result::map_err [function] [call site] 00173
19 Error::new [function] [call site] 00174
19 Error::with_context [function] [call site] 00175
19 tests::test_bytes_range_to_string [function] [call site] 00176
19 Ok [function] [call site] 00177
19 Fixture::new [function] [call site] 00178
18 ThrottleAccessor::write [function] [call site] 00179
19 RetryLayer::clone [function] [call site] 00180
19 test_copy_overwrite [function] [call site] 00181
20 uuid::Uuid::new_v4 [function] [call site] 00182
20 tests::test_bytes_range_to_string [function] [call site] 00183
21 BytesRange::new [function] [call site] 00184
21 Some [function] [call site] 00185
21 BytesRange::new [function] [call site] 00186
21 BytesRange::new [function] [call site] 00187
21 Some [function] [call site] 00188
21 BytesRange::suffix [function] [call site] 00189
20 gen_bytes [function] [call site] 00190
21 &mut [call site] 00191
21 Reader::read_into [function] [call site] 00192
22 RetryLayer::clone [function] [call site] 00193
22 Reader::into_stream [function] [call site] 00194
22 Result::try_next [function] [call site] 00195
22 Ok [function] [call site] 00196
22 Buffer::len [function] [call site] 00197
22 io::Result::put [function] [call site] 00198
20 ThrottleAccessor::info [function] [call site] 00199
21 ThrottleAccessor::info [function] [call site] 00200
20 ThrottleAccessor::capability [function] [call site] 00201
21 ThrottleAccessor::capability [function] [call site] 00202
22 ThrottleAccessor::capability [function] [call site] 00203
20 test_copy_overwrite [function] [call site] 00204
20 RetryLayer::clone [function] [call site] 00205
20 uuid::Uuid::new_v4 [function] [call site] 00206
20 tests::test_bytes_range_to_string [function] [call site] 00207
20 gen_bytes [function] [call site] 00208
20 ThrottleAccessor::info [function] [call site] 00209
20 ThrottleAccessor::capability [function] [call site] 00210
20 test_copy_overwrite [function] [call site] 00211
20 test_writer_futures_copy [function] [call site] 00212
21 ThrottleAccessor::info [function] [call site] 00213
21 ThrottleAccessor::capability [function] [call site] 00214
21 Ok [function] [call site] 00215
21 new_file_path [function] [call site] 00216
21 gen_bytes_with_range [function] [call site] 00217
22 rand::rng [function] [call site] 00218
22 random_range [function] [call site] 00219
22 fill_bytes [function] [call site] 00220
21 tests::test_writer_with [function] [call site] 00221
22 tests::new_test_operator [function] [call site] 00222
23 Operator::from_parts [function] [call site] 00223
23 OperationContext::default [function] [call site] 00224
23 Fixture::new [function] [call site] 00225
23 ThrottleLayer::layer [function] [call site] 00226
22 Fixture::default [function] [call site] 00227
23 Fixture::new [function] [call site] 00228
22 tests::test_writer_with [function] [call site] 00229
22 test_stat_with_override_content_type [function] [call site] 00230
23 ThrottleAccessor::info [function] [call site] 00231
23 ThrottleAccessor::capability [function] [call site] 00232
23 ThrottleAccessor::info [function] [call site] 00233
23 ThrottleAccessor::capability [function] [call site] 00234
23 Ok [function] [call site] 00235
23 test_copy_with_if_not_exists_to_new_file [function] [call site] 00236
24 ThrottleAccessor::info [function] [call site] 00237
24 ThrottleAccessor::capability [function] [call site] 00238
24 Ok [function] [call site] 00239
24 uuid::Uuid::new_v4 [function] [call site] 00240
24 tests::test_bytes_range_to_string [function] [call site] 00241
24 gen_bytes [function] [call site] 00242
24 ThrottleAccessor::info [function] [call site] 00243
24 ThrottleAccessor::capability [function] [call site] 00244
24 test_copy_overwrite [function] [call site] 00245
24 RetryLayer::clone [function] [call site] 00246
24 uuid::Uuid::new_v4 [function] [call site] 00247
24 tests::test_bytes_range_to_string [function] [call site] 00248
24 Operator::copy_with [function] [call site] 00249
25 normalize_path [function] [call site] 00250
25 normalize_path [function] [call site] 00251
25 OperatorFuture::new [function] [call site] 00252
25 Operator::context [function] [call site] 00253
25 RetryLayer::clone [function] [call site] 00254
26 RetryLayer::clone [function] [call site] 00255
25 Operator::service [function] [call site] 00256
25 RetryLayer::clone [function] [call site] 00257
26 RetryLayer::clone [function] [call site] 00258
25 options::CopyOptions::default [function] [call site] 00259
26 Fixture::new [function] [call site] 00260
24 FutureCopy::if_not_exists [function] [call site] 00261
24 test_presign_read [function] [call site] 00262
25 uuid::Uuid::new_v4 [function] [call site] 00263
25 tests::test_bytes_range_to_string [function] [call site] 00264
25 gen_bytes [function] [call site] 00265
25 ThrottleAccessor::info [function] [call site] 00266
25 ThrottleAccessor::capability [function] [call site] 00267
25 test_copy_overwrite [function] [call site] 00268
25 RetryLayer::clone [function] [call site] 00269
25 expect [function] [call site] 00270
25 test_presign_read [function] [call site] 00271
26 uuid::Uuid::new_v4 [function] [call site] 00272
26 tests::test_bytes_range_to_string [function] [call site] 00273
26 gen_bytes [function] [call site] 00274
26 ThrottleAccessor::info [function] [call site] 00275
26 ThrottleAccessor::capability [function] [call site] 00276
26 test_copy_overwrite [function] [call site] 00277
26 RetryLayer::clone [function] [call site] 00278
26 expect [function] [call site] 00279
26 test_presign_read [function] [call site] 00280
26 Duration::from_secs [function] [call site] 00281
26 reqwest::Client::new [function] [call site] 00282
27 Fixture::new [function] [call site] 00283
26 tests::build_http_request [function] [call site] 00284
27 http::Request::new [function] [call site] 00285
28 opendal::raw::PresignedRequest::method [function] [call site] 00286
29 PresignedRequest::method [function] [call site] 00287
30 PresignedRequest::method [function] [call site] 00288
30 HfRepoType::as_str [function] [call site] 00289
29 HfRepoType::as_str [function] [call site] 00290
28 tests::test_bytes_range_to_string [function] [call site] 00291
29 BytesRange::new [function] [call site] 00292
29 Some [function] [call site] 00293
29 BytesRange::new [function] [call site] 00294
29 BytesRange::new [function] [call site] 00295
29 Some [function] [call site] 00296
29 BytesRange::suffix [function] [call site] 00297
28 opendal::raw::PresignedRequest::uri [function] [call site] 00298
28 &http::Uri::to_string [function] [call site] 00299
29 BytesRange::new [function] [call site] 00300
29 Some [function] [call site] 00301
29 BytesRange::new [function] [call site] 00302
29 BytesRange::new [function] [call site] 00303
29 Some [function] [call site] 00304
29 BytesRange::suffix [function] [call site] 00305
28 opendal::raw::PresignedRequest::header [function] [call site] 00306
28 &http::HeaderMap::iter [function] [call site] 00307
29 extend [function] [call site] 00308
28 ConfigDeserializer::deserialize_map [function] [call site] 00309
28 HfRepoType::as_str [function] [call site] 00310
28 tests::test_bytes_range_to_string [function] [call site] 00311
29 BytesRange::new [function] [call site] 00312
29 Some [function] [call site] 00313
29 BytesRange::new [function] [call site] 00314
29 BytesRange::new [function] [call site] 00315
29 Some [function] [call site] 00316
29 BytesRange::suffix [function] [call site] 00317
28 Result::to_str [function] [call site] 00318
29 Timestamp::try_from [function] [call site] 00319
30 <web_time::SystemTime [call site] 00320
30 jiff::Timestamp::try_from [function] [call site] 00321
31 <web_time::SystemTime [call site] 00322
31 jiff::Timestamp::try_from [function] [call site] 00323
31 ConfigDeserializer::deserialize_map [function] [call site] 00324
32 V::visit_map [function] [call site] 00325
31 Result::map_err [function] [call site] 00326
31 Error::new [function] [call site] 00327
31 Error::set_source [function] [call site] 00328
32 Some [function] [call site] 00329
32 impl [call site] 00330
33 RetryLayer::clone [function] [call site] 00331
33 Reader::into_stream [function] [call site] 00332
33 Result::try_next [function] [call site] 00333
33 Ok [function] [call site] 00334
33 Buffer::len [function] [call site] 00335
33 io::Result::put [function] [call site] 00336
30 ConfigDeserializer::deserialize_map [function] [call site] 00337
30 Result::map_err [function] [call site] 00338
30 Error::new [function] [call site] 00339
30 Error::set_source [function] [call site] 00340
29 Result::map_err [function] [call site] 00341
29 Error::new [function] [call site] 00342
29 Error::with_operation [function] [call site] 00343
30 Buffer::is_empty [function] [call site] 00344
31 Buffer::len [function] [call site] 00345
30 QueryPairsWriter::push [function] [call site] 00346
30 tests::test_bytes_range_to_string [function] [call site] 00347
30 Reader::read_into [function] [call site] 00348
31 RetryLayer::clone [function] [call site] 00349
31 Reader::into_stream [function] [call site] 00350
31 Result::try_next [function] [call site] 00351
31 Ok [function] [call site] 00352
31 Buffer::len [function] [call site] 00353
31 io::Result::put [function] [call site] 00354
29 RouteRouter::target [function] [call site] 00355
30 RouteRouter::target [function] [call site] 00356
31 RouteRouter::target [function] [call site] 00357
31 cloned [function] [call site] 00358
30 cloned [function] [call site] 00359
29 Ok [function] [call site] 00360
29 Ok [function] [call site] 00361
29 Some [function] [call site] 00362
29 Vec::to_str [function] [call site] 00363
30 Timestamp::try_from [function] [call site] 00364
30 Result::map_err [function] [call site] 00365
30 Error::new [function] [call site] 00366
30 Error::with_operation [function] [call site] 00367
30 RouteRouter::target [function] [call site] 00368
30 Ok [function] [call site] 00369
30 Ok [function] [call site] 00370
30 Some [function] [call site] 00371
30 Vec::to_str [function] [call site] 00372
30 Result::map_err [function] [call site] 00373
30 Error::new [function] [call site] 00374
30 Error::with_operation [function] [call site] 00375
30 Error::with_context [function] [call site] 00376
30 HfRepoType::as_str [function] [call site] 00377
30 Error::set_source [function] [call site] 00378
29 Result::map_err [function] [call site] 00379
29 Error::new [function] [call site] 00380
29 Error::with_operation [function] [call site] 00381
29 Error::with_context [function] [call site] 00382
29 HfRepoType::as_str [function] [call site] 00383
29 Error::set_source [function] [call site] 00384
28 Result::expect [function] [call site] 00385
28 tests::test_bytes_range_to_string [function] [call site] 00386
28 QueueBuf::collect [function] [call site] 00387
29 Buffer::is_empty [function] [call site] 00388
29 Buffer::new [function] [call site] 00389
29 Buffer::len [function] [call site] 00390
29 pop_front [function] [call site] 00391
29 MonoiofsCore::unwrap [function] [call site] 00392
30 MonoiofsCore::propagate_worker_panic [function] [call site] 00393
31 Operator::spawn_block [function] [call site] 00394
32 Executor::block_on [function] [call site] 00395
33 Executor::block_on [function] [call site] 00396
32 MonoiofsCore::spawn [function] [call site] 00397
33 send_async [function] [call site] 00398
33 Fixture::new [function] [call site] 00399
34 Fixture::new [function] [call site] 00400
33 MonoiofsCore::spawn [function] [call site] 00401
34 send_async [function] [call site] 00402
34 Fixture::new [function] [call site] 00403
34 MonoiofsCore::spawn [function] [call site] 00404
34 test_copy_self [function] [call site] 00405
35 uuid::Uuid::new_v4 [function] [call site] 00406
35 tests::test_bytes_range_to_string [function] [call site] 00407
35 gen_bytes [function] [call site] 00408
35 ThrottleAccessor::info [function] [call site] 00409
35 ThrottleAccessor::capability [function] [call site] 00410
35 test_copy_overwrite [function] [call site] 00411
35 test_writer_futures_copy [function] [call site] 00412
35 expect_err [function] [call site] 00413
35 test_batch_delete [function] [call site] 00414
36 ThrottleAccessor::info [function] [call site] 00415
36 ThrottleAccessor::capability [function] [call site] 00416
36 unwrap_or [function] [call site] 00417
36 Ok [function] [call site] 00418
36 Some [function] [call site] 00419
36 ThrottleLayer::layer [function] [call site] 00420
37 RetryLayer::clone [function] [call site] 00421
36 CapabilityOverrideLayer::new [function] [call site] 00422
36 Fixture::new [function] [call site] 00423
36 test_copy_with_if_not_exists_to_new_file [function] [call site] 00424
36 RetryLayer::clone [function] [call site] 00425
36 test_copy_overwrite [function] [call site] 00426
36 HfRepoType::as_str [function] [call site] 00427
36 expect [function] [call site] 00428
36 QueryPairsWriter::push [function] [call site] 00429
37 QueryPairsWriter::push [function] [call site] 00430
37 QueryPairsWriter::push [function] [call site] 00431
37 push_str [function] [call site] 00432
37 Buffer::is_empty [function] [call site] 00433
37 QueryPairsWriter::push [function] [call site] 00434
37 push_str [function] [call site] 00435
36 Operator::delete_iter [function] [call site] 00436
37 Operator::deleter [function] [call site] 00437
38 std::future::ready [function] [call site] 00438
39 Poll::Ready [function] [call site] 00439
39 Ok [function] [call site] 00440
39 State::Idle [function] [call site] 00441
39 Some [function] [call site] 00442
39 Poll::Ready [function] [call site] 00443
39 ConfigDeserializer::deserialize_map [function] [call site] 00444
39 State::Idle [function] [call site] 00445
39 Some [function] [call site] 00446
39 Poll::Ready [function] [call site] 00447
39 ConfigDeserializer::deserialize_map [function] [call site] 00448
38 Deleter::create [function] [call site] 00449
39 Servicer::delete [function] [call site] 00450
40 ThrottleAccessor::info [function] [call site] 00451
40 ThrottleAccessor::capability [function] [call site] 00452
40 unwrap_or [function] [call site] 00453
40 Ok [function] [call site] 00454
40 Some [function] [call site] 00455
40 ThrottleLayer::layer [function] [call site] 00456
40 CapabilityOverrideLayer::new [function] [call site] 00457
40 Fixture::new [function] [call site] 00458
40 test_copy_with_if_not_exists_to_new_file [function] [call site] 00459
40 RetryLayer::clone [function] [call site] 00460
40 test_copy_overwrite [function] [call site] 00461
40 HfRepoType::as_str [function] [call site] 00462
40 expect [function] [call site] 00463
40 QueryPairsWriter::push [function] [call site] 00464
40 Operator::delete_iter [function] [call site] 00465
40 RetryLayer::clone [function] [call site] 00466
41 RetryLayer::clone [function] [call site] 00467
40 expect [function] [call site] 00468
40 test_presign_stat [function] [call site] 00469
41 uuid::Uuid::new_v4 [function] [call site] 00470
41 tests::test_bytes_range_to_string [function] [call site] 00471
41 gen_bytes [function] [call site] 00472
41 ThrottleAccessor::info [function] [call site] 00473
41 ThrottleAccessor::capability [function] [call site] 00474
41 test_copy_overwrite [function] [call site] 00475
41 RetryLayer::clone [function] [call site] 00476
41 expect [function] [call site] 00477
41 test_presign_stat [function] [call site] 00478
42 uuid::Uuid::new_v4 [function] [call site] 00479
42 tests::test_bytes_range_to_string [function] [call site] 00480
42 gen_bytes [function] [call site] 00481
42 ThrottleAccessor::info [function] [call site] 00482
42 ThrottleAccessor::capability [function] [call site] 00483
42 test_copy_overwrite [function] [call site] 00484
42 RetryLayer::clone [function] [call site] 00485
42 expect [function] [call site] 00486
42 test_presign_stat [function] [call site] 00487
42 Duration::from_secs [function] [call site] 00488
42 reqwest::Client::new [function] [call site] 00489
42 tests::build_http_request [function] [call site] 00490
42 PresignedRequest::method [function] [call site] 00491
42 RetryLayer::clone [function] [call site] 00492
42 BytesRange::from_str [function] [call site] 00493
43 Vec::strip_prefix [function] [call site] 00494
43 ok_or_else [function] [call site] 00495
43 Error::new [function] [call site] 00496
43 Error::with_operation [function] [call site] 00497
43 Error::with_context [function] [call site] 00498
43 SizeBucket::contains [function] [call site] 00499
44 is_none_or [function] [call site] 00500
43 Err [function] [call site] 00501
43 Error::new [function] [call site] 00502
43 Error::with_operation [function] [call site] 00503
43 Error::with_context [function] [call site] 00504
43 split [function] [call site] 00505
43 split('-').collect::<Vec<_>> [function] [call site] 00506
43 Buffer::len [function] [call site] 00507
43 Err [function] [call site] 00508
43 Error::new [function] [call site] 00509
43 Error::with_operation [function] [call site] 00510
43 Error::with_context [function] [call site] 00511
43 Error::new [function] [call site] 00512
43 Error::with_operation [function] [call site] 00513
43 Error::with_context [function] [call site] 00514
43 Error::set_source [function] [call site] 00515
43 Buffer::is_empty [function] [call site] 00516
43 Ok [function] [call site] 00517
43 BytesRange::new [function] [call site] 00518
43 parse [function] [call site] 00519
44 Fixture::default [function] [call site] 00520
45 Fixture::new [function] [call site] 00521
44 std::fs::read_dir [function] [call site] 00522
45 setup_temp [function] [call site] 00523
46 fs::remove_dir_all [function] [call site] 00524
46 Fixture::default [function] [call site] 00525
47 Fixture::new [function] [call site] 00526
46 Self::root [function] [call site] 00527
47 test_presign_stat [function] [call site] 00528
47 test_presign_stat [function] [call site] 00529
47 Ok [function] [call site] 00530
46 Operator::new [function] [call site] 00531
47 Result::unwrap_or_default [function] [call site] 00532
47 opendal::Operator::via_iter [function] [call site] 00533
48 Operator::from_uri [function] [call site] 00534
49 Result::unwrap_or_default [function] [call site] 00535
49 Buffer::is_empty [function] [call site] 00536
49 opendal::Operator::from_uri [function] [call site] 00537
50 Result::unwrap_or_default [function] [call site] 00538
50 Buffer::is_empty [function] [call site] 00539
50 opendal::Operator::from_uri [function] [call site] 00540
50 Result::map_err [function] [call site] 00541
50 opendal::Operator::from_uri [function] [call site] 00542
50 HfRepoType::as_str [function] [call site] 00543
50 Result::map_err [function] [call site] 00544
50 opendal::blocking::Operator::new [function] [call site] 00545
51 Result::unwrap_or_default [function] [call site] 00546
51 opendal::Operator::via_iter [function] [call site] 00547
51 Result::map_err [function] [call site] 00548
51 opendal::blocking::Operator::new [function] [call site] 00549
51 RetryLayer::clone [function] [call site] 00550
51 Result::map_err [function] [call site] 00551
51 Ok [function] [call site] 00552
50 RetryLayer::clone [function] [call site] 00553
50 Result::map_err [function] [call site] 00554
50 Ok [function] [call site] 00555
49 Result::map_err [function] [call site] 00556
49 opendal::Operator::from_uri [function] [call site] 00557
49 HfRepoType::as_str [function] [call site] 00558
49 Result::map_err [function] [call site] 00559
49 opendal::blocking::Operator::new [function] [call site] 00560
49 RetryLayer::clone [function] [call site] 00561
49 Result::map_err [function] [call site] 00562
49 Ok [function] [call site] 00563
48 OperationLabelNames::as_ref [function] [call site] 00564
47 Result::map_err [function] [call site] 00565
47 opendal::blocking::Operator::new [function] [call site] 00566
47 RetryLayer::clone [function] [call site] 00567
47 Result::map_err [function] [call site] 00568
47 Ok [function] [call site] 00569
46 MonoiofsCore::unwrap [function] [call site] 00570
47 MonoiofsCore::propagate_worker_panic [function] [call site] 00571
46 OpendalFs::new [function] [call site] 00572
47 Fixture::new [function] [call site] 00573
45 Box::create_dir [function] [call site] 00574
46 Fixture::new_dir_path [function] [call site] 00575
47 Operator::spawn_block [function] [call site] 00576
47 MonoiofsCore::unwrap [function] [call site] 00577
47 QueryPairsWriter::push [function] [call site] 00578
47 RetryLayer::clone [function] [call site] 00579
46 test_create_dir [function] [call site] 00580
47 Fixture::new_dir_path [function] [call site] 00581
47 test_create_dir [function] [call site] 00582
47 test_presign_stat [function] [call site] 00583
47 Ok [function] [call site] 00584
46 test_presign_stat [function] [call site] 00585
46 Ok [function] [call site] 00586
45 Fixture::new [function] [call site] 00587
46 Fixture::new [function] [call site] 00588
45 MonoiofsCore::unwrap [function] [call site] 00589
46 MonoiofsCore::propagate_worker_panic [function] [call site] 00590
45 MonoiofsCore::unwrap [function] [call site] 00591
45 Box::create_dir [function] [call site] 00592
45 Fixture::new [function] [call site] 00593
45 MonoiofsCore::unwrap [function] [call site] 00594
45 MonoiofsCore::unwrap [function] [call site] 00595
45 Box::create_dir [function] [call site] 00596
45 Fixture::new [function] [call site] 00597
45 MonoiofsCore::unwrap [function] [call site] 00598
45 MonoiofsCore::unwrap [function] [call site] 00599
45 Box::read_dir [function] [call site] 00600
46 setup_temp [function] [call site] 00601
46 Box::create_dir [function] [call site] 00602
46 Fixture::new [function] [call site] 00603
46 MonoiofsCore::unwrap [function] [call site] 00604
46 MonoiofsCore::unwrap [function] [call site] 00605
46 Box::create_dir [function] [call site] 00606
46 Fixture::new [function] [call site] 00607
46 MonoiofsCore::unwrap [function] [call site] 00608
46 MonoiofsCore::unwrap [function] [call site] 00609
46 Box::create_dir [function] [call site] 00610
46 Fixture::new [function] [call site] 00611
46 MonoiofsCore::unwrap [function] [call site] 00612
46 MonoiofsCore::unwrap [function] [call site] 00613
46 Box::read_dir [function] [call site] 00614
46 Fixture::new [function] [call site] 00615
46 MonoiofsCore::unwrap [function] [call site] 00616
46 MonoiofsCore::unwrap [function] [call site] 00617
46 collect::<Vec<_>> [function] [call site] 00618
46 ImmutableIndexLayer::extend_iter [function] [call site] 00619
47 extend [function] [call site] 00620
46 ConfigDeserializer::deserialize_map [function] [call site] 00621
46 String::from_utf8 [function] [call site] 00622
46 crate::Entry::as_ref [function] [call site] 00623
46 MonoiofsCore::unwrap [function] [call site] 00624
47 MonoiofsCore::propagate_worker_panic [function] [call site] 00625
46 T::name [function] [call site] 00626
47 uuid::Uuid::new_v4 [function] [call site] 00627
47 tests::test_bytes_range_to_string [function] [call site] 00628
47 gen_bytes [function] [call site] 00629
47 ThrottleAccessor::info [function] [call site] 00630
47 ThrottleAccessor::capability [function] [call site] 00631
47 test_copy_overwrite [function] [call site] 00632
47 RetryLayer::clone [function] [call site] 00633
47 uuid::Uuid::new_v4 [function] [call site] 00634
47 tests::test_bytes_range_to_string [function] [call site] 00635
47 test_writer_futures_copy [function] [call site] 00636
47 test_presign_read [function] [call site] 00637
47 expect [function] [call site] 00638
47 Buffer::to_bytes [function] [call site] 00639
48 RetryLayer::clone [function] [call site] 00640
49 RetryLayer::clone [function] [call site] 00641
48 Buffer::len [function] [call site] 00642
49 Buffer::remaining [function] [call site] 00643
48 Buffer::slice [function] [call site] 00644
49 Buffer::len [function] [call site] 00645
49 (Vec::start_bound [function] [call site] 00646
49 Result::checked_add [function] [call site] 00647
49 expect [function] [call site] 00648
49 (Vec::end_bound [function] [call site] 00649
49 Result::checked_add [function] [call site] 00650
49 expect [function] [call site] 00651
49 Buffer::new [function] [call site] 00652
49 RetryLayer::clone [function] [call site] 00653
50 RetryLayer::clone [function] [call site] 00654
49 Buffer::truncate [function] [call site] 00655
50 Buffer::truncate [function] [call site] 00656
51 Buffer::truncate [function] [call site] 00657
51 min [function] [call site] 00658
50 min [function] [call site] 00659
49 Buffer::advance [function] [call site] 00660
50 Buffer::advance [function] [call site] 00661
51 Buffer::advance [function] [call site] 00662
51 Buffer::len [function] [call site] 00663
50 Buffer::len [function] [call site] 00664
48 BytesMut::with_capacity [function] [call site] 00665
48 Buffer::len [function] [call site] 00666
48 DeleteInput::into_delete_input [function] [call site] 00667
48 RetryLayer::clone [function] [call site] 00668
48 FlexBuf::freeze [function] [call site] 00669
49 split [function] [call site] 00670
49 Some [function] [call site] 00671
49 FlexBuf::freeze [function] [call site] 00672
50 split [function] [call site] 00673
50 Some [function] [call site] 00674
50 FlexBuf::freeze [function] [call site] 00675
47 test_batch_delete [function] [call site] 00676
47 expect [function] [call site] 00677
47 test_batch_delete [function] [call site] 00678
47 expect [function] [call site] 00679
47 Ok [function] [call site] 00680
46 MonoiofsCore::unwrap [function] [call site] 00681
46 collect::<Vec<_>>() [call site] 00682
4 .await [call site] 00683
4 .iter() [call site] 00684
4 .map(|entry| [call site] 00685
4 .collect::<Vec<_>> [function] [call site] 00686
46 fs::remove_dir_all [function] [call site] 00687
46 MonoiofsCore::unwrap [function] [call site] 00688
45 Fixture::new [function] [call site] 00689
45 MonoiofsCore::unwrap [function] [call site] 00690
45 MonoiofsCore::unwrap [function] [call site] 00691
45 collect::<Vec<_>> [function] [call site] 00692
45 ImmutableIndexLayer::extend_iter [function] [call site] 00693
45 ConfigDeserializer::deserialize_map [function] [call site] 00694
45 String::from_utf8 [function] [call site] 00695
45 crate::Entry::as_ref [function] [call site] 00696
45 MonoiofsCore::unwrap [function] [call site] 00697
45 T::name [function] [call site] 00698
45 MonoiofsCore::unwrap [function] [call site] 00699
45 collect::<Vec<_>>() [call site] 00700
4 .await [call site] 00701
4 .iter() [call site] 00702
4 .map(|entry| [call site] 00703
4 .collect::<Vec<_>> [function] [call site] 00704
45 fs::remove_dir_all [function] [call site] 00705
45 MonoiofsCore::unwrap [function] [call site] 00706
44 Result::file_type [function] [call site] 00707
44 Metadata::is_file [function] [call site] 00708
45 Metadata::is_file [function] [call site] 00709
44 Fixture::add_path [function] [call site] 00710
45 Operator::spawn_block [function] [call site] 00711
45 MonoiofsCore::unwrap [function] [call site] 00712
45 QueryPairsWriter::push [function] [call site] 00713
44 FsCore::confined_join [function] [call site] 00714
45 trim_end_matches [function] [call site] 00715
45 Fixture::new [function] [call site] 00716
46 Fixture::new [function] [call site] 00717
45 tests::from_uri_with_all_components [function] [call site] 00718
46 OperatorUri::new [function] [call site] 00719
46 Vec::<(String, [call site] 00720
47 Fixture::new [function] [call site] 00721
46 MonoiofsCore::unwrap [function] [call site] 00722
46 HfConfig::from_uri [function] [call site] 00723
47 Operator::presign_stat_options [function] [call site] 00724
47 Fixture::new [function] [call site] 00725
48 Fixture::new [function] [call site] 00726
47 Result::name [function] [call site] 00727
48 uuid::Uuid::new_v4 [function] [call site] 00728
48 tests::test_bytes_range_to_string [function] [call site] 00729
48 gen_bytes [function] [call site] 00730
48 ThrottleAccessor::info [function] [call site] 00731
48 ThrottleAccessor::capability [function] [call site] 00732
48 test_copy_overwrite [function] [call site] 00733
48 RetryLayer::clone [function] [call site] 00734
48 uuid::Uuid::new_v4 [function] [call site] 00735
48 tests::test_bytes_range_to_string [function] [call site] 00736
48 test_writer_futures_copy [function] [call site] 00737
48 test_presign_read [function] [call site] 00738
48 expect [function] [call site] 00739
48 Buffer::to_bytes [function] [call site] 00740
48 test_batch_delete [function] [call site] 00741
48 expect [function] [call site] 00742
48 test_batch_delete [function] [call site] 00743
48 expect [function] [call site] 00744
48 Ok [function] [call site] 00745
47 Buffer::is_empty [function] [call site] 00746
47 push_str [function] [call site] 00747
47 Result::root [function] [call site] 00748
48 test_presign_stat [function] [call site] 00749
48 test_presign_stat [function] [call site] 00750
48 Ok [function] [call site] 00751
47 Buffer::is_empty [function] [call site] 00752
47 Buffer::is_empty [function] [call site] 00753
47 QueryPairsWriter::push [function] [call site] 00754
47 push_str [function] [call site] 00755
47 object_store::Result::get [function] [call site] 00756
48 RouteRouter::target [function] [call site] 00757
48 cloned [function] [call site] 00758
47 ConfigDeserializer::deserialize_map [function] [call site] 00759
48 V::visit_map [function] [call site] 00760
47 HfDownloadMode::parse [function] [call site] 00761
48 to_lowercase [function] [call site] 00762
48 HfRepoType::as_str [function] [call site] 00763
48 Ok [function] [call site] 00764
48 Ok [function] [call site] 00765
48 Err [function] [call site] 00766
48 Error::new [function] [call site] 00767
48 Error::with_context [function] [call site] 00768
47 Result::transpose [function] [call site] 00769
47 Buffer::is_empty [function] [call site] 00770
47 CapabilityOverrides::parse [function] [call site] 00771
48 Fixture::default [function] [call site] 00772
48 DeleteInput::split [function] [call site] 00773
48 ConfigDeserializer::deserialize_map [function] [call site] 00774
48 filter [function] [call site] 00775
48 Buffer::is_empty [function] [call site] 00776
48 parse_capability_override [function] [call site] 00777
48 ImmutableIndexLayer::insert [function] [call site] 00778
49 QueryPairsWriter::push [function] [call site] 00779
48 tests::test_bytes_range_to_string [function] [call site] 00780
49 BytesRange::new [function] [call site] 00781
49 Some [function] [call site] 00782
49 BytesRange::new [function] [call site] 00783
49 BytesRange::new [function] [call site] 00784
49 Some [function] [call site] 00785
49 BytesRange::suffix [function] [call site] 00786
48 CapabilityOverrides::try_apply [function] [call site] 00787
49 serde_json::to_value [function] [call site] 00788
49 map_err [function] [call site] 00789
49 Error::new [function] [call site] 00790
49 Vec::as_object_mut [function] [call site] 00791
49 ok_or_else [function] [call site] 00792
49 Error::new [function] [call site] 00793
49 Buffer::extend [function] [call site] 00794
49 RetryLayer::clone [function] [call site] 00795
49 serde_json::from_value [function] [call site] 00796
49 map_err [function] [call site] 00797
49 Error::new [function] [call site] 00798
48 Fixture::default [function] [call site] 00799
49 Fixture::new [function] [call site] 00800
48 Result::map_err [function] [call site] 00801
48 invalid_capability_override [function] [call site] 00802
48 Ok [function] [call site] 00803
47 Ok [function] [call site] 00804
47 Some [function] [call site] 00805
47 Some [function] [call site] 00806
47 object_store::Result::get [function] [call site] 00807
47 Option::cloned [function] [call site] 00808
47 object_store::Result::get [function] [call site] 00809
47 Option::cloned [function] [call site] 00810
47 object_store::Result::get [function] [call site] 00811
47 Option::cloned [function] [call site] 00812
47 object_store::Result::get [function] [call site] 00813
47 Option::ok_or_else [function] [call site] 00814
47 opendal_core::Error::new [function] [call site] 00815
48 Reader::read_into [function] [call site] 00816
48 Fixture::default [function] [call site] 00817
49 Fixture::new [function] [call site] 00818
48 ErrorKind::enable_backtrace [function] [call site] 00819
48 bool::then [function] [call site] 00820
48 filter [function] [call site] 00821
48 WebhdfsCore::webhdfs_list_status [function] [call site] 00822
49 build_abs_path [function] [call site] 00823
50 tests::test_bytes_range_to_string [function] [call site] 00824
49 HfRepoType::as_str [function] [call site] 00825
49 HfRepoType::as_str [function] [call site] 00826
49 RouteRouter::target [function] [call site] 00827
50 RouteRouter::target [function] [call site] 00828
50 cloned [function] [call site] 00829
49 Option::body [function] [call site] 00830
49 Buffer::new [function] [call site] 00831
49 map_err [function] [call site] 00832
49 OperationContext::with_http_transport [function] [call site] 00833
50 RetryLayer::clone [function] [call site] 00834
49 FuturesDeleteSink::start_send [function] [call site] 00835
50 QueueBuf::take [function] [call site] 00836
51 QueueBuf::take [function] [call site] 00837
52 QueueBuf::take [function] [call site] 00838
50 QueueBuf::ok_or_else [function] [call site] 00839
50 Error::new [function] [call site] 00840
50 DeleteInput::into_delete_input [function] [call site] 00841
50 Result::delete [function] [call site] 00842
51 ThrottleAccessor::info [function] [call site] 00843
51 ThrottleAccessor::capability [function] [call site] 00844
51 unwrap_or [function] [call site] 00845
51 Ok [function] [call site] 00846
51 Some [function] [call site] 00847
51 ThrottleLayer::layer [function] [call site] 00848
51 CapabilityOverrideLayer::new [function] [call site] 00849
51 Fixture::new [function] [call site] 00850
51 test_copy_with_if_not_exists_to_new_file [function] [call site] 00851
51 RetryLayer::clone [function] [call site] 00852
51 test_copy_overwrite [function] [call site] 00853
51 HfRepoType::as_str [function] [call site] 00854
51 expect [function] [call site] 00855
51 QueryPairsWriter::push [function] [call site] 00856
51 Operator::delete_iter [function] [call site] 00857
51 RetryLayer::clone [function] [call site] 00858
51 expect [function] [call site] 00859
51 test_presign_stat [function] [call site] 00860
51 HfRepoType::as_str [function] [call site] 00861
51 Ok [function] [call site] 00862
50 State::Delete [function] [call site] 00863
50 Box::pin [function] [call site] 00864
50 Ok [function] [call site] 00865
50 Err [function] [call site] 00866
50 Error::new [function] [call site] 00867
48 ConfigDeserializer::deserialize_map [function] [call site] 00868
47 Error::with_context [function] [call site] 00869
47 and_then [function] [call site] 00870
47 HfRepoType::parse [function] [call site] 00871
48 to_lowercase [function] [call site] 00872
48 Task::replace [function] [call site] 00873
48 HfRepoType::as_str [function] [call site] 00874
48 Ok [function] [call site] 00875
48 Ok [function] [call site] 00876
48 Ok [function] [call site] 00877
48 Ok [function] [call site] 00878
48 Err [function] [call site] 00879
48 Error::new [function] [call site] 00880
48 Error::with_context [function] [call site] 00881
47 Ok [function] [call site] 00882
47 Some [function] [call site] 00883
47 object_store::Result::get [function] [call site] 00884
47 Option::cloned [function] [call site] 00885
47 object_store::Result::get [function] [call site] 00886
47 Option::cloned [function] [call site] 00887
47 object_store::Result::get [function] [call site] 00888
47 Option::cloned [function] [call site] 00889
47 object_store::Result::get [function] [call site] 00890
47 Option::cloned [function] [call site] 00891
47 object_store::Result::get [function] [call site] 00892
47 Option::cloned [function] [call site] 00893
46 opendal_core::Result::unwrap [function] [call site] 00894
47 MonoiofsCore::propagate_worker_panic [function] [call site] 00895
45 ConfigDeserializer::deserialize_any [function] [call site] 00896
46 ConfigDeserializer::deserialize_map [function] [call site] 00897
47 V::visit_map [function] [call site] 00898
45 Err [function] [call site] 00899
45 Error::new [function] [call site] 00900
45 Error::with_context [function] [call site] 00901
45 Ok [function] [call site] 00902
45 FsCore::confined_join [function] [call site] 00903
46 trim_end_matches [function] [call site] 00904
46 Fixture::new [function] [call site] 00905
46 tests::from_uri_with_all_components [function] [call site] 00906
46 ConfigDeserializer::deserialize_any [function] [call site] 00907
46 Err [function] [call site] 00908
46 Error::new [function] [call site] 00909
46 Error::with_context [function] [call site] 00910
46 Ok [function] [call site] 00911
46 FsCore::confined_join [function] [call site] 00912
44 test_remove_all_with_prefix_exists [function] [call site] 00913
45 ThrottleAccessor::info [function] [call site] 00914
45 ServiceInfo::scheme [function] [call site] 00915
45 Ok [function] [call site] 00916
45 uuid::Uuid::new_v4 [function] [call site] 00917
45 tests::test_bytes_range_to_string [function] [call site] 00918
45 gen_bytes [function] [call site] 00919
45 ThrottleAccessor::info [function] [call site] 00920
45 ThrottleAccessor::capability [function] [call site] 00921
45 test_copy_overwrite [function] [call site] 00922
45 expect [function] [call site] 00923
45 test_blocking_remove_all_with_objects [function] [call site] 00924
46 gen_bytes [function] [call site] 00925
46 ThrottleAccessor::info [function] [call site] 00926
46 ThrottleAccessor::capability [function] [call site] 00927
46 test_copy_overwrite [function] [call site] 00928
46 expect [function] [call site] 00929
46 Operator::delete_with [function] [call site] 00930
47 normalize_path [function] [call site] 00931
47 OperatorFuture::new [function] [call site] 00932
47 Operator::context [function] [call site] 00933
47 RetryLayer::clone [function] [call site] 00934
47 Operator::service [function] [call site] 00935
47 RetryLayer::clone [function] [call site] 00936
47 options::DeleteOptions::default [function] [call site] 00937
48 Fixture::new [function] [call site] 00938
46 FutureDelete::recursive [function] [call site] 00939
46 Operator::lister_with [function] [call site] 00940
47 normalize_path [function] [call site] 00941
47 OperatorFuture::new [function] [call site] 00942
47 Operator::context [function] [call site] 00943
47 RetryLayer::clone [function] [call site] 00944
47 Operator::service [function] [call site] 00945
47 RetryLayer::clone [function] [call site] 00946
47 options::ListOptions::default [function] [call site] 00947
48 Fixture::new [function] [call site] 00948
46 FutureLister::recursive [function] [call site] 00949
46 expect [function] [call site] 00950
46 try_next [function] [call site] 00951
46 expect [function] [call site] 00952
46 is_some [function] [call site] 00953
46 Ok [function] [call site] 00954
44 Fixture::add_path [function] [call site] 00955
44 FsCore::confined_join [function] [call site] 00956
44 test_remove_all_with_prefix_exists [function] [call site] 00957
44 fs::read_to_string [function] [call site] 00958
44 Result::file_name [function] [call site] 00959
44 to_string_lossy [function] [call site] 00960
44 tests::test_bytes_range_to_string [function] [call site] 00961
44 to_string_lossy [function] [call site] 00962
44 tests::test_bytes_range_to_string [function] [call site] 00963
44 parse [function] [call site] 00964
44 OtelMetricsLayer::apply_context [function] [call site] 00965
45 observe::MetricsLayer::new [function] [call site] 00966
45 RetryLayer::clone [function] [call site] 00967
45 OtelMetricsLayer::apply_context [function] [call site] 00968
46 observe::MetricsLayer::new [function] [call site] 00969
46 RetryLayer::clone [function] [call site] 00970
46 OtelMetricsLayer::apply_context [function] [call site] 00971
44 ImmutableIndexLayer::insert [function] [call site] 00972
44 Ok [function] [call site] 00973
43 map_err [function] [call site] 00974
43 Buffer::is_empty [function] [call site] 00975
43 Ok [function] [call site] 00976
43 BytesRange::suffix [function] [call site] 00977
43 parse [function] [call site] 00978
43 map_err [function] [call site] 00979
43 parse [function] [call site] 00980
43 map_err [function] [call site] 00981
43 parse [function] [call site] 00982
43 map_err [function] [call site] 00983
43 Err [function] [call site] 00984
43 Error::new [function] [call site] 00985
43 Error::with_operation [function] [call site] 00986
43 Error::with_context [function] [call site] 00987
43 Ok [function] [call site] 00988
43 BytesRange::new [function] [call site] 00989
43 Some [function] [call site] 00990
42 Operator::from_uri [function] [call site] 00991
43 Result::unwrap_or_default [function] [call site] 00992
43 Buffer::is_empty [function] [call site] 00993
43 opendal::Operator::from_uri [function] [call site] 00994
43 Result::map_err [function] [call site] 00995
43 opendal::Operator::from_uri [function] [call site] 00996
43 HfRepoType::as_str [function] [call site] 00997
43 Result::map_err [function] [call site] 00998
43 opendal::blocking::Operator::new [function] [call site] 00999
43 RetryLayer::clone [function] [call site] 01000
43 Result::map_err [function] [call site] 01001
43 Ok [function] [call site] 01002
42 tests::test_bytes_range_to_string [function] [call site] 01003
42 Result::expect [function] [call site] 01004
42 BytesRange::to_header [function] [call site] 01005
42 http::Request::header [function] [call site] 01006
42 http::Request::send [function] [call site] 01007
43 QueueBuf::take [function] [call site] 01008
43 QueueBuf::ok_or_else [function] [call site] 01009
43 Error::new [function] [call site] 01010
43 DeleteInput::into_delete_input [function] [call site] 01011
43 Result::delete [function] [call site] 01012
43 State::Delete [function] [call site] 01013
43 Box::pin [function] [call site] 01014
43 Ok [function] [call site] 01015
43 Err [function] [call site] 01016
43 Error::new [function] [call site] 01017
42 expect [function] [call site] 01018
42 raw::parse_content_length [function] [call site] 01019
43 parse_header_to_str [function] [call site] 01020
44 Timestamp::try_from [function] [call site] 01021
44 Result::map_err [function] [call site] 01022
44 Error::new [function] [call site] 01023
44 Error::with_operation [function] [call site] 01024
44 RouteRouter::target [function] [call site] 01025
44 Ok [function] [call site] 01026
44 Ok [function] [call site] 01027
44 Some [function] [call site] 01028
44 Vec::to_str [function] [call site] 01029
44 Result::map_err [function] [call site] 01030
44 Error::new [function] [call site] 01031
44 Error::with_operation [function] [call site] 01032
44 Error::with_context [function] [call site] 01033
44 HfRepoType::as_str [function] [call site] 01034
44 Error::set_source [function] [call site] 01035
43 ConfigDeserializer::deserialize_map [function] [call site] 01036
43 parse::<u64> [function] [call site] 01037
43 map_err [function] [call site] 01038
43 Error::new [function] [call site] 01039
43 Error::set_source [function] [call site] 01040
43 transpose [function] [call site] 01041
42 parse_prefixed_headers [function] [call site] 01042
43 ImmutableIndexLayer::extend_iter [function] [call site] 01043
44 extend [function] [call site] 01044
43 filter_map [function] [call site] 01045
43 HfRepoType::as_str [function] [call site] 01046
43 &'static [call site] 01047
43 and_then [function] [call site] 01048
43 Vec::to_str [function] [call site] 01049
43 FFIResult::ok [function] [call site] 01050
44 Box::into_raw [function] [call site] 01051
44 Fixture::new [function] [call site] 01052
44 ptr::null_mut [function] [call site] 01053
43 ConfigDeserializer::deserialize_map [function] [call site] 01054
44 V::visit_map [function] [call site] 01055
43 tests::test_bytes_range_to_string [function] [call site] 01056
43 tests::test_bytes_range_to_string [function] [call site] 01057
43 QueueBuf::collect [function] [call site] 01058
44 Buffer::is_empty [function] [call site] 01059
44 Buffer::new [function] [call site] 01060
44 Buffer::len [function] [call site] 01061
44 pop_front [function] [call site] 01062
44 MonoiofsCore::unwrap [function] [call site] 01063
44 into_iter [function] [call site] 01064
44 flatten [function] [call site] 01065
44 QueueBuf::collect [function] [call site] 01066
42 Result::expect [function] [call site] 01067
42 expect [function] [call site] 01068
42 test_batch_delete [function] [call site] 01069
42 expect [function] [call site] 01070
42 Ok [function] [call site] 01071
41 Duration::from_secs [function] [call site] 01072
41 reqwest::Client::new [function] [call site] 01073
41 tests::build_http_request [function] [call site] 01074
41 PresignedRequest::method [function] [call site] 01075
41 RetryLayer::clone [function] [call site] 01076
41 BytesRange::from_str [function] [call site] 01077
41 Operator::from_uri [function] [call site] 01078
41 tests::test_bytes_range_to_string [function] [call site] 01079
41 Result::expect [function] [call site] 01080
41 BytesRange::to_header [function] [call site] 01081
41 http::Request::header [function] [call site] 01082
41 http::Request::send [function] [call site] 01083
41 expect [function] [call site] 01084
41 raw::parse_content_length [function] [call site] 01085
41 parse_prefixed_headers [function] [call site] 01086
41 Result::expect [function] [call site] 01087
41 expect [function] [call site] 01088
41 test_batch_delete [function] [call site] 01089
41 expect [function] [call site] 01090
41 Ok [function] [call site] 01091
40 HfRepoType::as_str [function] [call site] 01092
40 Ok [function] [call site] 01093
39 Ok [function] [call site] 01094
38 Operator::context [function] [call site] 01095
38 RetryLayer::clone [function] [call site] 01096
38 Operator::service [function] [call site] 01097
38 RetryLayer::clone [function] [call site] 01098
37 Operator::delete_iter [function] [call site] 01099
38 Operator::deleter [function] [call site] 01100
38 Operator::delete_iter [function] [call site] 01101
38 ThrottleWrapper::close [function] [call site] 01102
39 ThrottleWrapper::close [function] [call site] 01103
40 ThrottleWrapper::close [function] [call site] 01104
38 Ok [function] [call site] 01105
37 ThrottleWrapper::close [function] [call site] 01106
37 Ok [function] [call site] 01107
36 RetryLayer::clone [function] [call site] 01108
36 expect [function] [call site] 01109
36 test_presign_stat [function] [call site] 01110
36 HfRepoType::as_str [function] [call site] 01111
36 Ok [function] [call site] 01112
35 expect [function] [call site] 01113
35 Ok [function] [call site] 01114
34 MonoiofsCore::unwrap [function] [call site] 01115
35 MonoiofsCore::propagate_worker_panic [function] [call site] 01116
33 test_copy_self [function] [call site] 01117
33 MonoiofsCore::unwrap [function] [call site] 01118
32 map_err [function] [call site] 01119
32 Error::new [function] [call site] 01120
32 Error::set_source [function] [call site] 01121
31 expect [function] [call site] 01122
31 std::thread::sleep [function] [call site] 01123
31 Duration::from_millis [function] [call site] 01124
31 QueueBuf::take [function] [call site] 01125
31 is_finished [function] [call site] 01126
31 FsCore::confined_join [function] [call site] 01127
31 std::panic::resume_unwind [function] [call site] 01128
29 into_iter [function] [call site] 01129
29 flatten [function] [call site] 01130
29 QueueBuf::collect [function] [call site] 01131
27 Buffer::new [function] [call site] 01132
27 Self::uri_mut [function] [call site] 01133
27 CapabilityOverrides::parse [function] [call site] 01134
28 Fixture::default [function] [call site] 01135
28 DeleteInput::split [function] [call site] 01136
28 ConfigDeserializer::deserialize_map [function] [call site] 01137
28 filter [function] [call site] 01138
28 Buffer::is_empty [function] [call site] 01139
28 parse_capability_override [function] [call site] 01140
28 ImmutableIndexLayer::insert [function] [call site] 01141
28 tests::test_bytes_range_to_string [function] [call site] 01142
28 CapabilityOverrides::try_apply [function] [call site] 01143
28 Fixture::default [function] [call site] 01144
28 Result::map_err [function] [call site] 01145
28 invalid_capability_override [function] [call site] 01146
28 Ok [function] [call site] 01147
27 MonoiofsCore::unwrap [function] [call site] 01148
27 Self::extensions_mut [function] [call site] 01149
27 ImmutableIndexLayer::insert [function] [call site] 01150
26 PresignedRequest::method [function] [call site] 01151
26 RetryLayer::clone [function] [call site] 01152
26 BytesRange::from_str [function] [call site] 01153
26 Operator::from_uri [function] [call site] 01154
26 tests::test_bytes_range_to_string [function] [call site] 01155
26 Result::expect [function] [call site] 01156
26 BytesRange::to_header [function] [call site] 01157
26 http::Request::header [function] [call site] 01158
26 http::Request::send [function] [call site] 01159
26 expect [function] [call site] 01160
26 gen_bytes [function] [call site] 01161
27 &mut [call site] 01162
27 Reader::read_into [function] [call site] 01163
26 expect [function] [call site] 01164
26 test_batch_delete [function] [call site] 01165
26 expect [function] [call site] 01166
26 Ok [function] [call site] 01167
25 Duration::from_secs [function] [call site] 01168
25 reqwest::Client::new [function] [call site] 01169
25 tests::build_http_request [function] [call site] 01170
25 PresignedRequest::method [function] [call site] 01171
25 RetryLayer::clone [function] [call site] 01172
25 BytesRange::from_str [function] [call site] 01173
25 Operator::from_uri [function] [call site] 01174
25 tests::test_bytes_range_to_string [function] [call site] 01175
25 Result::expect [function] [call site] 01176
25 BytesRange::to_header [function] [call site] 01177
25 http::Request::header [function] [call site] 01178
25 http::Request::send [function] [call site] 01179
25 expect [function] [call site] 01180
25 gen_bytes [function] [call site] 01181
25 expect [function] [call site] 01182
25 test_batch_delete [function] [call site] 01183
25 expect [function] [call site] 01184
25 Ok [function] [call site] 01185
24 expect [function] [call site] 01186
24 Buffer::to_bytes [function] [call site] 01187
24 test_batch_delete [function] [call site] 01188
24 expect [function] [call site] 01189
24 test_batch_delete [function] [call site] 01190
24 expect [function] [call site] 01191
24 Ok [function] [call site] 01192
23 RetryLayer::clone [function] [call site] 01193
23 test_copy_overwrite [function] [call site] 01194
23 RetryLayer::clone [function] [call site] 01195
23 expect [function] [call site] 01196
23 Operator::presign_stat_with [function] [call site] 01197
24 normalize_path [function] [call site] 01198
24 OperatorFuture::new [function] [call site] 01199
24 Operator::context [function] [call site] 01200
24 RetryLayer::clone [function] [call site] 01201
24 Operator::service [function] [call site] 01202
24 RetryLayer::clone [function] [call site] 01203
24 options::StatOptions::default [function] [call site] 01204
25 Fixture::new [function] [call site] 01205
23 Duration::from_secs [function] [call site] 01206
23 FuturePresignStat::override_content_type [function] [call site] 01207
24 Some [function] [call site] 01208
24 tests::test_bytes_range_to_string [function] [call site] 01209
23 expect [function] [call site] 01210
23 reqwest::Client::new [function] [call site] 01211
23 tests::build_http_request [function] [call site] 01212
23 PresignedRequest::method [function] [call site] 01213
23 RetryLayer::clone [function] [call site] 01214
23 BytesRange::from_str [function] [call site] 01215
23 Operator::from_uri [function] [call site] 01216
23 tests::test_bytes_range_to_string [function] [call site] 01217
23 Result::expect [function] [call site] 01218
23 BytesRange::to_header [function] [call site] 01219
23 http::Request::header [function] [call site] 01220
23 http::Request::send [function] [call site] 01221
23 expect [function] [call site] 01222
23 Ok [function] [call site] 01223
22 tests::test_writer_with [function] [call site] 01224
22 test_stat_with_override_cache_control [function] [call site] 01225
23 ThrottleAccessor::info [function] [call site] 01226
23 ThrottleAccessor::capability [function] [call site] 01227
23 ThrottleAccessor::info [function] [call site] 01228
23 ThrottleAccessor::capability [function] [call site] 01229
23 Ok [function] [call site] 01230
23 test_copy_with_if_not_exists_to_new_file [function] [call site] 01231
23 RetryLayer::clone [function] [call site] 01232
23 test_copy_overwrite [function] [call site] 01233
23 RetryLayer::clone [function] [call site] 01234
23 expect [function] [call site] 01235
23 Operator::presign_stat_with [function] [call site] 01236
23 Duration::from_secs [function] [call site] 01237
23 FuturePresignStat::override_cache_control [function] [call site] 01238
24 Some [function] [call site] 01239
24 tests::test_bytes_range_to_string [function] [call site] 01240
23 expect [function] [call site] 01241
23 reqwest::Client::new [function] [call site] 01242
23 tests::build_http_request [function] [call site] 01243
23 PresignedRequest::method [function] [call site] 01244
23 RetryLayer::clone [function] [call site] 01245
23 BytesRange::from_str [function] [call site] 01246
23 Operator::from_uri [function] [call site] 01247
23 tests::test_bytes_range_to_string [function] [call site] 01248
23 Result::expect [function] [call site] 01249
23 BytesRange::to_header [function] [call site] 01250
23 http::Request::header [function] [call site] 01251
23 http::Request::send [function] [call site] 01252
23 expect [function] [call site] 01253
23 Ok [function] [call site] 01254
22 tests::test_writer_with [function] [call site] 01255
22 test_stat_with_override_content_disposition [function] [call site] 01256
23 ThrottleAccessor::info [function] [call site] 01257
23 ThrottleAccessor::capability [function] [call site] 01258
23 ThrottleAccessor::info [function] [call site] 01259
23 ThrottleAccessor::capability [function] [call site] 01260
23 Ok [function] [call site] 01261
23 test_copy_with_if_not_exists_to_new_file [function] [call site] 01262
23 RetryLayer::clone [function] [call site] 01263
23 test_copy_overwrite [function] [call site] 01264
23 RetryLayer::clone [function] [call site] 01265
23 expect [function] [call site] 01266
23 Operator::presign_stat_with [function] [call site] 01267
23 Duration::from_secs [function] [call site] 01268
23 FuturePresignStat::override_content_disposition [function] [call site] 01269
24 Some [function] [call site] 01270
24 tests::test_bytes_range_to_string [function] [call site] 01271
23 expect [function] [call site] 01272
23 reqwest::Client::new [function] [call site] 01273
23 tests::build_http_request [function] [call site] 01274
23 PresignedRequest::method [function] [call site] 01275
23 RetryLayer::clone [function] [call site] 01276
23 BytesRange::from_str [function] [call site] 01277
23 Operator::from_uri [function] [call site] 01278
23 tests::test_bytes_range_to_string [function] [call site] 01279
23 Result::expect [function] [call site] 01280
23 BytesRange::to_header [function] [call site] 01281
23 http::Request::header [function] [call site] 01282
23 http::Request::send [function] [call site] 01283
23 expect [function] [call site] 01284
23 Ok [function] [call site] 01285
22 tests::new_test_operator [function] [call site] 01286
22 Fixture::default [function] [call site] 01287
22 tests::test_writer_with [function] [call site] 01288
22 test_stat_with_override_content_type [function] [call site] 01289
22 tests::test_writer_with [function] [call site] 01290
22 test_stat_with_override_cache_control [function] [call site] 01291
22 tests::test_writer_with [function] [call site] 01292
22 test_stat_with_override_content_disposition [function] [call site] 01293
21 test_copy_with_chunk [function] [call site] 01294
22 ThrottleAccessor::info [function] [call site] 01295
22 ThrottleAccessor::capability [function] [call site] 01296
22 copy_multi_chunk_size [function] [call site] 01297
23 expect [function] [call site] 01298
23 expect [function] [call site] 01299
23 Result::checked_add [function] [call site] 01300
23 is_some_and [function] [call site] 01301
23 Some [function] [call site] 01302
22 Ok [function] [call site] 01303
22 uuid::Uuid::new_v4 [function] [call site] 01304
22 tests::test_bytes_range_to_string [function] [call site] 01305
22 gen_fixed_bytes [function] [call site] 01306
23 gen_bytes_with_range [function] [call site] 01307
22 test_copy_overwrite [function] [call site] 01308
22 RetryLayer::clone [function] [call site] 01309
22 uuid::Uuid::new_v4 [function] [call site] 01310
22 tests::test_bytes_range_to_string [function] [call site] 01311
22 Operator::copy_with [function] [call site] 01312
22 FutureCopy::chunk [function] [call site] 01313
23 Some [function] [call site] 01314
22 test_presign_read [function] [call site] 01315
22 expect [function] [call site] 01316
22 Buffer::to_bytes [function] [call site] 01317
22 test_batch_delete [function] [call site] 01318
22 expect [function] [call site] 01319
22 test_batch_delete [function] [call site] 01320
22 expect [function] [call site] 01321
22 Ok [function] [call site] 01322
21 Writer::into_futures_async_write [function] [call site] 01323
22 FuturesAsyncWriter::new [function] [call site] 01324
23 BufferSink::new [function] [call site] 01325
24 State::Idle [function] [call site] 01326
24 Some [function] [call site] 01327
24 Buffer::new [function] [call site] 01328
23 oio::FlexBuf::new [function] [call site] 01329
24 BytesMut::with_capacity [function] [call site] 01330
21 BufReader::with_capacity [function] [call site] 01331
21 Fixture::new [function] [call site] 01332
22 Fixture::new [function] [call site] 01333
21 RetryLayer::clone [function] [call site] 01334
21 futures::io::copy_buf [function] [call site] 01335
21 ThrottleWrapper::close [function] [call site] 01336
22 ThrottleWrapper::close [function] [call site] 01337
21 test_presign_stat [function] [call site] 01338
21 expect [function] [call site] 01339
21 test_presign_read [function] [call site] 01340
21 Buffer::to_bytes [function] [call site] 01341
21 Ok [function] [call site] 01342
20 test_presign_read [function] [call site] 01343
20 expect [function] [call site] 01344
20 Buffer::to_bytes [function] [call site] 01345
20 test_batch_delete [function] [call site] 01346
20 expect [function] [call site] 01347
20 test_batch_delete [function] [call site] 01348
20 expect [function] [call site] 01349
20 Ok [function] [call site] 01350
19 ConfigDeserializer::deserialize_map [function] [call site] 01351
19 ThrottleWrapper::new [function] [call site] 01352
18 ThrottleAccessor::copy [function] [call site] 01353
19 test_writer_futures_copy [function] [call site] 01354
18 tests::assert_missing [function] [call site] 01355
19 test_presign_stat [function] [call site] 01356
19 unwrap_err [function] [call site] 01357
19 Ok [function] [call site] 01358
18 ThrottleAccessor::write [function] [call site] 01359
18 ThrottleAccessor::rename [function] [call site] 01360
19 ThrottleAccessor::rename [function] [call site] 01361
20 ThrottleAccessor::rename [function] [call site] 01362
18 tests::assert_missing [function] [call site] 01363
18 tests::assert_missing [function] [call site] 01364
18 Ok [function] [call site] 01365
17 OperationLabelNames::as_ref [function] [call site] 01366
17 tests::test_copy_and_rename_route_by_from [function] [call site] 01367
17 OperationLabelNames::as_ref [function] [call site] 01368
16 Fixture::new [function] [call site] 01369
16 Fixture::new [function] [call site] 01370
16 Fixture::new [function] [call site] 01371
17 Fixture::new [function] [call site] 01372
15 tests::build_mock_operator [function] [call site] 01373
15 RetryLayer::clone [function] [call site] 01374
15 ThrottleLayer::layer [function] [call site] 01375
15 RouteLayer::builder [function] [call site] 01376
15 RouteLayerBuilder::route [function] [call site] 01377
15 RetryLayer::clone [function] [call site] 01378
15 RouteLayerBuilder::build [function] [call site] 01379
15 ThrottleAccessor::write [function] [call site] 01380
15 ThrottleAccessor::copy [function] [call site] 01381
15 tests::assert_missing [function] [call site] 01382
15 ThrottleAccessor::write [function] [call site] 01383
15 ThrottleAccessor::rename [function] [call site] 01384
15 tests::assert_missing [function] [call site] 01385
15 tests::assert_missing [function] [call site] 01386
15 Ok [function] [call site] 01387
14 map_err [function] [call site] 01388
14 Error::new [function] [call site] 01389
13 Vec::trim [function] [call site] 01390
13 Result::map_err [function] [call site] 01391
13 invalid_capability_override [function] [call site] 01392
13 tests::test_bytes_range_to_string [function] [call site] 01393
12 ImmutableIndexLayer::insert [function] [call site] 01394
12 tests::test_bytes_range_to_string [function] [call site] 01395
12 CapabilityOverrides::try_apply [function] [call site] 01396
12 Fixture::default [function] [call site] 01397
12 Result::map_err [function] [call site] 01398
12 invalid_capability_override [function] [call site] 01399
12 Ok [function] [call site] 01400
11 Result::map_err [function] [call site] 01401
11 Error::new [function] [call site] 01402
11 Error::set_source [function] [call site] 01403
11 tests::global_registry_exposes_memory_scheme [function] [call site] 01404
12 OperatorRegistry::get [function] [call site] 01405
12 OperatorRegistry::schemes [function] [call site] 01406
13 Operator::spawn_block [function] [call site] 01407
13 expect [function] [call site] 01408
13 tests::test_prepare_path_allows_normal_keys [function] [call site] 01409
14 Fixture::new [function] [call site] 01410
14 MonoiofsCore::new [function] [call site] 01411
15 flume::unbounded [function] [call site] 01412
15 ConfigDeserializer::deserialize_map [function] [call site] 01413
15 RetryLayer::clone [function] [call site] 01414
15 std::thread::Builder::new [function] [call site] 01415
16 Fixture::default [function] [call site] 01416
15 Self::name [function] [call site] 01417
16 uuid::Uuid::new_v4 [function] [call site] 01418
16 tests::test_bytes_range_to_string [function] [call site] 01419
16 gen_bytes [function] [call site] 01420
16 ThrottleAccessor::info [function] [call site] 01421
16 ThrottleAccessor::capability [function] [call site] 01422
16 test_copy_overwrite [function] [call site] 01423
16 RetryLayer::clone [function] [call site] 01424
16 uuid::Uuid::new_v4 [function] [call site] 01425
16 tests::test_bytes_range_to_string [function] [call site] 01426
16 test_writer_futures_copy [function] [call site] 01427
16 test_presign_read [function] [call site] 01428
16 expect [function] [call site] 01429
16 Buffer::to_bytes [function] [call site] 01430
16 test_batch_delete [function] [call site] 01431
16 expect [function] [call site] 01432
16 test_batch_delete [function] [call site] 01433
16 expect [function] [call site] 01434
16 Ok [function] [call site] 01435
15 MonoiofsCore::spawn [function] [call site] 01436
16 send_async [function] [call site] 01437
16 Fixture::new [function] [call site] 01438
16 MonoiofsCore::spawn [function] [call site] 01439
16 test_copy_self [function] [call site] 01440
16 MonoiofsCore::unwrap [function] [call site] 01441
15 MonoiofsReader::worker_entrypoint [function] [call site] 01442
16 Fixture::new [function] [call site] 01443
17 Fixture::new [function] [call site] 01444
16 Self::read [function] [call site] 01445
17 uuid::Uuid::new_v4 [function] [call site] 01446
17 tests::test_bytes_range_to_string [function] [call site] 01447
17 gen_bytes [function] [call site] 01448
17 ThrottleAccessor::info [function] [call site] 01449
17 ThrottleAccessor::capability [function] [call site] 01450
17 test_copy_overwrite [function] [call site] 01451
17 RetryLayer::clone [function] [call site] 01452
17 expect [function] [call site] 01453
17 test_presign_read [function] [call site] 01454
17 Duration::from_secs [function] [call site] 01455
17 reqwest::Client::new [function] [call site] 01456
17 tests::build_http_request [function] [call site] 01457
17 PresignedRequest::method [function] [call site] 01458
17 RetryLayer::clone [function] [call site] 01459
17 BytesRange::from_str [function] [call site] 01460
17 Operator::from_uri [function] [call site] 01461
17 tests::test_bytes_range_to_string [function] [call site] 01462
17 Result::expect [function] [call site] 01463
17 BytesRange::to_header [function] [call site] 01464
17 http::Request::header [function] [call site] 01465
17 http::Request::send [function] [call site] 01466
17 expect [function] [call site] 01467
17 gen_bytes [function] [call site] 01468
17 expect [function] [call site] 01469
17 test_batch_delete [function] [call site] 01470
17 expect [function] [call site] 01471
17 Ok [function] [call site] 01472
16 ThrottleWrapper::open [function] [call site] 01473
17 ThrottleWrapper::open [function] [call site] 01474
18 ThrottleWrapper::open [function] [call site] 01475
18 Ok [function] [call site] 01476
18 Fixture::new [function] [call site] 01477
18 ThrottleWrapper::new [function] [call site] 01478
18 RetryLayer::clone [function] [call site] 01479
17 Ok [function] [call site] 01480
17 Fixture::new [function] [call site] 01481
17 ThrottleWrapper::new [function] [call site] 01482
17 RetryLayer::clone [function] [call site] 01483
16 oneshot::Sender<Result<()>>::send [function] [call site] 01484
17 QueueBuf::take [function] [call site] 01485
17 QueueBuf::ok_or_else [function] [call site] 01486
17 Error::new [function] [call site] 01487
17 DeleteInput::into_delete_input [function] [call site] 01488
17 Result::delete [function] [call site] 01489
17 State::Delete [function] [call site] 01490
17 Box::pin [function] [call site] 01491
17 Ok [function] [call site] 01492
17 Err [function] [call site] 01493
17 Error::new [function] [call site] 01494
16 Ok [function] [call site] 01495
16 oneshot::Sender<Result<()>>::send [function] [call site] 01496
16 Err [function] [call site] 01497
16 new_std_io_error [function] [call site] 01498
17 Error::kind [function] [call site] 01499
17 Error::new [function] [call site] 01500
17 Error::kind [function] [call site] 01501
17 tests::test_bytes_range_to_string [function] [call site] 01502
18 BytesRange::new [function] [call site] 01503
18 Some [function] [call site] 01504
18 BytesRange::new [function] [call site] 01505
18 BytesRange::new [function] [call site] 01506
18 Some [function] [call site] 01507
18 BytesRange::suffix [function] [call site] 01508
17 Error::set_source [function] [call site] 01509
17 Error::set_temporary [function] [call site] 01510
16 mpsc::UnboundedReceiver<ReaderRequest>::next [function] [call site] 01511
17 AwaitTreeWrapper::next [function] [call site] 01512
18 AwaitTreeWrapper::next [function] [call site] 01513
18 instrument_await [function] [call site] 01514
17 instrument_await [function] [call site] 01515
16 CompfsReader::read_at [function] [call site] 01516
17 Ok [function] [call site] 01517
17 Buffer::new [function] [call site] 01518
17 RouteRouter::target [function] [call site] 01519
17 Result::reserve [function] [call site] 01520
17 RetryLayer::clone [function] [call site] 01521
17 CompfsCore::exec [function] [call site] 01522
18 MonoiofsCore::dispatch [function] [call site] 01523
19 oneshot::channel [function] [call site] 01524
19 send_async [function] [call site] 01525
19 Fixture::new [function] [call site] 01526
19 MonoiofsCore::spawn [function] [call site] 01527
19 FuturesDeleteSink::start_send [function] [call site] 01528
20 QueueBuf::take [function] [call site] 01529
20 QueueBuf::ok_or_else [function] [call site] 01530
20 Error::new [function] [call site] 01531
20 DeleteInput::into_delete_input [function] [call site] 01532
20 Result::delete [function] [call site] 01533
20 State::Delete [function] [call site] 01534
20 Box::pin [function] [call site] 01535
20 Ok [function] [call site] 01536
20 Err [function] [call site] 01537
20 Error::new [function] [call site] 01538
19 test_copy_self [function] [call site] 01539
19 MonoiofsCore::unwrap [function] [call site] 01540
19 MonoiofsCore::unwrap [function] [call site] 01541
18 map_err [function] [call site] 01542
18 Error::new [function] [call site] 01543
18 map_err [function] [call site] 01544
18 Error::new [function] [call site] 01545
18 map_err [function] [call site] 01546
17 Ok [function] [call site] 01547
17 Executor::into_inner [function] [call site] 01548
17 Buffer::split_to [function] [call site] 01549
18 Buffer::len [function] [call site] 01550
18 Buffer::slice [function] [call site] 01551
19 Buffer::len [function] [call site] 01552
19 (Vec::start_bound [function] [call site] 01553
19 Result::checked_add [function] [call site] 01554
19 expect [function] [call site] 01555
19 (Vec::end_bound [function] [call site] 01556
19 Result::checked_add [function] [call site] 01557
19 expect [function] [call site] 01558
19 Buffer::new [function] [call site] 01559
19 RetryLayer::clone [function] [call site] 01560
19 Buffer::truncate [function] [call site] 01561
19 Buffer::advance [function] [call site] 01562
18 Buffer::advance [function] [call site] 01563
19 Buffer::advance [function] [call site] 01564
19 Buffer::len [function] [call site] 01565
17 FlexBuf::freeze [function] [call site] 01566
17 DeleteInput::into_delete_input [function] [call site] 01567
17 Ok [function] [call site] 01568
17 CompfsBuffer::from [function] [call site] 01569
18 Self [function] [call site] 01570
18 io::Result::by_ref [function] [call site] 01571
18 QueueBuf::collect [function] [call site] 01572
17 Buffer::from [function] [call site] 01573
18 ImmutableIndexLayer::extend_iter [function] [call site] 01574
19 extend [function] [call site] 01575
18 ConfigDeserializer::deserialize_map [function] [call site] 01576
18 S3Core::calculate_checksum [function] [call site] 01577
19 Some [function] [call site] 01578
19 format_crc32c_iter [function] [call site] 01579
20 Fixture::new [function] [call site] 01580
21 Fixture::new [function] [call site] 01581
20 Buffer::for_each [function] [call site] 01582
20 AzfileCore::azfile_update [function] [call site] 01583
21 build_abs_path [function] [call site] 01584
21 String::trim_start_matches [function] [call site] 01585
21 tests::test_bytes_range_to_string [function] [call site] 01586
21 DeleteInput::into_delete_input [function] [call site] 01587
21 BytesRange::to_header [function] [call site] 01588
21 BytesRange::to_header [function] [call site] 01589
21 BytesRange::to_header [function] [call site] 01590
21 BytesRange::from [function] [call site] 01591
22 (Vec::start_bound [function] [call site] 01592
22 cloned [function] [call site] 01593
22 Result::saturating_add [function] [call site] 01594
22 (Vec::end_bound [function] [call site] 01595
22 cloned [function] [call site] 01596
22 Some [function] [call site] 01597
22 Result::saturating_add [function] [call site] 01598
22 saturating_sub [function] [call site] 01599
22 Some [function] [call site] 01600
22 Result::saturating_sub [function] [call site] 01601
22 BytesRange::new [function] [call site] 01602
21 BytesRange::to_header [function] [call site] 01603
21 DeleteInput::extension [function] [call site] 01604
21 extension [function] [call site] 01605
21 ServiceOperation [function] [call site] 01606
21 DeleteInput::body [function] [call site] 01607
21 map_err [function] [call site] 01608
21 AzfileCore::sign [function] [call site] 01609
22 Entry::into_parts [function] [call site] 01610
22 ImmutableIndexLayer::insert [function] [call site] 01611
22 HeaderName::from_static [function] [call site] 01612
22 HeaderValue::from_static [function] [call site] 01613
22 AzfileCore::signer [function] [call site] 01614
23 RetryLayer::clone [function] [call site] 01615
23 Error::with_context [function] [call site] 01616
24 QueryPairsWriter::push [function] [call site] 01617
24 tests::test_bytes_range_to_string [function] [call site] 01618
23 RetryLayer::clone [function] [call site] 01619
23 with_http_send [function] [call site] 01620
23 OperationContext::with_http_transport [function] [call site] 01621
23 RetryLayer::clone [function] [call site] 01622
22 GdriveSigner::sign [function] [call site] 01623
23 Buffer::is_empty [function] [call site] 01624
23 Timestamp::now [function] [call site] 01625
24 Self [function] [call site] 01626
24 jiff::Timestamp::now [function] [call site] 01627
25 Self [function] [call site] 01628
25 jiff::Timestamp::now [function] [call site] 01629
23 parse [function] [call site] 01630
23 expect [function] [call site] 01631
23 &mut [call site] 01632
23 ImmutableIndexLayer::insert [function] [call site] 01633
23 Ok [function] [call site] 01634
23 Request::post [function] [call site] 01635
23 BytesRange::to_header [function] [call site] 01636
23 body [function] [call site] 01637
23 Buffer::new [function] [call site] 01638
23 map_err [function] [call site] 01639
23 OperationContext::with_http_transport [function] [call site] 01640
23 FuturesDeleteSink::start_send [function] [call site] 01641
23 WebhdfsCore::webhdfs_list_status [function] [call site] 01642
23 into_body [function] [call site] 01643
23 serde_json::from_reader [function] [call site] 01644
23 test_reader [function] [call site] 01645
24 test_copy_with_if_not_exists_to_new_file [function] [call site] 01646
24 RetryLayer::clone [function] [call site] 01647
24 test_copy_overwrite [function] [call site] 01648
24 RetryLayer::clone [function] [call site] 01649
24 expect [function] [call site] 01650
24 test_reader [function] [call site] 01651
24 test_presign_read [function] [call site] 01652
24 Buffer::to_bytes [function] [call site] 01653
24 test_reader [function] [call site] 01654
24 Reader::into_bytes_stream [function] [call site] 01655
25 FuturesBytesStream::new [function] [call site] 01656
26 BufferStream::create [function] [call site] 01657
26 Ok [function] [call site] 01658
26 Buffer::new [function] [call site] 01659
24 try_fold [function] [call site] 01660
24 Fixture::new [function] [call site] 01661
24 extend_from_slice [function] [call site] 01662
24 Ok [function] [call site] 01663
24 test_reader [function] [call site] 01664
24 Reader::into_futures_async_read [function] [call site] 01665
25 ReadContext::parse_into_range [function] [call site] 01666
26 Reader::read_into [function] [call site] 01667
26 u64::checked_add [function] [call site] 01668
26 ok_or_else [function] [call site] 01669
26 Error::new [function] [call site] 01670
26 ReadContext::content_length [function] [call site] 01671
27 ReadContext::args [function] [call site] 01672
27 FutureRead::content_length_hint [function] [call site] 01673
28 Some [function] [call site] 01674
27 Ok [function] [call site] 01675
27 ReadContext::metadata [function] [call site] 01676
28 RouteRouter::target [function] [call site] 01677
27 ConfigDeserializer::deserialize_map [function] [call site] 01678
27 CompleteLister::ensure_file_content_length [function] [call site] 01679
28 crate::Entry::path [function] [call site] 01680
29 Fixture::add_path [function] [call site] 01681
30 Operator::spawn_block [function] [call site] 01682
30 MonoiofsCore::unwrap [function] [call site] 01683
30 QueryPairsWriter::push [function] [call site] 01684
29 tests::test_bytes_range_to_string [function] [call site] 01685
28 tests::test_bytes_range_to_string [function] [call site] 01686
29 BytesRange::new [function] [call site] 01687
29 Some [function] [call site] 01688
29 BytesRange::new [function] [call site] 01689
29 BytesRange::new [function] [call site] 01690
29 Some [function] [call site] 01691
29 BytesRange::suffix [function] [call site] 01692
28 crate::Entry::metadata [function] [call site] 01693
29 io::frbgen_opendal_rust_arc_increment_strong_count_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerMetadata [function] [call site] 01694
30 MoiArc::<flutter_rust_bridge::for_generated::RustAutoOpaqueInner<Metadata>>::increment_strong_count [function] [call site] 01695
29 test_buffer_stream_metadata [function] [call site] 01696
30 new_file_path [function] [call site] 01697
30 gen_fixed_bytes [function] [call site] 01698
30 test_copy_overwrite [function] [call site] 01699
30 RetryLayer::clone [function] [call site] 01700
30 expect [function] [call site] 01701
30 test_reader [function] [call site] 01702
30 Reader::into_stream [function] [call site] 01703
31 BufferStream::create [function] [call site] 01704
30 Result::metadata [function] [call site] 01705
31 new_file_path [function] [call site] 01706
31 gen_fixed_bytes [function] [call site] 01707
31 test_copy_overwrite [function] [call site] 01708
31 RetryLayer::clone [function] [call site] 01709
31 expect [function] [call site] 01710
31 test_reader [function] [call site] 01711
31 Reader::into_stream [function] [call site] 01712
31 Result::metadata [function] [call site] 01713
31 Error::kind [function] [call site] 01714
31 Err [function] [call site] 01715
31 Reader::read_into [function] [call site] 01716
32 RetryLayer::clone [function] [call site] 01717
32 Reader::into_stream [function] [call site] 01718
32 Result::try_next [function] [call site] 01719
32 Ok [function] [call site] 01720
32 Buffer::len [function] [call site] 01721
32 io::Result::put [function] [call site] 01722
31 Result::try_collect [function] [call site] 01723
31 Result::into_iter [function] [call site] 01724
31 flatten [function] [call site] 01725
31 QueueBuf::collect [function] [call site] 01726
31 Ok [function] [call site] 01727
30 Error::kind [function] [call site] 01728
30 Err [function] [call site] 01729
30 Reader::read_into [function] [call site] 01730
30 Result::try_collect [function] [call site] 01731
30 Result::into_iter [function] [call site] 01732
30 flatten [function] [call site] 01733
30 QueueBuf::collect [function] [call site] 01734
30 Ok [function] [call site] 01735
29 RetryLayer::clone [function] [call site] 01736
28 Metadata::version [function] [call site] 01737
29 test_delete_with_version [function] [call site] 01738
30 ThrottleAccessor::info [function] [call site] 01739
30 ThrottleAccessor::capability [function] [call site] 01740
30 Ok [function] [call site] 01741
30 test_copy_with_if_not_exists_to_new_file [function] [call site] 01742
30 RetryLayer::clone [function] [call site] 01743
30 test_copy_overwrite [function] [call site] 01744
30 HfRepoType::as_str [function] [call site] 01745
30 expect [function] [call site] 01746
30 test_presign_stat [function] [call site] 01747
30 HfRepoType::as_str [function] [call site] 01748
30 expect [function] [call site] 01749
30 Result::version [function] [call site] 01750
31 ThrottleAccessor::info [function] [call site] 01751
31 ThrottleAccessor::capability [function] [call site] 01752
31 Ok [function] [call site] 01753
31 test_copy_with_if_not_exists_to_new_file [function] [call site] 01754
31 RetryLayer::clone [function] [call site] 01755
31 test_copy_overwrite [function] [call site] 01756
31 HfRepoType::as_str [function] [call site] 01757
31 expect [function] [call site] 01758
31 test_presign_stat [function] [call site] 01759
31 HfRepoType::as_str [function] [call site] 01760
31 expect [function] [call site] 01761
31 Result::version [function] [call site] 01762
31 Result::expect [function] [call site] 01763
31 test_batch_delete [function] [call site] 01764
31 HfRepoType::as_str [function] [call site] 01765
31 expect [function] [call site] 01766
31 Operator::stat_with [function] [call site] 01767
32 normalize_path [function] [call site] 01768
32 OperatorFuture::new [function] [call site] 01769
32 Operator::context [function] [call site] 01770
32 RetryLayer::clone [function] [call site] 01771
32 Operator::service [function] [call site] 01772
32 RetryLayer::clone [function] [call site] 01773
32 options::StatOptions::default [function] [call site] 01774
31 HfRepoType::as_str [function] [call site] 01775
31 FutureStat::version [function] [call site] 01776
32 Some [function] [call site] 01777
32 tests::test_bytes_range_to_string [function] [call site] 01778
31 expect [function] [call site] 01779
31 Operator::delete_with [function] [call site] 01780
31 HfRepoType::as_str [function] [call site] 01781
31 FutureDelete::version [function] [call site] 01782
32 Some [function] [call site] 01783
32 tests::test_bytes_range_to_string [function] [call site] 01784
31 expect [function] [call site] 01785
31 Operator::stat_with [function] [call site] 01786
31 HfRepoType::as_str [function] [call site] 01787
31 FutureStat::version [function] [call site] 01788
31 Ok [function] [call site] 01789
30 Result::expect [function] [call site] 01790
30 test_batch_delete [function] [call site] 01791
30 HfRepoType::as_str [function] [call site] 01792
30 expect [function] [call site] 01793
30 Operator::stat_with [function] [call site] 01794
30 HfRepoType::as_str [function] [call site] 01795
30 FutureStat::version [function] [call site] 01796
30 expect [function] [call site] 01797
30 Operator::delete_with [function] [call site] 01798
30 HfRepoType::as_str [function] [call site] 01799
30 FutureDelete::version [function] [call site] 01800
30 expect [function] [call site] 01801
30 Operator::stat_with [function] [call site] 01802
30 HfRepoType::as_str [function] [call site] 01803
30 FutureStat::version [function] [call site] 01804
30 Ok [function] [call site] 01805
29 ConfigDeserializer::deserialize_map [function] [call site] 01806
29 tests::test_bytes_range_to_string [function] [call site] 01807
28 ConfigDeserializer::deserialize_map [function] [call site] 01808
28 OpStat::new [function] [call site] 01809
29 Fixture::default [function] [call site] 01810
28 Result::as_deref [function] [call site] 01811
28 test_delete_with_version [function] [call site] 01812
29 ThrottleAccessor::info [function] [call site] 01813
29 ThrottleAccessor::capability [function] [call site] 01814
29 Ok [function] [call site] 01815
29 test_copy_with_if_not_exists_to_new_file [function] [call site] 01816
29 RetryLayer::clone [function] [call site] 01817
29 test_copy_overwrite [function] [call site] 01818
29 HfRepoType::as_str [function] [call site] 01819
29 expect [function] [call site] 01820
29 test_presign_stat [function] [call site] 01821
29 HfRepoType::as_str [function] [call site] 01822
29 expect [function] [call site] 01823
29 Result::version [function] [call site] 01824
29 Result::expect [function] [call site] 01825
29 test_batch_delete [function] [call site] 01826
29 HfRepoType::as_str [function] [call site] 01827
29 expect [function] [call site] 01828
29 Operator::stat_with [function] [call site] 01829
29 HfRepoType::as_str [function] [call site] 01830
29 FutureStat::version [function] [call site] 01831
29 expect [function] [call site] 01832
29 Operator::delete_with [function] [call site] 01833
29 HfRepoType::as_str [function] [call site] 01834
29 FutureDelete::version [function] [call site] 01835
29 expect [function] [call site] 01836
29 Operator::stat_with [function] [call site] 01837
29 HfRepoType::as_str [function] [call site] 01838
29 FutureStat::version [function] [call site] 01839
29 Ok [function] [call site] 01840
28 test_presign_stat [function] [call site] 01841
28 RpRead::into_metadata [function] [call site] 01842
28 Metadata::has_content_length [function] [call site] 01843
29 is_some [function] [call site] 01844
28 Err [function] [call site] 01845
28 Error::new [function] [call site] 01846
28 Error::with_operation [function] [call site] 01847
28 Error::with_context [function] [call site] 01848
28 ThrottleAccessor::info [function] [call site] 01849
28 tests::global_registry_exposes_memory_scheme [function] [call site] 01850
29 OperatorRegistry::get [function] [call site] 01851
29 OperatorRegistry::schemes [function] [call site] 01852
28 tests::test_bytes_range_to_string [function] [call site] 01853
28 Error::with_context [function] [call site] 01854
28 crate::Entry::metadata_mut [function] [call site] 01855
28 Metadata::set_content_length [function] [call site] 01856
29 Some [function] [call site] 01857
28 CompleteLister::ensure_file_content_length [function] [call site] 01858
28 Ok [function] [call site] 01859
27 Ok [function] [call site] 01860
27 OpStat::new [function] [call site] 01861
27 ReadContext::args [function] [call site] 01862
27 &OpRead::version [function] [call site] 01863
28 ThrottleAccessor::info [function] [call site] 01864
28 ThrottleAccessor::capability [function] [call site] 01865
28 Ok [function] [call site] 01866
28 test_copy_with_if_not_exists_to_new_file [function] [call site] 01867
28 RetryLayer::clone [function] [call site] 01868
28 test_copy_overwrite [function] [call site] 01869
28 HfRepoType::as_str [function] [call site] 01870
28 expect [function] [call site] 01871
28 test_presign_stat [function] [call site] 01872
28 HfRepoType::as_str [function] [call site] 01873
28 expect [function] [call site] 01874
28 Result::version [function] [call site] 01875
28 Result::expect [function] [call site] 01876
28 test_batch_delete [function] [call site] 01877
28 HfRepoType::as_str [function] [call site] 01878
28 expect [function] [call site] 01879
28 Operator::stat_with [function] [call site] 01880
28 HfRepoType::as_str [function] [call site] 01881
28 FutureStat::version [function] [call site] 01882
28 expect [function] [call site] 01883
28 Operator::delete_with [function] [call site] 01884
28 HfRepoType::as_str [function] [call site] 01885
28 FutureDelete::version [function] [call site] 01886
28 expect [function] [call site] 01887
28 Operator::stat_with [function] [call site] 01888
28 HfRepoType::as_str [function] [call site] 01889
28 FutureStat::version [function] [call site] 01890
28 Ok [function] [call site] 01891
27 Result::with_version [function] [call site] 01892
28 ThrottleAccessor::info [function] [call site] 01893
28 ThrottleAccessor::capability [function] [call site] 01894
28 Ok [function] [call site] 01895
28 test_copy_with_if_not_exists_to_new_file [function] [call site] 01896
28 RetryLayer::clone [function] [call site] 01897
28 test_copy_overwrite [function] [call site] 01898
28 HfRepoType::as_str [function] [call site] 01899
28 expect [function] [call site] 01900
28 test_presign_stat [function] [call site] 01901
28 HfRepoType::as_str [function] [call site] 01902
28 expect [function] [call site] 01903
28 Result::version [function] [call site] 01904
28 Result::expect [function] [call site] 01905
28 test_batch_delete [function] [call site] 01906
28 HfRepoType::as_str [function] [call site] 01907
28 expect [function] [call site] 01908
28 Operator::stat_with [function] [call site] 01909
28 HfRepoType::as_str [function] [call site] 01910
28 FutureStat::version [function] [call site] 01911
28 expect [function] [call site] 01912
28 Operator::delete_with [function] [call site] 01913
28 HfRepoType::as_str [function] [call site] 01914
28 FutureDelete::version [function] [call site] 01915
28 expect [function] [call site] 01916
28 Operator::stat_with [function] [call site] 01917
28 HfRepoType::as_str [function] [call site] 01918
28 FutureStat::version [function] [call site] 01919
28 Ok [function] [call site] 01920
27 Ok [function] [call site] 01921
27 test_presign_stat [function] [call site] 01922
27 ReadContext::path [function] [call site] 01923
27 RpRead::into_metadata [function] [call site] 01924
27 CompleteLister::ensure_file_content_length [function] [call site] 01925
28 crate::Entry::path [function] [call site] 01926
28 tests::test_bytes_range_to_string [function] [call site] 01927
28 crate::Entry::metadata [function] [call site] 01928
28 Metadata::version [function] [call site] 01929
28 ConfigDeserializer::deserialize_map [function] [call site] 01930
28 OpStat::new [function] [call site] 01931
28 Result::as_deref [function] [call site] 01932
28 test_delete_with_version [function] [call site] 01933
28 test_presign_stat [function] [call site] 01934
28 RpRead::into_metadata [function] [call site] 01935
28 Metadata::has_content_length [function] [call site] 01936
28 Err [function] [call site] 01937
28 Error::new [function] [call site] 01938
28 Error::with_operation [function] [call site] 01939
28 Error::with_context [function] [call site] 01940
28 ThrottleAccessor::info [function] [call site] 01941
28 tests::global_registry_exposes_memory_scheme [function] [call site] 01942
28 tests::test_bytes_range_to_string [function] [call site] 01943
28 Error::with_context [function] [call site] 01944
28 crate::Entry::metadata_mut [function] [call site] 01945
28 Metadata::set_content_length [function] [call site] 01946
28 CompleteLister::ensure_file_content_length [function] [call site] 01947
28 Ok [function] [call site] 01948
26 ReadContext::content_length [function] [call site] 01949
26 Result::saturating_sub [function] [call site] 01950
26 Ok [function] [call site] 01951
25 Ok [function] [call site] 01952
25 FuturesAsyncReader::new [function] [call site] 01953
26 BufferStream::new [function] [call site] 01954
27 Operator::presign_stat_options [function] [call site] 01955
27 Result::chunk [function] [call site] 01956
28 ThrottleAccessor::info [function] [call site] 01957
28 ThrottleAccessor::capability [function] [call site] 01958
28 copy_multi_chunk_size [function] [call site] 01959
28 Ok [function] [call site] 01960
28 uuid::Uuid::new_v4 [function] [call site] 01961
28 tests::test_bytes_range_to_string [function] [call site] 01962
28 gen_fixed_bytes [function] [call site] 01963
28 test_copy_overwrite [function] [call site] 01964
28 RetryLayer::clone [function] [call site] 01965
28 uuid::Uuid::new_v4 [function] [call site] 01966
28 tests::test_bytes_range_to_string [function] [call site] 01967
28 Operator::copy_with [function] [call site] 01968
28 FutureCopy::chunk [function] [call site] 01969
28 test_presign_read [function] [call site] 01970
28 expect [function] [call site] 01971
28 Buffer::to_bytes [function] [call site] 01972
28 test_batch_delete [function] [call site] 01973
28 expect [function] [call site] 01974
28 test_batch_delete [function] [call site] 01975
28 expect [function] [call site] 01976
28 Ok [function] [call site] 01977
27 Result::is_some [function] [call site] 01978
27 TwoWays::Two [function] [call site] 01979
27 ChunkedReader::new [function] [call site] 01980
28 ConcurrentTasks::new [function] [call site] 01981
29 VecDeque::with_capacity [function] [call site] 01982
29 VecDeque::with_capacity [function] [call site] 01983
29 Fixture::default [function] [call site] 01984
30 Fixture::new [function] [call site] 01985
28 OtelMetricsLayer::apply_context [function] [call site] 01986
29 observe::MetricsLayer::new [function] [call site] 01987
29 RetryLayer::clone [function] [call site] 01988
29 OtelMetricsLayer::apply_context [function] [call site] 01989
28 OperationContext::executor [function] [call site] 01990
28 RetryLayer::clone [function] [call site] 01991
29 RetryLayer::clone [function] [call site] 01992
28 Operator::presign_stat_options [function] [call site] 01993
28 Result::concurrent [function] [call site] 01994
29 ThrottleAccessor::info [function] [call site] 01995
29 ThrottleAccessor::capability [function] [call site] 01996
29 copy_multi_chunk_size [function] [call site] 01997
29 Ok [function] [call site] 01998
29 uuid::Uuid::new_v4 [function] [call site] 01999
29 tests::test_bytes_range_to_string [function] [call site] 02000
29 gen_fixed_bytes [function] [call site] 02001
29 test_copy_overwrite [function] [call site] 02002
29 RetryLayer::clone [function] [call site] 02003
29 uuid::Uuid::new_v4 [function] [call site] 02004
29 tests::test_bytes_range_to_string [function] [call site] 02005
29 Operator::copy_with [function] [call site] 02006
29 FutureCopy::chunk [function] [call site] 02007
29 Self::concurrent [function] [call site] 02008
30 ThrottleAccessor::info [function] [call site] 02009
30 ThrottleAccessor::capability [function] [call site] 02010
30 copy_multi_chunk_size [function] [call site] 02011
30 Ok [function] [call site] 02012
30 uuid::Uuid::new_v4 [function] [call site] 02013
30 tests::test_bytes_range_to_string [function] [call site] 02014
30 gen_fixed_bytes [function] [call site] 02015
30 test_copy_overwrite [function] [call site] 02016
30 RetryLayer::clone [function] [call site] 02017
30 uuid::Uuid::new_v4 [function] [call site] 02018
30 tests::test_bytes_range_to_string [function] [call site] 02019
30 Operator::copy_with [function] [call site] 02020
30 FutureCopy::chunk [function] [call site] 02021
30 Self::concurrent [function] [call site] 02022
30 test_presign_read [function] [call site] 02023
30 expect [function] [call site] 02024
30 Buffer::to_bytes [function] [call site] 02025
30 test_batch_delete [function] [call site] 02026
30 expect [function] [call site] 02027
30 test_batch_delete [function] [call site] 02028
30 expect [function] [call site] 02029
30 Ok [function] [call site] 02030
29 test_presign_read [function] [call site] 02031
29 expect [function] [call site] 02032
29 Buffer::to_bytes [function] [call site] 02033
29 test_batch_delete [function] [call site] 02034
29 expect [function] [call site] 02035
29 test_batch_delete [function] [call site] 02036
29 expect [function] [call site] 02037
29 Ok [function] [call site] 02038
28 Operator::presign_stat_options [function] [call site] 02039
28 OpReader::with_prefetch [function] [call site] 02040
28 Box::pin [function] [call site] 02041
28 QueueBuf::take [function] [call site] 02042
29 QueueBuf::take [function] [call site] 02043
28 anyhow::Result::read_all [function] [call site] 02044
29 RetryReadStream::read [function] [call site] 02045
30 RetryLayer::clone [function] [call site] 02046
30 QueueBuf::take [function] [call site] 02047
30 anyhow::Result::clone [function] [call site] 02048
31 RetryLayer::clone [function] [call site] 02049
30 Buffer::advance [function] [call site] 02050
31 Buffer::advance [function] [call site] 02051
31 Buffer::len [function] [call site] 02052
30 anyhow::Result::open [function] [call site] 02053
31 ThrottleWrapper::open [function] [call site] 02054
31 Ok [function] [call site] 02055
31 Fixture::new [function] [call site] 02056
31 ThrottleWrapper::new [function] [call site] 02057
31 RetryLayer::clone [function] [call site] 02058
30 Err [function] [call site] 02059
30 Result::read [function] [call site] 02060
31 uuid::Uuid::new_v4 [function] [call site] 02061
31 tests::test_bytes_range_to_string [function] [call site] 02062
31 gen_bytes [function] [call site] 02063
31 ThrottleAccessor::info [function] [call site] 02064
31 ThrottleAccessor::capability [function] [call site] 02065
31 test_copy_overwrite [function] [call site] 02066
31 RetryLayer::clone [function] [call site] 02067
31 expect [function] [call site] 02068
31 test_presign_read [function] [call site] 02069
31 Duration::from_secs [function] [call site] 02070
31 reqwest::Client::new [function] [call site] 02071
31 tests::build_http_request [function] [call site] 02072
31 PresignedRequest::method [function] [call site] 02073
31 RetryLayer::clone [function] [call site] 02074
31 BytesRange::from_str [function] [call site] 02075
31 Operator::from_uri [function] [call site] 02076
31 tests::test_bytes_range_to_string [function] [call site] 02077
31 Result::expect [function] [call site] 02078
31 BytesRange::to_header [function] [call site] 02079
31 http::Request::header [function] [call site] 02080
31 http::Request::send [function] [call site] 02081
31 expect [function] [call site] 02082
31 gen_bytes [function] [call site] 02083
31 expect [function] [call site] 02084
31 test_batch_delete [function] [call site] 02085
31 expect [function] [call site] 02086
31 Ok [function] [call site] 02087
30 io::Result::is_empty [function] [call site] 02088
31 Buffer::len [function] [call site] 02089
30 io::Result::len [function] [call site] 02090
31 Buffer::remaining [function] [call site] 02091
30 Some [function] [call site] 02092
30 Ok [function] [call site] 02093
30 Err [function] [call site] 02094
30 opendal_operator_layers::add_retry [function] [call site] 02095
31 opendal_operator_layers::deref_mut [function] [call site] 02096
31 QueryPairsWriter::push [function] [call site] 02097
32 QueryPairsWriter::push [function] [call site] 02098
32 QueryPairsWriter::push [function] [call site] 02099
32 push_str [function] [call site] 02100
32 Buffer::is_empty [function] [call site] 02101
32 QueryPairsWriter::push [function] [call site] 02102
32 push_str [function] [call site] 02103
31 Duration::from_nanos [function] [call site] 02104
31 Duration::from_nanos [function] [call site] 02105
30 when [function] [call site] 02106
30 Error::is_temporary [function] [call site] 02107
30 OtelMetricsLayer::apply_context [function] [call site] 02108
30 RetryLayer::with_notify [function] [call site] 02109
31 Fixture::new [function] [call site] 02110
30 F::intercept [function] [call site] 02111
30 map_err [function] [call site] 02112
30 Error::set_persistent [function] [call site] 02113
29 io::Result::is_empty [function] [call site] 02114
29 QueryPairsWriter::push [function] [call site] 02115
29 Err [function] [call site] 02116
29 Ok [function] [call site] 02117
29 into_iter [function] [call site] 02118
29 flatten [function] [call site] 02119
29 QueueBuf::collect [function] [call site] 02120
28 test_reader [function] [call site] 02121
28 test_presign_read [function] [call site] 02122
28 ReadContext::observe_read_response [function] [call site] 02123
29 RpRead::into_metadata [function] [call site] 02124
29 ReadContext::metadata [function] [call site] 02125
29 Option::is_none [function] [call site] 02126
29 ReadContext::set_metadata [function] [call site] 02127
30 MemoryCore::set [function] [call site] 02128
31 Operator::spawn_block [function] [call site] 02129
31 MonoiofsCore::unwrap [function] [call site] 02130
31 ImmutableIndexLayer::insert [function] [call site] 02131
31 tests::test_bytes_range_to_string [function] [call site] 02132
32 BytesRange::new [function] [call site] 02133
32 Some [function] [call site] 02134
32 BytesRange::new [function] [call site] 02135
32 BytesRange::new [function] [call site] 02136
32 Some [function] [call site] 02137
32 BytesRange::suffix [function] [call site] 02138
31 Ok [function] [call site] 02139
28 Ok [function] [call site] 02140
28 Err [function] [call site] 02141
28 BytesRange::offset [function] [call site] 02142
28 (Vec::size [function] [call site] 02143
29 expect [function] [call site] 02144
29 expect [function] [call site] 02145
29 Result::checked_add [function] [call site] 02146
29 is_some_and [function] [call site] 02147
29 Some [function] [call site] 02148
27 RetryLayer::clone [function] [call site] 02149
27 BytesRange::new [function] [call site] 02150
27 TwoWays::One [function] [call site] 02151
27 StreamingReader::new [function] [call site] 02152
28 ReadGenerator::new [function] [call site] 02153
27 RetryLayer::clone [function] [call site] 02154
27 BytesRange::new [function] [call site] 02155
27 State::Idle [function] [call site] 02156
27 Some [function] [call site] 02157
26 RetryLayer::clone [function] [call site] 02158
26 Some [function] [call site] 02159
26 Buffer::new [function] [call site] 02160
24 Fixture::new [function] [call site] 02161
24 read_to_end [function] [call site] 02162
24 Ok [function] [call site] 02163
23 map_err [function] [call site] 02164
23 clone_from [function] [call site] 02165
23 Timestamp::now [function] [call site] 02166
23 Duration::from_secs [function] [call site] 02167
23 Duration::from_secs [function] [call site] 02168
23 Err [function] [call site] 02169
23 parse_error [function] [call site] 02170
24 Error::new [function] [call site] 02171
24 Error::set_source [function] [call site] 02172
24 Error::new [function] [call site] 02173
24 Error::set_source [function] [call site] 02174
24 Error::new [function] [call site] 02175
24 Error::set_source [function] [call site] 02176
24 Error::new [function] [call site] 02177
24 Error::set_source [function] [call site] 02178
24 Error::new [function] [call site] 02179
24 Error::set_source [function] [call site] 02180
24 Error::new [function] [call site] 02181
24 Error::set_source [function] [call site] 02182
24 Error::new [function] [call site] 02183
24 Error::set_source [function] [call site] 02184
24 Error::new [function] [call site] 02185
24 Error::set_source [function] [call site] 02186
23 &mut [call site] 02187
23 ImmutableIndexLayer::insert [function] [call site] 02188
23 parse [function] [call site] 02189
23 MonoiofsCore::unwrap [function] [call site] 02190
23 Ok [function] [call site] 02191
22 map_err [function] [call site] 02192
22 new_request_sign_error [function] [call site] 02193
23 Error::new [function] [call site] 02194
23 Error::with_operation [function] [call site] 02195
23 Error::set_source [function] [call site] 02196
22 Reader::read_into [function] [call site] 02197
22 Ok [function] [call site] 02198
22 Operator::from_parts [function] [call site] 02199
23 RetryLayer::clone [function] [call site] 02200
23 RetryLayer::clone [function] [call site] 02201
23 Fixture::new [function] [call site] 02202
23 Fixture::new [function] [call site] 02203
21 AzfileCore::send [function] [call site] 02204
22 OperationContext::with_http_transport [function] [call site] 02205
22 FuturesDeleteSink::start_send [function] [call site] 02206
20 String::finalize [function] [call site] 02207
20 OperationLabels::encode [function] [call site] 02208
21 OperationLabels::encode [function] [call site] 02209
21 &mut [call site] 02210
21 OperationLabelNames::as_ref [function] [call site] 02211
21 OperationLabels::encode [function] [call site] 02212
21 &mut [call site] 02213
21 OperationLabelNames::as_ref [function] [call site] 02214
21 OperationLabels::encode [function] [call site] 02215
21 &mut [call site] 02216
21 OperationLabels::encode [function] [call site] 02217
21 &mut [call site] 02218
21 ErrorKind::into_static [function] [call site] 02219
22 Reader::read_into [function] [call site] 02220
23 RetryLayer::clone [function] [call site] 02221
23 Reader::into_stream [function] [call site] 02222
23 Result::try_next [function] [call site] 02223
23 Ok [function] [call site] 02224
23 Buffer::len [function] [call site] 02225
23 io::Result::put [function] [call site] 02226
21 OperationLabels::encode [function] [call site] 02227
21 &mut [call site] 02228
21 std::fmt::Result::as_str [function] [call site] 02229
21 OperationLabels::encode [function] [call site] 02230
21 &mut [call site] 02231
21 OperationLabels::encode [function] [call site] 02232
21 &mut [call site] 02233
21 Ok [function] [call site] 02234
20 u32::to_be_bytes [function] [call site] 02235
19 RetryLayer::clone [function] [call site] 02236
20 RetryLayer::clone [function] [call site] 02237
19 Some [function] [call site] 02238
19 format_content_md5_iter [function] [call site] 02239
20 md5::Md5::new [function] [call site] 02240
21 Fixture::new [function] [call site] 02241
20 AzfileCore::azfile_update [function] [call site] 02242
21 build_abs_path [function] [call site] 02243
21 String::trim_start_matches [function] [call site] 02244
21 tests::test_bytes_range_to_string [function] [call site] 02245
21 DeleteInput::into_delete_input [function] [call site] 02246
21 BytesRange::to_header [function] [call site] 02247
21 BytesRange::to_header [function] [call site] 02248
21 BytesRange::to_header [function] [call site] 02249
21 BytesRange::from [function] [call site] 02250
21 BytesRange::to_header [function] [call site] 02251
21 DeleteInput::extension [function] [call site] 02252
21 extension [function] [call site] 02253
21 ServiceOperation [function] [call site] 02254
21 DeleteInput::body [function] [call site] 02255
21 map_err [function] [call site] 02256
21 AzfileCore::sign [function] [call site] 02257
21 AzfileCore::send [function] [call site] 02258
20 OperationLabelNames::as_ref [function] [call site] 02259
20 OperationLabels::encode [function] [call site] 02260
20 Self::finalize [function] [call site] 02261
19 RetryLayer::clone [function] [call site] 02262
18 Self [function] [call site] 02263
17 Reader::read_into [function] [call site] 02264
16 ConfigDeserializer::deserialize_map [function] [call site] 02265
17 V::visit_map [function] [call site] 02266
16 Result::map_err [function] [call site] 02267
16 FuturesDeleteSink::start_send [function] [call site] 02268
15 expect [function] [call site] 02269
15 QueueBuf::collect [function] [call site] 02270
15 Fixture::new [function] [call site] 02271
15 ServiceInfo::new [function] [call site] 02272
15 Result::to_string_lossy [function] [call site] 02273
15 Fixture::default [function] [call site] 02274
15 oio::PooledBuf::new [function] [call site] 02275
16 Fixture::new [function] [call site] 02276
16 VecDeque::with_capacity [function] [call site] 02277
15 PooledBuf::with_initial_capacity [function] [call site] 02278
14 tests::test_copy_and_rename_route_by_from [function] [call site] 02279
15 tests::build_mock_operator [function] [call site] 02280
15 tests::build_mock_operator [function] [call site] 02281
15 RetryLayer::clone [function] [call site] 02282
15 ThrottleLayer::layer [function] [call site] 02283
15 RouteLayer::builder [function] [call site] 02284
15 RouteLayerBuilder::route [function] [call site] 02285
15 RetryLayer::clone [function] [call site] 02286
15 RouteLayerBuilder::build [function] [call site] 02287
15 ThrottleAccessor::write [function] [call site] 02288
15 ThrottleAccessor::copy [function] [call site] 02289
15 tests::assert_missing [function] [call site] 02290
15 ThrottleAccessor::write [function] [call site] 02291
15 ThrottleAccessor::rename [function] [call site] 02292
15 tests::assert_missing [function] [call site] 02293
15 tests::assert_missing [function] [call site] 02294
15 Ok [function] [call site] 02295
13 cloned [function] [call site] 02296
13 QueueBuf::collect [function] [call site] 02297
11 to_ascii_lowercase [function] [call site] 02298
11 Result::query_pairs [function] [call site] 02299
11 ImmutableIndexLayer::insert [function] [call site] 02300
11 FoyerKey::to_ascii_lowercase [function] [call site] 02301
11 Vec::into_owned [function] [call site] 02302
11 ImmutableIndexLayer::insert [function] [call site] 02303
11 OperatorUri::username [function] [call site] 02304
12 as_deref [function] [call site] 02305
11 Buffer::is_empty [function] [call site] 02306
12 Buffer::len [function] [call site] 02307
11 Some [function] [call site] 02308
11 OperatorUri::username [function] [call site] 02309
11 tests::test_bytes_range_to_string [function] [call site] 02310
12 BytesRange::new [function] [call site] 02311
12 Some [function] [call site] 02312
12 BytesRange::new [function] [call site] 02313
12 BytesRange::new [function] [call site] 02314
12 Some [function] [call site] 02315
12 BytesRange::suffix [function] [call site] 02316
11 OperatorUri::password [function] [call site] 02317
12 as_deref [function] [call site] 02318
11 ConfigDeserializer::deserialize_map [function] [call site] 02319
11 tests::test_bytes_range_to_string [function] [call site] 02320
11 Result::host_str [function] [call site] 02321
11 filter [function] [call site] 02322
11 Buffer::is_empty [function] [call site] 02323
12 Buffer::len [function] [call site] 02324
11 ConfigDeserializer::deserialize_map [function] [call site] 02325
11 OperationContext::with_http_transport [function] [call site] 02326
12 RetryLayer::clone [function] [call site] 02327
11 tests::test_bytes_range_to_string [function] [call site] 02328
12 BytesRange::new [function] [call site] 02329
12 Some [function] [call site] 02330
12 BytesRange::new [function] [call site] 02331
12 BytesRange::new [function] [call site] 02332
12 Some [function] [call site] 02333
12 BytesRange::suffix [function] [call site] 02334
11 Result::host_str [function] [call site] 02335
11 filter [function] [call site] 02336
11 Buffer::is_empty [function] [call site] 02337
11 ConfigDeserializer::deserialize_map [function] [call site] 02338
11 tests::test_bytes_range_to_string [function] [call site] 02339
11 percent_encoding::percent_decode_str [function] [call site] 02340
11 Fixture::add_path [function] [call site] 02341
11 decode_utf8_lossy [function] [call site] 02342
11 trim_matches [function] [call site] 02343
11 Buffer::is_empty [function] [call site] 02344
11 Some [function] [call site] 02345
11 tests::test_bytes_range_to_string [function] [call site] 02346
11 Ok [function] [call site] 02347
10 Vec::<(String, [call site] 02348
10 MonoiofsCore::unwrap [function] [call site] 02349
10 HfConfig::from_uri [function] [call site] 02350
10 opendal_core::Result::unwrap [function] [call site] 02351
9 Self::pop [function] [call site] 02352
9 QueryPairsWriter::push [function] [call site] 02353
9 as_os_str [function] [call site] 02354
7 Operator::presign_stat_inner [function] [call site] 02355
8 OpPresign::new [function] [call site] 02356
9 Reader::read_into [function] [call site] 02357
10 RetryLayer::clone [function] [call site] 02358
10 Reader::into_stream [function] [call site] 02359
10 Result::try_next [function] [call site] 02360
10 Ok [function] [call site] 02361
10 Buffer::len [function] [call site] 02362
10 io::Result::put [function] [call site] 02363
8 OpStat::from [function] [call site] 02364
8 ThrottleAccessor::presign [function] [call site] 02365
9 ThrottleAccessor::presign [function] [call site] 02366
10 ThrottleAccessor::presign [function] [call site] 02367
8 Ok [function] [call site] 02368
8 RpPresign::into_presigned_request [function] [call site] 02369
7 Operator::context [function] [call site] 02370
7 RetryLayer::clone [function] [call site] 02371
7 Operator::service [function] [call site] 02372
7 RetryLayer::clone [function] [call site] 02373
6 Result::chunk [function] [call site] 02374
6 Result::is_some [function] [call site] 02375
6 ReadContext::parse_into_range [function] [call site] 02376
7 Reader::read_into [function] [call site] 02377
7 u64::checked_add [function] [call site] 02378
7 ok_or_else [function] [call site] 02379
7 Error::new [function] [call site] 02380
7 ReadContext::content_length [function] [call site] 02381
7 ReadContext::content_length [function] [call site] 02382
7 Result::saturating_sub [function] [call site] 02383
7 Ok [function] [call site] 02384
6 TwoWays::Two [function] [call site] 02385
6 ChunkedReader::new [function] [call site] 02386
6 RetryLayer::clone [function] [call site] 02387
6 Reader::read_into [function] [call site] 02388
6 TwoWays::One [function] [call site] 02389
6 StreamingReader::new [function] [call site] 02390
6 RetryLayer::clone [function] [call site] 02391
6 Ok [function] [call site] 02392
6 State::Idle [function] [call site] 02393
6 Some [function] [call site] 02394
4 Result::try_next [function] [call site] 02395
4 Ok [function] [call site] 02396
4 Buffer::len [function] [call site] 02397
4 io::Result::put [function] [call site] 02398
3 Fixture::default [function] [call site] 02399
3 ErrorKind::enable_backtrace [function] [call site] 02400
3 bool::then [function] [call site] 02401
3 filter [function] [call site] 02402
3 WebhdfsCore::webhdfs_list_status [function] [call site] 02403
3 ConfigDeserializer::deserialize_map [function] [call site] 02404
2 Vec::as_object_mut [function] [call site] 02405
2 ok_or_else [function] [call site] 02406
2 Error::new [function] [call site] 02407
2 Buffer::extend [function] [call site] 02408
2 RetryLayer::clone [function] [call site] 02409
2 serde_json::from_value [function] [call site] 02410
2 map_err [function] [call site] 02411
2 Error::new [function] [call site] 02412
1 OperatorUri::new [function] [call site] 02413
1 RetryLayer::clone [function] [call site] 02414
1 Operator::from_uri [function] [call site] 02415
1 HfRepoType::as_str [function] [call site] 02416
1 Operator::via_iter [function] [call site] 02417
2 Operator::from_uri [function] [call site] 02418
2 OperationLabelNames::as_ref [function] [call site] 02419