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