Fuzz introspector: parser
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
2262 1485 get_push_kind call site: 01485 cluster::test_cluster_reconnect_after_complete_server_disconnect
844 639 RedisCluster::new call site: 00639 cluster::test_cluster_reconnect_after_complete_server_disconnect
583 55 parse_redis_value call site: 00055 cluster::test_cluster_reconnect_after_complete_server_disconnect
50 3 Parser::new call site: 00003 tests_routing::test_multi_shard_keys_and_path
1 0 EP call site: 00000

Fuzzer calltree

0 fuzz_target [function] [call site] 00000
1 redis::parse_redis_value [function] [call site] 00001
2 Parser::new [function] [call site] 00002
3 RedisServer::new [function] [call site] 00003
4 RedisServer::with_modules [function] [call site] 00004
5 utils::get_random_available_port [function] [call site] 00005
6 get_listener_on_free_port [function] [call site] 00006
7 0.0.1:0".parse::<SocketAddr> [function] [call site] 00007
7 unwrap [function] [call site] 00008
7 into [function] [call site] 00009
7 RedisServer::new [function] [call site] 00010
8 RedisServer::with_modules [function] [call site] 00011
7 RedisServer::unwrap [function] [call site] 00012
7 set_reuse_address [function] [call site] 00013
7 unwrap [function] [call site] 00014
7 bind [function] [call site] 00015
7 unwrap [function] [call site] 00016
7 listen [function] [call site] 00017
7 unwrap [function] [call site] 00018
7 ValueType::from [function] [call site] 00019
8 TlsFilePaths::as_ref [function] [call site] 00020
8 ValueType::Unknown [function] [call site] 00021
8 TlsFilePaths::to_string [function] [call site] 00022
6 TcpListener::local_addr [function] [call site] 00023
6 unwrap [function] [call site] 00024
6 get_listener_on_free_port [function] [call site] 00025
7 0.0.1:0".parse::<SocketAddr> [function] [call site] 00026
7 unwrap [function] [call site] 00027
7 into [function] [call site] 00028
7 RedisServer::new [function] [call site] 00029
7 RedisServer::unwrap [function] [call site] 00030
7 set_reuse_address [function] [call site] 00031
7 unwrap [function] [call site] 00032
7 bind [function] [call site] 00033
7 unwrap [function] [call site] 00034
7 listen [function] [call site] 00035
7 unwrap [function] [call site] 00036
7 ValueType::from [function] [call site] 00037
5 RedisServer::get_addr [function] [call site] 00038
6 ServerType::get_intended [function] [call site] 00039
7 env::var [function] [call site] 00040
7 wait_for_status_ok [function] [call site] 00041
8 RedisServer::log_file [function] [call site] 00042
9 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00043
10 cmd [function] [call site] 00044
11 Cmd::new [function] [call site] 00045
11 Cmd::arg [function] [call site] 00046
12 u8::write_redis_args [function] [call site] 00047
13 ::itoa::Buffer::new [function] [call site] 00048
14 RedisServer::with_modules [function] [call site] 00049
13 RedisServer::format [function] [call site] 00050
13 Vec::write_arg [function] [call site] 00051
14 tests::decode_resp3_push [function] [call site] 00052
15 parse_redis_value [function] [call site] 00053
16 Parser::new [function] [call site] 00054
16 Parser::parse_value [function] [call site] 00055
17 Err [function] [call site] 00056
17 to_redis_err [function] [call site] 00057
18 into [function] [call site] 00058
18 is_unexpected_end_of_input [function] [call site] 00059
18 RedisError::from [function] [call site] 00060
18 io::Error::from [function] [call site] 00061
18 map_range [function] [call site] 00062
18 map_position [function] [call site] 00063
18 translate_position [function] [call site] 00064
18 buffer [function] [call site] 00065
18 to_string [function] [call site] 00066
18 RedisError::from [function] [call site] 00067
18 ParsingError::from [function] [call site] 00068
17 Ok [function] [call site] 00069
15 RedisResult::unwrap [function] [call site] 00070
14 to_owned [function] [call site] 00071
13 TlsFilePaths::as_bytes [function] [call site] 00072
10 Cmd::arg [function] [call site] 00073
10 types::test_is_single_arg [function] [call site] 00074
10 types::test_is_single_arg [function] [call site] 00075
10 types::test_is_single_arg [function] [call site] 00076
10 types::test_is_single_arg [function] [call site] 00077
10 RoutingInfo::for_routable [function] [call site] 00078
11 MockRedisConnection::req_packed_command [function] [call site] 00079
12 Cmd::get_packed_command [function] [call site] 00080
13 RedisServer::new [function] [call site] 00081
14 RedisServer::with_modules [function] [call site] 00082
13 Cmd::write_packed_command [function] [call site] 00083
14 write_command_to_vec [function] [call site] 00084
15 args_len [function] [call site] 00085
16 countdigits [function] [call site] 00086
16 basic::test_pipeline_len [function] [call site] 00087
17 redis::pipe [function] [call site] 00088
18 redis::pipe [function] [call site] 00089
18 Pipeline::atomic [function] [call site] 00090
18 redis::pipe [function] [call site] 00091
17 cmd [function] [call site] 00092
17 cmd [function] [call site] 00093
17 types::test_is_single_arg [function] [call site] 00094
16 bulklen [function] [call site] 00095
17 countdigits [function] [call site] 00096
16 countdigits [function] [call site] 00097
16 basic::test_pipeline_len [function] [call site] 00098
15 ClientTlsParams::clone [function] [call site] 00099
16 ClientTlsParams::clone [function] [call site] 00100
16 Pkcs1 [function] [call site] 00101
16 secret_pkcs1_der [function] [call site] 00102
16 write_command_to_vec [function] [call site] 00103
17 args_len [function] [call site] 00104
17 ClientTlsParams::clone [function] [call site] 00105
17 Cmd::reserve [function] [call site] 00106
17 write_command [function] [call site] 00107
18 ::itoa::Buffer::new [function] [call site] 00108
18 Cmd::write_all [function] [call site] 00109
18 RedisServer::format [function] [call site] 00110
18 basic::test_pipeline_len [function] [call site] 00111
18 Cmd::write_all [function] [call site] 00112
18 TlsFilePaths::as_bytes [function] [call site] 00113
18 Cmd::write_all [function] [call site] 00114
18 itoa::Buffer::new [function] [call site] 00115
19 RedisServer::with_modules [function] [call site] 00116
18 RedisServer::format [function] [call site] 00117
18 as_bytes [function] [call site] 00118
18 Cmd::write_all [function] [call site] 00119
18 RedisServer::format [function] [call site] 00120
18 basic::test_pipeline_len [function] [call site] 00121
19 redis::pipe [function] [call site] 00122
19 cmd [function] [call site] 00123
19 cmd [function] [call site] 00124
19 types::test_is_single_arg [function] [call site] 00125
18 Cmd::write_all [function] [call site] 00126
18 TlsFilePaths::as_bytes [function] [call site] 00127
18 Cmd::write_all [function] [call site] 00128
18 Cmd::write_all [function] [call site] 00129
18 Cmd::write_all [function] [call site] 00130
18 Ok [function] [call site] 00131
17 io::Result::unwrap [function] [call site] 00132
16 into [function] [call site] 00133
16 Pkcs8 [function] [call site] 00134
16 secret_pkcs8_der [function] [call site] 00135
16 write_command_to_vec [function] [call site] 00136
16 into [function] [call site] 00137
16 Sec1 [function] [call site] 00138
16 secret_sec1_der [function] [call site] 00139
16 write_command_to_vec [function] [call site] 00140
16 into [function] [call site] 00141
15 Cmd::reserve [function] [call site] 00142
15 write_command [function] [call site] 00143
15 io::Result::unwrap [function] [call site] 00144
14 Cmd::args_iter [function] [call site] 00145
15 basic::test_tuple_decoding_from_iter [function] [call site] 00146
16 TestContext::new [function] [call site] 00147
17 TestContext::with_modules [function] [call site] 00148
18 TestContext::with_modules_and_tls [function] [call site] 00149
19 start_tls_crypto_provider [function] [call site] 00150
20 rustls::crypto::CryptoProvider::get_default [function] [call site] 00151
20 is_none [function] [call site] 00152
20 rustls::crypto::ring::default_provider [function] [call site] 00153
20 install_default [function] [call site] 00154
19 redis_test::utils::get_random_available_port [function] [call site] 00155
20 get_listener_on_free_port [function] [call site] 00156
20 TcpListener::local_addr [function] [call site] 00157
20 unwrap [function] [call site] 00158
20 get_listener_on_free_port [function] [call site] 00159
19 RedisServer::get_addr [function] [call site] 00160
19 TestContext::with_modules_addr_and_tls [function] [call site] 00161
20 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00162
21 process::Command::new [function] [call site] 00163
22 RedisServer::with_modules [function] [call site] 00164
21 types::test_is_single_arg [function] [call site] 00165
21 types::test_is_single_arg [function] [call site] 00166
21 types::test_is_single_arg [function] [call site] 00167
21 env::var [function] [call site] 00168
21 expect [function] [call site] 00169
21 RedisServer::stdout [function] [call site] 00170
21 process::Stdio::piped [function] [call site] 00171
21 stderr [function] [call site] 00172
21 process::Stdio::piped [function] [call site] 00173
21 tempfile::Builder::new [function] [call site] 00174
22 Ok [function] [call site] 00175
22 &'a [call site] 00176
23 std::iter::once [function] [call site] 00177
23 chain [function] [call site] 00178
23 basic::test_tuple_decoding_from_iter [function] [call site] 00179
22 into_iter().collect::<Vec<_>> [function] [call site] 00180
22 impl [call site] 00181
22 into [function] [call site] 00182
21 RedisResult::prefix [function] [call site] 00183
21 tempdir [function] [call site] 00184
21 expect [function] [call site] 00185
21 RedisServer::log_file [function] [call site] 00186
22 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00187
22 join [function] [call site] 00188
21 types::test_is_single_arg [function] [call site] 00189
21 types::test_is_single_arg [function] [call site] 00190
21 ClientTlsParams::clone [function] [call site] 00191
22 ClientTlsParams::clone [function] [call site] 00192
22 Pkcs1 [function] [call site] 00193
22 secret_pkcs1_der [function] [call site] 00194
22 write_command_to_vec [function] [call site] 00195
22 into [function] [call site] 00196
22 Pkcs8 [function] [call site] 00197
22 secret_pkcs8_der [function] [call site] 00198
22 write_command_to_vec [function] [call site] 00199
22 into [function] [call site] 00200
22 Sec1 [function] [call site] 00201
22 secret_sec1_der [function] [call site] 00202
22 write_command_to_vec [function] [call site] 00203
22 into [function] [call site] 00204
21 get_major_version [function] [call site] 00205
22 String::from_utf8 [function] [call site] 00206
22 process::Command::new [function] [call site] 00207
22 types::test_is_single_arg [function] [call site] 00208
22 output [function] [call site] 00209
22 unwrap [function] [call site] 00210
22 unwrap [function] [call site] 00211
22 split_once [function] [call site] 00212
22 unwrap [function] [call site] 00213
22 split_once [function] [call site] 00214
22 unwrap [function] [call site] 00215
22 parse [function] [call site] 00216
22 unwrap [function] [call site] 00217
21 types::test_is_single_arg [function] [call site] 00218
21 types::test_is_single_arg [function] [call site] 00219
21 types::test_is_single_arg [function] [call site] 00220
21 types::test_is_single_arg [function] [call site] 00221
21 to_string [function] [call site] 00222
21 types::test_is_single_arg [function] [call site] 00223
21 types::test_is_single_arg [function] [call site] 00224
21 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00225
22 process::Command::new [function] [call site] 00226
22 types::test_is_single_arg [function] [call site] 00227
22 types::test_is_single_arg [function] [call site] 00228
22 types::test_is_single_arg [function] [call site] 00229
22 env::var [function] [call site] 00230
22 expect [function] [call site] 00231
22 RedisServer::stdout [function] [call site] 00232
22 process::Stdio::piped [function] [call site] 00233
22 stderr [function] [call site] 00234
22 process::Stdio::piped [function] [call site] 00235
22 tempfile::Builder::new [function] [call site] 00236
22 RedisResult::prefix [function] [call site] 00237
22 tempdir [function] [call site] 00238
22 expect [function] [call site] 00239
22 RedisServer::log_file [function] [call site] 00240
22 types::test_is_single_arg [function] [call site] 00241
22 types::test_is_single_arg [function] [call site] 00242
22 ClientTlsParams::clone [function] [call site] 00243
22 get_major_version [function] [call site] 00244
22 types::test_is_single_arg [function] [call site] 00245
22 types::test_is_single_arg [function] [call site] 00246
22 types::test_is_single_arg [function] [call site] 00247
22 types::test_is_single_arg [function] [call site] 00248
22 to_string [function] [call site] 00249
22 types::test_is_single_arg [function] [call site] 00250
22 types::test_is_single_arg [function] [call site] 00251
22 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00252
22 Option<TlsFilePaths>::unwrap_or_else [function] [call site] 00253
22 utils::build_keys_and_certs_for_tls [function] [call site] 00254
23 build_keys_and_certs_for_tls_ext [function] [call site] 00255
24 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00256
24 join [function] [call site] 00257
24 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00258
24 join [function] [call site] 00259
24 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00260
24 join [function] [call site] 00261
24 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00262
24 join [function] [call site] 00263
24 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00264
24 join [function] [call site] 00265
24 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00266
24 join [function] [call site] 00267
24 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::e::x::t::make_key [function] [call site] 00268
25 process::Command::new [function] [call site] 00269
25 types::test_is_single_arg [function] [call site] 00270
25 types::test_is_single_arg [function] [call site] 00271
25 types::test_is_single_arg [function] [call site] 00272
25 types::test_is_single_arg [function] [call site] 00273
25 stdout [function] [call site] 00274
25 process::Stdio::piped [function] [call site] 00275
25 stderr [function] [call site] 00276
25 process::Stdio::piped [function] [call site] 00277
25 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00278
26 tokio::runtime::Handle::try_current [function] [call site] 00279
26 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00280
26 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00281
27 tokio::runtime::Handle::try_current [function] [call site] 00282
27 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00283
27 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00284
27 TaskHandle::detach [function] [call site] 00285
28 TaskHandle::detach [function] [call site] 00286
26 TaskHandle::detach [function] [call site] 00287
25 expect [function] [call site] 00288
25 ClusterClientBuilder::max_retry_wait [function] [call site] 00289
25 expect [function] [call site] 00290
24 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::e::x::t::make_key [function] [call site] 00291
24 process::Command::new [function] [call site] 00292
24 types::test_is_single_arg [function] [call site] 00293
24 types::test_is_single_arg [function] [call site] 00294
24 types::test_is_single_arg [function] [call site] 00295
24 types::test_is_single_arg [function] [call site] 00296
24 types::test_is_single_arg [function] [call site] 00297
24 types::test_is_single_arg [function] [call site] 00298
24 types::test_is_single_arg [function] [call site] 00299
24 types::test_is_single_arg [function] [call site] 00300
24 types::test_is_single_arg [function] [call site] 00301
24 types::test_is_single_arg [function] [call site] 00302
24 types::test_is_single_arg [function] [call site] 00303
24 types::test_is_single_arg [function] [call site] 00304
24 types::test_is_single_arg [function] [call site] 00305
24 stdout [function] [call site] 00306
24 process::Stdio::piped [function] [call site] 00307
24 stderr [function] [call site] 00308
24 process::Stdio::piped [function] [call site] 00309
24 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00310
24 expect [function] [call site] 00311
24 ClusterClientBuilder::max_retry_wait [function] [call site] 00312
24 expect [function] [call site] 00313
24 Tokio::poll_write [function] [call site] 00314
25 RedisServer::new [function] [call site] 00315
26 RedisServer::with_modules [function] [call site] 00316
25 Tokio::poll_write [function] [call site] 00317
26 RedisServer::new [function] [call site] 00318
26 Tokio::poll_write [function] [call site] 00319
26 RedisServer::new [function] [call site] 00320
26 Tokio::poll_write [function] [call site] 00321
26 RedisServer::new [function] [call site] 00322
26 Tokio::poll_write [function] [call site] 00323
25 RedisServer::new [function] [call site] 00324
25 Tokio::poll_write [function] [call site] 00325
25 RedisServer::new [function] [call site] 00326
25 Tokio::poll_write [function] [call site] 00327
24 Poll::expect [function] [call site] 00328
24 process::Command::new [function] [call site] 00329
24 types::test_is_single_arg [function] [call site] 00330
24 types::test_is_single_arg [function] [call site] 00331
24 types::test_is_single_arg [function] [call site] 00332
24 types::test_is_single_arg [function] [call site] 00333
24 types::test_is_single_arg [function] [call site] 00334
24 types::test_is_single_arg [function] [call site] 00335
24 types::test_is_single_arg [function] [call site] 00336
24 stdout [function] [call site] 00337
24 process::Stdio::piped [function] [call site] 00338
24 stderr [function] [call site] 00339
24 process::Stdio::piped [function] [call site] 00340
24 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00341
24 expect [function] [call site] 00342
24 process::Command::new [function] [call site] 00343
24 types::test_is_single_arg [function] [call site] 00344
24 types::test_is_single_arg [function] [call site] 00345
24 types::test_is_single_arg [function] [call site] 00346
24 types::test_is_single_arg [function] [call site] 00347
24 types::test_is_single_arg [function] [call site] 00348
24 types::test_is_single_arg [function] [call site] 00349
24 types::test_is_single_arg [function] [call site] 00350
24 types::test_is_single_arg [function] [call site] 00351
24 types::test_is_single_arg [function] [call site] 00352
24 types::test_is_single_arg [function] [call site] 00353
24 types::test_is_single_arg [function] [call site] 00354
24 types::test_is_single_arg [function] [call site] 00355
24 types::test_is_single_arg [function] [call site] 00356
24 types::test_is_single_arg [function] [call site] 00357
24 types::test_is_single_arg [function] [call site] 00358
24 types::test_is_single_arg [function] [call site] 00359
24 types::test_is_single_arg [function] [call site] 00360
24 types::test_is_single_arg [function] [call site] 00361
24 stdin [function] [call site] 00362
24 take [function] [call site] 00363
24 expect [function] [call site] 00364
24 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00365
24 expect [function] [call site] 00366
24 ClusterClientBuilder::max_retry_wait [function] [call site] 00367
24 expect [function] [call site] 00368
24 ClusterClientBuilder::max_retry_wait [function] [call site] 00369
24 expect [function] [call site] 00370
22 types::test_is_single_arg [function] [call site] 00371
22 types::test_is_single_arg [function] [call site] 00372
22 TcpListener::to_string [function] [call site] 00373
22 types::test_is_single_arg [function] [call site] 00374
22 types::test_is_single_arg [function] [call site] 00375
22 types::test_is_single_arg [function] [call site] 00376
22 types::test_is_single_arg [function] [call site] 00377
22 types::test_is_single_arg [function] [call site] 00378
22 types::test_is_single_arg [function] [call site] 00379
22 types::test_is_single_arg [function] [call site] 00380
22 types::test_is_single_arg [function] [call site] 00381
22 types::test_is_single_arg [function] [call site] 00382
22 types::test_is_single_arg [function] [call site] 00383
22 types::test_is_single_arg [function] [call site] 00384
22 types::test_is_single_arg [function] [call site] 00385
22 ClientTlsParams::clone [function] [call site] 00386
22 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00387
22 Some [function] [call site] 00388
22 types::test_is_single_arg [function] [call site] 00389
22 types::test_is_single_arg [function] [call site] 00390
22 types::test_is_single_arg [function] [call site] 00391
22 types::test_is_single_arg [function] [call site] 00392
22 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00393
21 Option<TlsFilePaths>::unwrap_or_else [function] [call site] 00394
21 utils::build_keys_and_certs_for_tls [function] [call site] 00395
21 types::test_is_single_arg [function] [call site] 00396
21 types::test_is_single_arg [function] [call site] 00397
21 TcpListener::to_string [function] [call site] 00398
21 types::test_is_single_arg [function] [call site] 00399
21 types::test_is_single_arg [function] [call site] 00400
21 types::test_is_single_arg [function] [call site] 00401
21 types::test_is_single_arg [function] [call site] 00402
21 types::test_is_single_arg [function] [call site] 00403
21 types::test_is_single_arg [function] [call site] 00404
21 types::test_is_single_arg [function] [call site] 00405
21 types::test_is_single_arg [function] [call site] 00406
21 types::test_is_single_arg [function] [call site] 00407
21 types::test_is_single_arg [function] [call site] 00408
21 types::test_is_single_arg [function] [call site] 00409
21 types::test_is_single_arg [function] [call site] 00410
21 ClientTlsParams::clone [function] [call site] 00411
21 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00412
21 Some [function] [call site] 00413
21 types::test_is_single_arg [function] [call site] 00414
21 types::test_is_single_arg [function] [call site] 00415
21 types::test_is_single_arg [function] [call site] 00416
21 types::test_is_single_arg [function] [call site] 00417
21 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00418
20 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00419
21 tokio::runtime::Handle::try_current [function] [call site] 00420
21 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00421
21 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00422
21 TaskHandle::detach [function] [call site] 00423
20 unwrap_or_else [function] [call site] 00424
20 build_single_client [function] [call site] 00425
21 redis::Client::open [function] [call site] 00426
22 Ok [function] [call site] 00427
22 ConnectionInfo::into_connection_info [function] [call site] 00428
23 Ok [function] [call site] 00429
20 RedisServer::connection_info [function] [call site] 00430
21 RedisServer::client_addr [function] [call site] 00431
21 &redis::ConnectionAddr::clone [function] [call site] 00432
22 ClientTlsParams::clone [function] [call site] 00433
22 Pkcs1 [function] [call site] 00434
22 secret_pkcs1_der [function] [call site] 00435
22 write_command_to_vec [function] [call site] 00436
22 into [function] [call site] 00437
22 Pkcs8 [function] [call site] 00438
22 secret_pkcs8_der [function] [call site] 00439
22 write_command_to_vec [function] [call site] 00440
22 into [function] [call site] 00441
22 Sec1 [function] [call site] 00442
22 secret_sec1_der [function] [call site] 00443
22 write_command_to_vec [function] [call site] 00444
22 into [function] [call site] 00445
21 ConnectionInfo::into_connection_info [function] [call site] 00446
22 Ok [function] [call site] 00447
21 RedisResult::unwrap [function] [call site] 00448
21 ConnectionInfo::set_redis_settings [function] [call site] 00449
21 redis_settings [function] [call site] 00450
22 RedisServer::default [function] [call site] 00451
23 RedisServer::new [function] [call site] 00452
24 RedisServer::with_modules [function] [call site] 00453
22 RedisConnectionInfo::set_protocol [function] [call site] 00454
22 use_protocol [function] [call site] 00455
23 env::var [function] [call site] 00456
23 unwrap_or_default [function] [call site] 00457
20 RedisResult::unwrap [function] [call site] 00458
20 Duration::from_millis [function] [call site] 00459
20 Client::get_connection [function] [call site] 00460
21 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 00461
22 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 00462
23 TestClusterContext::new_with_config_and_builder [function] [call site] 00463
24 support::start_tls_crypto_provider [function] [call site] 00464
25 rustls::crypto::CryptoProvider::get_default [function] [call site] 00465
25 is_none [function] [call site] 00466
25 rustls::crypto::ring::default_provider [function] [call site] 00467
25 install_default [function] [call site] 00468
24 RedisCluster::new [function] [call site] 00469
25 basic::test_pipeline_is_empty [function] [call site] 00470
26 redis::pipe [function] [call site] 00471
26 cmd [function] [call site] 00472
26 cmd [function] [call site] 00473
26 types::test_is_single_arg [function] [call site] 00474
25 &'a [call site] 00475
26 std::iter::once [function] [call site] 00476
26 chain [function] [call site] 00477
26 basic::test_tuple_decoding_from_iter [function] [call site] 00478
25 std::iter::Chain::map [function] [call site] 00479
26 parse_redis_value [function] [call site] 00480
26 Value::Array [function] [call site] 00481
26 RedisServer::new [function] [call site] 00482
27 RedisServer::with_modules [function] [call site] 00483
26 PathBuf::insert [function] [call site] 00484
27 TestContext::with_modules [function] [call site] 00485
27 TestContext::connection [function] [call site] 00486
28 Client::get_connection [function] [call site] 00487
28 unwrap [function] [call site] 00488
27 redis::Connection::json_set [function] [call site] 00489
28 TestContext::with_modules [function] [call site] 00490
28 TestContext::connection [function] [call site] 00491
28 redis::Connection::json_set [function] [call site] 00492
27 redis::Connection::json_arr_insert [function] [call site] 00493
28 TestContext::with_modules [function] [call site] 00494
28 TestContext::connection [function] [call site] 00495
28 redis::Connection::json_set [function] [call site] 00496
28 redis::Connection::json_arr_insert [function] [call site] 00497
28 redis::Connection::json_set [function] [call site] 00498
28 redis::Connection::json_arr_insert [function] [call site] 00499
27 redis::Connection::json_set [function] [call site] 00500
27 redis::Connection::json_arr_insert [function] [call site] 00501
26 &str::into [function] [call site] 00502
26 PathBuf::insert [function] [call site] 00503
26 &str::into [function] [call site] 00504
26 PathBuf::insert [function] [call site] 00505
26 &str::into [function] [call site] 00506
26 parse_redis_value [function] [call site] 00507
26 Value::Array [function] [call site] 00508
26 RedisServer::default [function] [call site] 00509
27 RedisServer::new [function] [call site] 00510
26 HashMap::with_hasher [function] [call site] 00511
26 PathBuf::insert [function] [call site] 00512
26 &str::into [function] [call site] 00513
26 PathBuf::insert [function] [call site] 00514
26 &str::into [function] [call site] 00515
26 PathBuf::insert [function] [call site] 00516
26 &str::into [function] [call site] 00517
26 parse_redis_value [function] [call site] 00518
26 Value::Array [function] [call site] 00519
25 collect [function] [call site] 00520
25 std::collections::HashSet::new [function] [call site] 00521
26 RedisServer::with_modules [function] [call site] 00522
25 ClusterType::get_intended [function] [call site] 00523
26 env::var [function] [call site] 00524
26 wait_for_status_ok [function] [call site] 00525
26 as_ref [function] [call site] 00526
26 types::test_hashmap [function] [call site] 00527
27 parse_redis_value [function] [call site] 00528
27 Value::Array [function] [call site] 00529
27 RedisServer::new [function] [call site] 00530
27 PathBuf::insert [function] [call site] 00531
27 &str::into [function] [call site] 00532
27 PathBuf::insert [function] [call site] 00533
27 &str::into [function] [call site] 00534
27 PathBuf::insert [function] [call site] 00535
27 &str::into [function] [call site] 00536
27 parse_redis_value [function] [call site] 00537
27 Value::Array [function] [call site] 00538
27 RedisServer::default [function] [call site] 00539
27 HashMap::with_hasher [function] [call site] 00540
27 PathBuf::insert [function] [call site] 00541
27 &str::into [function] [call site] 00542
27 PathBuf::insert [function] [call site] 00543
27 &str::into [function] [call site] 00544
27 PathBuf::insert [function] [call site] 00545
27 &str::into [function] [call site] 00546
27 parse_redis_value [function] [call site] 00547
27 Value::Array [function] [call site] 00548
25 tempfile::Builder::new [function] [call site] 00549
25 RedisResult::prefix [function] [call site] 00550
25 tempdir [function] [call site] 00551
25 expect [function] [call site] 00552
25 { [call site] 00553
0 server::RedisServer}, [call site] 00554
0 utils::build_keys_and_certs_for_tls_ext [function] [call site] 00555
26 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00556
26 join [function] [call site] 00557
26 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00558
26 join [function] [call site] 00559
26 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00560
26 join [function] [call site] 00561
26 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00562
26 join [function] [call site] 00563
26 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00564
26 join [function] [call site] 00565
26 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00566
26 join [function] [call site] 00567
26 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::e::x::t::make_key [function] [call site] 00568
26 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::e::x::t::make_key [function] [call site] 00569
26 process::Command::new [function] [call site] 00570
26 types::test_is_single_arg [function] [call site] 00571
26 types::test_is_single_arg [function] [call site] 00572
26 types::test_is_single_arg [function] [call site] 00573
26 types::test_is_single_arg [function] [call site] 00574
26 types::test_is_single_arg [function] [call site] 00575
26 types::test_is_single_arg [function] [call site] 00576
26 types::test_is_single_arg [function] [call site] 00577
26 types::test_is_single_arg [function] [call site] 00578
26 types::test_is_single_arg [function] [call site] 00579
26 types::test_is_single_arg [function] [call site] 00580
26 types::test_is_single_arg [function] [call site] 00581
26 types::test_is_single_arg [function] [call site] 00582
26 types::test_is_single_arg [function] [call site] 00583
26 stdout [function] [call site] 00584
26 process::Stdio::piped [function] [call site] 00585
26 stderr [function] [call site] 00586
26 process::Stdio::piped [function] [call site] 00587
26 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00588
26 expect [function] [call site] 00589
26 ClusterClientBuilder::max_retry_wait [function] [call site] 00590
26 expect [function] [call site] 00591
26 Tokio::poll_write [function] [call site] 00592
26 Poll::expect [function] [call site] 00593
26 process::Command::new [function] [call site] 00594
26 types::test_is_single_arg [function] [call site] 00595
26 types::test_is_single_arg [function] [call site] 00596
26 types::test_is_single_arg [function] [call site] 00597
26 types::test_is_single_arg [function] [call site] 00598
26 types::test_is_single_arg [function] [call site] 00599
26 types::test_is_single_arg [function] [call site] 00600
26 types::test_is_single_arg [function] [call site] 00601
26 stdout [function] [call site] 00602
26 process::Stdio::piped [function] [call site] 00603
26 stderr [function] [call site] 00604
26 process::Stdio::piped [function] [call site] 00605
26 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00606
26 expect [function] [call site] 00607
26 process::Command::new [function] [call site] 00608
26 types::test_is_single_arg [function] [call site] 00609
26 types::test_is_single_arg [function] [call site] 00610
26 types::test_is_single_arg [function] [call site] 00611
26 types::test_is_single_arg [function] [call site] 00612
26 types::test_is_single_arg [function] [call site] 00613
26 types::test_is_single_arg [function] [call site] 00614
26 types::test_is_single_arg [function] [call site] 00615
26 types::test_is_single_arg [function] [call site] 00616
26 types::test_is_single_arg [function] [call site] 00617
26 types::test_is_single_arg [function] [call site] 00618
26 types::test_is_single_arg [function] [call site] 00619
26 types::test_is_single_arg [function] [call site] 00620
26 types::test_is_single_arg [function] [call site] 00621
26 types::test_is_single_arg [function] [call site] 00622
26 types::test_is_single_arg [function] [call site] 00623
26 types::test_is_single_arg [function] [call site] 00624
26 types::test_is_single_arg [function] [call site] 00625
26 types::test_is_single_arg [function] [call site] 00626
26 stdin [function] [call site] 00627
26 take [function] [call site] 00628
26 expect [function] [call site] 00629
26 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00630
26 expect [function] [call site] 00631
26 ClusterClientBuilder::max_retry_wait [function] [call site] 00632
26 expect [function] [call site] 00633
26 ClusterClientBuilder::max_retry_wait [function] [call site] 00634
26 expect [function] [call site] 00635
25 tests::decode_resp3_push [function] [call site] 00636
26 parse_redis_value [function] [call site] 00637
26 RedisResult::unwrap [function] [call site] 00638
25 Some [function] [call site] 00639
25 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00640
25 ClusterType::build_addr [function] [call site] 00641
26 ClusterType::get_intended [function] [call site] 00642
26 redis::ConnectionAddr::Tcp [function] [call site] 00643
26 &str::into [function] [call site] 00644
26 &str::into [function] [call site] 00645
25 ClientTlsParams::clone [function] [call site] 00646
26 ClientTlsParams::clone [function] [call site] 00647
26 Pkcs1 [function] [call site] 00648
26 secret_pkcs1_der [function] [call site] 00649
26 write_command_to_vec [function] [call site] 00650
26 into [function] [call site] 00651
26 Pkcs8 [function] [call site] 00652
26 secret_pkcs8_der [function] [call site] 00653
26 write_command_to_vec [function] [call site] 00654
26 into [function] [call site] 00655
26 Sec1 [function] [call site] 00656
26 secret_sec1_der [function] [call site] 00657
26 write_command_to_vec [function] [call site] 00658
26 into [function] [call site] 00659
25 tempfile::Builder::new [function] [call site] 00660
25 RedisResult::prefix [function] [call site] 00661
25 tempdir [function] [call site] 00662
25 expect [function] [call site] 00663
25 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00664
26 cmd [function] [call site] 00665
26 Cmd::arg [function] [call site] 00666
26 types::test_is_single_arg [function] [call site] 00667
26 types::test_is_single_arg [function] [call site] 00668
26 types::test_is_single_arg [function] [call site] 00669
26 types::test_is_single_arg [function] [call site] 00670
26 RoutingInfo::for_routable [function] [call site] 00671
26 std::collections::HashMap::new [function] [call site] 00672
27 RedisServer::with_modules [function] [call site] 00673
26 RedisServer::insert [function] [call site] 00674
27 TestContext::with_modules [function] [call site] 00675
27 TestContext::connection [function] [call site] 00676
27 redis::Connection::json_set [function] [call site] 00677
27 redis::Connection::json_arr_insert [function] [call site] 00678
27 redis::Connection::json_set [function] [call site] 00679
27 redis::Connection::json_arr_insert [function] [call site] 00680
26 Route [function] [call site] 00681
26 RedisServer::insert [function] [call site] 00682
26 Route [function] [call site] 00683
26 RedisServer::insert [function] [call site] 00684
26 Route [function] [call site] 00685
25 join [function] [call site] 00686
25 std::fs::write [function] [call site] 00687
26 RedisServer::new [function] [call site] 00688
26 Tokio::poll_write [function] [call site] 00689
26 RedisServer::new [function] [call site] 00690
26 Tokio::poll_write [function] [call site] 00691
26 RedisServer::new [function] [call site] 00692
26 Tokio::poll_write [function] [call site] 00693
25 Poll::expect [function] [call site] 00694
25 Cmd::arg [function] [call site] 00695
25 types::test_is_single_arg [function] [call site] 00696
25 types::test_is_single_arg [function] [call site] 00697
25 types::test_is_single_arg [function] [call site] 00698
25 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00699
25 join [function] [call site] 00700
25 types::test_is_single_arg [function] [call site] 00701
25 types::test_is_single_arg [function] [call site] 00702
25 types::test_is_single_arg [function] [call site] 00703
25 types::test_is_single_arg [function] [call site] 00704
25 types::test_is_single_arg [function] [call site] 00705
25 types::test_is_single_arg [function] [call site] 00706
25 Cmd::arg [function] [call site] 00707
25 types::test_is_single_arg [function] [call site] 00708
25 Cmd::arg [function] [call site] 00709
25 types::test_is_single_arg [function] [call site] 00710
25 Cmd::current_dir [function] [call site] 00711
25 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00712
25 tests::decode_resp3_push [function] [call site] 00713
25 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 00714
25 unwrap [function] [call site] 00715
25 ClusterClientBuilder::max_retry_wait [function] [call site] 00716
25 RedisServer::log_file_contents [function] [call site] 00717
26 std::fs::read_to_string [function] [call site] 00718
26 ClientTlsParams::clone [function] [call site] 00719
26 wait_for_status_ok [function] [call site] 00720
25 Err [function] [call site] 00721
25 RedisServer::log_file_contents [function] [call site] 00722
25 Err [function] [call site] 00723
25 port_in_use [function] [call site] 00724
26 ConnectionAddr::parse [function] [call site] 00725
26 expect [function] [call site] 00726
26 socket2::Socket::new [function] [call site] 00727
27 RedisServer::with_modules [function] [call site] 00728
26 socket2::Domain::for_address [function] [call site] 00729
26 RedisServer::expect [function] [call site] 00730
26 connect [function] [call site] 00731
27 Instant::now [function] [call site] 00732
27 ActualConnection::new [function] [call site] 00733
28 Ok [function] [call site] 00734
28 is_wildcard_address [function] [call site] 00735
28 fail [function] [call site] 00736
29 Err [function] [call site] 00737
29 ::std::convert::From::from [function] [call site] 00738
28 as_str [function] [call site] 00739
28 connect_tcp [function] [call site] 00740
29 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 00741
30 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 00742
30 cluster::test_cluster_retries [function] [call site] 00743
31 atomic::AtomicUsize::new [function] [call site] 00744
32 RedisServer::with_modules [function] [call site] 00745
31 MockEnv::with_client_builder [function] [call site] 00746
32 tokio::runtime::Builder::new_current_thread [function] [call site] 00747
32 enable_io [function] [call site] 00748
32 enable_time [function] [call site] 00749
32 Sentinel::build [function] [call site] 00750
33 Sentinel::build_inner [function] [call site] 00751
34 basic::test_pipeline_is_empty [function] [call site] 00752
35 redis::pipe [function] [call site] 00753
35 cmd [function] [call site] 00754
35 cmd [function] [call site] 00755
35 types::test_is_single_arg [function] [call site] 00756
34 fail [function] [call site] 00757
34 &'a [call site] 00758
35 std::iter::once [function] [call site] 00759
35 chain [function] [call site] 00760
35 basic::test_tuple_decoding_from_iter [function] [call site] 00761
34 std::iter::Chain::map [function] [call site] 00762
34 ConnectionInfo::into_connection_info [function] [call site] 00763
35 Ok [function] [call site] 00764
34 into_iter() [call site] 00765
6 .map(|p| [call site] 00766
6 .collect::<RedisResult<Vec<ConnectionInfo>>> [function] [call site] 00767
34 resize_with [function] [call site] 00768
34 basic::test_pipeline_len [function] [call site] 00769
35 redis::pipe [function] [call site] 00770
35 cmd [function] [call site] 00771
35 cmd [function] [call site] 00772
35 types::test_is_single_arg [function] [call site] 00773
34 resize_with [function] [call site] 00774
34 basic::test_pipeline_len [function] [call site] 00775
34 Ok [function] [call site] 00776
34 random_replica_index [function] [call site] 00777
35 rand::rng [function] [call site] 00778
35 random_range [function] [call site] 00779
35 NonZeroUsize::into [function] [call site] 00780
34 RedisServer::new [function] [call site] 00781
35 RedisServer::with_modules [function] [call site] 00782
34 RedisServer::unwrap [function] [call site] 00783
34 resize_with [function] [call site] 00784
34 basic::test_pipeline_len [function] [call site] 00785
34 Ok [function] [call site] 00786
34 random_replica_index [function] [call site] 00787
34 RedisServer::new [function] [call site] 00788
34 RedisServer::unwrap [function] [call site] 00789
34 Ok [function] [call site] 00790
34 random_replica_index [function] [call site] 00791
34 RedisServer::new [function] [call site] 00792
34 RedisServer::unwrap [function] [call site] 00793
34 Ok [function] [call site] 00794
34 random_replica_index [function] [call site] 00795
34 RedisServer::new [function] [call site] 00796
34 RedisServer::unwrap [function] [call site] 00797
32 unwrap [function] [call site] 00798
32 to_string [function] [call site] 00799
32 Tokio::poll_write [function] [call site] 00800
33 RedisServer::new [function] [call site] 00801
33 Tokio::poll_write [function] [call site] 00802
33 RedisServer::new [function] [call site] 00803
33 Tokio::poll_write [function] [call site] 00804
33 RedisServer::new [function] [call site] 00805
33 Tokio::poll_write [function] [call site] 00806
32 unwrap [function] [call site] 00807
32 test_module_json_arr_insert [function] [call site] 00808
33 TestContext::with_modules [function] [call site] 00809
33 TestContext::connection [function] [call site] 00810
33 redis::Connection::json_set [function] [call site] 00811
33 redis::Connection::json_arr_insert [function] [call site] 00812
33 redis::Connection::json_set [function] [call site] 00813
33 redis::Connection::json_arr_insert [function] [call site] 00814
32 ClientTlsParams::clone [function] [call site] 00815
32 RedisServer::new [function] [call site] 00816
33 RedisServer::with_modules [function] [call site] 00817
32 Sentinel::build [function] [call site] 00818
32 RedisResult::unwrap [function] [call site] 00819
32 ClusterClient::get_generic_connection [function] [call site] 00820
33 cluster::ClusterConnection::new [function] [call site] 00821
34 unwrap_or_default [function] [call site] 00822
34 ClientTlsParams::clone [function] [call site] 00823
34 Runtime::locate [function] [call site] 00824
35 cache_mget [function] [call site] 00825
36 TestContext::new [function] [call site] 00826
36 Ok [function] [call site] 00827
36 TestContext::async_connection_with_cache [function] [call site] 00828
37 TestContext::async_connection_with_cache_config [function] [call site] 00829
38 ClientTlsParams::clone [function] [call site] 00830
38 Client::get_multiplexed_async_connection_with_config [function] [call site] 00831
39 Runtime::locate [function] [call site] 00832
39 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::tokio::Tokio> [function] [call site] 00833
39 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::smol::Smol> [function] [call site] 00834
38 AsyncConnectionConfig::new [function] [call site] 00835
39 RedisServer::default [function] [call site] 00836
40 RedisServer::new [function] [call site] 00837
38 Cmd::set_cache_config [function] [call site] 00838
39 Some [function] [call site] 00839
37 CacheConfig::default [function] [call site] 00840
38 CacheConfig::new [function] [call site] 00841
39 RedisServer::new [function] [call site] 00842
39 RedisServer::unwrap [function] [call site] 00843
39 Duration::from_secs [function] [call site] 00844
36 get_pipe [function] [call site] 00845
37 redis::pipe [function] [call site] 00846
37 Pipeline::atomic [function] [call site] 00847
37 redis::pipe [function] [call site] 00848
36 redis::Pipeline::cmd [function] [call site] 00849
37 redis::cmd [function] [call site] 00850
38 redis::cmd [function] [call site] 00851
38 Cmd::set_cache_config [function] [call site] 00852
39 Some [function] [call site] 00853
38 CommandCacheConfig::new [function] [call site] 00854
38 CommandCacheConfig::set_enable_cache [function] [call site] 00855
37 Cmd::set_cache_config [function] [call site] 00856
37 CommandCacheConfig::new [function] [call site] 00857
37 CommandCacheConfig::set_enable_cache [function] [call site] 00858
36 redis::Cmd::arg [function] [call site] 00859
37 u8::write_redis_args [function] [call site] 00860
36 types::test_is_single_arg [function] [call site] 00861
36 ignore [function] [call site] 00862
36 cmd [function] [call site] 00863
36 types::test_is_single_arg [function] [call site] 00864
36 types::test_is_single_arg [function] [call site] 00865
36 ignore [function] [call site] 00866
36 Cmd::query_async [function] [call site] 00867
37 &mut [call site] 00868
38 Cmd::get_packed_command [function] [call site] 00869
38 MockRedisConnection::req_packed_command [function] [call site] 00870
39 Cmd::get_packed_command [function] [call site] 00871
39 MockRedisConnection::req_packed_command [function] [call site] 00872
39 as_slice [function] [call site] 00873
39 PipelineSink::poll_ready [function] [call site] 00874
40 PipelineSink::as_mut [function] [call site] 00875
40 project [function] [call site] 00876
40 PipelineSink::poll_ready [function] [call site] 00877
41 PipelineSink::as_mut [function] [call site] 00878
41 project [function] [call site] 00879
41 PipelineSink::poll_ready [function] [call site] 00880
41 map_err [function] [call site] 00881
40 map_err [function] [call site] 00882
39 types::test_parse_boxed [function] [call site] 00883
40 &str::to_string [function] [call site] 00884
40 parse_redis_value [function] [call site] 00885
40 Value::SimpleString [function] [call site] 00886
40 ClientTlsParams::clone [function] [call site] 00887
38 as_slice [function] [call site] 00888
38 PipelineSink::poll_ready [function] [call site] 00889
38 types::test_parse_boxed [function] [call site] 00890
37 Ok [function] [call site] 00891
37 RedisResult::from_redis_value [function] [call site] 00892
38 Ok [function] [call site] 00893
38 Err [function] [call site] 00894
38 into [function] [call site] 00895
38 from_redis_value [function] [call site] 00896
39 RedisResult::from_redis_value [function] [call site] 00897
40 Ok [function] [call site] 00898
40 Err [function] [call site] 00899
40 into [function] [call site] 00900
40 from_redis_value [function] [call site] 00901
40 types::test_hashmap [function] [call site] 00902
41 parse_redis_value [function] [call site] 00903
41 Value::Array [function] [call site] 00904
41 RedisServer::new [function] [call site] 00905
41 PathBuf::insert [function] [call site] 00906
41 &str::into [function] [call site] 00907
41 PathBuf::insert [function] [call site] 00908
41 &str::into [function] [call site] 00909
41 PathBuf::insert [function] [call site] 00910
41 &str::into [function] [call site] 00911
41 parse_redis_value [function] [call site] 00912
41 Value::Array [function] [call site] 00913
41 RedisServer::default [function] [call site] 00914
41 HashMap::with_hasher [function] [call site] 00915
41 PathBuf::insert [function] [call site] 00916
41 &str::into [function] [call site] 00917
41 PathBuf::insert [function] [call site] 00918
41 &str::into [function] [call site] 00919
41 PathBuf::insert [function] [call site] 00920
41 &str::into [function] [call site] 00921
41 parse_redis_value [function] [call site] 00922
41 Value::Array [function] [call site] 00923
40 Ok [function] [call site] 00924
38 types::test_hashmap [function] [call site] 00925
38 Ok [function] [call site] 00926
37 Value::extract_error [function] [call site] 00927
38 Ok [function] [call site] 00928
38 Self::Array [function] [call site] 00929
38 Value::extract_error_vec [function] [call site] 00930
39 &'a [call site] 00931
40 std::iter::once [function] [call site] 00932
40 chain [function] [call site] 00933
40 basic::test_tuple_decoding_from_iter [function] [call site] 00934
39 std::iter::Chain::map [function] [call site] 00935
39 into_iter() [call site] 00936
6 .map(Self::extract_error) [call site] 00937
6 .collect::<RedisResult<Vec<_>>> [function] [call site] 00938
38 Ok [function] [call site] 00939
38 Self::Map [function] [call site] 00940
38 Value::extract_error_map [function] [call site] 00941
39 Cmd::with_capacity [function] [call site] 00942
40 Cmd::with_capacity [function] [call site] 00943
40 Cmd::with_capacity [function] [call site] 00944
39 basic::test_pipeline_len [function] [call site] 00945
39 &'a [call site] 00946
39 tests::decode_resp3_push [function] [call site] 00947
39 Value::extract_error [function] [call site] 00948
39 impl [call site] 00949
40 Ok [function] [call site] 00950
40 Self::Array [function] [call site] 00951
40 Value::extract_error_vec [function] [call site] 00952
40 Ok [function] [call site] 00953
40 Self::Map [function] [call site] 00954
40 Value::extract_error_map [function] [call site] 00955
40 RedisServer::new [function] [call site] 00956
41 RedisServer::with_modules [function] [call site] 00957
40 Value::extract_error [function] [call site] 00958
40 Value::extract_error_map [function] [call site] 00959
40 Ok [function] [call site] 00960
40 Ok [function] [call site] 00961
40 Self::Set [function] [call site] 00962
40 Value::extract_error_vec [function] [call site] 00963
40 Ok [function] [call site] 00964
40 Value::extract_error_vec [function] [call site] 00965
40 Err [function] [call site] 00966
40 into [function] [call site] 00967
40 Ok [function] [call site] 00968
39 Ok [function] [call site] 00969
38 RedisServer::new [function] [call site] 00970
38 Value::extract_error [function] [call site] 00971
38 Value::extract_error_map [function] [call site] 00972
38 Ok [function] [call site] 00973
38 Ok [function] [call site] 00974
38 Self::Set [function] [call site] 00975
38 Value::extract_error_vec [function] [call site] 00976
38 Ok [function] [call site] 00977
38 Value::extract_error_vec [function] [call site] 00978
38 Err [function] [call site] 00979
38 into [function] [call site] 00980
38 Ok [function] [call site] 00981
36 redis::cmd [function] [call site] 00982
36 redis::Cmd::arg [function] [call site] 00983
36 types::test_is_single_arg [function] [call site] 00984
36 Cmd::query_async [function] [call site] 00985
36 assert_hit [function] [call site] 00986
36 assert_miss [function] [call site] 00987
36 redis::cmd [function] [call site] 00988
36 redis::Cmd::arg [function] [call site] 00989
36 types::test_is_single_arg [function] [call site] 00990
36 types::test_is_single_arg [function] [call site] 00991
36 Cmd::query_async [function] [call site] 00992
36 assert_hit [function] [call site] 00993
36 assert_miss [function] [call site] 00994
36 redis::cmd [function] [call site] 00995
36 redis::Cmd::arg [function] [call site] 00996
36 Cmd::query_async [function] [call site] 00997
37 &mut [call site] 00998
37 Ok [function] [call site] 00999
37 RedisResult::from_redis_value [function] [call site] 01000
37 Value::extract_error [function] [call site] 01001
36 assert_hit [function] [call site] 01002
36 assert_miss [function] [call site] 01003
36 Ok::<_, [call site] 01004
34 ClusterConnInner::new [function] [call site] 01005
35 ClusterConnection::create_initial_connections [function] [call site] 01006
36 Cmd::with_capacity [function] [call site] 01007
37 Cmd::with_capacity [function] [call site] 01008
37 Cmd::with_capacity [function] [call site] 01009
36 basic::test_pipeline_len [function] [call site] 01010
36 RedisServer::new [function] [call site] 01011
36 basic::test_tuple_decoding_from_iter [function] [call site] 01012
36 to_string [function] [call site] 01013
36 into [function] [call site] 01014
36 ClusterConnection::connect [function] [call site] 01015
37 Client::get_connection_info [function] [call site] 01016
37 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 01017
38 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 01018
38 cluster::test_cluster_retries [function] [call site] 01019
38 TestClusterContext::get_ports [function] [call site] 01020
39 basic::test_tuple_decoding_from_iter [function] [call site] 01021
39 types::test_hashmap [function] [call site] 01022
39 redis::ConnectionInfo::addr [function] [call site] 01023
39 collect [function] [call site] 01024
38 MockRedisConnection::check_connection [function] [call site] 01025
38 RedisServer::drop [function] [call site] 01026
39 RedisServer::stop [function] [call site] 01027
40 kill [function] [call site] 01028
40 ClusterClientBuilder::max_retry_wait [function] [call site] 01029
40 RedisServer::client_addr [function] [call site] 01030
40 fs::remove_file [function] [call site] 01031
40 wait_for_status_ok [function] [call site] 01032
38 cmd [function] [call site] 01033
38 ClusterConnection::route_command [function] [call site] 01034
39 Msg::get_channel [function] [call site] 01035
40 Ok [function] [call site] 01036
40 from_redis_value_ref [function] [call site] 01037
41 FromRedisValue::from_redis_value_ref [function] [call site] 01038
42 RedisResult::from_redis_value [function] [call site] 01039
43 Ok [function] [call site] 01040
43 Err [function] [call site] 01041
43 into [function] [call site] 01042
43 from_redis_value [function] [call site] 01043
43 types::test_hashmap [function] [call site] 01044
43 Ok [function] [call site] 01045
42 ClientTlsParams::clone [function] [call site] 01046
43 ClientTlsParams::clone [function] [call site] 01047
43 Pkcs1 [function] [call site] 01048
43 secret_pkcs1_der [function] [call site] 01049
43 write_command_to_vec [function] [call site] 01050
43 into [function] [call site] 01051
43 Pkcs8 [function] [call site] 01052
43 secret_pkcs8_der [function] [call site] 01053
43 write_command_to_vec [function] [call site] 01054
43 into [function] [call site] 01055
43 Sec1 [function] [call site] 01056
43 secret_sec1_der [function] [call site] 01057
43 write_command_to_vec [function] [call site] 01058
43 into [function] [call site] 01059
39 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01060
39 RedisServer::new [function] [call site] 01061
39 ClientTlsParams::clone [function] [call site] 01062
40 ClientTlsParams::clone [function] [call site] 01063
40 Pkcs1 [function] [call site] 01064
40 secret_pkcs1_der [function] [call site] 01065
40 write_command_to_vec [function] [call site] 01066
40 into [function] [call site] 01067
40 Pkcs8 [function] [call site] 01068
40 secret_pkcs8_der [function] [call site] 01069
40 write_command_to_vec [function] [call site] 01070
40 into [function] [call site] 01071
40 Sec1 [function] [call site] 01072
40 secret_sec1_der [function] [call site] 01073
40 write_command_to_vec [function] [call site] 01074
40 into [function] [call site] 01075
39 RouteBy::into [function] [call site] 01076
39 map_err [function] [call site] 01077
39 RedisError::from [function] [call site] 01078
40 io::Error::from [function] [call site] 01079
41 io::Error::from [function] [call site] 01080
41 Self::into [function] [call site] 01081
40 Self::into [function] [call site] 01082
39 io::Error::new [function] [call site] 01083
40 RedisServer::with_modules [function] [call site] 01084
39 unwrap_or_else [function] [call site] 01085
39 Err [function] [call site] 01086
39 RedisError::from [function] [call site] 01087
39 io::Error::new [function] [call site] 01088
39 types::test_hashmap [function] [call site] 01089
39 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 01090
40 TestSentinelContext::new [function] [call site] 01091
41 TestSentinelContext::new_with_cluster_client_builder [function] [call site] 01092
42 support::start_tls_crypto_provider [function] [call site] 01093
42 RedisSentinelCluster::new [function] [call site] 01094
43 RedisSentinelCluster::with_modules [function] [call site] 01095
44 tempfile::Builder::new [function] [call site] 01096
44 RedisResult::prefix [function] [call site] 01097
44 tempdir [function] [call site] 01098
44 expect [function] [call site] 01099
44 { [call site] 01100
0 server::RedisServer}, [call site] 01101
0 utils::build_keys_and_certs_for_tls [function] [call site] 01102
45 build_keys_and_certs_for_tls_ext [function] [call site] 01103
44 tests::decode_resp3_push [function] [call site] 01104
44 std::collections::HashSet::new [function] [call site] 01105
44 basic::test_pipeline_len [function] [call site] 01106
45 redis::pipe [function] [call site] 01107
45 cmd [function] [call site] 01108
45 cmd [function] [call site] 01109
45 types::test_is_single_arg [function] [call site] 01110
44 RedisServer::insert [function] [call site] 01111
44 { [call site] 01112
0 server::get_random_available_port [function] [call site] 01113
45 get_listener_on_free_port [function] [call site] 01114
45 TcpListener::local_addr [function] [call site] 01115
45 unwrap [function] [call site] 01116
45 get_listener_on_free_port [function] [call site] 01117
44 &'a [call site] 01118
45 std::iter::once [function] [call site] 01119
45 chain [function] [call site] 01120
45 basic::test_tuple_decoding_from_iter [function] [call site] 01121
44 std::iter::Chain::collect [function] [call site] 01122
44 RedisServer::pop [function] [call site] 01123
45 TestContext::with_modules [function] [call site] 01124
45 TestContext::connection [function] [call site] 01125
45 redis::Connection::json_set [function] [call site] 01126
45 redis::Connection::json_arr_pop [function] [call site] 01127
46 TestContext::with_modules [function] [call site] 01128
46 TestContext::connection [function] [call site] 01129
46 redis::Connection::json_set [function] [call site] 01130
46 redis::Connection::json_arr_pop [function] [call site] 01131
46 redis::Connection::json_set [function] [call site] 01132
46 redis::Connection::json_arr_pop [function] [call site] 01133
45 redis::Connection::json_set [function] [call site] 01134
45 redis::Connection::json_arr_pop [function] [call site] 01135
44 unwrap [function] [call site] 01136
44 tempfile::Builder::new [function] [call site] 01137
44 RedisResult::prefix [function] [call site] 01138
44 tempdir [function] [call site] 01139
44 expect [function] [call site] 01140
44 tests::decode_resp3_push [function] [call site] 01141
45 parse_redis_value [function] [call site] 01142
45 RedisResult::unwrap [function] [call site] 01143
44 spawn_master_server [function] [call site] 01144
45 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 01145
45 get_addr [function] [call site] 01146
46 RedisServer::get_addr [function] [call site] 01147
46 ConnectionAddr::Tcp [function] [call site] 01148
46 String::from [function] [call site] 01149
47 &str::to_string [function] [call site] 01150
47 &str::to_string [function] [call site] 01151
47 &str::to_string [function] [call site] 01152
47 &str::to_string [function] [call site] 01153
47 &str::to_string [function] [call site] 01154
47 &str::to_string [function] [call site] 01155
45 Some [function] [call site] 01156
45 ClientTlsParams::clone [function] [call site] 01157
46 ClientTlsParams::clone [function] [call site] 01158
46 Pkcs1 [function] [call site] 01159
46 secret_pkcs1_der [function] [call site] 01160
46 write_command_to_vec [function] [call site] 01161
46 into [function] [call site] 01162
46 Pkcs8 [function] [call site] 01163
46 secret_pkcs8_der [function] [call site] 01164
46 write_command_to_vec [function] [call site] 01165
46 into [function] [call site] 01166
46 Sec1 [function] [call site] 01167
46 secret_sec1_der [function] [call site] 01168
46 write_command_to_vec [function] [call site] 01169
46 into [function] [call site] 01170
45 Cmd::arg [function] [call site] 01171
45 types::test_is_single_arg [function] [call site] 01172
45 Cmd::arg [function] [call site] 01173
45 types::test_is_single_arg [function] [call site] 01174
45 get_addr [function] [call site] 01175
45 Cmd::arg [function] [call site] 01176
45 types::test_is_single_arg [function] [call site] 01177
45 Cmd::current_dir [function] [call site] 01178
45 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01179
45 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 01180
45 unwrap [function] [call site] 01181
44 tests::decode_resp3_push [function] [call site] 01182
44 tests::decode_resp3_push [function] [call site] 01183
44 RedisServer::pop [function] [call site] 01184
44 unwrap [function] [call site] 01185
44 tempfile::Builder::new [function] [call site] 01186
44 RedisResult::prefix [function] [call site] 01187
44 tempdir [function] [call site] 01188
44 expect [function] [call site] 01189
44 tests::decode_resp3_push [function] [call site] 01190
44 spawn_replica_server [function] [call site] 01191
45 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01192
45 join [function] [call site] 01193
45 File::create [function] [call site] 01194
46 TestContext::new [function] [call site] 01195
46 TestContext::connection [function] [call site] 01196
46 xadd [function] [call site] 01197
47 &mut [call site] 01198
48 &mut [call site] 01199
48 unwrap [function] [call site] 01200
48 &mut [call site] 01201
48 unwrap [function] [call site] 01202
48 &mut [call site] 01203
48 unwrap [function] [call site] 01204
48 &mut [call site] 01205
48 unwrap [function] [call site] 01206
47 unwrap [function] [call site] 01207
47 &mut [call site] 01208
47 unwrap [function] [call site] 01209
47 &mut [call site] 01210
47 unwrap [function] [call site] 01211
47 &mut [call site] 01212
47 unwrap [function] [call site] 01213
46 redis::Connection::xinfo_stream [function] [call site] 01214
46 TestContext::connection [function] [call site] 01215
46 redis::Connection::xinfo_stream [function] [call site] 01216
46 unwrap [function] [call site] 01217
46 redis::Connection::xgroup_create [function] [call site] 01218
47 TestContext::new [function] [call site] 01219
47 TestContext::connection [function] [call site] 01220
47 xadd [function] [call site] 01221
47 redis::Connection::xinfo_stream [function] [call site] 01222
47 TestContext::connection [function] [call site] 01223
47 redis::Connection::xinfo_stream [function] [call site] 01224
47 unwrap [function] [call site] 01225
47 redis::Connection::xgroup_create [function] [call site] 01226
47 redis::Connection::xinfo_groups [function] [call site] 01227
47 unwrap [function] [call site] 01228
46 redis::Connection::xinfo_groups [function] [call site] 01229
46 unwrap [function] [call site] 01230
45 unwrap [function] [call site] 01231
45 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 01232
45 get_addr [function] [call site] 01233
45 Some [function] [call site] 01234
45 Some [function] [call site] 01235
45 ClientTlsParams::clone [function] [call site] 01236
45 Cmd::arg [function] [call site] 01237
45 types::test_is_single_arg [function] [call site] 01238
45 types::test_is_single_arg [function] [call site] 01239
45 u16::to_string [function] [call site] 01240
45 get_addr [function] [call site] 01241
45 Cmd::arg [function] [call site] 01242
45 types::test_is_single_arg [function] [call site] 01243
45 Cmd::arg [function] [call site] 01244
45 types::test_is_single_arg [function] [call site] 01245
45 Cmd::current_dir [function] [call site] 01246
45 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01247
45 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 01248
45 unwrap [function] [call site] 01249
44 tests::decode_resp3_push [function] [call site] 01250
44 wait_for_replicas_to_sync [function] [call site] 01251
45 basic::test_pipeline_len [function] [call site] 01252
46 redis::pipe [function] [call site] 01253
46 cmd [function] [call site] 01254
46 cmd [function] [call site] 01255
46 types::test_is_single_arg [function] [call site] 01256
45 basic::test_pipeline_len [function] [call site] 01257
45 RedisServer::connection_info [function] [call site] 01258
46 RedisServer::client_addr [function] [call site] 01259
46 &redis::ConnectionAddr::clone [function] [call site] 01260
46 ConnectionInfo::into_connection_info [function] [call site] 01261
46 RedisResult::unwrap [function] [call site] 01262
46 ConnectionInfo::set_redis_settings [function] [call site] 01263
46 redis_settings [function] [call site] 01264
45 wait_for_master_server [function] [call site] 01265
46 redis::cmd [function] [call site] 01266
46 Client::get_connection [function] [call site] 01267
46 redis::Cmd::query [function] [call site] 01268
47 ConnectionLike::req_command [function] [call site] 01269
48 Cmd::get_packed_command [function] [call site] 01270
48 MockRedisConnection::req_packed_command [function] [call site] 01271
49 Cmd::get_packed_command [function] [call site] 01272
49 MockRedisConnection::req_packed_command [function] [call site] 01273
49 as_slice [function] [call site] 01274
49 PipelineSink::poll_ready [function] [call site] 01275
49 types::test_parse_boxed [function] [call site] 01276
47 Ok [function] [call site] 01277
47 RedisResult::from_redis_value [function] [call site] 01278
47 Value::extract_error [function] [call site] 01279
47 Err [function] [call site] 01280
46 RedisResult::unwrap [function] [call site] 01281
46 String::from_redis_value_ref [function] [call site] 01282
47 get_inner_value [function] [call site] 01283
48 as_ref [function] [call site] 01284
47 Ok [function] [call site] 01285
47 std::str::from_utf8 [function] [call site] 01286
47 to_string [function] [call site] 01287
47 Ok [function] [call site] 01288
47 &str::to_string [function] [call site] 01289
47 Ok [function] [call site] 01290
47 to_string [function] [call site] 01291
47 Ok [function] [call site] 01292
47 to_string [function] [call site] 01293
47 Ok [function] [call site] 01294
47 to_string [function] [call site] 01295
47 Ok [function] [call site] 01296
47 to_string [function] [call site] 01297
46 ConnectionAddr::first [function] [call site] 01298
46 unwrap [function] [call site] 01299
46 Result::unwrap [function] [call site] 01300
46 starts_with [function] [call site] 01301
46 Ok [function] [call site] 01302
46 std::thread::sleep [function] [call site] 01303
47 tokio::time::sleep [function] [call site] 01304
48 tokio::time::sleep [function] [call site] 01305
48 smol::Timer::after [function] [call site] 01306
47 smol::Timer::after [function] [call site] 01307
46 Duration::from_millis [function] [call site] 01308
46 Err [function] [call site] 01309
45 redis::Client::open [function] [call site] 01310
45 ClientTlsParams::clone [function] [call site] 01311
45 ConnectionAddr::is_err [function] [call site] 01312
46 into [function] [call site] 01313
46 is_unexpected_end_of_input [function] [call site] 01314
46 RedisError::from [function] [call site] 01315
46 io::Error::from [function] [call site] 01316
46 map_range [function] [call site] 01317
46 map_position [function] [call site] 01318
46 translate_position [function] [call site] 01319
46 buffer [function] [call site] 01320
46 to_string [function] [call site] 01321
46 RedisError::from [function] [call site] 01322
46 ParsingError::from [function] [call site] 01323
45 RedisServer::connection_info [function] [call site] 01324
45 wait_for_replica [function] [call site] 01325
46 redis::cmd [function] [call site] 01326
46 Client::get_connection [function] [call site] 01327
46 redis::Cmd::query [function] [call site] 01328
46 RedisResult::unwrap [function] [call site] 01329
46 String::from_redis_value_ref [function] [call site] 01330
46 ConnectionAddr::first [function] [call site] 01331
46 unwrap [function] [call site] 01332
46 Result::unwrap [function] [call site] 01333
46 String::from_redis_value_ref [function] [call site] 01334
46 ConnectionAddr::get [function] [call site] 01335
47 TestContext::new [function] [call site] 01336
47 Ok [function] [call site] 01337
47 TestContext::async_connection_with_cache [function] [call site] 01338
47 get_pipe [function] [call site] 01339
47 redis::Pipeline::cmd [function] [call site] 01340
47 redis::Cmd::arg [function] [call site] 01341
47 types::test_is_single_arg [function] [call site] 01342
47 ignore [function] [call site] 01343
47 cmd [function] [call site] 01344
47 types::test_is_single_arg [function] [call site] 01345
47 types::test_is_single_arg [function] [call site] 01346
47 ignore [function] [call site] 01347
47 Cmd::query_async [function] [call site] 01348
47 redis::cmd [function] [call site] 01349
47 redis::Cmd::arg [function] [call site] 01350
47 types::test_is_single_arg [function] [call site] 01351
47 Cmd::query_async [function] [call site] 01352
47 assert_hit [function] [call site] 01353
47 assert_miss [function] [call site] 01354
47 redis::cmd [function] [call site] 01355
47 redis::Cmd::arg [function] [call site] 01356
47 types::test_is_single_arg [function] [call site] 01357
47 types::test_is_single_arg [function] [call site] 01358
47 Cmd::query_async [function] [call site] 01359
47 assert_hit [function] [call site] 01360
47 assert_miss [function] [call site] 01361
47 redis::cmd [function] [call site] 01362
47 redis::Cmd::arg [function] [call site] 01363
47 Cmd::query_async [function] [call site] 01364
47 assert_hit [function] [call site] 01365
47 assert_miss [function] [call site] 01366
47 Ok::<_, [call site] 01367
46 RedisResult::unwrap [function] [call site] 01368
46 Result::unwrap [function] [call site] 01369
46 starts_with [function] [call site] 01370
46 Ok [function] [call site] 01371
46 std::thread::sleep [function] [call site] 01372
46 Duration::from_millis [function] [call site] 01373
46 Err [function] [call site] 01374
45 redis::Client::open [function] [call site] 01375
45 ClientTlsParams::clone [function] [call site] 01376
45 ConnectionAddr::is_err [function] [call site] 01377
44 RedisServer::pop [function] [call site] 01378
44 unwrap [function] [call site] 01379
44 tempfile::Builder::new [function] [call site] 01380
44 RedisResult::prefix [function] [call site] 01381
44 tempdir [function] [call site] 01382
44 expect [function] [call site] 01383
44 tests::decode_resp3_push [function] [call site] 01384
44 spawn_sentinel_server [function] [call site] 01385
45 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01386
45 join [function] [call site] 01387
45 File::create [function] [call site] 01388
45 unwrap [function] [call site] 01389
45 basic::test_tuple_decoding_from_iter [function] [call site] 01390
46 TestContext::new [function] [call site] 01391
46 TestContext::connection [function] [call site] 01392
46 ValueType::from [function] [call site] 01393
47 TlsFilePaths::as_ref [function] [call site] 01394
47 ValueType::Unknown [function] [call site] 01395
47 TlsFilePaths::to_string [function] [call site] 01396
46 basic::test_tuple_decoding_from_iter [function] [call site] 01397
46 hscan::<_, [call site] 01398
46 unwrap [function] [call site] 01399
46 unwrap [function] [call site] 01400
45 enumerate [function] [call site] 01401
45 PathBuf::write_all [function] [call site] 01402
45 as_bytes [function] [call site] 01403
45 unwrap [function] [call site] 01404
45 PipelineSink::poll_flush [function] [call site] 01405
46 PipelineSink::poll_read [function] [call site] 01406
47 PipelineSink::as_mut [function] [call site] 01407
47 project [function] [call site] 01408
47 ResultExpectation::is_closed [function] [call site] 01409
48 ResultExpectation::is_closed [function] [call site] 01410
49 ResultExpectation::is_closed [function] [call site] 01411
47 Poll::Ready [function] [call site] 01412
47 Err [function] [call site] 01413
47 Poll::Ready [function] [call site] 01414
47 Err [function] [call site] 01415
47 PipelineSink::as_mut [function] [call site] 01416
47 PipelineSink::handle_message [function] [call site] 01417
48 PipelineSink::project [function] [call site] 01418
48 impl [call site] 01419
48 pop_front [function] [call site] 01420
48 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01421
48 Ok [function] [call site] 01422
48 Value::Array [function] [call site] 01423
48 Ok [function] [call site] 01424
48 Msg::from_owned_value [function] [call site] 01425
49 Msg::from_push_info [function] [call site] 01426
50 &'a [call site] 01427
50 MapIter::next [function] [call site] 01428
51 Some [function] [call site] 01429
51 MapIter::next [function] [call site] 01430
51 MapIter::next [function] [call site] 01431
51 MapIter::next [function] [call site] 01432
51 Some [function] [call site] 01433
50 MapIter::next [function] [call site] 01434
50 Some [function] [call site] 01435
50 MapIter::next [function] [call site] 01436
50 MapIter::next [function] [call site] 01437
50 MapIter::next [function] [call site] 01438
50 Some [function] [call site] 01439
49 from_redis_value [function] [call site] 01440
49 Result::ok [function] [call site] 01441
50 RedisServer::log_file [function] [call site] 01442
50 std::fs::read_to_string [function] [call site] 01443
50 expect [function] [call site] 01444
50 Option::contains [function] [call site] 01445
50 std::thread::sleep [function] [call site] 01446
50 Duration::from_millis [function] [call site] 01447
49 &'a [call site] 01448
49 from_redis_value [function] [call site] 01449
49 MapIter::next [function] [call site] 01450
49 Result::ok [function] [call site] 01451
49 MapIter::next [function] [call site] 01452
49 MapIter::next [function] [call site] 01453
49 Some [function] [call site] 01454
49 MapIter::next [function] [call site] 01455
49 MapIter::next [function] [call site] 01456
49 MapIter::next [function] [call site] 01457
49 Some [function] [call site] 01458
48 Value::Array [function] [call site] 01459
48 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01460
48 Ok [function] [call site] 01461
48 Err [function] [call site] 01462
48 PushKind::has_reply [function] [call site] 01463
48 pop_front [function] [call site] 01464
48 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01465
48 Ok [function] [call site] 01466
48 Ok [function] [call site] 01467
48 Msg::from_push_info [function] [call site] 01468
49 &'a [call site] 01469
49 MapIter::next [function] [call site] 01470
49 MapIter::next [function] [call site] 01471
49 Some [function] [call site] 01472
49 MapIter::next [function] [call site] 01473
49 MapIter::next [function] [call site] 01474
49 MapIter::next [function] [call site] 01475
49 Some [function] [call site] 01476
48 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01477
48 Ok [function] [call site] 01478
48 Err [function] [call site] 01479
48 RedisError::is_unrecoverable_error [function] [call site] 01480
49 RedisError::retry_method [function] [call site] 01481
50 RedisError::kind [function] [call site] 01482
51 get_push_kind [function] [call site] 01483
52 PushKind::as_str [function] [call site] 01484
52 PushKind::Other [function] [call site] 01485
51 ErrorKind::Server [function] [call site] 01486
51 first [function] [call site] 01487
51 and_then [function] [call site] 01488
51 get_push_kind [function] [call site] 01489
51 types::test_hashmap [function] [call site] 01490
51 PushKind::into [function] [call site] 01491
51 unwrap_or [function] [call site] 01492
51 ErrorKind::Server [function] [call site] 01493
50 RedisError::retry_method [function] [call site] 01494
51 RedisError::kind [function] [call site] 01495
51 RedisError::retry_method [function] [call site] 01496
51 RedisError::as_io_error [function] [call site] 01497
52 downcast_ref [function] [call site] 01498
51 types::test_hashmap [function] [call site] 01499
52 parse_redis_value [function] [call site] 01500
52 Value::Array [function] [call site] 01501
52 RedisServer::new [function] [call site] 01502
52 PathBuf::insert [function] [call site] 01503
52 &str::into [function] [call site] 01504
52 PathBuf::insert [function] [call site] 01505
52 &str::into [function] [call site] 01506
52 PathBuf::insert [function] [call site] 01507
52 &str::into [function] [call site] 01508
52 parse_redis_value [function] [call site] 01509
52 Value::Array [function] [call site] 01510
52 RedisServer::default [function] [call site] 01511
52 HashMap::with_hasher [function] [call site] 01512
52 PathBuf::insert [function] [call site] 01513
52 &str::into [function] [call site] 01514
52 PathBuf::insert [function] [call site] 01515
52 &str::into [function] [call site] 01516
52 PathBuf::insert [function] [call site] 01517
52 &str::into [function] [call site] 01518
52 parse_redis_value [function] [call site] 01519
52 Value::Array [function] [call site] 01520
51 get_push_kind [function] [call site] 01521
51 unwrap_or [function] [call site] 01522
50 RedisError::as_io_error [function] [call site] 01523
50 types::test_hashmap [function] [call site] 01524
50 get_push_kind [function] [call site] 01525
50 unwrap_or [function] [call site] 01526
48 Err [function] [call site] 01527
48 pop_front [function] [call site] 01528
48 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01529
48 Ok [function] [call site] 01530
48 Err [function] [call site] 01531
45 Poll::unwrap [function] [call site] 01532
45 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 01533
45 get_addr [function] [call site] 01534
45 Some [function] [call site] 01535
45 Some [function] [call site] 01536
45 ClientTlsParams::clone [function] [call site] 01537
45 Cmd::arg [function] [call site] 01538
45 Cmd::arg [function] [call site] 01539
45 types::test_is_single_arg [function] [call site] 01540
45 get_addr [function] [call site] 01541
45 Cmd::arg [function] [call site] 01542
45 types::test_is_single_arg [function] [call site] 01543
45 Cmd::current_dir [function] [call site] 01544
45 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01545
45 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 01546
45 unwrap [function] [call site] 01547
44 tests::decode_resp3_push [function] [call site] 01548
42 RedisSentinelCluster::iter_sentinel_servers [function] [call site] 01549
43 basic::test_tuple_decoding_from_iter [function] [call site] 01550
42 types::test_hashmap [function] [call site] 01551
43 parse_redis_value [function] [call site] 01552
43 Value::Array [function] [call site] 01553
43 RedisServer::new [function] [call site] 01554
43 PathBuf::insert [function] [call site] 01555
43 &str::into [function] [call site] 01556
43 PathBuf::insert [function] [call site] 01557
43 &str::into [function] [call site] 01558
43 PathBuf::insert [function] [call site] 01559
43 &str::into [function] [call site] 01560
43 parse_redis_value [function] [call site] 01561
43 Value::Array [function] [call site] 01562
43 RedisServer::default [function] [call site] 01563
43 HashMap::with_hasher [function] [call site] 01564
43 PathBuf::insert [function] [call site] 01565
43 &str::into [function] [call site] 01566
43 PathBuf::insert [function] [call site] 01567
43 &str::into [function] [call site] 01568
43 PathBuf::insert [function] [call site] 01569
43 &str::into [function] [call site] 01570
43 parse_redis_value [function] [call site] 01571
43 Value::Array [function] [call site] 01572
42 collect [function] [call site] 01573
42 redis::sentinel::Sentinel::build [function] [call site] 01574
43 Sentinel::build_inner [function] [call site] 01575
42 ClientTlsParams::clone [function] [call site] 01576
42 &redis::sentinel::Sentinel::unwrap [function] [call site] 01577
42 TestSentinelContext::wait_for_cluster_up [function] [call site] 01578
43 TestSentinelContext::sentinel_node_connection_info [function] [call site] 01579
44 TestSentinelContext::tls_mode [function] [call site] 01580
45 RedisServer::client_addr [function] [call site] 01581
45 Some [function] [call site] 01582
45 Some [function] [call site] 01583
44 &SentinelNodeConnectionInfo::default [function] [call site] 01584
44 SentinelNodeConnectionInfo::set_tls_mode [function] [call site] 01585
45 Some [function] [call site] 01586
44 &SentinelNodeConnectionInfo::default [function] [call site] 01587
43 TestSentinelContext::sentinel_mut [function] [call site] 01588
43 redis_test::sentinel::wait_for_master_server [function] [call site] 01589
44 redis::cmd [function] [call site] 01590
44 Client::get_connection [function] [call site] 01591
44 redis::Cmd::query [function] [call site] 01592
44 RedisResult::unwrap [function] [call site] 01593
44 String::from_redis_value_ref [function] [call site] 01594
44 ConnectionAddr::first [function] [call site] 01595
44 unwrap [function] [call site] 01596
44 Result::unwrap [function] [call site] 01597
44 starts_with [function] [call site] 01598
44 Ok [function] [call site] 01599
44 std::thread::sleep [function] [call site] 01600
44 Duration::from_millis [function] [call site] 01601
44 Err [function] [call site] 01602
43 &mut [call site] 01603
44 Sentinel::find_master_address [function] [call site] 01604
45 Sentinel::get_sentinel_masters [function] [call site] 01605
46 Sentinel::try_all_sentinels [function] [call site] 01606
47 basic::test_tuple_decoding_from_iter [function] [call site] 01607
47 zip [function] [call site] 01608
47 iter_mut [function] [call site] 01609
47 try_single_sentinel [function] [call site] 01610
48 &mut [call site] 01611
48 reconnect [function] [call site] 01612
49 Client::open [function] [call site] 01613
50 Ok [function] [call site] 01614
50 ConnectionInfo::into_connection_info [function] [call site] 01615
49 redis::ConnectionInfo::clone [function] [call site] 01616
50 ClientTlsParams::clone [function] [call site] 01617
50 Pkcs1 [function] [call site] 01618
50 secret_pkcs1_der [function] [call site] 01619
50 write_command_to_vec [function] [call site] 01620
50 into [function] [call site] 01621
50 Pkcs8 [function] [call site] 01622
50 secret_pkcs8_der [function] [call site] 01623
50 write_command_to_vec [function] [call site] 01624
50 into [function] [call site] 01625
50 Sec1 [function] [call site] 01626
50 secret_sec1_der [function] [call site] 01627
50 write_command_to_vec [function] [call site] 01628
50 into [function] [call site] 01629
49 Client::get_connection [function] [call site] 01630
49 CopyOptions::replace [function] [call site] 01631
49 Ok [function] [call site] 01632
48 Cmd::query [function] [call site] 01633
49 ConnectionLike::req_command [function] [call site] 01634
49 Ok [function] [call site] 01635
49 RedisResult::from_redis_value [function] [call site] 01636
49 Value::extract_error [function] [call site] 01637
49 Err [function] [call site] 01638
48 &mut [call site] 01639
48 unwrap [function] [call site] 01640
48 RedisError::is_unrecoverable_error [function] [call site] 01641
48 types::test_is_io_error [function] [call site] 01642
49 RedisError::from [function] [call site] 01643
48 reconnect [function] [call site] 01644
48 Cmd::query [function] [call site] 01645
48 &mut [call site] 01646
48 unwrap [function] [call site] 01647
48 Err [function] [call site] 01648
47 ClientTlsParams::clone [function] [call site] 01649
47 Ok [function] [call site] 01650
47 Some [function] [call site] 01651
47 Err [function] [call site] 01652
47 None::expect [function] [call site] 01653
46 sentinel_masters_cmd [function] [call site] 01654
47 crate::cmd [function] [call site] 01655
48 redis::cmd [function] [call site] 01656
48 Cmd::set_cache_config [function] [call site] 01657
48 CommandCacheConfig::new [function] [call site] 01658
48 CommandCacheConfig::set_enable_cache [function] [call site] 01659
47 Cmd::arg [function] [call site] 01660
45 find_valid_master [function] [call site] 01661
46 valid_addrs [function] [call site] 01662
47 &'a [call site] 01663
48 std::iter::once [function] [call site] 01664
48 chain [function] [call site] 01665
48 basic::test_tuple_decoding_from_iter [function] [call site] 01666
47 std::iter::Chain::filter [function] [call site] 01667
47 types::test_hashmap [function] [call site] 01668
47 redis::ConnectionInfo::remove [function] [call site] 01669
47 unwrap [function] [call site] 01670
47 parse::<u16> [function] [call site] 01671
47 unwrap [function] [call site] 01672
46 is_master_valid [function] [call site] 01673
47 &HashMap<String, [call site] 01674
48 TestContext::new [function] [call site] 01675
48 Ok [function] [call site] 01676
48 TestContext::async_connection_with_cache [function] [call site] 01677
48 get_pipe [function] [call site] 01678
48 redis::Pipeline::cmd [function] [call site] 01679
48 redis::Cmd::arg [function] [call site] 01680
48 types::test_is_single_arg [function] [call site] 01681
48 ignore [function] [call site] 01682
48 cmd [function] [call site] 01683
48 types::test_is_single_arg [function] [call site] 01684
48 types::test_is_single_arg [function] [call site] 01685
48 ignore [function] [call site] 01686
48 Cmd::query_async [function] [call site] 01687
48 redis::cmd [function] [call site] 01688
48 redis::Cmd::arg [function] [call site] 01689
48 types::test_is_single_arg [function] [call site] 01690
48 Cmd::query_async [function] [call site] 01691
48 assert_hit [function] [call site] 01692
48 assert_miss [function] [call site] 01693
48 redis::cmd [function] [call site] 01694
48 redis::Cmd::arg [function] [call site] 01695
48 types::test_is_single_arg [function] [call site] 01696
48 types::test_is_single_arg [function] [call site] 01697
48 Cmd::query_async [function] [call site] 01698
48 assert_hit [function] [call site] 01699
48 assert_miss [function] [call site] 01700
48 redis::cmd [function] [call site] 01701
48 redis::Cmd::arg [function] [call site] 01702
48 Cmd::query_async [function] [call site] 01703
48 assert_hit [function] [call site] 01704
48 assert_miss [function] [call site] 01705
48 Ok::<_, [call site] 01706
47 types::test_hashmap [function] [call site] 01707
48 parse_redis_value [function] [call site] 01708
48 Value::Array [function] [call site] 01709
48 RedisServer::new [function] [call site] 01710
48 PathBuf::insert [function] [call site] 01711
48 &str::into [function] [call site] 01712
48 PathBuf::insert [function] [call site] 01713
48 &str::into [function] [call site] 01714
48 PathBuf::insert [function] [call site] 01715
48 &str::into [function] [call site] 01716
48 parse_redis_value [function] [call site] 01717
48 Value::Array [function] [call site] 01718
48 RedisServer::default [function] [call site] 01719
48 HashMap::with_hasher [function] [call site] 01720
48 PathBuf::insert [function] [call site] 01721
48 &str::into [function] [call site] 01722
48 PathBuf::insert [function] [call site] 01723
48 &str::into [function] [call site] 01724
48 PathBuf::insert [function] [call site] 01725
48 &str::into [function] [call site] 01726
48 parse_redis_value [function] [call site] 01727
48 Value::Array [function] [call site] 01728
47 TlsFilePaths::as_str [function] [call site] 01729
47 Some [function] [call site] 01730
47 InfoDict::contains_key [function] [call site] 01731
48 InfoDict::find [function] [call site] 01732
49 cache_mget [function] [call site] 01733
48 Option::is_some [function] [call site] 01734
47 InfoDict::contains_key [function] [call site] 01735
47 &HashMap<String, [call site] 01736
47 RedisResult::is_some_and [function] [call site] 01737
47 contains [function] [call site] 01738
47 contains [function] [call site] 01739
47 contains [function] [call site] 01740
47 parse::<u16> [function] [call site] 01741
47 is_ok [function] [call site] 01742
46 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01743
47 crate::ConnectionAddr::Tcp [function] [call site] 01744
47 ClusterClientBuilder::as_ref [function] [call site] 01745
47 types::test_hashmap [function] [call site] 01746
47 transpose [function] [call site] 01747
47 Ok [function] [call site] 01748
47 ClientTlsParams::clone [function] [call site] 01749
47 unwrap_or_default [function] [call site] 01750
47 RedisServer::default [function] [call site] 01751
48 RedisServer::new [function] [call site] 01752
46 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01753
46 determine_master_from_role_or_info_replication [function] [call site] 01754
47 Client::open [function] [call site] 01755
47 redis::ConnectionInfo::clone [function] [call site] 01756
47 Client::get_connection [function] [call site] 01757
47 check_role [function] [call site] 01758
48 crate::cmd [function] [call site] 01759
48 redis::Cmd::query [function] [call site] 01760
47 Ok [function] [call site] 01761
47 check_info_replication [function] [call site] 01762
48 crate::cmd [function] [call site] 01763
48 redis::Cmd::arg [function] [call site] 01764
48 basic::test_pipeline_reuse_query [function] [call site] 01765
49 TestContext::new [function] [call site] 01766
49 TestContext::connection [function] [call site] 01767
49 redis::pipe [function] [call site] 01768
49 cmd [function] [call site] 01769
49 types::test_is_single_arg [function] [call site] 01770
49 types::test_is_single_arg [function] [call site] 01771
49 ignore [function] [call site] 01772
49 cmd [function] [call site] 01773
49 types::test_is_single_arg [function] [call site] 01774
49 basic::test_pipeline_reuse_query [function] [call site] 01775
50 TestContext::new [function] [call site] 01776
50 TestContext::connection [function] [call site] 01777
50 redis::pipe [function] [call site] 01778
50 cmd [function] [call site] 01779
50 types::test_is_single_arg [function] [call site] 01780
50 types::test_is_single_arg [function] [call site] 01781
50 ignore [function] [call site] 01782
50 cmd [function] [call site] 01783
50 types::test_is_single_arg [function] [call site] 01784
50 basic::test_pipeline_reuse_query [function] [call site] 01785
50 unwrap [function] [call site] 01786
50 redis::cmd [function] [call site] 01787
50 redis::Cmd::arg [function] [call site] 01788
50 Cmd::exec [function] [call site] 01789
51 query::<()> [function] [call site] 01790
50 RedisResult::unwrap [function] [call site] 01791
50 cmd [function] [call site] 01792
50 types::test_is_single_arg [function] [call site] 01793
50 types::test_is_single_arg [function] [call site] 01794
50 ignore [function] [call site] 01795
50 cmd [function] [call site] 01796
50 types::test_is_single_arg [function] [call site] 01797
50 types::test_is_single_arg [function] [call site] 01798
50 basic::test_pipeline_reuse_query [function] [call site] 01799
50 unwrap [function] [call site] 01800
49 unwrap [function] [call site] 01801
49 redis::cmd [function] [call site] 01802
49 redis::Cmd::arg [function] [call site] 01803
49 Cmd::exec [function] [call site] 01804
49 RedisResult::unwrap [function] [call site] 01805
49 cmd [function] [call site] 01806
49 types::test_is_single_arg [function] [call site] 01807
49 types::test_is_single_arg [function] [call site] 01808
49 ignore [function] [call site] 01809
49 cmd [function] [call site] 01810
49 types::test_is_single_arg [function] [call site] 01811
49 types::test_is_single_arg [function] [call site] 01812
49 basic::test_pipeline_reuse_query [function] [call site] 01813
49 unwrap [function] [call site] 01814
48 parse_replication_info [function] [call site] 01815
49 impl [call site] 01816
50 TestContext::new [function] [call site] 01817
50 TestContext::async_pubsub [function] [call site] 01818
51 Client::get_async_pubsub [function] [call site] 01819
52 Client::get_simple_async_connection_dynamically [function] [call site] 01820
53 Runtime::locate [function] [call site] 01821
53 get_simple_async_connection::<crate::aio::tokio::Tokio> [function] [call site] 01822
53 get_simple_async_connection::<crate::aio::smol::Smol> [function] [call site] 01823
52 crate::aio::PubSub::new [function] [call site] 01824
53 RedisServer::default [function] [call site] 01825
54 RedisServer::new [function] [call site] 01826
53 Self::framed [function] [call site] 01827
53 super::setup_connection [function] [call site] 01828
54 execute_connection_pipeline [function] [call site] 01829
55 basic::test_pipeline_len [function] [call site] 01830
56 redis::pipe [function] [call site] 01831
56 cmd [function] [call site] 01832
56 cmd [function] [call site] 01833
56 types::test_is_single_arg [function] [call site] 01834
55 Ok [function] [call site] 01835
55 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01836
55 Pipeline::get_packed_pipeline [function] [call site] 01837
56 encode_pipeline [function] [call site] 01838
57 write_pipeline [function] [call site] 01839
58 basic::test_tuple_decoding_from_iter [function] [call site] 01840
59 TestContext::new [function] [call site] 01841
59 TestContext::connection [function] [call site] 01842
59 ValueType::from [function] [call site] 01843
59 basic::test_tuple_decoding_from_iter [function] [call site] 01844
59 hscan::<_, [call site] 01845
59 unwrap [function] [call site] 01846
59 unwrap [function] [call site] 01847
58 types::test_hashmap [function] [call site] 01848
58 sum [function] [call site] 01849
58 cmd::cmd [function] [call site] 01850
59 redis::cmd [function] [call site] 01851
59 Cmd::set_cache_config [function] [call site] 01852
59 CommandCacheConfig::new [function] [call site] 01853
59 CommandCacheConfig::set_enable_cache [function] [call site] 01854
58 cmd::cmd [function] [call site] 01855
58 &mut [call site] 01856
58 cmd::cmd_len [function] [call site] 01857
59 args_len [function] [call site] 01858
59 Cmd::args_iter [function] [call site] 01859
59 unwrap_or [function] [call site] 01860
58 cmd::cmd_len [function] [call site] 01861
58 Cmd::write_packed_command_preallocated [function] [call site] 01862
59 write_command [function] [call site] 01863
59 Cmd::args_iter [function] [call site] 01864
59 unwrap_or [function] [call site] 01865
59 io::Result::unwrap [function] [call site] 01866
58 Cmd::write_packed_command_preallocated [function] [call site] 01867
59 write_command [function] [call site] 01868
59 Cmd::args_iter [function] [call site] 01869
59 unwrap_or [function] [call site] 01870
59 io::Result::unwrap [function] [call site] 01871
58 Cmd::write_packed_command_preallocated [function] [call site] 01872
58 &mut [call site] 01873
58 Cmd::write_packed_command_preallocated [function] [call site] 01874
55 Cmd::with_capacity [function] [call site] 01875
55 MapIter::next [function] [call site] 01876
56 Some [function] [call site] 01877
56 MapIter::next [function] [call site] 01878
56 MapIter::next [function] [call site] 01879
56 MapIter::next [function] [call site] 01880
56 Some [function] [call site] 01881
55 ok_or_else [function] [call site] 01882
55 tests::decode_resp3_push [function] [call site] 01883
56 parse_redis_value [function] [call site] 01884
56 RedisResult::unwrap [function] [call site] 01885
55 check_connection_setup [function] [call site] 01886
56 RedisResult::get [function] [call site] 01887
57 TestContext::new [function] [call site] 01888
57 Ok [function] [call site] 01889
57 TestContext::async_connection_with_cache [function] [call site] 01890
57 get_pipe [function] [call site] 01891
57 redis::Pipeline::cmd [function] [call site] 01892
57 redis::Cmd::arg [function] [call site] 01893
57 types::test_is_single_arg [function] [call site] 01894
57 ignore [function] [call site] 01895
57 cmd [function] [call site] 01896
57 types::test_is_single_arg [function] [call site] 01897
57 types::test_is_single_arg [function] [call site] 01898
57 ignore [function] [call site] 01899
57 Cmd::query_async [function] [call site] 01900
57 redis::cmd [function] [call site] 01901
57 redis::Cmd::arg [function] [call site] 01902
57 types::test_is_single_arg [function] [call site] 01903
57 Cmd::query_async [function] [call site] 01904
57 assert_hit [function] [call site] 01905
57 assert_miss [function] [call site] 01906
57 redis::cmd [function] [call site] 01907
57 redis::Cmd::arg [function] [call site] 01908
57 types::test_is_single_arg [function] [call site] 01909
57 types::test_is_single_arg [function] [call site] 01910
57 Cmd::query_async [function] [call site] 01911
57 assert_hit [function] [call site] 01912
57 assert_miss [function] [call site] 01913
57 redis::cmd [function] [call site] 01914
57 redis::Cmd::arg [function] [call site] 01915
57 Cmd::query_async [function] [call site] 01916
57 assert_hit [function] [call site] 01917
57 assert_miss [function] [call site] 01918
57 Ok::<_, [call site] 01919
56 Err [function] [call site] 01920
56 into [function] [call site] 01921
56 check_resp3_auth [function] [call site] 01922
57 Err [function] [call site] 01923
57 get_resp3_hello_command_error [function] [call site] 01924
58 RedisError::detail [function] [call site] 01925
59 Option::as_ref [function] [call site] 01926
59 types::test_hashmap [function] [call site] 01927
59 Option::as_str [function] [call site] 01928
59 Some [function] [call site] 01929
59 ServerError::details [function] [call site] 01930
60 Option::as_ref [function] [call site] 01931
60 types::test_hashmap [function] [call site] 01932
60 as_str [function] [call site] 01933
60 Option::as_ref [function] [call site] 01934
60 types::test_hashmap [function] [call site] 01935
60 as_str [function] [call site] 01936
58 Option::starts_with [function] [call site] 01937
58 into [function] [call site] 01938
57 ClientTlsParams::clone [function] [call site] 01939
57 Self::into [function] [call site] 01940
57 Ok [function] [call site] 01941
56 RedisResult::get [function] [call site] 01942
56 Err [function] [call site] 01943
56 into [function] [call site] 01944
56 check_resp2_auth [function] [call site] 01945
57 Ok [function] [call site] 01946
57 Err [function] [call site] 01947
57 into [function] [call site] 01948
57 into [function] [call site] 01949
57 ServerError::details [function] [call site] 01950
57 Option::ok_or [function] [call site] 01951
57 contains [function] [call site] 01952
57 Err [function] [call site] 01953
57 into [function] [call site] 01954
57 Ok [function] [call site] 01955
56 Ok [function] [call site] 01956
56 RedisResult::get [function] [call site] 01957
56 Err [function] [call site] 01958
56 into [function] [call site] 01959
56 check_db_select [function] [call site] 01960
57 Ok [function] [call site] 01961
57 ServerError::details [function] [call site] 01962
57 Err [function] [call site] 01963
57 into [function] [call site] 01964
57 to_string [function] [call site] 01965
57 into [function] [call site] 01966
57 Err [function] [call site] 01967
57 into [function] [call site] 01968
57 into [function] [call site] 01969
56 RedisResult::get [function] [call site] 01970
56 Err [function] [call site] 01971
56 into [function] [call site] 01972
56 check_caching [function] [call site] 01973
57 Ok [function] [call site] 01974
57 Err [function] [call site] 01975
57 into [function] [call site] 01976
57 into [function] [call site] 01977
56 Ok [function] [call site] 01978
54 connection::connection_setup_pipeline [function] [call site] 01979
55 cmd::pipe [function] [call site] 01980
56 redis::pipe [function] [call site] 01981
56 Pipeline::atomic [function] [call site] 01982
56 redis::pipe [function] [call site] 01983
55 RedisResult::add_command [function] [call site] 01984
55 commands::resp3_hello [function] [call site] 01985
56 cmd::cmd [function] [call site] 01986
56 Cmd::arg [function] [call site] 01987
56 as_ref [function] [call site] 01988
56 Cmd::arg [function] [call site] 01989
56 types::test_is_single_arg [function] [call site] 01990
56 types::test_is_single_arg [function] [call site] 01991
56 &'static [call site] 01992
55 Some [function] [call site] 01993
55 is_some [function] [call site] 01994
55 RedisResult::add_command [function] [call site] 01995
55 authenticate_cmd [function] [call site] 01996
56 cmd::cmd [function] [call site] 01997
56 types::test_is_single_arg [function] [call site] 01998
56 &'static [call site] 01999
56 types::test_is_single_arg [function] [call site] 02000
55 as_ref [function] [call site] 02001
55 unwrap [function] [call site] 02002
55 Some [function] [call site] 02003
55 then [function] [call site] 02004
55 basic::test_pipeline_len [function] [call site] 02005
55 inspect [function] [call site] 02006
55 RedisResult::cmd [function] [call site] 02007
56 redis::cmd [function] [call site] 02008
56 Cmd::set_cache_config [function] [call site] 02009
56 CommandCacheConfig::new [function] [call site] 02010
56 CommandCacheConfig::set_enable_cache [function] [call site] 02011
55 redis::Cmd::arg [function] [call site] 02012
55 types::test_hashmap [function] [call site] 02013
56 parse_redis_value [function] [call site] 02014
56 Value::Array [function] [call site] 02015
56 RedisServer::new [function] [call site] 02016
56 PathBuf::insert [function] [call site] 02017
56 &str::into [function] [call site] 02018
56 PathBuf::insert [function] [call site] 02019
56 &str::into [function] [call site] 02020
56 PathBuf::insert [function] [call site] 02021
56 &str::into [function] [call site] 02022
56 parse_redis_value [function] [call site] 02023
56 Value::Array [function] [call site] 02024
56 RedisServer::default [function] [call site] 02025
56 HashMap::with_hasher [function] [call site] 02026
56 PathBuf::insert [function] [call site] 02027
56 &str::into [function] [call site] 02028
56 PathBuf::insert [function] [call site] 02029
56 &str::into [function] [call site] 02030
56 PathBuf::insert [function] [call site] 02031
56 &str::into [function] [call site] 02032
56 parse_redis_value [function] [call site] 02033
56 Value::Array [function] [call site] 02034
55 RedisResult::cmd [function] [call site] 02035
55 redis::Cmd::arg [function] [call site] 02036
55 types::test_is_single_arg [function] [call site] 02037
55 types::test_is_single_arg [function] [call site] 02038
55 basic::test_pipeline_len [function] [call site] 02039
55 RedisResult::cmd [function] [call site] 02040
55 redis::Cmd::arg [function] [call site] 02041
55 types::test_is_single_arg [function] [call site] 02042
55 types::test_is_single_arg [function] [call site] 02043
55 ignore [function] [call site] 02044
55 RedisResult::cmd [function] [call site] 02045
55 redis::Cmd::arg [function] [call site] 02046
55 types::test_is_single_arg [function] [call site] 02047
55 types::test_is_single_arg [function] [call site] 02048
55 ignore [function] [call site] 02049
54 execute_connection_pipeline [function] [call site] 02050
54 connection::connection_setup_pipeline [function] [call site] 02051
54 Ok [function] [call site] 02052
53 tokio::sync::mpsc::unbounded_channel [function] [call site] 02053
53 PubSubSink::new [function] [call site] 02054
54 tokio::sync::mpsc::unbounded_channel [function] [call site] 02055
54 PipelineSink::new [function] [call site] 02056
55 RedisServer::new [function] [call site] 02057
56 RedisServer::with_modules [function] [call site] 02058
54 stream::poll_fn [function] [call site] 02059
54 ( [call site] 02060
4 PendingRequest::poll_recv [function] [call site] 02061
54 types::test_hashmap [function] [call site] 02062
54 forward [function] [call site] 02063
54 types::test_hashmap [function] [call site] 02064
53 Runtime::locate [function] [call site] 02065
53 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 02066
54 tokio::runtime::Handle::try_current [function] [call site] 02067
54 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 02068
54 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 02069
54 TaskHandle::detach [function] [call site] 02070
53 Some [function] [call site] 02071
53 SharedHandleContainer::new [function] [call site] 02072
54 Self [function] [call site] 02073
54 RedisServer::new [function] [call site] 02074
54 HandleContainer::new [function] [call site] 02075
55 Self [function] [call site] 02076
55 Some [function] [call site] 02077
53 Ok [function] [call site] 02078
50 basic_async::automatic_unsubscription_on_split [function] [call site] 02079
51 TestContext::new [function] [call site] 02080
51 TestContext::async_pubsub [function] [call site] 02081
51 basic_async::automatic_unsubscription_on_split [function] [call site] 02082
51 basic::test_pubsub_unsubscribe [function] [call site] 02083
52 TestContext::new [function] [call site] 02084
52 TestContext::connection [function] [call site] 02085
52 std::sync::mpsc::channel [function] [call site] 02086
53 Ok [function] [call site] 02087
53 from_redis_value_ref [function] [call site] 02088
52 redis::Connection::set_push_sender [function] [call site] 02089
53 Some [function] [call site] 02090
52 redis::Connection::as_pubsub [function] [call site] 02091
53 PubSub::new [function] [call site] 02092
54 RedisServer::default [function] [call site] 02093
54 Self::framed [function] [call site] 02094
54 super::setup_connection [function] [call site] 02095
54 tokio::sync::mpsc::unbounded_channel [function] [call site] 02096
54 PubSubSink::new [function] [call site] 02097
54 Runtime::locate [function] [call site] 02098
54 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 02099
54 Some [function] [call site] 02100
54 SharedHandleContainer::new [function] [call site] 02101
54 Ok [function] [call site] 02102
52 basic::test_pubsub_unsubscribe [function] [call site] 02103
53 TestContext::new [function] [call site] 02104
53 TestContext::connection [function] [call site] 02105
53 std::sync::mpsc::channel [function] [call site] 02106
53 redis::Connection::set_push_sender [function] [call site] 02107
53 redis::Connection::as_pubsub [function] [call site] 02108
53 basic::test_pubsub_unsubscribe [function] [call site] 02109
53 unwrap [function] [call site] 02110
53 basic::test_pubsub_unsubscribe [function] [call site] 02111
53 unwrap [function] [call site] 02112
53 basic::test_pubsub_unsubscribe [function] [call site] 02113
53 unwrap [function] [call site] 02114
53 PubSub::psubscribe [function] [call site] 02115
54 PubSub::psubscribe [function] [call site] 02116
55 PubSub::psubscribe [function] [call site] 02117
53 RedisResult::unwrap [function] [call site] 02118
53 PubSub::psubscribe [function] [call site] 02119
53 RedisResult::unwrap [function] [call site] 02120
53 PubSub::psubscribe [function] [call site] 02121
53 RedisResult::unwrap [function] [call site] 02122
53 redis::Connection::set [function] [call site] 02123
54 parse_redis_value [function] [call site] 02124
54 Value::Array [function] [call site] 02125
54 RedisServer::new [function] [call site] 02126
55 RedisServer::with_modules [function] [call site] 02127
54 RedisServer::insert [function] [call site] 02128
54 &str::to_string [function] [call site] 02129
54 RedisServer::insert [function] [call site] 02130
54 &str::to_string [function] [call site] 02131
54 RedisServer::insert [function] [call site] 02132
54 &str::to_string [function] [call site] 02133
54 parse_redis_value [function] [call site] 02134
54 Value::Int [function] [call site] 02135
54 RedisServer::new [function] [call site] 02136
54 test_module_json_arr_insert [function] [call site] 02137
54 &str::to_string [function] [call site] 02138
54 test_module_json_arr_insert [function] [call site] 02139
54 &str::to_string [function] [call site] 02140
54 test_module_json_arr_insert [function] [call site] 02141
54 &str::to_string [function] [call site] 02142
54 types::test_std_types_to_redis_args [function] [call site] 02143
54 &'a [call site] 02144
54 std::iter::Chain::collect [function] [call site] 02145
53 unwrap [function] [call site] 02146
53 redis::Connection::get [function] [call site] 02147
54 TestContext::new [function] [call site] 02148
54 Ok [function] [call site] 02149
54 TestContext::async_connection_with_cache [function] [call site] 02150
54 get_pipe [function] [call site] 02151
54 redis::Pipeline::cmd [function] [call site] 02152
54 redis::Cmd::arg [function] [call site] 02153
54 types::test_is_single_arg [function] [call site] 02154
54 ignore [function] [call site] 02155
54 cmd [function] [call site] 02156
54 types::test_is_single_arg [function] [call site] 02157
54 types::test_is_single_arg [function] [call site] 02158
54 ignore [function] [call site] 02159
54 Cmd::query_async [function] [call site] 02160
54 redis::cmd [function] [call site] 02161
54 redis::Cmd::arg [function] [call site] 02162
54 types::test_is_single_arg [function] [call site] 02163
54 Cmd::query_async [function] [call site] 02164
54 assert_hit [function] [call site] 02165
54 assert_miss [function] [call site] 02166
54 redis::cmd [function] [call site] 02167
54 redis::Cmd::arg [function] [call site] 02168
54 types::test_is_single_arg [function] [call site] 02169
54 types::test_is_single_arg [function] [call site] 02170
54 Cmd::query_async [function] [call site] 02171
54 assert_hit [function] [call site] 02172
54 assert_miss [function] [call site] 02173
54 redis::cmd [function] [call site] 02174
54 redis::Cmd::arg [function] [call site] 02175
54 Cmd::query_async [function] [call site] 02176
54 assert_hit [function] [call site] 02177
54 assert_miss [function] [call site] 02178
54 Ok::<_, [call site] 02179
53 RedisResult::unwrap [function] [call site] 02180
53 unwrap [function] [call site] 02181
53 try_recv [function] [call site] 02182
53 unwrap [function] [call site] 02183
53 RedisResult::from_redis_value_ref [function] [call site] 02184
54 Ok [function] [call site] 02185
54 Err [function] [call site] 02186
54 ClientTlsParams::clone [function] [call site] 02187
54 Self::into [function] [call site] 02188
54 from_redis_value_ref [function] [call site] 02189
54 types::test_hashmap [function] [call site] 02190
54 Ok [function] [call site] 02191
53 first [function] [call site] 02192
53 unwrap [function] [call site] 02193
53 Result::unwrap [function] [call site] 02194
53 tests::decode_resp3_push [function] [call site] 02195
52 unwrap [function] [call site] 02196
52 basic::test_pubsub_unsubscribe [function] [call site] 02197
52 unwrap [function] [call site] 02198
52 basic::test_pubsub_unsubscribe [function] [call site] 02199
52 unwrap [function] [call site] 02200
52 PubSub::psubscribe [function] [call site] 02201
52 RedisResult::unwrap [function] [call site] 02202
52 PubSub::psubscribe [function] [call site] 02203
52 RedisResult::unwrap [function] [call site] 02204
52 PubSub::psubscribe [function] [call site] 02205
52 RedisResult::unwrap [function] [call site] 02206
52 redis::Connection::set [function] [call site] 02207
52 unwrap [function] [call site] 02208
52 redis::Connection::get [function] [call site] 02209
52 RedisResult::unwrap [function] [call site] 02210
52 unwrap [function] [call site] 02211
52 try_recv [function] [call site] 02212
52 unwrap [function] [call site] 02213
52 RedisResult::from_redis_value_ref [function] [call site] 02214
52 first [function] [call site] 02215
52 unwrap [function] [call site] 02216
52 Result::unwrap [function] [call site] 02217
52 tests::decode_resp3_push [function] [call site] 02218
51 TestContext::async_connection [function] [call site] 02219
52 Client::get_multiplexed_async_connection [function] [call site] 02220
53 Client::get_multiplexed_async_connection_with_config [function] [call site] 02221
54 Runtime::locate [function] [call site] 02222
54 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::tokio::Tokio> [function] [call site] 02223
54 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::smol::Smol> [function] [call site] 02224
53 AsyncConnectionConfig::new [function] [call site] 02225
51 Runtime::sleep [function] [call site] 02226
52 tokio::time::sleep [function] [call site] 02227
52 smol::Timer::after [function] [call site] 02228
51 Duration::from_millis [function] [call site] 02229
51 into [function] [call site] 02230
51 redis::cmd [function] [call site] 02231
51 redis::Cmd::arg [function] [call site] 02232
51 types::test_is_single_arg [function] [call site] 02233
51 Cmd::query_async [function] [call site] 02234
51 cache_mget [function] [call site] 02235
51 unwrap [function] [call site] 02236
51 RedisServer::drop [function] [call site] 02237
51 redis::cmd [function] [call site] 02238
51 redis::Cmd::arg [function] [call site] 02239
51 types::test_is_single_arg [function] [call site] 02240
51 Cmd::query_async [function] [call site] 02241
51 cache_mget [function] [call site] 02242
51 unwrap [function] [call site] 02243
51 Runtime::sleep [function] [call site] 02244
51 Duration::from_millis [function] [call site] 02245
51 into [function] [call site] 02246
51 basic::test_pubsub_unsubscribe [function] [call site] 02247
51 unwrap_err [function] [call site] 02248
51 Ok::<_, [call site] 02249
50 basic::test_pubsub_unsubscribe [function] [call site] 02250
50 TestContext::async_connection [function] [call site] 02251
50 Runtime::sleep [function] [call site] 02252
50 Duration::from_millis [function] [call site] 02253
50 into [function] [call site] 02254
50 redis::cmd [function] [call site] 02255
50 redis::Cmd::arg [function] [call site] 02256
50 types::test_is_single_arg [function] [call site] 02257
50 Cmd::query_async [function] [call site] 02258
50 cache_mget [function] [call site] 02259
50 unwrap [function] [call site] 02260
50 RedisServer::drop [function] [call site] 02261
50 redis::cmd [function] [call site] 02262
50 redis::Cmd::arg [function] [call site] 02263
50 types::test_is_single_arg [function] [call site] 02264
50 Cmd::query_async [function] [call site] 02265
50 cache_mget [function] [call site] 02266
50 unwrap [function] [call site] 02267
50 Runtime::sleep [function] [call site] 02268
50 Duration::from_millis [function] [call site] 02269
50 into [function] [call site] 02270
50 basic::test_pubsub_unsubscribe [function] [call site] 02271
50 unwrap_err [function] [call site] 02272
50 Ok::<_, [call site] 02273
49 RedisResult::filter [function] [call site] 02274
49 RedisResult::trim_start [function] [call site] 02275
49 starts_with [function] [call site] 02276
49 filter_map [function] [call site] 02277
49 RedisResult::split_once [function] [call site] 02278
49 types::test_hashmap [function] [call site] 02279
49 to_string [function] [call site] 02280
49 to_string [function] [call site] 02281
49 collect [function] [call site] 02282
48 HashMap::get [function] [call site] 02283
49 TestContext::new [function] [call site] 02284
49 Ok [function] [call site] 02285
49 TestContext::async_connection_with_cache [function] [call site] 02286
49 get_pipe [function] [call site] 02287
49 redis::Pipeline::cmd [function] [call site] 02288
49 redis::Cmd::arg [function] [call site] 02289
49 types::test_is_single_arg [function] [call site] 02290
49 ignore [function] [call site] 02291
49 cmd [function] [call site] 02292
49 types::test_is_single_arg [function] [call site] 02293
49 types::test_is_single_arg [function] [call site] 02294
49 ignore [function] [call site] 02295
49 Cmd::query_async [function] [call site] 02296
49 redis::cmd [function] [call site] 02297
49 redis::Cmd::arg [function] [call site] 02298
49 types::test_is_single_arg [function] [call site] 02299
49 Cmd::query_async [function] [call site] 02300
49 assert_hit [function] [call site] 02301
49 assert_miss [function] [call site] 02302
49 redis::cmd [function] [call site] 02303
49 redis::Cmd::arg [function] [call site] 02304
49 types::test_is_single_arg [function] [call site] 02305
49 types::test_is_single_arg [function] [call site] 02306
49 Cmd::query_async [function] [call site] 02307
49 assert_hit [function] [call site] 02308
49 assert_miss [function] [call site] 02309
49 redis::cmd [function] [call site] 02310
49 redis::Cmd::arg [function] [call site] 02311
49 Cmd::query_async [function] [call site] 02312
49 assert_hit [function] [call site] 02313
49 assert_miss [function] [call site] 02314
49 Ok::<_, [call site] 02315
48 Ok [function] [call site] 02316
48 ClientTlsParams::clone [function] [call site] 02317
48 Err [function] [call site] 02318
48 RedisError::from [function] [call site] 02319
47 Ok [function] [call site] 02320
47 evaluate_role_check_errors [function] [call site] 02321
48 RedisError::kind [function] [call site] 02322
48 into [function] [call site] 02323
48 Err [function] [call site] 02324
48 Err [function] [call site] 02325
47 RedisResult::unwrap_err [function] [call site] 02326
47 RedisResult::unwrap_err [function] [call site] 02327
46 Ok [function] [call site] 02328
44 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02329
44 Client::open [function] [call site] 02330
43 Some [function] [call site] 02331
43 ConnectionAddr::is_err [function] [call site] 02332
43 redis_test::sentinel::wait_for_replica [function] [call site] 02333
44 redis::cmd [function] [call site] 02334
44 Client::get_connection [function] [call site] 02335
44 redis::Cmd::query [function] [call site] 02336
44 RedisResult::unwrap [function] [call site] 02337
44 String::from_redis_value_ref [function] [call site] 02338
44 ConnectionAddr::first [function] [call site] 02339
44 unwrap [function] [call site] 02340
44 Result::unwrap [function] [call site] 02341
44 String::from_redis_value_ref [function] [call site] 02342
44 ConnectionAddr::get [function] [call site] 02343
44 RedisResult::unwrap [function] [call site] 02344
44 Result::unwrap [function] [call site] 02345
44 starts_with [function] [call site] 02346
44 Ok [function] [call site] 02347
44 std::thread::sleep [function] [call site] 02348
44 Duration::from_millis [function] [call site] 02349
44 Err [function] [call site] 02350
43 &mut [call site] 02351
44 Sentinel::find_valid_replica_addresses [function] [call site] 02352
45 Sentinel::get_sentinel_replicas [function] [call site] 02353
46 Sentinel::try_all_sentinels [function] [call site] 02354
46 sentinel_replicas_cmd [function] [call site] 02355
47 crate::cmd [function] [call site] 02356
47 Cmd::arg [function] [call site] 02357
47 Cmd::arg [function] [call site] 02358
45 get_valid_replicas_addresses [function] [call site] 02359
46 valid_addrs [function] [call site] 02360
46 types::test_hashmap [function] [call site] 02361
46 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02362
46 map(|(ip, [call site] 02363
4 .collect::<RedisResult<Vec<ConnectionInfo>>> [function] [call site] 02364
46 Ok [function] [call site] 02365
46 &'a [call site] 02366
46 std::iter::Chain::filter [function] [call site] 02367
46 get_node_role [function] [call site] 02368
47 Client::open [function] [call site] 02369
47 redis::ConnectionInfo::clone [function] [call site] 02370
47 Client::get_connection [function] [call site] 02371
47 crate::cmd [function] [call site] 02372
47 redis::Cmd::query [function] [call site] 02373
46 RedisResult::is_ok_and [function] [call site] 02374
46 collect [function] [call site] 02375
44 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02376
44 RedisServer::new [function] [call site] 02377
44 basic::test_pipeline_len [function] [call site] 02378
44 types::test_hashmap [function] [call site] 02379
45 parse_redis_value [function] [call site] 02380
45 Value::Array [function] [call site] 02381
45 RedisServer::new [function] [call site] 02382
45 PathBuf::insert [function] [call site] 02383
45 &str::into [function] [call site] 02384
45 PathBuf::insert [function] [call site] 02385
45 &str::into [function] [call site] 02386
45 PathBuf::insert [function] [call site] 02387
45 &str::into [function] [call site] 02388
45 parse_redis_value [function] [call site] 02389
45 Value::Array [function] [call site] 02390
45 RedisServer::default [function] [call site] 02391
45 HashMap::with_hasher [function] [call site] 02392
45 PathBuf::insert [function] [call site] 02393
45 &str::into [function] [call site] 02394
45 PathBuf::insert [function] [call site] 02395
45 &str::into [function] [call site] 02396
45 PathBuf::insert [function] [call site] 02397
45 &str::into [function] [call site] 02398
45 parse_redis_value [function] [call site] 02399
45 Value::Array [function] [call site] 02400
44 try_connect_to_first_replica [function] [call site] 02401
45 basic::test_pipeline_is_empty [function] [call site] 02402
46 redis::pipe [function] [call site] 02403
46 cmd [function] [call site] 02404
46 cmd [function] [call site] 02405
46 types::test_is_single_arg [function] [call site] 02406
45 fail [function] [call site] 02407
45 Option<usize>::unwrap_or [function] [call site] 02408
45 basic::test_pipeline_len [function] [call site] 02409
45 basic::test_pipeline_len [function] [call site] 02410
45 Client::open [function] [call site] 02411
45 ClientTlsParams::clone [function] [call site] 02412
45 Ok [function] [call site] 02413
45 Some [function] [call site] 02414
45 Err [function] [call site] 02415
45 None::expect [function] [call site] 02416
43 Some [function] [call site] 02417
43 ConnectionAddr::is_err [function] [call site] 02418
40 SentinelClient::build [function] [call site] 02419
41 Sentinel::build_inner [function] [call site] 02420
40 TestSentinelContext::sentinels_connection_info [function] [call site] 02421
40 ClientTlsParams::clone [function] [call site] 02422
41 ClientTlsParams::clone [function] [call site] 02423
41 Pkcs1 [function] [call site] 02424
41 secret_pkcs1_der [function] [call site] 02425
41 write_command_to_vec [function] [call site] 02426
41 into [function] [call site] 02427
41 Pkcs8 [function] [call site] 02428
41 secret_pkcs8_der [function] [call site] 02429
41 write_command_to_vec [function] [call site] 02430
41 into [function] [call site] 02431
41 Sec1 [function] [call site] 02432
41 secret_sec1_der [function] [call site] 02433
41 write_command_to_vec [function] [call site] 02434
41 into [function] [call site] 02435
40 String::from [function] [call site] 02436
40 Some [function] [call site] 02437
40 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02438
40 RedisResult::unwrap [function] [call site] 02439
40 SentinelClient::build [function] [call site] 02440
40 TestSentinelContext::sentinels_connection_info [function] [call site] 02441
40 ClientTlsParams::clone [function] [call site] 02442
40 String::from [function] [call site] 02443
40 Some [function] [call site] 02444
40 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02445
40 RedisResult::unwrap [function] [call site] 02446
40 AsyncConnectionConfig::new [function] [call site] 02447
40 AsyncConnectionConfig::set_connection_timeout [function] [call site] 02448
40 Some [function] [call site] 02449
40 Duration::from_secs [function] [call site] 02450
40 SentinelClient::get_async_connection_with_config [function] [call site] 02451
41 SentinelClient::async_get_client [function] [call site] 02452
42 Sentinel::async_master_for [function] [call site] 02453
43 Sentinel::async_find_master_address [function] [call site] 02454
44 Sentinel::async_get_sentinel_masters [function] [call site] 02455
45 Sentinel::async_try_all_sentinels [function] [call site] 02456
46 basic::test_tuple_decoding_from_iter [function] [call site] 02457
46 zip [function] [call site] 02458
46 iter_mut [function] [call site] 02459
46 async_try_single_sentinel [function] [call site] 02460
47 &mut [call site] 02461
47 async_reconnect [function] [call site] 02462
48 Client::open [function] [call site] 02463
48 redis::ConnectionInfo::clone [function] [call site] 02464
48 Client::get_multiplexed_async_connection [function] [call site] 02465
48 CopyOptions::replace [function] [call site] 02466
48 Ok [function] [call site] 02467
47 Cmd::query_async [function] [call site] 02468
48 &mut [call site] 02469
48 Ok [function] [call site] 02470
48 RedisResult::from_redis_value [function] [call site] 02471
48 Value::extract_error [function] [call site] 02472
47 &mut [call site] 02473
47 unwrap [function] [call site] 02474
47 RedisError::is_unrecoverable_error [function] [call site] 02475
47 types::test_is_io_error [function] [call site] 02476
47 async_reconnect [function] [call site] 02477
47 Cmd::query_async [function] [call site] 02478
47 &mut [call site] 02479
47 unwrap [function] [call site] 02480
47 Err [function] [call site] 02481
46 ClientTlsParams::clone [function] [call site] 02482
46 Ok [function] [call site] 02483
46 Some [function] [call site] 02484
46 Err [function] [call site] 02485
46 None::expect [function] [call site] 02486
45 sentinel_masters_cmd [function] [call site] 02487
44 async_find_valid_master [function] [call site] 02488
45 valid_addrs [function] [call site] 02489
45 is_master_valid [function] [call site] 02490
45 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02491
45 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02492
45 async_determine_master_from_role_or_info_replication [function] [call site] 02493
46 Client::open [function] [call site] 02494
46 redis::ConnectionInfo::clone [function] [call site] 02495
46 Client::get_multiplexed_async_connection [function] [call site] 02496
46 async_check_role [function] [call site] 02497
47 crate::cmd [function] [call site] 02498
47 redis::Cmd::query_async [function] [call site] 02499
48 &mut [call site] 02500
48 Ok [function] [call site] 02501
48 RedisResult::from_redis_value [function] [call site] 02502
48 Value::extract_error [function] [call site] 02503
46 Ok [function] [call site] 02504
46 async_check_info_replication [function] [call site] 02505
47 crate::cmd [function] [call site] 02506
47 redis::Cmd::arg [function] [call site] 02507
47 Cmd::query_async [function] [call site] 02508
47 parse_replication_info [function] [call site] 02509
47 HashMap::get [function] [call site] 02510
47 Ok [function] [call site] 02511
47 ClientTlsParams::clone [function] [call site] 02512
47 Err [function] [call site] 02513
47 RedisError::from [function] [call site] 02514
46 Ok [function] [call site] 02515
46 evaluate_role_check_errors [function] [call site] 02516
46 unwrap_err [function] [call site] 02517
46 unwrap_err [function] [call site] 02518
45 Ok [function] [call site] 02519
43 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02520
43 Client::open [function] [call site] 02521
42 as_str [function] [call site] 02522
42 Some [function] [call site] 02523
42 Sentinel::async_replica_for [function] [call site] 02524
43 Sentinel::async_find_valid_replica_addresses [function] [call site] 02525
44 Sentinel::async_get_sentinel_replicas [function] [call site] 02526
45 Sentinel::async_try_all_sentinels [function] [call site] 02527
45 sentinel_replicas_cmd [function] [call site] 02528
44 async_get_valid_replicas_addresses [function] [call site] 02529
45 valid_addrs [function] [call site] 02530
45 types::test_hashmap [function] [call site] 02531
45 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02532
45 map(|(ip, [call site] 02533
4 .collect::<RedisResult<Vec<_>>> [function] [call site] 02534
45 Ok [function] [call site] 02535
45 futures_util::stream::iter [function] [call site] 02536
46 TestContext::new [function] [call site] 02537
46 TestContext::connection [function] [call site] 02538
46 ValueType::from [function] [call site] 02539
46 basic::test_tuple_decoding_from_iter [function] [call site] 02540
46 hscan::<_, [call site] 02541
46 unwrap [function] [call site] 02542
46 unwrap [function] [call site] 02543
45 filter_map [function] [call site] 02544
45 collect [function] [call site] 02545
43 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02546
43 RedisServer::new [function] [call site] 02547
43 basic::test_pipeline_len [function] [call site] 02548
43 types::test_hashmap [function] [call site] 02549
43 try_connect_to_first_replica [function] [call site] 02550
42 as_str [function] [call site] 02551
42 Some [function] [call site] 02552
41 Client::get_multiplexed_async_connection_with_config [function] [call site] 02553
40 async_tests::async_assert_is_connection_to_master [function] [call site] 02554
41 redis::cmd [function] [call site] 02555
41 redis::Cmd::arg [function] [call site] 02556
41 Cmd::query_async [function] [call site] 02557
41 unwrap [function] [call site] 02558
41 assert_is_master_role [function] [call site] 02559
42 parse_replication_info [function] [call site] 02560
40 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02561
40 TestSentinelContext::sentinel_mut [function] [call site] 02562
40 &redis::sentinel::Sentinel::async_master_for [function] [call site] 02563
41 Sentinel::async_find_master_address [function] [call site] 02564
41 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02565
41 Client::open [function] [call site] 02566
40 Some [function] [call site] 02567
40 SentinelClient::get_async_connection_with_config [function] [call site] 02568
40 async_tests::async_assert_connection_is_replica_of_correct_master [function] [call site] 02569
41 redis::cmd [function] [call site] 02570
41 redis::Cmd::arg [function] [call site] 02571
41 Cmd::query_async [function] [call site] 02572
41 unwrap [function] [call site] 02573
41 assert_replica_role_and_master_addr [function] [call site] 02574
42 parse_replication_info [function] [call site] 02575
42 RedisServer::get_addr [function] [call site] 02576
43 ServerType::get_intended [function] [call site] 02577
43 &str::to_string [function] [call site] 02578
43 redis::ConnectionAddr::Tcp [function] [call site] 02579
43 &str::to_string [function] [call site] 02580
43 rand::random::<(u64, [call site] 02581
43 redis::ConnectionAddr::Unix [function] [call site] 02582
43 ValueType::from [function] [call site] 02583
44 TlsFilePaths::as_ref [function] [call site] 02584
44 ValueType::Unknown [function] [call site] 02585
44 TlsFilePaths::to_string [function] [call site] 02586
41 Client::get_connection_info [function] [call site] 02587
40 Ok::<(), [call site] 02588
38 RoutingInfo::SingleNode [function] [call site] 02589
38 MockRedisConnection::req_packed_command [function] [call site] 02590
39 Cmd::get_packed_command [function] [call site] 02591
39 MockRedisConnection::req_packed_command [function] [call site] 02592
39 as_slice [function] [call site] 02593
39 PipelineSink::poll_ready [function] [call site] 02594
39 types::test_parse_boxed [function] [call site] 02595
38 Cmd::get_packed_command [function] [call site] 02596
38 RedisCluster::new [function] [call site] 02597
38 RedisServer::default [function] [call site] 02598
38 ClusterConnection::route_command [function] [call site] 02599
38 RoutingInfo::SingleNode [function] [call site] 02600
38 RedisResult::unwrap [function] [call site] 02601
37 Some [function] [call site] 02602
37 cmd::cmd [function] [call site] 02603
37 Cmd::exec [function] [call site] 02604
38 query::<()> [function] [call site] 02605
37 MockConnection::set_read_timeout [function] [call site] 02606
38 Ok [function] [call site] 02607
37 borrow [function] [call site] 02608
37 MockConnection::set_write_timeout [function] [call site] 02609
38 Ok [function] [call site] 02610
37 borrow [function] [call site] 02611
37 Ok [function] [call site] 02612
36 MockRedisConnection::check_connection [function] [call site] 02613
36 RedisResult::insert [function] [call site] 02614
37 TestContext::with_modules [function] [call site] 02615
37 TestContext::connection [function] [call site] 02616
37 redis::Connection::json_set [function] [call site] 02617
37 redis::Connection::json_arr_insert [function] [call site] 02618
37 redis::Connection::json_set [function] [call site] 02619
37 redis::Connection::json_arr_insert [function] [call site] 02620
36 tests::decode_resp3_push [function] [call site] 02621
37 parse_redis_value [function] [call site] 02622
37 RedisResult::unwrap [function] [call site] 02623
36 RedisError::from [function] [call site] 02624
36 tests::decode_resp3_push [function] [call site] 02625
36 basic::test_pipeline_is_empty [function] [call site] 02626
36 basic::test_pipeline_is_empty [function] [call site] 02627
37 redis::pipe [function] [call site] 02628
37 cmd [function] [call site] 02629
37 cmd [function] [call site] 02630
37 types::test_is_single_arg [function] [call site] 02631
36 &str::to_string [function] [call site] 02632
36 &str::to_string [function] [call site] 02633
36 &'a [call site] 02634
36 std::iter::Chain::enumerate [function] [call site] 02635
36 Err [function] [call site] 02636
36 RedisError::from [function] [call site] 02637
36 borrow_mut [function] [call site] 02638
36 ClusterConnection::refresh_slots [function] [call site] 02639
37 borrow_mut [function] [call site] 02640
37 ClusterConnection::create_new_slots [function] [call site] 02641
38 borrow_mut [function] [call site] 02642
38 RedisResult::iter_mut [function] [call site] 02643
38 ConnectionLike::req_command [function] [call site] 02644
39 Cmd::get_packed_command [function] [call site] 02645
39 MockRedisConnection::req_packed_command [function] [call site] 02646
38 cluster_handling::slot_cmd [function] [call site] 02647
39 Cmd::new [function] [call site] 02648
39 Cmd::arg [function] [call site] 02649
39 types::test_is_single_arg [function] [call site] 02650
38 super::topology::parse_slots [function] [call site] 02651
39 Cmd::with_capacity [function] [call site] 02652
39 &'a [call site] 02653
39 MapIter::next [function] [call site] 02654
39 basic::test_pipeline_len [function] [call site] 02655
40 redis::pipe [function] [call site] 02656
40 cmd [function] [call site] 02657
40 cmd [function] [call site] 02658
40 types::test_is_single_arg [function] [call site] 02659
39 basic::test_pipeline_len [function] [call site] 02660
39 String::from_utf8_lossy [function] [call site] 02661
39 basic::test_pipeline_is_empty [function] [call site] 02662
40 redis::pipe [function] [call site] 02663
40 cmd [function] [call site] 02664
40 cmd [function] [call site] 02665
40 types::test_is_single_arg [function] [call site] 02666
39 is_wildcard_address [function] [call site] 02667
39 &str::into [function] [call site] 02668
39 &str::into [function] [call site] 02669
39 basic::test_pipeline_is_empty [function] [call site] 02670
39 Some [function] [call site] 02671
39 into [function] [call site] 02672
39 &'a [call site] 02673
40 std::iter::once [function] [call site] 02674
40 chain [function] [call site] 02675
40 basic::test_tuple_decoding_from_iter [function] [call site] 02676
39 std::iter::Chain::skip [function] [call site] 02677
39 is_none [function] [call site] 02678
39 MapIter::next [function] [call site] 02679
39 try_to_address [function] [call site] 02680
39 filter_map [function] [call site] 02681
39 collect [function] [call site] 02682
39 tests::decode_resp3_push [function] [call site] 02683
39 Slot::new [function] [call site] 02684
39 Ok [function] [call site] 02685
38 ConnectionAddr::rsplit_once [function] [call site] 02686
38 unwrap [function] [call site] 02687
38 Some [function] [call site] 02688
38 SlotMap::from_slots [function] [call site] 02689
39 &'a [call site] 02690
39 std::iter::Chain::map [function] [call site] 02691
39 SlotMapValue::from_slot [function] [call site] 02692
40 SlotAddrs::from_slot [function] [call site] 02693
41 SlotAddrs::new [function] [call site] 02694
39 collect [function] [call site] 02695
38 Ok [function] [call site] 02696
38 Err [function] [call site] 02697
38 RedisError::from [function] [call site] 02698
37 MockCmd::with_values [function] [call site] 02699
38 Cmd::into_redis_cmd_bytes [function] [call site] 02700
39 Cmd::get_packed_command [function] [call site] 02701
38 types::test_hashmap [function] [call site] 02702
39 parse_redis_value [function] [call site] 02703
39 Value::Array [function] [call site] 02704
39 RedisServer::new [function] [call site] 02705
39 PathBuf::insert [function] [call site] 02706
39 &str::into [function] [call site] 02707
39 PathBuf::insert [function] [call site] 02708
39 &str::into [function] [call site] 02709
39 PathBuf::insert [function] [call site] 02710
39 &str::into [function] [call site] 02711
39 parse_redis_value [function] [call site] 02712
39 Value::Array [function] [call site] 02713
39 RedisServer::default [function] [call site] 02714
39 HashMap::with_hasher [function] [call site] 02715
39 PathBuf::insert [function] [call site] 02716
39 &str::into [function] [call site] 02717
39 PathBuf::insert [function] [call site] 02718
39 &str::into [function] [call site] 02719
39 PathBuf::insert [function] [call site] 02720
39 &str::into [function] [call site] 02721
39 parse_redis_value [function] [call site] 02722
39 Value::Array [function] [call site] 02723
38 &'a [call site] 02724
38 types::test_hashmap [function] [call site] 02725
38 String::into_redis_value [function] [call site] 02726
39 Value::BulkString [function] [call site] 02727
39 String::as_bytes [function] [call site] 02728
39 write_command_to_vec [function] [call site] 02729
38 collect [function] [call site] 02730
37 Self::flatten [function] [call site] 02731
37 values().flatten().collect::<Vec<_>> [function] [call site] 02732
37 RedisResult::sort_unstable [function] [call site] 02733
37 RedisResult::dedup [function] [call site] 02734
37 borrow_mut [function] [call site] 02735
37 &'a [call site] 02736
37 std::iter::Chain::filter_map [function] [call site] 02737
37 RedisResult::remove [function] [call site] 02738
37 MockRedisConnection::check_connection [function] [call site] 02739
37 Some [function] [call site] 02740
37 ClientTlsParams::clone [function] [call site] 02741
38 ClientTlsParams::clone [function] [call site] 02742
38 Pkcs1 [function] [call site] 02743
38 secret_pkcs1_der [function] [call site] 02744
38 write_command_to_vec [function] [call site] 02745
38 into [function] [call site] 02746
38 Pkcs8 [function] [call site] 02747
38 secret_pkcs8_der [function] [call site] 02748
38 write_command_to_vec [function] [call site] 02749
38 into [function] [call site] 02750
38 Sec1 [function] [call site] 02751
38 secret_sec1_der [function] [call site] 02752
38 write_command_to_vec [function] [call site] 02753
38 into [function] [call site] 02754
37 ClusterConnection::connect [function] [call site] 02755
37 MockRedisConnection::check_connection [function] [call site] 02756
37 Some [function] [call site] 02757
37 ClientTlsParams::clone [function] [call site] 02758
37 collect [function] [call site] 02759
37 Ok [function] [call site] 02760
36 Ok [function] [call site] 02761
35 is_some [function] [call site] 02762
35 Some [function] [call site] 02763
35 RedisServer::new [function] [call site] 02764
36 RedisServer::with_modules [function] [call site] 02765
35 RedisServer::default [function] [call site] 02766
36 RedisServer::new [function] [call site] 02767
35 RedisServer::new [function] [call site] 02768
35 RedisServer::new [function] [call site] 02769
36 RedisServer::with_modules [function] [call site] 02770
35 SlotMap::new [function] [call site] 02771
36 RedisServer::default [function] [call site] 02772
35 RedisServer::new [function] [call site] 02773
35 RedisServer::new [function] [call site] 02774
35 write_command_to_vec [function] [call site] 02775
35 RedisServer::default [function] [call site] 02776
35 ClusterConnection::refresh_slots [function] [call site] 02777
36 borrow_mut [function] [call site] 02778
36 ClusterConnection::create_new_slots [function] [call site] 02779
36 MockCmd::with_values [function] [call site] 02780
36 Self::flatten [function] [call site] 02781
36 values().flatten().collect::<Vec<_>> [function] [call site] 02782
36 RedisResult::sort_unstable [function] [call site] 02783
36 RedisResult::dedup [function] [call site] 02784
36 borrow_mut [function] [call site] 02785
36 &'a [call site] 02786
36 std::iter::Chain::filter_map [function] [call site] 02787
36 RedisResult::remove [function] [call site] 02788
36 MockRedisConnection::check_connection [function] [call site] 02789
36 Some [function] [call site] 02790
36 ClientTlsParams::clone [function] [call site] 02791
36 ClusterConnection::connect [function] [call site] 02792
36 MockRedisConnection::check_connection [function] [call site] 02793
36 Some [function] [call site] 02794
36 ClientTlsParams::clone [function] [call site] 02795
36 collect [function] [call site] 02796
36 Ok [function] [call site] 02797
35 ClientTlsParams::clone [function] [call site] 02798
35 Ok [function] [call site] 02799
34 types::test_hashmap [function] [call site] 02800
34 mpsc::channel::<Message<_>> [function] [call site] 02801
34 stream::poll_fn [function] [call site] 02802
34 ( [call site] 02803
4 PendingRequest::poll_recv [function] [call site] 02804
34 types::test_hashmap [function] [call site] 02805
34 forward [function] [call site] 02806
34 HandleContainer::new [function] [call site] 02807
34 tokio::runtime::Runtime::spawn [function] [call site] 02808
35 crate_tokio::Tokio::spawn [function] [call site] 02809
36 TaskHandle::Tokio [function] [call site] 02810
36 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 02811
37 tokio::runtime::Handle::try_current [function] [call site] 02812
37 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 02813
37 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 02814
37 TaskHandle::detach [function] [call site] 02815
35 crate_smol::Smol::spawn [function] [call site] 02816
36 TaskHandle::Smol [function] [call site] 02817
36 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 02818
34 RedisServer::new [function] [call site] 02819
33 ClientTlsParams::clone [function] [call site] 02820
33 ClientTlsParams::clone [function] [call site] 02821
32 RedisResult::unwrap [function] [call site] 02822
32 tokio::runtime::Runtime::block_on [function] [call site] 02823
32 ClusterClient::get_async_generic_connection [function] [call site] 02824
33 cluster_async::ClusterConnection::new [function] [call site] 02825
34 unwrap_or_default [function] [call site] 02826
34 ClientTlsParams::clone [function] [call site] 02827
34 Runtime::locate [function] [call site] 02828
34 ClusterConnInner::new [function] [call site] 02829
34 types::test_hashmap [function] [call site] 02830
34 mpsc::channel::<Message<_>> [function] [call site] 02831
34 stream::poll_fn [function] [call site] 02832
34 ( [call site] 02833
4 PendingRequest::poll_recv [function] [call site] 02834
34 types::test_hashmap [function] [call site] 02835
34 forward [function] [call site] 02836
34 HandleContainer::new [function] [call site] 02837
34 tokio::runtime::Runtime::spawn [function] [call site] 02838
34 RedisServer::new [function] [call site] 02839
33 ClientTlsParams::clone [function] [call site] 02840
32 unwrap [function] [call site] 02841
32 RemoveHandler [function] [call site] 02842
31 ClusterClient::builder [function] [call site] 02843
32 ClusterClientBuilder::new [function] [call site] 02844
33 &'a [call site] 02845
33 std::iter::Chain::map [function] [call site] 02846
33 ConnectionInfo::into_connection_info [function] [call site] 02847
33 collect [function] [call site] 02848
33 RedisServer::default [function] [call site] 02849
31 ClusterClientBuilder::retries [function] [call site] 02850
31 respond_startup [function] [call site] 02851
32 contains_slice [function] [call site] 02852
33 basic::test_pipeline_len [function] [call site] 02853
34 redis::pipe [function] [call site] 02854
34 cmd [function] [call site] 02855
34 cmd [function] [call site] 02856
34 types::test_is_single_arg [function] [call site] 02857
33 starts_with [function] [call site] 02858
32 Err [function] [call site] 02859
32 Ok [function] [call site] 02860
32 Value::SimpleString [function] [call site] 02861
32 &str::into [function] [call site] 02862
32 contains_slice [function] [call site] 02863
32 contains_slice [function] [call site] 02864
32 Err [function] [call site] 02865
32 Ok [function] [call site] 02866
32 Value::Array [function] [call site] 02867
32 contains_slice [function] [call site] 02868
32 Err [function] [call site] 02869
32 Ok [function] [call site] 02870
32 Value::SimpleString [function] [call site] 02871
32 &str::into [function] [call site] 02872
32 Ok [function] [call site] 02873
31 fetch_add [function] [call site] 02874
31 Err [function] [call site] 02875
31 parse_redis_value [function] [call site] 02876
31 Err [function] [call site] 02877
31 Ok [function] [call site] 02878
31 Value::BulkString [function] [call site] 02879
31 &str::to_vec [function] [call site] 02880
32 args_len [function] [call site] 02881
32 ClientTlsParams::clone [function] [call site] 02882
32 Cmd::reserve [function] [call site] 02883
32 write_command [function] [call site] 02884
32 io::Result::unwrap [function] [call site] 02885
31 cmd [function] [call site] 02886
31 Cmd::arg [function] [call site] 02887
31 arg("test").query::<Option<i32>> [function] [call site] 02888
30 TestClusterContext::get_ports [function] [call site] 02889
30 MockRedisConnection::check_connection [function] [call site] 02890
30 RedisServer::drop [function] [call site] 02891
30 cmd [function] [call site] 02892
30 ClusterConnection::route_command [function] [call site] 02893
30 RoutingInfo::SingleNode [function] [call site] 02894
30 MockRedisConnection::req_packed_command [function] [call site] 02895
30 Cmd::get_packed_command [function] [call site] 02896
30 RedisCluster::new [function] [call site] 02897
30 RedisServer::default [function] [call site] 02898
30 ClusterConnection::route_command [function] [call site] 02899
30 RoutingInfo::SingleNode [function] [call site] 02900
30 RedisResult::unwrap [function] [call site] 02901
29 into [function] [call site] 02902
29 Arc::into_inner [function] [call site] 02903
29 unwrap [function] [call site] 02904
29 into_inner [function] [call site] 02905
29 crate::io::tcp::stream_with_settings [function] [call site] 02906
30 TcpSettings::set_nodelay [function] [call site] 02907
30 TcpStream::into [function] [call site] 02908
30 set_tcp_keepalive [function] [call site] 02909
30 set_tcp_user_timeout [function] [call site] 02910
30 Ok [function] [call site] 02911
30 into [function] [call site] 02912
30 Ok [function] [call site] 02913
29 try_into [function] [call site] 02914
28 ConnectionAddr::to_socket_addrs [function] [call site] 02915
28 connect_tcp_timeout [function] [call site] 02916
29 TcpStream::connect_timeout [function] [call site] 02917
29 io::tcp::stream_with_settings [function] [call site] 02918
30 TcpSettings::set_nodelay [function] [call site] 02919
30 TcpStream::into [function] [call site] 02920
30 set_tcp_keepalive [function] [call site] 02921
30 set_tcp_user_timeout [function] [call site] 02922
30 Ok [function] [call site] 02923
30 into [function] [call site] 02924
30 Ok [function] [call site] 02925
28 Some [function] [call site] 02926
28 Some [function] [call site] 02927
28 fail [function] [call site] 02928
28 fail [function] [call site] 02929
28 ActualConnection::Tcp [function] [call site] 02930
28 TlsConnector::builder [function] [call site] 02931
29 TestSentinelContext::new [function] [call site] 02932
29 TestSentinelContext::sentinels_connection_info [function] [call site] 02933
29 Client::open [function] [call site] 02934
29 &redis::sentinel::Sentinel::clone [function] [call site] 02935
30 ClientTlsParams::clone [function] [call site] 02936
30 Pkcs1 [function] [call site] 02937
30 secret_pkcs1_der [function] [call site] 02938
30 write_command_to_vec [function] [call site] 02939
30 into [function] [call site] 02940
30 Pkcs8 [function] [call site] 02941
30 secret_pkcs8_der [function] [call site] 02942
30 write_command_to_vec [function] [call site] 02943
30 into [function] [call site] 02944
30 Sec1 [function] [call site] 02945
30 secret_sec1_der [function] [call site] 02946
30 write_command_to_vec [function] [call site] 02947
30 into [function] [call site] 02948
29 RedisResult::unwrap [function] [call site] 02949
29 Client::get_connection [function] [call site] 02950
29 unwrap [function] [call site] 02951
29 redis::cmd [function] [call site] 02952
29 redis::Cmd::query [function] [call site] 02953
29 RedisResult::unwrap [function] [call site] 02954
29 SentinelClientBuilder::new [function] [call site] 02955
30 Ok [function] [call site] 02956
30 &'a [call site] 02957
30 into_iter().collect::<Vec<_>> [function] [call site] 02958
30 impl [call site] 02959
30 into [function] [call site] 02960
29 basic::test_tuple_decoding_from_iter [function] [call site] 02961
29 types::test_hashmap [function] [call site] 02962
29 &redis::sentinel::Sentinel::addr [function] [call site] 02963
30 ServerType::get_intended [function] [call site] 02964
30 &str::to_string [function] [call site] 02965
30 redis::ConnectionAddr::Tcp [function] [call site] 02966
30 &str::to_string [function] [call site] 02967
30 rand::random::<(u64, [call site] 02968
30 redis::ConnectionAddr::Unix [function] [call site] 02969
30 ValueType::from [function] [call site] 02970
29 ClientTlsParams::clone [function] [call site] 02971
29 String::from [function] [call site] 02972
29 RedisResult::unwrap [function] [call site] 02973
29 SentinelClientBuilder::new [function] [call site] 02974
29 basic::test_tuple_decoding_from_iter [function] [call site] 02975
29 types::test_hashmap [function] [call site] 02976
29 &redis::sentinel::Sentinel::addr [function] [call site] 02977
29 ClientTlsParams::clone [function] [call site] 02978
29 String::from [function] [call site] 02979
29 RedisResult::unwrap [function] [call site] 02980
29 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 02981
30 Some [function] [call site] 02982
29 redis_test::server::use_protocol [function] [call site] 02983
30 env::var [function] [call site] 02984
30 unwrap_or_default [function] [call site] 02985
29 TestSentinelContext::tls_mode [function] [call site] 02986
29 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 02987
30 Some [function] [call site] 02988
29 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 02989
29 Sentinel::build [function] [call site] 02990
29 unwrap [function] [call site] 02991
29 Sentinel::build [function] [call site] 02992
29 unwrap [function] [call site] 02993
29 Client::get_connection [function] [call site] 02994
29 unwrap [function] [call site] 02995
29 redis::cmd [function] [call site] 02996
29 redis::Cmd::query [function] [call site] 02997
29 RedisResult::unwrap [function] [call site] 02998
29 assert_is_connection_to_master [function] [call site] 02999
30 redis::cmd [function] [call site] 03000
30 redis::Cmd::arg [function] [call site] 03001
30 basic::test_pipeline_reuse_query [function] [call site] 03002
30 unwrap [function] [call site] 03003
30 assert_is_master_role [function] [call site] 03004
29 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03005
29 TestSentinelContext::sentinel_mut [function] [call site] 03006
29 &redis::sentinel::Sentinel::master_for [function] [call site] 03007
30 Sentinel::find_master_address [function] [call site] 03008
30 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 03009
30 Client::open [function] [call site] 03010
29 Some [function] [call site] 03011
29 RedisResult::unwrap [function] [call site] 03012
29 Client::get_connection [function] [call site] 03013
29 unwrap [function] [call site] 03014
29 redis::cmd [function] [call site] 03015
29 redis::Cmd::query [function] [call site] 03016
29 RedisResult::unwrap [function] [call site] 03017
29 assert_connection_is_replica_of_correct_master [function] [call site] 03018
30 redis::cmd [function] [call site] 03019
30 redis::Cmd::arg [function] [call site] 03020
30 basic::test_pipeline_reuse_query [function] [call site] 03021
30 unwrap [function] [call site] 03022
30 assert_replica_role_and_master_addr [function] [call site] 03023
30 Client::get_connection_info [function] [call site] 03024
28 danger_accept_invalid_certs [function] [call site] 03025
28 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03026
29 ClusterType::get_intended [function] [call site] 03027
29 TestClusterContext::new_with_config_and_builder [function] [call site] 03028
30 support::start_tls_crypto_provider [function] [call site] 03029
30 RedisCluster::new [function] [call site] 03030
30 RedisCluster::iter_servers [function] [call site] 03031
31 basic::test_tuple_decoding_from_iter [function] [call site] 03032
30 types::test_hashmap [function] [call site] 03033
30 collect [function] [call site] 03034
30 redis::cluster::ClusterClientBuilder::new [function] [call site] 03035
31 &'a [call site] 03036
31 std::iter::Chain::map [function] [call site] 03037
31 ConnectionInfo::into_connection_info [function] [call site] 03038
31 collect [function] [call site] 03039
31 RedisServer::default [function] [call site] 03040
30 ClientTlsParams::clone [function] [call site] 03041
30 ClusterClientBuilder::use_protocol [function] [call site] 03042
31 Some [function] [call site] 03043
30 redis_test::server::use_protocol [function] [call site] 03044
30 ClusterType::get_intended [function] [call site] 03045
30 ClusterClientBuilder::certs [function] [call site] 03046
31 is_none [function] [call site] 03047
31 Some [function] [call site] 03048
31 Some [function] [call site] 03049
30 super::load_certs_from_file [function] [call site] 03050
31 MockRedisConnection::is_open [function] [call site] 03051
31 bool::expect [function] [call site] 03052
31 RedisServer::new [function] [call site] 03053
31 RedisServer::new [function] [call site] 03054
32 RedisServer::with_modules [function] [call site] 03055
31 RedisServer::read_to_end [function] [call site] 03056
31 expect [function] [call site] 03057
31 MockRedisConnection::is_open [function] [call site] 03058
31 bool::expect [function] [call site] 03059
31 RedisServer::new [function] [call site] 03060
31 RedisServer::new [function] [call site] 03061
31 RedisServer::read_to_end [function] [call site] 03062
31 expect [function] [call site] 03063
31 MockRedisConnection::is_open [function] [call site] 03064
31 bool::expect [function] [call site] 03065
31 RedisServer::new [function] [call site] 03066
31 RedisServer::new [function] [call site] 03067
31 RedisServer::read_to_end [function] [call site] 03068
31 expect [function] [call site] 03069
31 Some [function] [call site] 03070
31 Some [function] [call site] 03071
30 initializer [function] [call site] 03072
30 Sentinel::build [function] [call site] 03073
30 RedisResult::unwrap [function] [call site] 03074
30 redis_test::server::use_protocol [function] [call site] 03075
29 RedisServer::default [function] [call site] 03076
29 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03077
29 cluster::smoke_test_connection [function] [call site] 03078
30 redis::cmd [function] [call site] 03079
30 redis::Cmd::arg [function] [call site] 03080
30 types::test_is_single_arg [function] [call site] 03081
30 Cmd::exec [function] [call site] 03082
31 query::<()> [function] [call site] 03083
30 RedisResult::unwrap [function] [call site] 03084
30 redis::cmd [function] [call site] 03085
30 redis::Cmd::arg [function] [call site] 03086
30 Cmd::exec [function] [call site] 03087
30 RedisResult::unwrap [function] [call site] 03088
29 MockRedisConnection::check_connection [function] [call site] 03089
28 use_sni [function] [call site] 03090
28 Sentinel::build [function] [call site] 03091
28 TlsConnector::builder [function] [call site] 03092
28 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03093
28 Sentinel::build [function] [call site] 03094
28 RedisServer::new [function] [call site] 03095
29 RedisServer::with_modules [function] [call site] 03096
28 as_str [function] [call site] 03097
28 connect_tcp [function] [call site] 03098
28 connect [function] [call site] 03099
28 fail [function] [call site] 03100
28 as_str [function] [call site] 03101
28 to_socket_addrs [function] [call site] 03102
28 connect_tcp_timeout [function] [call site] 03103
28 Some [function] [call site] 03104
28 Some [function] [call site] 03105
28 connect [function] [call site] 03106
28 unwrap [function] [call site] 03107
28 fail [function] [call site] 03108
28 fail [function] [call site] 03109
28 ActualConnection::TcpNativeTls [function] [call site] 03110
28 RedisServer::new [function] [call site] 03111
28 create_rustls_config [function] [call site] 03112
29 basic::test_pipeline_is_empty [function] [call site] 03113
30 redis::pipe [function] [call site] 03114
30 cmd [function] [call site] 03115
30 cmd [function] [call site] 03116
30 types::test_is_single_arg [function] [call site] 03117
29 extend [function] [call site] 03118
29 basic::test_tuple_decoding_from_iter [function] [call site] 03119
29 cloned [function] [call site] 03120
29 rustls_native_certs::load_native_certs [function] [call site] 03121
29 test_module_json_arr_pop [function] [call site] 03122
30 TestContext::with_modules [function] [call site] 03123
30 TestContext::connection [function] [call site] 03124
30 redis::Connection::json_set [function] [call site] 03125
30 redis::Connection::json_arr_pop [function] [call site] 03126
30 redis::Connection::json_set [function] [call site] 03127
30 redis::Connection::json_arr_pop [function] [call site] 03128
29 Err [function] [call site] 03129
29 into [function] [call site] 03130
29 xadd [function] [call site] 03131
30 &mut [call site] 03132
30 unwrap [function] [call site] 03133
30 &mut [call site] 03134
30 unwrap [function] [call site] 03135
30 &mut [call site] 03136
30 unwrap [function] [call site] 03137
30 &mut [call site] 03138
30 unwrap [function] [call site] 03139
29 rustls::ClientConfig::builder [function] [call site] 03140
30 TestSentinelContext::new [function] [call site] 03141
30 TestSentinelContext::sentinels_connection_info [function] [call site] 03142
30 Client::open [function] [call site] 03143
30 &redis::sentinel::Sentinel::clone [function] [call site] 03144
30 RedisResult::unwrap [function] [call site] 03145
30 Client::get_connection [function] [call site] 03146
30 unwrap [function] [call site] 03147
30 redis::cmd [function] [call site] 03148
30 redis::Cmd::query [function] [call site] 03149
30 RedisResult::unwrap [function] [call site] 03150
30 SentinelClientBuilder::new [function] [call site] 03151
30 basic::test_tuple_decoding_from_iter [function] [call site] 03152
30 types::test_hashmap [function] [call site] 03153
30 &redis::sentinel::Sentinel::addr [function] [call site] 03154
30 ClientTlsParams::clone [function] [call site] 03155
30 String::from [function] [call site] 03156
30 RedisResult::unwrap [function] [call site] 03157
30 SentinelClientBuilder::new [function] [call site] 03158
30 basic::test_tuple_decoding_from_iter [function] [call site] 03159
30 types::test_hashmap [function] [call site] 03160
30 &redis::sentinel::Sentinel::addr [function] [call site] 03161
30 ClientTlsParams::clone [function] [call site] 03162
30 String::from [function] [call site] 03163
30 RedisResult::unwrap [function] [call site] 03164
30 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 03165
30 redis_test::server::use_protocol [function] [call site] 03166
30 TestSentinelContext::tls_mode [function] [call site] 03167
30 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03168
30 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03169
30 Sentinel::build [function] [call site] 03170
30 unwrap [function] [call site] 03171
30 Sentinel::build [function] [call site] 03172
30 unwrap [function] [call site] 03173
30 Client::get_connection [function] [call site] 03174
30 unwrap [function] [call site] 03175
30 redis::cmd [function] [call site] 03176
30 redis::Cmd::query [function] [call site] 03177
30 RedisResult::unwrap [function] [call site] 03178
30 assert_is_connection_to_master [function] [call site] 03179
30 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03180
30 TestSentinelContext::sentinel_mut [function] [call site] 03181
30 &redis::sentinel::Sentinel::master_for [function] [call site] 03182
30 Some [function] [call site] 03183
30 RedisResult::unwrap [function] [call site] 03184
30 Client::get_connection [function] [call site] 03185
30 unwrap [function] [call site] 03186
30 redis::cmd [function] [call site] 03187
30 redis::Cmd::query [function] [call site] 03188
30 RedisResult::unwrap [function] [call site] 03189
30 assert_connection_is_replica_of_correct_master [function] [call site] 03190
29 unwrap_or [function] [call site] 03191
29 Self::with_root_certificates [function] [call site] 03192
29 ClientTlsParams::clone [function] [call site] 03193
29 with_client_auth_cert [function] [call site] 03194
29 map_err [function] [call site] 03195
29 RedisError::from [function] [call site] 03196
29 to_string [function] [call site] 03197
29 with_no_client_auth [function] [call site] 03198
29 fail [function] [call site] 03199
29 Self::dangerous [function] [call site] 03200
29 set_certificate_verifier [function] [call site] 03201
29 RedisServer::new [function] [call site] 03202
29 rustls::client::WebPkiServerVerifier::builder [function] [call site] 03203
30 TestSentinelContext::new [function] [call site] 03204
30 TestSentinelContext::sentinels_connection_info [function] [call site] 03205
30 Client::open [function] [call site] 03206
30 &redis::sentinel::Sentinel::clone [function] [call site] 03207
30 RedisResult::unwrap [function] [call site] 03208
30 Client::get_connection [function] [call site] 03209
30 unwrap [function] [call site] 03210
30 redis::cmd [function] [call site] 03211
30 redis::Cmd::query [function] [call site] 03212
30 RedisResult::unwrap [function] [call site] 03213
30 SentinelClientBuilder::new [function] [call site] 03214
30 basic::test_tuple_decoding_from_iter [function] [call site] 03215
30 types::test_hashmap [function] [call site] 03216
30 &redis::sentinel::Sentinel::addr [function] [call site] 03217
30 ClientTlsParams::clone [function] [call site] 03218
30 String::from [function] [call site] 03219
30 RedisResult::unwrap [function] [call site] 03220
30 SentinelClientBuilder::new [function] [call site] 03221
30 basic::test_tuple_decoding_from_iter [function] [call site] 03222
30 types::test_hashmap [function] [call site] 03223
30 &redis::sentinel::Sentinel::addr [function] [call site] 03224
30 ClientTlsParams::clone [function] [call site] 03225
30 String::from [function] [call site] 03226
30 RedisResult::unwrap [function] [call site] 03227
30 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 03228
30 redis_test::server::use_protocol [function] [call site] 03229
30 TestSentinelContext::tls_mode [function] [call site] 03230
30 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03231
30 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03232
30 Sentinel::build [function] [call site] 03233
30 unwrap [function] [call site] 03234
30 Sentinel::build [function] [call site] 03235
30 unwrap [function] [call site] 03236
30 Client::get_connection [function] [call site] 03237
30 unwrap [function] [call site] 03238
30 redis::cmd [function] [call site] 03239
30 redis::Cmd::query [function] [call site] 03240
30 RedisResult::unwrap [function] [call site] 03241
30 assert_is_connection_to_master [function] [call site] 03242
30 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03243
30 TestSentinelContext::sentinel_mut [function] [call site] 03244
30 &redis::sentinel::Sentinel::master_for [function] [call site] 03245
30 Some [function] [call site] 03246
30 RedisResult::unwrap [function] [call site] 03247
30 Client::get_connection [function] [call site] 03248
30 unwrap [function] [call site] 03249
30 redis::cmd [function] [call site] 03250
30 redis::Cmd::query [function] [call site] 03251
30 RedisResult::unwrap [function] [call site] 03252
30 assert_connection_is_replica_of_correct_master [function] [call site] 03253
29 RedisServer::new [function] [call site] 03254
29 Sentinel::build [function] [call site] 03255
29 RedisResult::map_err [function] [call site] 03256
29 rustls::Error::from [function] [call site] 03257
30 io::Error::from [function] [call site] 03258
30 Self::into [function] [call site] 03259
29 rustls::OtherError [function] [call site] 03260
29 RedisServer::new [function] [call site] 03261
29 Self::with_root_certificates [function] [call site] 03262
29 with_no_client_auth [function] [call site] 03263
29 rustls::crypto::CryptoProvider::get_default [function] [call site] 03264
29 Err [function] [call site] 03265
29 RedisError::from [function] [call site] 03266
29 Self::dangerous [function] [call site] 03267
29 set_certificate_verifier [function] [call site] 03268
29 RedisServer::new [function] [call site] 03269
29 Ok [function] [call site] 03270
29 fail [function] [call site] 03271
29 Ok [function] [call site] 03272
28 ClientTlsParams::clone [function] [call site] 03273
28 rustls::ClientConnection::new [function] [call site] 03274
29 RedisServer::with_modules [function] [call site] 03275
28 RedisServer::new [function] [call site] 03276
28 rustls::pki_types::ServerName::try_from [function] [call site] 03277
29 Ok [function] [call site] 03278
29 Err [function] [call site] 03279
28 to_owned [function] [call site] 03280
28 connect_tcp [function] [call site] 03281
28 RedisServer::new [function] [call site] 03282
29 RedisServer::with_modules [function] [call site] 03283
28 to_socket_addrs [function] [call site] 03284
28 connect_tcp_timeout [function] [call site] 03285
28 Some [function] [call site] 03286
28 Some [function] [call site] 03287
28 RedisServer::new [function] [call site] 03288
28 fail [function] [call site] 03289
28 fail [function] [call site] 03290
28 ActualConnection::TcpRustls [function] [call site] 03291
28 RedisServer::new [function] [call site] 03292
28 fail [function] [call site] 03293
28 ActualConnection::Unix [function] [call site] 03294
28 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 03295
29 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 03296
29 cluster::test_cluster_retries [function] [call site] 03297
29 TestClusterContext::get_ports [function] [call site] 03298
29 MockRedisConnection::check_connection [function] [call site] 03299
29 RedisServer::drop [function] [call site] 03300
29 cmd [function] [call site] 03301
29 ClusterConnection::route_command [function] [call site] 03302
29 RoutingInfo::SingleNode [function] [call site] 03303
29 MockRedisConnection::req_packed_command [function] [call site] 03304
29 Cmd::get_packed_command [function] [call site] 03305
29 RedisCluster::new [function] [call site] 03306
29 RedisServer::default [function] [call site] 03307
29 ClusterConnection::route_command [function] [call site] 03308
29 RoutingInfo::SingleNode [function] [call site] 03309
29 RedisResult::unwrap [function] [call site] 03310
28 fail [function] [call site] 03311
27 RedisResult::and_then [function] [call site] 03312
27 RedisResult::checked_sub [function] [call site] 03313
27 elapsed [function] [call site] 03314
27 RedisResult::is_some [function] [call site] 03315
27 is_none [function] [call site] 03316
27 Err [function] [call site] 03317
27 RedisError::from [function] [call site] 03318
27 std::io::Error::new [function] [call site] 03319
28 RedisServer::with_modules [function] [call site] 03320
27 MockConnection::set_read_timeout [function] [call site] 03321
28 Ok [function] [call site] 03322
27 MockConnection::set_write_timeout [function] [call site] 03323
28 Ok [function] [call site] 03324
27 setup_connection [function] [call site] 03325
28 execute_connection_pipeline [function] [call site] 03326
28 connection::connection_setup_pipeline [function] [call site] 03327
28 execute_connection_pipeline [function] [call site] 03328
28 connection::connection_setup_pipeline [function] [call site] 03329
28 Ok [function] [call site] 03330
27 MockConnection::set_read_timeout [function] [call site] 03331
27 MockConnection::set_write_timeout [function] [call site] 03332
27 Ok [function] [call site] 03333
26 into [function] [call site] 03334
26 is_ok [function] [call site] 03335
25 to_string [function] [call site] 03336
25 Ok [function] [call site] 03337
25 std::thread::sleep [function] [call site] 03338
25 Duration::from_millis [function] [call site] 03339
25 &'a [call site] 03340
25 types::test_hashmap [function] [call site] 03341
25 { [call site] 03342
0 server::get_random_available_port [function] [call site] 03343
25 RedisServer::contains [function] [call site] 03344
25 RedisServer::insert [function] [call site] 03345
25 make_server [function] [call site] 03346
25 std::thread::sleep [function] [call site] 03347
25 Duration::from_millis [function] [call site] 03348
25 verify_server [function] [call site] 03349
25 tests::decode_resp3_push [function] [call site] 03350
25 ClientTlsParams::clone [function] [call site] 03351
25 collect [function] [call site] 03352
25 process::Command::new [function] [call site] 03353
25 Cmd::stdout [function] [call site] 03354
25 process::Stdio::piped [function] [call site] 03355
25 types::test_is_single_arg [function] [call site] 03356
25 types::test_is_single_arg [function] [call site] 03357
25 types::test_std_types_to_redis_args [function] [call site] 03358
25 Cmd::arg [function] [call site] 03359
25 types::test_is_single_arg [function] [call site] 03360
25 to_string [function] [call site] 03361
25 Cmd::arg [function] [call site] 03362
25 Cmd::arg [function] [call site] 03363
25 Cmd::arg [function] [call site] 03364
25 Cmd::arg [function] [call site] 03365
25 Cmd::arg [function] [call site] 03366
25 Cmd::arg [function] [call site] 03367
25 Cmd::arg [function] [call site] 03368
25 Cmd::arg [function] [call site] 03369
25 None::is_some [function] [call site] 03370
25 None::as_ref [function] [call site] 03371
25 unwrap [function] [call site] 03372
25 Cmd::arg [function] [call site] 03373
25 types::test_is_single_arg [function] [call site] 03374
25 types::test_is_single_arg [function] [call site] 03375
25 Cmd::arg [function] [call site] 03376
25 types::test_is_single_arg [function] [call site] 03377
25 Cmd::output [function] [call site] 03378
25 unwrap [function] [call site] 03379
25 test_get_replica_clients_success [function] [call site] 03380
26 TestSentinelContext::new [function] [call site] 03381
26 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03382
26 TestSentinelContext::sentinel_mut [function] [call site] 03383
26 &redis::sentinel::Sentinel::get_replica_clients [function] [call site] 03384
27 Sentinel::find_valid_replica_addresses [function] [call site] 03385
27 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 03386
27 build_replica_clients [function] [call site] 03387
28 basic::test_pipeline_is_empty [function] [call site] 03388
28 fail [function] [call site] 03389
28 basic::test_tuple_decoding_from_iter [function] [call site] 03390
28 types::test_hashmap [function] [call site] 03391
28 Client::open [function] [call site] 03392
28 ClientTlsParams::clone [function] [call site] 03393
28 collect [function] [call site] 03394
26 Some [function] [call site] 03395
26 RedisResult::unwrap [function] [call site] 03396
25 std::thread::sleep [function] [call site] 03397
25 Duration::from_millis [function] [call site] 03398
25 RedisCluster::wait_for_replicas [function] [call site] 03399
26 RedisServer::connection_info [function] [call site] 03400
26 redis::Client::open [function] [call site] 03401
26 RedisServer::connection_info [function] [call site] 03402
26 RedisResult::unwrap [function] [call site] 03403
26 Client::get_connection [function] [call site] 03404
26 RedisResult::unwrap [function] [call site] 03405
26 redis::cmd [function] [call site] 03406
26 redis::Cmd::arg [function] [call site] 03407
26 basic::test_pipeline_reuse_query [function] [call site] 03408
26 unwrap [function] [call site] 03409
26 RedisResult::from_redis_value [function] [call site] 03410
27 Ok [function] [call site] 03411
27 Err [function] [call site] 03412
27 into [function] [call site] 03413
27 from_redis_value [function] [call site] 03414
27 types::test_hashmap [function] [call site] 03415
27 Ok [function] [call site] 03416
26 Result::unwrap [function] [call site] 03417
26 basic::test_tuple_decoding_from_iter [function] [call site] 03418
26 block_on_all [function] [call site] 03419
27 panic::set_hook [function] [call site] 03420
27 RedisServer::new [function] [call site] 03421
27 RadiusOptions::store [function] [call site] 03422
28 Some [function] [call site] 03423
28 ToRedisArgs::to_redis_args [function] [call site] 03424
29 RedisServer::new [function] [call site] 03425
29 u8::write_redis_args [function] [call site] 03426
30 ::itoa::Buffer::new [function] [call site] 03427
30 RedisServer::format [function] [call site] 03428
30 Vec::write_arg [function] [call site] 03429
30 TlsFilePaths::as_bytes [function] [call site] 03430
27 futures_util::FutureExt::fuse [function] [call site] 03431
27 script::test_script_load [function] [call site] 03432
28 TestContext::new [function] [call site] 03433
28 TestContext::connection [function] [call site] 03434
28 redis::Script::new [function] [call site] 03435
29 RedisServer::new [function] [call site] 03436
30 RedisServer::with_modules [function] [call site] 03437
29 SortedSetAddOptions::add_or_update [function] [call site] 03438
30 RedisServer::default [function] [call site] 03439
29 Option::as_bytes [function] [call site] 03440
29 Option::to_string [function] [call site] 03441
29 digest [function] [call site] 03442
29 to_string [function] [call site] 03443
28 script::test_script_load [function] [call site] 03444
27 Err [function] [call site] 03445
27 into [function] [call site] 03446
27 futures_time::task::sleep [function] [call site] 03447
28 tokio::time::sleep [function] [call site] 03448
28 smol::Timer::after [function] [call site] 03449
27 futures_time::time::Duration::from_millis [function] [call site] 03450
27 futures_util::FutureExt::fuse [function] [call site] 03451
27 block_on_all_using_tokio [function] [call site] 03452
28 redis::aio::prefer_tokio [function] [call site] 03453
29 set_runtime [function] [call site] 03454
30 types::test_hashbrown_hashset [function] [call site] 03455
31 parse_redis_value [function] [call site] 03456
31 Value::Array [function] [call site] 03457
31 RedisServer::new [function] [call site] 03458
31 RedisServer::insert [function] [call site] 03459
31 &str::to_string [function] [call site] 03460
31 RedisServer::insert [function] [call site] 03461
31 &str::to_string [function] [call site] 03462
31 RedisServer::insert [function] [call site] 03463
31 &str::to_string [function] [call site] 03464
31 parse_redis_value [function] [call site] 03465
31 Value::Int [function] [call site] 03466
31 RedisServer::new [function] [call site] 03467
31 test_module_json_arr_insert [function] [call site] 03468
31 &str::to_string [function] [call site] 03469
31 test_module_json_arr_insert [function] [call site] 03470
31 &str::to_string [function] [call site] 03471
31 test_module_json_arr_insert [function] [call site] 03472
31 &str::to_string [function] [call site] 03473
31 types::test_std_types_to_redis_args [function] [call site] 03474
31 &'a [call site] 03475
31 std::iter::Chain::collect [function] [call site] 03476
30 map_err [function] [call site] 03477
30 RedisError::from [function] [call site] 03478
28 Result::unwrap [function] [call site] 03479
28 current_thread_runtime [function] [call site] 03480
29 tokio::runtime::Builder::new_current_thread [function] [call site] 03481
29 enable_io [function] [call site] 03482
29 enable_time [function] [call site] 03483
29 Sentinel::build [function] [call site] 03484
29 RedisResult::unwrap [function] [call site] 03485
28 tokio::runtime::Runtime::block_on [function] [call site] 03486
27 block_on_all_using_smol [function] [call site] 03487
28 redis::aio::prefer_smol [function] [call site] 03488
29 set_runtime [function] [call site] 03489
28 Result::unwrap [function] [call site] 03490
28 smol::block_on [function] [call site] 03491
27 panic::take_hook [function] [call site] 03492
27 swap [function] [call site] 03493
26 basic::test_pipeline_len [function] [call site] 03494
27 redis::pipe [function] [call site] 03495
27 cmd [function] [call site] 03496
27 cmd [function] [call site] 03497
27 types::test_is_single_arg [function] [call site] 03498
26 std::thread::sleep [function] [call site] 03499
26 Duration::from_millis [function] [call site] 03500
25 wait_for_status_ok [function] [call site] 03501
26 RedisServer::log_file [function] [call site] 03502
26 std::fs::read_to_string [function] [call site] 03503
26 expect [function] [call site] 03504
26 Option::contains [function] [call site] 03505
26 std::thread::sleep [function] [call site] 03506
26 Duration::from_millis [function] [call site] 03507
24 RedisCluster::iter_servers [function] [call site] 03508
24 types::test_hashmap [function] [call site] 03509
24 collect [function] [call site] 03510
24 redis::cluster::ClusterClientBuilder::new [function] [call site] 03511
24 ClientTlsParams::clone [function] [call site] 03512
24 ClusterClientBuilder::use_protocol [function] [call site] 03513
24 redis_test::server::use_protocol [function] [call site] 03514
24 ClusterType::get_intended [function] [call site] 03515
24 ClusterClientBuilder::certs [function] [call site] 03516
24 super::load_certs_from_file [function] [call site] 03517
24 initializer [function] [call site] 03518
24 Sentinel::build [function] [call site] 03519
24 RedisResult::unwrap [function] [call site] 03520
24 redis_test::server::use_protocol [function] [call site] 03521
23 RedisClusterConfiguration::default [function] [call site] 03522
22 cluster::test_cluster_retries [function] [call site] 03523
22 TestClusterContext::get_ports [function] [call site] 03524
22 MockRedisConnection::check_connection [function] [call site] 03525
22 RedisServer::drop [function] [call site] 03526
22 cmd [function] [call site] 03527
22 ClusterConnection::route_command [function] [call site] 03528
22 RoutingInfo::SingleNode [function] [call site] 03529
22 MockRedisConnection::req_packed_command [function] [call site] 03530
22 Cmd::get_packed_command [function] [call site] 03531
22 RedisCluster::new [function] [call site] 03532
22 RedisServer::default [function] [call site] 03533
22 ClusterConnection::route_command [function] [call site] 03534
22 RoutingInfo::SingleNode [function] [call site] 03535
22 RedisResult::unwrap [function] [call site] 03536
20 RedisError::is_connection_refusal [function] [call site] 03537
21 RedisError::as_io_error [function] [call site] 03538
21 Option::is_some_and [function] [call site] 03539
21 get_push_kind [function] [call site] 03540
20 std::thread::sleep [function] [call site] 03541
20 flushdb::<()> [function] [call site] 03542
20 unwrap [function] [call site] 03543
20 redis_test::server::use_protocol [function] [call site] 03544
16 TestContext::connection [function] [call site] 03545
16 ValueType::from [function] [call site] 03546
16 basic::test_tuple_decoding_from_iter [function] [call site] 03547
16 hscan::<_, [call site] 03548
16 unwrap [function] [call site] 03549
16 unwrap [function] [call site] 03550
15 types::test_hashmap [function] [call site] 03551
15 Arg::Simple [function] [call site] 03552
14 unwrap_or [function] [call site] 03553
12 MockRedisConnection::req_packed_command [function] [call site] 03554
12 as_slice [function] [call site] 03555
12 PipelineSink::poll_ready [function] [call site] 03556
12 types::test_parse_boxed [function] [call site] 03557
11 base_routing [function] [call site] 03558
12 RouteBy::MultiShard [function] [call site] 03559
12 RouteBy::MultiShard [function] [call site] 03560
12 RouteBy::MultiShard [function] [call site] 03561
12 RouteBy::MultiShard [function] [call site] 03562
11 Some [function] [call site] 03563
11 RoutingInfo::MultiNode [function] [call site] 03564
11 ResponsePolicy::for_command [function] [call site] 03565
12 Some [function] [call site] 03566
12 ResponsePolicy::AggregateLogical [function] [call site] 03567
12 Some [function] [call site] 03568
12 ResponsePolicy::Aggregate [function] [call site] 03569
12 Some [function] [call site] 03570
12 ResponsePolicy::Aggregate [function] [call site] 03571
12 Some [function] [call site] 03572
12 Some [function] [call site] 03573
12 Some [function] [call site] 03574
12 Some [function] [call site] 03575
12 Some [function] [call site] 03576
12 Some [function] [call site] 03577
12 Some [function] [call site] 03578
12 Some [function] [call site] 03579
12 Some [function] [call site] 03580
11 Some [function] [call site] 03581
11 RoutingInfo::MultiNode [function] [call site] 03582
11 ResponsePolicy::for_command [function] [call site] 03583
11 multi_shard [function] [call site] 03584
12 commands::is_readonly_cmd [function] [call site] 03585
12 RedisServer::new [function] [call site] 03586
12 Cmd::arg_idx [function] [call site] 03587
13 Cmd::arg_idx [function] [call site] 03588
14 Cmd::arg_idx [function] [call site] 03589
12 tests::decode_resp3_push [function] [call site] 03590
12 Some [function] [call site] 03591
12 Cmd::arg_idx [function] [call site] 03592
12 get_route [function] [call site] 03593
13 get_slot [function] [call site] 03594
14 get_hashtag [function] [call site] 03595
15 basic::test_tuple_decoding_from_iter [function] [call site] 03596
15 Cmd::position [function] [call site] 03597
16 Cmd::args_iter [function] [call site] 03598
16 Cmd::position [function] [call site] 03599
17 Cmd::args_iter [function] [call site] 03600
17 Cmd::position [function] [call site] 03601
17 ServerType::eq_ignore_ascii_case [function] [call site] 03602
16 ServerType::eq_ignore_ascii_case [function] [call site] 03603
15 basic::test_tuple_decoding_from_iter [function] [call site] 03604
15 Cmd::position [function] [call site] 03605
15 basic::test_pipeline_is_empty [function] [call site] 03606
15 then_some [function] [call site] 03607
14 slot [function] [call site] 03608
15 crc16::State::<crc16::XMODEM>::calculate [function] [call site] 03609
13 Route::new [function] [call site] 03610
14 Self [function] [call site] 03611
13 Route::new [function] [call site] 03612
12 RedisServer::entry [function] [call site] 03613
13 TestContext::new [function] [call site] 03614
13 TestContext::connection [function] [call site] 03615
13 redis::Connection::xgroup_create_mkstream [function] [call site] 03616
13 redis::Connection::xadd_maxlen [function] [call site] 03617
13 StreamMaxlen::Equals [function] [call site] 03618
13 redis::Connection::xread_options [function] [call site] 03619
13 RedisServer::default [function] [call site] 03620
14 RedisServer::new [function] [call site] 03621
13 Self::group [function] [call site] 03622
14 TestContext::new [function] [call site] 03623
14 TestContext::connection [function] [call site] 03624
14 redis::Connection::xgroup_create_mkstream [function] [call site] 03625
14 redis::Connection::xgroup_destroy [function] [call site] 03626
14 xadd [function] [call site] 03627
14 redis::Connection::xgroup_create [function] [call site] 03628
14 redis::Connection::xread_options [function] [call site] 03629
14 RedisServer::default [function] [call site] 03630
14 Self::group [function] [call site] 03631
14 unwrap [function] [call site] 03632
14 unwrap [function] [call site] 03633
14 redis::Connection::xgroup_delconsumer [function] [call site] 03634
14 redis::Connection::xgroup_destroy [function] [call site] 03635
13 unwrap [function] [call site] 03636
13 unwrap [function] [call site] 03637
13 redis::Connection::xadd_maxlen [function] [call site] 03638
13 StreamMaxlen::Equals [function] [call site] 03639
13 redis::Connection::xread_options [function] [call site] 03640
13 RedisServer::default [function] [call site] 03641
13 Self::group [function] [call site] 03642
13 unwrap [function] [call site] 03643
13 unwrap [function] [call site] 03644
12 or_insert [function] [call site] 03645
12 RedisServer::new [function] [call site] 03646
12 tests::decode_resp3_push [function] [call site] 03647
12 incr_add_next_arg [function] [call site] 03648
12 Cmd::arg_idx [function] [call site] 03649
12 Option::is_none [function] [call site] 03650
12 RedisServer::iter_mut [function] [call site] 03651
12 tests::decode_resp3_push [function] [call site] 03652
12 incr_add_next_arg [function] [call site] 03653
12 incr_add_next_arg [function] [call site] 03654
12 &'a [call site] 03655
12 std::iter::Chain::collect [function] [call site] 03656
12 basic::test_pipeline_is_empty [function] [call site] 03657
12 Some [function] [call site] 03658
12 basic::test_pipeline_len [function] [call site] 03659
12 RoutingInfo::SingleNode [function] [call site] 03660
12 SingleNodeRoutingInfo::SpecificNode [function] [call site] 03661
12 RedisServer::pop [function] [call site] 03662
12 unwrap [function] [call site] 03663
12 RoutingInfo::MultiNode [function] [call site] 03664
12 MultipleNodeRoutingInfo::MultiSlot [function] [call site] 03665
12 ResponsePolicy::for_command [function] [call site] 03666
11 Some [function] [call site] 03667
11 RoutingInfo::SingleNode [function] [call site] 03668
11 Cmd::arg_idx [function] [call site] 03669
12 Cmd::arg_idx [function] [call site] 03670
11 Option::and_then [function] [call site] 03671
11 std::str::from_utf8 [function] [call site] 03672
11 wait_for_status_ok [function] [call site] 03673
11 and_then [function] [call site] 03674
11 parse::<u64> [function] [call site] 03675
11 wait_for_status_ok [function] [call site] 03676
11 Some [function] [call site] 03677
11 RoutingInfo::SingleNode [function] [call site] 03678
11 Cmd::arg_idx [function] [call site] 03679
11 types::test_hashmap [function] [call site] 03680
11 RoutingInfo::for_key [function] [call site] 03681
12 RoutingInfo::SingleNode [function] [call site] 03682
12 SingleNodeRoutingInfo::SpecificNode [function] [call site] 03683
12 get_route [function] [call site] 03684
12 commands::is_readonly_cmd [function] [call site] 03685
11 Cmd::arg_idx [function] [call site] 03686
11 types::test_hashmap [function] [call site] 03687
11 RoutingInfo::for_key [function] [call site] 03688
11 Cmd::arg_idx [function] [call site] 03689
11 Option::and_then [function] [call site] 03690
11 std::str::from_utf8 [function] [call site] 03691
11 wait_for_status_ok [function] [call site] 03692
11 and_then [function] [call site] 03693
11 parse::<u64> [function] [call site] 03694
11 wait_for_status_ok [function] [call site] 03695
11 Some [function] [call site] 03696
11 RoutingInfo::SingleNode [function] [call site] 03697
11 Cmd::arg_idx [function] [call site] 03698
11 types::test_hashmap [function] [call site] 03699
11 RoutingInfo::for_key [function] [call site] 03700
11 Cmd::position [function] [call site] 03701
12 Cmd::args_iter [function] [call site] 03702
12 Cmd::position [function] [call site] 03703
12 ServerType::eq_ignore_ascii_case [function] [call site] 03704
11 Cmd::arg_idx [function] [call site] 03705
11 types::test_hashmap [function] [call site] 03706
11 RoutingInfo::for_key [function] [call site] 03707
11 Cmd::arg_idx [function] [call site] 03708
11 Option::and_then [function] [call site] 03709
11 std::str::from_utf8 [function] [call site] 03710
11 wait_for_status_ok [function] [call site] 03711
11 and_then [function] [call site] 03712
11 parse::<u16> [function] [call site] 03713
11 wait_for_status_ok [function] [call site] 03714
11 types::test_hashmap [function] [call site] 03715
11 RoutingInfo::SingleNode [function] [call site] 03716
11 SingleNodeRoutingInfo::SpecificNode [function] [call site] 03717
11 Route::new [function] [call site] 03718
11 Cmd::arg_idx [function] [call site] 03719
11 Some [function] [call site] 03720
11 RoutingInfo::for_key [function] [call site] 03721
11 Some [function] [call site] 03722
11 RoutingInfo::SingleNode [function] [call site] 03723
10 std::collections::HashMap::new [function] [call site] 03724
10 RedisServer::insert [function] [call site] 03725
10 Route [function] [call site] 03726
10 RedisServer::insert [function] [call site] 03727
10 Route [function] [call site] 03728
10 RedisServer::insert [function] [call site] 03729
10 Route [function] [call site] 03730
9 join [function] [call site] 03731
8 std::fs::read_to_string [function] [call site] 03732
8 expect [function] [call site] 03733
8 Option::contains [function] [call site] 03734
8 std::thread::sleep [function] [call site] 03735
8 Duration::from_millis [function] [call site] 03736
7 as_ref [function] [call site] 03737
7 types::test_hashmap [function] [call site] 03738
6 &str::to_string [function] [call site] 03739
6 redis::ConnectionAddr::Tcp [function] [call site] 03740
6 &str::to_string [function] [call site] 03741
6 rand::random::<(u64, [call site] 03742
6 redis::ConnectionAddr::Unix [function] [call site] 03743
6 ValueType::from [function] [call site] 03744
5 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 03745
5 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 03746
5 unwrap_or_else [function] [call site] 03747
2 Parser::parse_value [function] [call site] 03748