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