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
1604 2302 RedisCluster::new call site: 02302 cluster::test_cluster_reconnect_after_complete_server_disconnect
1189 1112 get_push_kind call site: 01112 Client::get_connection
1025 85 parse_redis_value call site: 00085 cluster::test_cluster_reconnect_after_complete_server_disconnect
80 3 Parser::new call site: 00003 tests_routing::test_multi_shard_keys_and_path
1 0 EP call site: 00000

Fuzzer calltree

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