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
1602 1122 get_push_kind call site: 01122 cluster::test_cluster_reconnect_after_complete_server_disconnect
1193 2725 RedisCluster::new call site: 02725 cluster::test_cluster_reconnect_after_complete_server_disconnect
1031 89 parse_redis_value call site: 00089 cluster::test_cluster_reconnect_after_complete_server_disconnect
84 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 entra_id_tests::get_env_var [function] [call site] 00043
8 std::env::var [function] [call site] 00044
9 std::env::var [function] [call site] 00045
9 String::unwrap_or_else [function] [call site] 00046
8 String::unwrap_or_else [function] [call site] 00047
7 String::ok [function] [call site] 00048
8 RedisServer::log_file [function] [call site] 00049
9 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00050
10 cmd [function] [call site] 00051
11 Cmd::new [function] [call site] 00052
11 Cmd::arg [function] [call site] 00053
12 SetExpiry::write_redis_args [function] [call site] 00054
13 Vec::write_arg [function] [call site] 00055
14 cluster_async::get_push [function] [call site] 00056
15 Pipeline::send_recv [function] [call site] 00057
16 MockRedisConnection::is_empty [function] [call site] 00058
17 StreamReadOptions::block [function] [call site] 00059
17 MockRedisConnection::is_empty [function] [call site] 00062
18 StreamReadOptions::block [function] [call site] 00063
18 MockRedisConnection::is_empty [function] [call site] 00065
16 RedisError::make_empty_command [function] [call site] 00067
17 ErrorRepr::General [function] [call site] 00068
16 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 00069
16 Msg::get_channel [function] [call site] 00072
17 from_redis_value_ref [function] [call site] 00074
18 FromRedisValue::from_redis_value_ref [function] [call site] 00075
19 RedisResult::from_redis_value [function] [call site] 00076
20 from_redis_value [function] [call site] 00080
21 RedisResult::from_redis_value [function] [call site] 00081
22 from_redis_value [function] [call site] 00085
22 types::test_hashmap [function] [call site] 00086
23 parse_redis_value [function] [call site] 00087
24 Parser::new [function] [call site] 00088
24 Parser::parse_value [function] [call site] 00089
25 to_redis_err [function] [call site] 00091
26 is_unexpected_end_of_input [function] [call site] 00093
26 RedisError::from [function] [call site] 00094
26 io::Error::from [function] [call site] 00095
26 map_range [function] [call site] 00096
26 map_position [function] [call site] 00097
26 translate_position [function] [call site] 00098
26 to_string [function] [call site] 00100
26 RedisError::from [function] [call site] 00101
26 ParsingError::from [function] [call site] 00102
23 Value::Array [function] [call site] 00104
23 RedisServer::new [function] [call site] 00105
24 RedisServer::with_modules [function] [call site] 00106
23 PathBuf::insert [function] [call site] 00107
24 TestContext::with_modules [function] [call site] 00108
25 TestContext::with_modules_and_tls [function] [call site] 00109
26 start_tls_crypto_provider [function] [call site] 00110
27 rustls::crypto::CryptoProvider::get_default [function] [call site] 00111
27 rustls::crypto::ring::default_provider [function] [call site] 00113
27 install_default [function] [call site] 00114
26 redis_test::utils::get_random_available_port [function] [call site] 00115
27 get_listener_on_free_port [function] [call site] 00116
27 TcpListener::local_addr [function] [call site] 00117
27 get_listener_on_free_port [function] [call site] 00119
26 RedisServer::get_addr [function] [call site] 00120
26 TestContext::with_modules_addr_and_tls [function] [call site] 00121
27 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00122
28 process::Command::new [function] [call site] 00123
29 RedisServer::with_modules [function] [call site] 00124
28 types::test_is_single_arg [function] [call site] 00125
28 types::test_is_single_arg [function] [call site] 00126
28 types::test_is_single_arg [function] [call site] 00127
28 entra_id_tests::get_env_var [function] [call site] 00128
28 String::expect [function] [call site] 00129
28 RedisServer::stdout [function] [call site] 00130
28 process::Stdio::piped [function] [call site] 00131
28 process::Stdio::piped [function] [call site] 00133
28 tempfile::Builder::new [function] [call site] 00134
29 &'a [call site] 00136
30 std::iter::once [function] [call site] 00137
30 basic::test_tuple_decoding_from_iter [function] [call site] 00139
31 TestContext::new [function] [call site] 00140
32 TestContext::with_modules [function] [call site] 00141
31 TestContext::connection [function] [call site] 00142
32 Client::get_connection [function] [call site] 00143
33 connect [function] [call site] 00144
34 Instant::now [function] [call site] 00145
34 ActualConnection::new [function] [call site] 00146
35 is_wildcard_address [function] [call site] 00148
35 fail [function] [call site] 00149
36 ::std::convert::From::from [function] [call site] 00151
35 connect_tcp [function] [call site] 00153
36 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 00154
37 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 00155
38 TestClusterContext::new_with_config_and_builder [function] [call site] 00156
39 support::start_tls_crypto_provider [function] [call site] 00157
40 rustls::crypto::CryptoProvider::get_default [function] [call site] 00158
40 rustls::crypto::ring::default_provider [function] [call site] 00160
40 install_default [function] [call site] 00161
39 RedisCluster::new [function] [call site] 00162
40 MockRedisConnection::is_empty [function] [call site] 00163
41 StreamReadOptions::block [function] [call site] 00164
41 MockRedisConnection::is_empty [function] [call site] 00166
40 &'a [call site] 00167
41 std::iter::once [function] [call site] 00168
41 basic::test_tuple_decoding_from_iter [function] [call site] 00170
40 std::iter::Chain::map [function] [call site] 00171
41 parse_redis_value [function] [call site] 00172
41 Value::Array [function] [call site] 00173
41 RedisServer::new [function] [call site] 00174
41 PathBuf::insert [function] [call site] 00175
41 &str::into [function] [call site] 00176
41 PathBuf::insert [function] [call site] 00177
41 &str::into [function] [call site] 00178
41 PathBuf::insert [function] [call site] 00179
41 &str::into [function] [call site] 00180
41 parse_redis_value [function] [call site] 00181
41 Value::Array [function] [call site] 00182
41 RedisServer::default [function] [call site] 00183
42 RedisServer::new [function] [call site] 00184
43 RedisServer::with_modules [function] [call site] 00185
41 HashMap::with_hasher [function] [call site] 00186
41 PathBuf::insert [function] [call site] 00187
41 &str::into [function] [call site] 00188
41 PathBuf::insert [function] [call site] 00189
41 &str::into [function] [call site] 00190
41 PathBuf::insert [function] [call site] 00191
41 &str::into [function] [call site] 00192
41 parse_redis_value [function] [call site] 00193
41 Value::Array [function] [call site] 00194
40 std::collections::HashSet::new [function] [call site] 00196
41 RedisServer::with_modules [function] [call site] 00197
40 ClusterType::get_intended [function] [call site] 00198
41 entra_id_tests::get_env_var [function] [call site] 00199
41 String::ok [function] [call site] 00200
41 types::test_hashmap [function] [call site] 00202
42 parse_redis_value [function] [call site] 00203
42 Value::Array [function] [call site] 00204
42 RedisServer::new [function] [call site] 00205
42 PathBuf::insert [function] [call site] 00206
42 &str::into [function] [call site] 00207
42 PathBuf::insert [function] [call site] 00208
42 &str::into [function] [call site] 00209
42 PathBuf::insert [function] [call site] 00210
42 &str::into [function] [call site] 00211
42 parse_redis_value [function] [call site] 00212
42 Value::Array [function] [call site] 00213
42 RedisServer::default [function] [call site] 00214
42 HashMap::with_hasher [function] [call site] 00215
42 PathBuf::insert [function] [call site] 00216
42 &str::into [function] [call site] 00217
42 PathBuf::insert [function] [call site] 00218
42 &str::into [function] [call site] 00219
42 PathBuf::insert [function] [call site] 00220
42 &str::into [function] [call site] 00221
42 parse_redis_value [function] [call site] 00222
42 Value::Array [function] [call site] 00223
40 tempfile::Builder::new [function] [call site] 00224
40 RedisResult::prefix [function] [call site] 00225
40 { [call site] 00228
0 server::build_keys_and_certs_for_tls_ext [function] [call site] 00229
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 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00238
41 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00240
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] 00242
42 process::Command::new [function] [call site] 00243
42 types::test_is_single_arg [function] [call site] 00244
42 types::test_is_single_arg [function] [call site] 00245
42 types::test_is_single_arg [function] [call site] 00246
42 types::test_is_single_arg [function] [call site] 00247
42 process::Stdio::piped [function] [call site] 00249
42 process::Stdio::piped [function] [call site] 00251
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] 00252
43 tokio::runtime::Handle::try_current [function] [call site] 00253
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] 00254
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] 00255
44 tokio::runtime::Handle::try_current [function] [call site] 00256
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] 00257
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] 00258
44 TaskHandle::detach [function] [call site] 00259
45 TaskHandle::detach [function] [call site] 00260
43 TaskHandle::detach [function] [call site] 00261
42 ClusterClientBuilder::max_retry_wait [function] [call site] 00263
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] 00265
41 process::Command::new [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 types::test_is_single_arg [function] [call site] 00276
41 types::test_is_single_arg [function] [call site] 00277
41 types::test_is_single_arg [function] [call site] 00278
41 types::test_is_single_arg [function] [call site] 00279
41 process::Stdio::piped [function] [call site] 00281
41 process::Stdio::piped [function] [call site] 00283
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] 00284
41 ClusterClientBuilder::max_retry_wait [function] [call site] 00286
41 Tokio::poll_write [function] [call site] 00288
42 RedisServer::new [function] [call site] 00289
43 RedisServer::with_modules [function] [call site] 00290
42 Tokio::poll_write [function] [call site] 00291
43 RedisServer::new [function] [call site] 00292
43 Tokio::poll_write [function] [call site] 00293
43 RedisServer::new [function] [call site] 00294
43 Tokio::poll_write [function] [call site] 00295
43 RedisServer::new [function] [call site] 00296
43 Tokio::poll_write [function] [call site] 00297
42 RedisServer::new [function] [call site] 00298
42 Tokio::poll_write [function] [call site] 00299
42 RedisServer::new [function] [call site] 00300
42 Tokio::poll_write [function] [call site] 00301
41 Poll::expect [function] [call site] 00302
41 process::Command::new [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 types::test_is_single_arg [function] [call site] 00307
41 types::test_is_single_arg [function] [call site] 00308
41 types::test_is_single_arg [function] [call site] 00309
41 types::test_is_single_arg [function] [call site] 00310
41 process::Stdio::piped [function] [call site] 00312
41 process::Stdio::piped [function] [call site] 00314
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] 00315
41 process::Command::new [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 types::test_is_single_arg [function] [call site] 00332
41 types::test_is_single_arg [function] [call site] 00333
41 types::test_is_single_arg [function] [call site] 00334
41 types::test_is_single_arg [function] [call site] 00335
41 Cmd::take [function] [call site] 00337
42 std::mem::take [function] [call site] 00338
43 std::mem::take [function] [call site] 00339
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] 00341
41 ClusterClientBuilder::max_retry_wait [function] [call site] 00343
41 ClusterClientBuilder::max_retry_wait [function] [call site] 00345
40 cluster_async::get_push [function] [call site] 00347
41 Pipeline::send_recv [function] [call site] 00348
41 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 00349
42 TestSentinelContext::new [function] [call site] 00350
43 TestSentinelContext::new_with_cluster_client_builder [function] [call site] 00351
44 support::start_tls_crypto_provider [function] [call site] 00352
44 RedisSentinelCluster::new [function] [call site] 00353
45 RedisSentinelCluster::with_modules [function] [call site] 00354
46 tempfile::Builder::new [function] [call site] 00355
46 RedisResult::prefix [function] [call site] 00356
46 { [call site] 00359
0 server::build_keys_and_certs_for_tls [function] [call site] 00360
47 build_keys_and_certs_for_tls_ext [function] [call site] 00361
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 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00370
48 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00372
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] 00374
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] 00375
48 process::Command::new [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 types::test_is_single_arg [function] [call site] 00386
48 types::test_is_single_arg [function] [call site] 00387
48 types::test_is_single_arg [function] [call site] 00388
48 types::test_is_single_arg [function] [call site] 00389
48 process::Stdio::piped [function] [call site] 00391
48 process::Stdio::piped [function] [call site] 00393
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] 00394
48 ClusterClientBuilder::max_retry_wait [function] [call site] 00396
48 Tokio::poll_write [function] [call site] 00398
48 Poll::expect [function] [call site] 00399
48 process::Command::new [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 types::test_is_single_arg [function] [call site] 00404
48 types::test_is_single_arg [function] [call site] 00405
48 types::test_is_single_arg [function] [call site] 00406
48 types::test_is_single_arg [function] [call site] 00407
48 process::Stdio::piped [function] [call site] 00409
48 process::Stdio::piped [function] [call site] 00411
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] 00412
48 process::Command::new [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 types::test_is_single_arg [function] [call site] 00429
48 types::test_is_single_arg [function] [call site] 00430
48 types::test_is_single_arg [function] [call site] 00431
48 types::test_is_single_arg [function] [call site] 00432
48 Cmd::take [function] [call site] 00434
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] 00436
48 ClusterClientBuilder::max_retry_wait [function] [call site] 00438
48 ClusterClientBuilder::max_retry_wait [function] [call site] 00440
46 cluster_async::get_push [function] [call site] 00442
46 std::collections::HashSet::new [function] [call site] 00443
46 basic::test_pipeline_len [function] [call site] 00444
47 redis::pipe [function] [call site] 00445
48 redis::pipe [function] [call site] 00446
48 Pipeline::atomic [function] [call site] 00447
48 redis::pipe [function] [call site] 00448
47 types::test_is_single_arg [function] [call site] 00451
46 RedisServer::insert [function] [call site] 00452
47 TestContext::with_modules [function] [call site] 00453
47 TestContext::connection [function] [call site] 00454
47 redis::Connection::json_set [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
47 redis::Connection::json_arr_insert [function] [call site] 00459
48 TestContext::with_modules [function] [call site] 00460
48 TestContext::connection [function] [call site] 00461
48 redis::Connection::json_set [function] [call site] 00462
48 redis::Connection::json_arr_insert [function] [call site] 00463
48 redis::Connection::json_set [function] [call site] 00464
48 redis::Connection::json_arr_insert [function] [call site] 00465
47 redis::Connection::json_set [function] [call site] 00466
47 redis::Connection::json_arr_insert [function] [call site] 00467
46 get_random_available_port [function] [call site] 00468
47 get_listener_on_free_port [function] [call site] 00469
47 TcpListener::local_addr [function] [call site] 00470
47 get_listener_on_free_port [function] [call site] 00472
46 &'a [call site] 00473
47 std::iter::once [function] [call site] 00474
47 basic::test_tuple_decoding_from_iter [function] [call site] 00476
46 std::iter::Chain::collect [function] [call site] 00477
46 RedisServer::pop [function] [call site] 00478
47 TestContext::with_modules [function] [call site] 00479
47 TestContext::connection [function] [call site] 00480
47 redis::Connection::json_set [function] [call site] 00481
47 redis::Connection::json_arr_pop [function] [call site] 00482
48 TestContext::with_modules [function] [call site] 00483
48 TestContext::connection [function] [call site] 00484
48 redis::Connection::json_set [function] [call site] 00485
48 redis::Connection::json_arr_pop [function] [call site] 00486
48 redis::Connection::json_set [function] [call site] 00487
48 redis::Connection::json_arr_pop [function] [call site] 00488
47 redis::Connection::json_set [function] [call site] 00489
47 redis::Connection::json_arr_pop [function] [call site] 00490
46 unwrap [function] [call site] 00491
46 tempfile::Builder::new [function] [call site] 00492
46 RedisResult::prefix [function] [call site] 00493
46 tempdir [function] [call site] 00494
46 expect [function] [call site] 00495
46 cluster_async::get_push [function] [call site] 00496
47 Pipeline::send_recv [function] [call site] 00497
47 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 00498
47 futures_time::time::Duration::from_millis [function] [call site] 00499
46 spawn_master_server [function] [call site] 00502
47 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00503
47 get_addr [function] [call site] 00504
48 RedisServer::get_addr [function] [call site] 00505
48 ConnectionAddr::Tcp [function] [call site] 00506
48 String::from [function] [call site] 00507
49 ValueComparison::arg_to_string [function] [call site] 00508
50 impl [call site] 00509
50 String::from_utf8_lossy [function] [call site] 00510
50 into_owned [function] [call site] 00511
49 ValueComparison::arg_to_string [function] [call site] 00512
49 ValueComparison::arg_to_string [function] [call site] 00513
49 ValueComparison::arg_to_string [function] [call site] 00514
49 ValueComparison::arg_to_string [function] [call site] 00515
49 ValueComparison::arg_to_string [function] [call site] 00516
47 ClientTlsParams::clone [function] [call site] 00518
48 ClientTlsParams::clone [function] [call site] 00519
49 ClientTlsParams::clone [function] [call site] 00520
49 secret_pkcs1_der [function] [call site] 00522
49 write_command_to_vec [function] [call site] 00523
50 args_len [function] [call site] 00524
51 countdigits [function] [call site] 00525
51 basic::test_pipeline_len [function] [call site] 00526
52 redis::pipe [function] [call site] 00527
52 types::test_is_single_arg [function] [call site] 00530
51 bulklen [function] [call site] 00531
52 countdigits [function] [call site] 00532
51 countdigits [function] [call site] 00533
51 basic::test_pipeline_len [function] [call site] 00534
50 ClientTlsParams::clone [function] [call site] 00535
50 Cmd::reserve [function] [call site] 00536
50 write_command [function] [call site] 00537
51 ::itoa::Buffer::new [function] [call site] 00538
52 RedisServer::with_modules [function] [call site] 00539
51 Cmd::write_all [function] [call site] 00540
51 RedisServer::format [function] [call site] 00541
51 basic::test_pipeline_len [function] [call site] 00542
51 Cmd::write_all [function] [call site] 00543
51 TlsFilePaths::as_bytes [function] [call site] 00544
51 Cmd::write_all [function] [call site] 00545
51 itoa::Buffer::new [function] [call site] 00546
52 RedisServer::with_modules [function] [call site] 00547
51 RedisServer::format [function] [call site] 00548
51 as_bytes [function] [call site] 00549
51 Cmd::write_all [function] [call site] 00550
51 RedisServer::format [function] [call site] 00551
51 basic::test_pipeline_len [function] [call site] 00552
52 redis::pipe [function] [call site] 00553
52 types::test_is_single_arg [function] [call site] 00556
51 Cmd::write_all [function] [call site] 00557
51 TlsFilePaths::as_bytes [function] [call site] 00558
51 Cmd::write_all [function] [call site] 00559
51 Cmd::write_all [function] [call site] 00560
51 Cmd::write_all [function] [call site] 00561
50 io::Result::unwrap [function] [call site] 00563
49 secret_pkcs8_der [function] [call site] 00566
49 write_command_to_vec [function] [call site] 00567
49 secret_sec1_der [function] [call site] 00570
49 write_command_to_vec [function] [call site] 00571
48 secret_pkcs1_der [function] [call site] 00574
48 write_command_to_vec [function] [call site] 00575
48 secret_pkcs8_der [function] [call site] 00578
48 write_command_to_vec [function] [call site] 00579
48 secret_sec1_der [function] [call site] 00582
48 write_command_to_vec [function] [call site] 00583
47 Cmd::arg [function] [call site] 00585
47 types::test_is_single_arg [function] [call site] 00586
47 Cmd::arg [function] [call site] 00587
47 types::test_is_single_arg [function] [call site] 00588
47 get_addr [function] [call site] 00589
47 Cmd::arg [function] [call site] 00590
47 types::test_is_single_arg [function] [call site] 00591
47 Cmd::current_dir [function] [call site] 00592
47 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00593
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] 00594
48 tokio::runtime::Handle::try_current [function] [call site] 00595
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] 00596
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] 00597
48 TaskHandle::detach [function] [call site] 00598
46 cluster_async::get_push [function] [call site] 00600
46 cluster_async::get_push [function] [call site] 00601
46 RedisServer::pop [function] [call site] 00602
46 unwrap [function] [call site] 00603
46 tempfile::Builder::new [function] [call site] 00604
46 RedisResult::prefix [function] [call site] 00605
46 tempdir [function] [call site] 00606
46 expect [function] [call site] 00607
46 cluster_async::get_push [function] [call site] 00608
46 spawn_replica_server [function] [call site] 00609
47 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00610
47 File::create [function] [call site] 00612
48 TestContext::new [function] [call site] 00613
48 TestContext::connection [function] [call site] 00614
48 xadd [function] [call site] 00615
49 &mut [call site] 00616
50 &mut [call site] 00617
50 &mut [call site] 00619
50 &mut [call site] 00621
50 &mut [call site] 00623
49 &mut [call site] 00626
49 &mut [call site] 00628
49 &mut [call site] 00630
48 redis::Connection::xinfo_stream [function] [call site] 00632
48 TestContext::connection [function] [call site] 00633
48 redis::Connection::xinfo_stream [function] [call site] 00634
48 redis::Connection::xgroup_create [function] [call site] 00636
49 TestContext::new [function] [call site] 00637
49 TestContext::connection [function] [call site] 00638
49 redis::Connection::xinfo_stream [function] [call site] 00640
49 TestContext::connection [function] [call site] 00641
49 redis::Connection::xinfo_stream [function] [call site] 00642
49 redis::Connection::xgroup_create [function] [call site] 00644
49 redis::Connection::xinfo_groups [function] [call site] 00645
48 redis::Connection::xinfo_groups [function] [call site] 00647
47 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00650
47 get_addr [function] [call site] 00651
47 ClientTlsParams::clone [function] [call site] 00654
47 Cmd::arg [function] [call site] 00655
47 types::test_is_single_arg [function] [call site] 00656
47 types::test_is_single_arg [function] [call site] 00657
47 ValueComparison::arg_to_string [function] [call site] 00658
48 impl [call site] 00659
48 String::from_utf8_lossy [function] [call site] 00660
48 into_owned [function] [call site] 00661
47 get_addr [function] [call site] 00662
47 Cmd::arg [function] [call site] 00663
47 types::test_is_single_arg [function] [call site] 00664
47 Cmd::arg [function] [call site] 00665
47 types::test_is_single_arg [function] [call site] 00666
47 Cmd::current_dir [function] [call site] 00667
47 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00668
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] 00669
46 cluster_async::get_push [function] [call site] 00671
46 wait_for_replicas_to_sync [function] [call site] 00672
47 basic::test_pipeline_len [function] [call site] 00673
48 redis::pipe [function] [call site] 00674
48 types::test_is_single_arg [function] [call site] 00677
47 basic::test_pipeline_len [function] [call site] 00678
47 RedisServer::connection_info [function] [call site] 00679
48 RedisServer::client_addr [function] [call site] 00680
48 &redis::ConnectionAddr::clone [function] [call site] 00681
49 ClientTlsParams::clone [function] [call site] 00682
49 secret_pkcs1_der [function] [call site] 00684
49 write_command_to_vec [function] [call site] 00685
49 secret_pkcs8_der [function] [call site] 00688
49 write_command_to_vec [function] [call site] 00689
49 secret_sec1_der [function] [call site] 00692
49 write_command_to_vec [function] [call site] 00693
48 ConnectionInfo::into_connection_info [function] [call site] 00695
48 RedisResult::unwrap [function] [call site] 00697
48 ConnectionInfo::set_redis_settings [function] [call site] 00698
48 redis_settings [function] [call site] 00699
49 RedisServer::default [function] [call site] 00700
50 RedisServer::new [function] [call site] 00701
49 RedisConnectionInfo::set_protocol [function] [call site] 00702
49 use_protocol [function] [call site] 00703
50 entra_id_tests::get_env_var [function] [call site] 00704
50 String::unwrap_or_default [function] [call site] 00705
47 wait_for_master_server [function] [call site] 00706
48 redis::cmd [function] [call site] 00707
49 redis::cmd [function] [call site] 00708
49 Cmd::set_cache_config [function] [call site] 00709
49 CommandCacheConfig::new [function] [call site] 00711
49 CommandCacheConfig::set_enable_cache [function] [call site] 00712
48 Client::get_connection [function] [call site] 00713
48 redis::Cmd::query [function] [call site] 00714
49 ConnectionLike::req_command [function] [call site] 00715
50 Cmd::get_packed_command [function] [call site] 00716
51 RedisServer::new [function] [call site] 00717
52 RedisServer::with_modules [function] [call site] 00718
51 Cmd::is_empty [function] [call site] 00719
52 MockRedisConnection::is_empty [function] [call site] 00720
51 Cmd::write_packed_command [function] [call site] 00721
52 write_command_to_vec [function] [call site] 00722
53 args_len [function] [call site] 00723
53 ClientTlsParams::clone [function] [call site] 00724
53 Cmd::reserve [function] [call site] 00725
53 write_command [function] [call site] 00726
53 io::Result::unwrap [function] [call site] 00727
52 Cmd::args_iter [function] [call site] 00728
53 basic::test_tuple_decoding_from_iter [function] [call site] 00729
53 types::test_hashmap [function] [call site] 00730
53 Arg::Simple [function] [call site] 00731
52 unwrap_or [function] [call site] 00732
50 MockRedisConnection::req_packed_command [function] [call site] 00733
51 Cmd::get_packed_command [function] [call site] 00734
51 MockRedisConnection::req_packed_command [function] [call site] 00735
52 Cmd::get_packed_command [function] [call site] 00736
52 MockRedisConnection::req_packed_command [function] [call site] 00737
52 as_slice [function] [call site] 00738
52 PipelineSink::poll_ready [function] [call site] 00739
53 PipelineSink::as_mut [function] [call site] 00740
53 PipelineSink::poll_ready [function] [call site] 00742
54 PipelineSink::as_mut [function] [call site] 00743
54 PipelineSink::poll_ready [function] [call site] 00745
52 types::test_parse_boxed [function] [call site] 00748
53 ValueComparison::arg_to_string [function] [call site] 00749
53 parse_redis_value [function] [call site] 00750
53 Value::SimpleString [function] [call site] 00751
53 ClientTlsParams::clone [function] [call site] 00752
54 ClientTlsParams::clone [function] [call site] 00753
54 secret_pkcs1_der [function] [call site] 00755
54 write_command_to_vec [function] [call site] 00756
54 secret_pkcs8_der [function] [call site] 00759
54 write_command_to_vec [function] [call site] 00760
54 secret_sec1_der [function] [call site] 00763
54 write_command_to_vec [function] [call site] 00764
51 as_slice [function] [call site] 00766
51 PipelineSink::poll_ready [function] [call site] 00767
51 types::test_parse_boxed [function] [call site] 00768
49 RedisResult::from_redis_value [function] [call site] 00770
49 Value::extract_error [function] [call site] 00777
50 Self::Array [function] [call site] 00779
50 Value::extract_error_vec [function] [call site] 00780
51 &'a [call site] 00781
52 std::iter::once [function] [call site] 00782
52 basic::test_tuple_decoding_from_iter [function] [call site] 00784
51 std::iter::Chain::map [function] [call site] 00785
51 into_iter() [call site] 00786
6 .map(Self::extract_error) [call site] 00787
6 .collect::<RedisResult<Vec<_>>> [function] [call site] 00788
50 Self::Map [function] [call site] 00790
50 Value::extract_error_map [function] [call site] 00791
51 Cmd::with_capacity [function] [call site] 00792
52 Cmd::with_capacity [function] [call site] 00793
52 Cmd::with_capacity [function] [call site] 00794
51 basic::test_pipeline_len [function] [call site] 00795
51 &'a [call site] 00796
51 cluster_async::get_push [function] [call site] 00797
51 Value::extract_error [function] [call site] 00798
51 impl [call site] 00799
52 Self::Array [function] [call site] 00801
52 Value::extract_error_vec [function] [call site] 00802
52 Self::Map [function] [call site] 00804
52 Value::extract_error_map [function] [call site] 00805
52 RedisServer::new [function] [call site] 00806
53 RedisServer::with_modules [function] [call site] 00807
52 Value::extract_error [function] [call site] 00808
52 Value::extract_error_map [function] [call site] 00809
52 Self::Set [function] [call site] 00812
52 Value::extract_error_vec [function] [call site] 00813
52 Value::extract_error_vec [function] [call site] 00815
50 RedisServer::new [function] [call site] 00820
50 Value::extract_error [function] [call site] 00821
50 Value::extract_error_map [function] [call site] 00822
50 Self::Set [function] [call site] 00825
50 Value::extract_error_vec [function] [call site] 00826
50 Value::extract_error_vec [function] [call site] 00828
49 Err [function] [call site] 00832
48 RedisResult::unwrap [function] [call site] 00833
48 String::from_redis_value_ref [function] [call site] 00834
49 get_inner_value [function] [call site] 00835
49 std::str::from_utf8 [function] [call site] 00838
49 ValueComparison::arg_to_string [function] [call site] 00839
50 impl [call site] 00840
50 String::from_utf8_lossy [function] [call site] 00841
50 into_owned [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
49 ValueComparison::arg_to_string [function] [call site] 00850
49 ValueComparison::arg_to_string [function] [call site] 00852
48 ConnectionAddr::first [function] [call site] 00853
48 unwrap [function] [call site] 00854
48 Result::unwrap [function] [call site] 00855
48 starts_with [function] [call site] 00856
48 Ok [function] [call site] 00857
48 std::thread::sleep [function] [call site] 00858
49 tokio::time::sleep [function] [call site] 00859
50 tokio::time::sleep [function] [call site] 00860
50 smol::Timer::after [function] [call site] 00861
49 smol::Timer::after [function] [call site] 00862
48 Duration::from_millis [function] [call site] 00863
48 Err [function] [call site] 00864
47 redis::Client::open [function] [call site] 00865
48 ConnectionInfo::into_connection_info [function] [call site] 00867
47 ClientTlsParams::clone [function] [call site] 00869
47 ConnectionAddr::is_err [function] [call site] 00870
48 is_unexpected_end_of_input [function] [call site] 00872
48 RedisError::from [function] [call site] 00873
48 io::Error::from [function] [call site] 00874
48 map_range [function] [call site] 00875
48 map_position [function] [call site] 00876
48 translate_position [function] [call site] 00877
48 to_string [function] [call site] 00879
48 RedisError::from [function] [call site] 00880
48 ParsingError::from [function] [call site] 00881
47 RedisServer::connection_info [function] [call site] 00882
47 wait_for_replica [function] [call site] 00883
48 redis::cmd [function] [call site] 00884
48 Client::get_connection [function] [call site] 00885
48 redis::Cmd::query [function] [call site] 00886
48 RedisResult::unwrap [function] [call site] 00887
48 String::from_redis_value_ref [function] [call site] 00888
48 ConnectionAddr::first [function] [call site] 00889
48 Result::unwrap [function] [call site] 00891
48 String::from_redis_value_ref [function] [call site] 00892
48 ConnectionAddr::get [function] [call site] 00893
49 TestContext::new [function] [call site] 00894
49 ProtocolVersion::supports_resp3 [function] [call site] 00895
49 TestContext::async_connection_with_cache [function] [call site] 00896
50 TestContext::async_connection_with_cache_config [function] [call site] 00897
51 ClientTlsParams::clone [function] [call site] 00898
51 Client::get_multiplexed_async_connection_with_config [function] [call site] 00899
52 Runtime::locate [function] [call site] 00900
53 cache_mget [function] [call site] 00901
54 TestContext::new [function] [call site] 00902
54 ProtocolVersion::supports_resp3 [function] [call site] 00903
54 TestContext::async_connection_with_cache [function] [call site] 00904
54 get_pipe [function] [call site] 00906
55 redis::pipe [function] [call site] 00907
55 Pipeline::atomic [function] [call site] 00908
55 redis::pipe [function] [call site] 00909
54 redis::Pipeline::cmd [function] [call site] 00910
55 redis::cmd [function] [call site] 00911
55 Cmd::set_cache_config [function] [call site] 00912
55 CommandCacheConfig::new [function] [call site] 00913
55 CommandCacheConfig::set_enable_cache [function] [call site] 00914
54 redis::Cmd::arg [function] [call site] 00915
55 SetExpiry::write_redis_args [function] [call site] 00916
54 types::test_is_single_arg [function] [call site] 00917
54 types::test_is_single_arg [function] [call site] 00920
54 types::test_is_single_arg [function] [call site] 00921
54 Cmd::query_async [function] [call site] 00923
55 &mut [call site] 00924
56 Cmd::get_packed_command [function] [call site] 00925
56 MockRedisConnection::req_packed_command [function] [call site] 00926
56 as_slice [function] [call site] 00927
56 PipelineSink::poll_ready [function] [call site] 00928
56 types::test_parse_boxed [function] [call site] 00929
55 RedisResult::from_redis_value [function] [call site] 00931
55 Value::extract_error [function] [call site] 00932
54 redis::cmd [function] [call site] 00934
54 redis::Cmd::arg [function] [call site] 00935
54 types::test_is_single_arg [function] [call site] 00936
54 Cmd::query_async [function] [call site] 00937
54 assert_hit [function] [call site] 00939
54 assert_miss [function] [call site] 00940
54 redis::cmd [function] [call site] 00941
54 redis::Cmd::arg [function] [call site] 00942
54 types::test_is_single_arg [function] [call site] 00943
54 types::test_is_single_arg [function] [call site] 00944
54 Cmd::query_async [function] [call site] 00945
54 assert_hit [function] [call site] 00947
54 assert_miss [function] [call site] 00948
54 redis::cmd [function] [call site] 00949
54 redis::Cmd::arg [function] [call site] 00950
54 Cmd::query_async [function] [call site] 00951
55 &mut [call site] 00952
55 RedisResult::from_redis_value [function] [call site] 00954
55 Value::extract_error [function] [call site] 00955
54 assert_hit [function] [call site] 00957
54 assert_miss [function] [call site] 00958
52 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::tokio::Tokio> [function] [call site] 00959
52 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::smol::Smol> [function] [call site] 00960
51 AsyncConnectionConfig::new [function] [call site] 00961
52 RedisServer::default [function] [call site] 00962
53 RedisServer::new [function] [call site] 00963
51 Cmd::set_cache_config [function] [call site] 00964
50 CacheConfig::default [function] [call site] 00966
51 CacheConfig::new [function] [call site] 00967
52 RedisServer::new [function] [call site] 00968
53 RedisServer::with_modules [function] [call site] 00969
52 RedisServer::unwrap [function] [call site] 00970
52 Duration::from_secs [function] [call site] 00971
49 get_pipe [function] [call site] 00973
49 redis::Pipeline::cmd [function] [call site] 00974
49 redis::Cmd::arg [function] [call site] 00975
49 types::test_is_single_arg [function] [call site] 00976
49 types::test_is_single_arg [function] [call site] 00979
49 types::test_is_single_arg [function] [call site] 00980
49 Cmd::query_async [function] [call site] 00982
49 redis::cmd [function] [call site] 00984
49 redis::Cmd::arg [function] [call site] 00985
49 types::test_is_single_arg [function] [call site] 00986
49 Cmd::query_async [function] [call site] 00987
49 assert_hit [function] [call site] 00989
49 assert_miss [function] [call site] 00990
49 redis::cmd [function] [call site] 00991
49 redis::Cmd::arg [function] [call site] 00992
49 types::test_is_single_arg [function] [call site] 00993
49 types::test_is_single_arg [function] [call site] 00994
49 Cmd::query_async [function] [call site] 00995
49 assert_hit [function] [call site] 00997
49 assert_miss [function] [call site] 00998
49 redis::cmd [function] [call site] 00999
49 redis::Cmd::arg [function] [call site] 01000
49 Cmd::query_async [function] [call site] 01001
49 assert_hit [function] [call site] 01003
49 assert_miss [function] [call site] 01004
48 Result::unwrap [function] [call site] 01006
48 starts_with [function] [call site] 01007
48 std::thread::sleep [function] [call site] 01009
48 Duration::from_millis [function] [call site] 01010
47 redis::Client::open [function] [call site] 01012
47 ClientTlsParams::clone [function] [call site] 01013
47 ConnectionAddr::is_err [function] [call site] 01014
46 RedisServer::pop [function] [call site] 01015
46 unwrap [function] [call site] 01016
46 tempfile::Builder::new [function] [call site] 01017
46 RedisResult::prefix [function] [call site] 01018
46 tempdir [function] [call site] 01019
46 expect [function] [call site] 01020
46 cluster_async::get_push [function] [call site] 01021
46 spawn_sentinel_server [function] [call site] 01022
47 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01023
47 File::create [function] [call site] 01025
47 basic::test_tuple_decoding_from_iter [function] [call site] 01027
48 TestContext::new [function] [call site] 01028
48 TestContext::connection [function] [call site] 01029
48 ValueType::from [function] [call site] 01030
49 TlsFilePaths::as_ref [function] [call site] 01031
49 ValueType::Unknown [function] [call site] 01032
49 ValueComparison::arg_to_string [function] [call site] 01033
48 basic::test_tuple_decoding_from_iter [function] [call site] 01034
48 hscan::<_, [call site] 01035
47 enumerate [function] [call site] 01038
47 PathBuf::write_all [function] [call site] 01039
47 as_bytes [function] [call site] 01040
47 PipelineSink::poll_flush [function] [call site] 01042
48 PipelineSink::poll_read [function] [call site] 01043
49 PipelineSink::as_mut [function] [call site] 01044
49 ResultExpectation::is_closed [function] [call site] 01046
50 ResultExpectation::is_closed [function] [call site] 01047
51 ResultExpectation::is_closed [function] [call site] 01048
49 Poll::Ready [function] [call site] 01049
49 Poll::Ready [function] [call site] 01051
49 PipelineSink::as_mut [function] [call site] 01053
49 PipelineSink::handle_message [function] [call site] 01054
50 PipelineSink::project [function] [call site] 01055
50 impl [call site] 01056
50 pop_front [function] [call site] 01057
50 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01058
50 Value::Array [function] [call site] 01060
50 Msg::from_owned_value [function] [call site] 01062
51 Msg::from_push_info [function] [call site] 01063
52 &'a [call site] 01064
52 MapIter::next [function] [call site] 01065
53 MapIter::next [function] [call site] 01067
53 MapIter::next [function] [call site] 01068
53 MapIter::next [function] [call site] 01069
52 MapIter::next [function] [call site] 01071
52 MapIter::next [function] [call site] 01073
52 MapIter::next [function] [call site] 01074
52 MapIter::next [function] [call site] 01075
51 from_redis_value [function] [call site] 01077
51 Result::ok [function] [call site] 01078
52 RedisServer::log_file [function] [call site] 01079
52 std::fs::read_to_string [function] [call site] 01080
52 Option::contains [function] [call site] 01082
52 std::thread::sleep [function] [call site] 01083
52 Duration::from_millis [function] [call site] 01084
51 &'a [call site] 01085
51 from_redis_value [function] [call site] 01086
51 MapIter::next [function] [call site] 01087
51 Result::ok [function] [call site] 01088
51 MapIter::next [function] [call site] 01089
51 MapIter::next [function] [call site] 01090
51 MapIter::next [function] [call site] 01092
51 MapIter::next [function] [call site] 01093
51 MapIter::next [function] [call site] 01094
50 Value::Array [function] [call site] 01096
50 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01097
50 PushKind::has_reply [function] [call site] 01100
50 pop_front [function] [call site] 01101
50 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01102
50 Msg::from_push_info [function] [call site] 01105
51 &'a [call site] 01106
51 MapIter::next [function] [call site] 01107
51 MapIter::next [function] [call site] 01108
51 MapIter::next [function] [call site] 01110
51 MapIter::next [function] [call site] 01111
51 MapIter::next [function] [call site] 01112
50 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01114
50 RedisError::is_unrecoverable_error [function] [call site] 01117
51 RedisError::retry_method [function] [call site] 01118
52 RedisError::kind [function] [call site] 01119
53 get_push_kind [function] [call site] 01120
54 PushKind::as_str [function] [call site] 01121
54 PushKind::Other [function] [call site] 01122
53 ErrorKind::Server [function] [call site] 01123
53 and_then [function] [call site] 01125
53 get_push_kind [function] [call site] 01126
53 types::test_hashmap [function] [call site] 01127
53 PushKind::into [function] [call site] 01128
53 unwrap_or [function] [call site] 01129
53 ErrorKind::Server [function] [call site] 01130
52 RedisError::retry_method [function] [call site] 01131
53 RedisError::kind [function] [call site] 01132
53 RedisError::retry_method [function] [call site] 01133
53 RedisError::is_connection_dropped [function] [call site] 01134
54 RedisError::as_io_error [function] [call site] 01135
55 downcast_ref [function] [call site] 01136
54 Option::is_some_and [function] [call site] 01137
53 RedisError::as_io_error [function] [call site] 01138
53 types::test_hashmap [function] [call site] 01139
54 parse_redis_value [function] [call site] 01140
54 Value::Array [function] [call site] 01141
54 RedisServer::new [function] [call site] 01142
54 PathBuf::insert [function] [call site] 01143
54 &str::into [function] [call site] 01144
54 PathBuf::insert [function] [call site] 01145
54 &str::into [function] [call site] 01146
54 PathBuf::insert [function] [call site] 01147
54 &str::into [function] [call site] 01148
54 parse_redis_value [function] [call site] 01149
54 Value::Array [function] [call site] 01150
54 RedisServer::default [function] [call site] 01151
54 HashMap::with_hasher [function] [call site] 01152
54 PathBuf::insert [function] [call site] 01153
54 &str::into [function] [call site] 01154
54 PathBuf::insert [function] [call site] 01155
54 &str::into [function] [call site] 01156
54 PathBuf::insert [function] [call site] 01157
54 &str::into [function] [call site] 01158
54 parse_redis_value [function] [call site] 01159
54 Value::Array [function] [call site] 01160
53 get_push_kind [function] [call site] 01161
53 unwrap_or [function] [call site] 01162
52 RedisError::is_connection_dropped [function] [call site] 01163
52 RedisError::as_io_error [function] [call site] 01164
52 types::test_hashmap [function] [call site] 01165
52 get_push_kind [function] [call site] 01166
52 unwrap_or [function] [call site] 01167
50 pop_front [function] [call site] 01169
50 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01170
47 Poll::unwrap [function] [call site] 01173
47 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 01174
47 get_addr [function] [call site] 01175
47 ClientTlsParams::clone [function] [call site] 01178
47 Cmd::arg [function] [call site] 01179
47 Cmd::arg [function] [call site] 01180
47 types::test_is_single_arg [function] [call site] 01181
47 get_addr [function] [call site] 01182
47 Cmd::arg [function] [call site] 01183
47 types::test_is_single_arg [function] [call site] 01184
47 Cmd::current_dir [function] [call site] 01185
47 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01186
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] 01187
46 cluster_async::get_push [function] [call site] 01189
44 RedisSentinelCluster::iter_sentinel_servers [function] [call site] 01190
45 basic::test_tuple_decoding_from_iter [function] [call site] 01191
44 types::test_hashmap [function] [call site] 01192
45 parse_redis_value [function] [call site] 01193
45 Value::Array [function] [call site] 01194
45 RedisServer::new [function] [call site] 01195
45 PathBuf::insert [function] [call site] 01196
45 &str::into [function] [call site] 01197
45 PathBuf::insert [function] [call site] 01198
45 &str::into [function] [call site] 01199
45 PathBuf::insert [function] [call site] 01200
45 &str::into [function] [call site] 01201
45 parse_redis_value [function] [call site] 01202
45 Value::Array [function] [call site] 01203
45 RedisServer::default [function] [call site] 01204
45 HashMap::with_hasher [function] [call site] 01205
45 PathBuf::insert [function] [call site] 01206
45 &str::into [function] [call site] 01207
45 PathBuf::insert [function] [call site] 01208
45 &str::into [function] [call site] 01209
45 PathBuf::insert [function] [call site] 01210
45 &str::into [function] [call site] 01211
45 parse_redis_value [function] [call site] 01212
45 Value::Array [function] [call site] 01213
44 collect [function] [call site] 01214
44 redis::sentinel::Sentinel::build [function] [call site] 01215
45 Sentinel::build_inner [function] [call site] 01216
46 MockRedisConnection::is_empty [function] [call site] 01217
47 StreamReadOptions::block [function] [call site] 01218
47 MockRedisConnection::is_empty [function] [call site] 01220
46 &'a [call site] 01222
47 std::iter::once [function] [call site] 01223
47 basic::test_tuple_decoding_from_iter [function] [call site] 01225
46 std::iter::Chain::map [function] [call site] 01226
46 ConnectionInfo::into_connection_info [function] [call site] 01227
46 into_iter() [call site] 01229
6 .map(|p| [call site] 01230
6 .collect::<RedisResult<Vec<ConnectionInfo>>> [function] [call site] 01231
46 basic::test_tuple_decoding_from_iter [function] [call site] 01232
47 TestContext::new [function] [call site] 01233
47 TestContext::connection [function] [call site] 01234
47 ValueType::from [function] [call site] 01235
47 basic::test_tuple_decoding_from_iter [function] [call site] 01236
47 hscan::<_, [call site] 01237
46 cluster::test_cluster_reconnect_after_complete_server_disconnect_route_to_many [function] [call site] 01240
47 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 01241
47 cluster::test_cluster_retries [function] [call site] 01242
48 atomic::AtomicUsize::new [function] [call site] 01243
49 RedisServer::with_modules [function] [call site] 01244
48 MockEnv::with_client_builder [function] [call site] 01245
49 tokio::runtime::Builder::new_current_thread [function] [call site] 01246
49 enable_io [function] [call site] 01247
49 enable_time [function] [call site] 01248
49 Sentinel::build [function] [call site] 01249
50 Sentinel::build_inner [function] [call site] 01250
49 ValueComparison::arg_to_string [function] [call site] 01252
49 Tokio::poll_write [function] [call site] 01253
50 RedisServer::new [function] [call site] 01254
50 Tokio::poll_write [function] [call site] 01255
50 RedisServer::new [function] [call site] 01256
50 Tokio::poll_write [function] [call site] 01257
50 RedisServer::new [function] [call site] 01258
50 Tokio::poll_write [function] [call site] 01259
49 test_module_json_arr_insert [function] [call site] 01261
50 TestContext::with_modules [function] [call site] 01262
50 TestContext::connection [function] [call site] 01263
50 redis::Connection::json_set [function] [call site] 01264
50 redis::Connection::json_arr_insert [function] [call site] 01265
50 redis::Connection::json_set [function] [call site] 01266
50 redis::Connection::json_arr_insert [function] [call site] 01267
49 ClientTlsParams::clone [function] [call site] 01268
49 RedisServer::new [function] [call site] 01269
50 RedisServer::with_modules [function] [call site] 01270
49 Sentinel::build [function] [call site] 01271
49 RedisResult::unwrap [function] [call site] 01272
49 ClusterClient::get_generic_connection [function] [call site] 01273
50 cluster::ClusterConnection::new [function] [call site] 01274
51 ClusterConnection::new_inner [function] [call site] 01275
52 unwrap_or_default [function] [call site] 01276
52 ClientTlsParams::clone [function] [call site] 01277
52 Runtime::locate [function] [call site] 01278
52 ClusterConnInner::new [function] [call site] 01279
53 RedisServer::new [function] [call site] 01282
54 RedisServer::with_modules [function] [call site] 01283
53 RedisServer::default [function] [call site] 01284
54 RedisServer::new [function] [call site] 01285
53 RedisServer::new [function] [call site] 01286
53 RedisServer::new [function] [call site] 01287
54 RedisServer::with_modules [function] [call site] 01288
53 RedisServer::default [function] [call site] 01289
54 RedisServer::new [function] [call site] 01290
53 SlotMap::new [function] [call site] 01291
54 RedisServer::default [function] [call site] 01292
53 RedisServer::new [function] [call site] 01293
53 RedisServer::new [function] [call site] 01294
53 write_command_to_vec [function] [call site] 01295
53 ClientTlsParams::clone [function] [call site] 01297
54 ClientTlsParams::clone [function] [call site] 01298
54 secret_pkcs1_der [function] [call site] 01300
54 write_command_to_vec [function] [call site] 01301
54 secret_pkcs8_der [function] [call site] 01304
54 write_command_to_vec [function] [call site] 01305
54 secret_sec1_der [function] [call site] 01308
54 write_command_to_vec [function] [call site] 01309
53 RedisServer::default [function] [call site] 01311
53 ConnectionState::Recover [function] [call site] 01312
53 RecoverFuture::Reconnect [function] [call site] 01313
53 Box::pin [function] [call site] 01314
53 ClusterConnInner::reconnect_to_initial_nodes [function] [call site] 01315
54 ClientTlsParams::clone [function] [call site] 01316
54 ClusterConnection::create_initial_connections [function] [call site] 01317
55 Cmd::with_capacity [function] [call site] 01318
56 Cmd::with_capacity [function] [call site] 01319
56 Cmd::with_capacity [function] [call site] 01320
55 basic::test_pipeline_len [function] [call site] 01321
55 RedisServer::new [function] [call site] 01322
55 basic::test_tuple_decoding_from_iter [function] [call site] 01323
55 ValueComparison::arg_to_string [function] [call site] 01324
55 ClusterConnection::connect [function] [call site] 01326
56 Client::get_connection_info [function] [call site] 01327
56 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 01328
57 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 01329
57 cluster::test_cluster_retries [function] [call site] 01330
57 TestClusterContext::get_ports [function] [call site] 01331
58 basic::test_tuple_decoding_from_iter [function] [call site] 01332
58 types::test_hashmap [function] [call site] 01333
58 redis::ConnectionInfo::addr [function] [call site] 01334
57 MockRedisConnection::check_connection [function] [call site] 01336
57 RedisServer::drop [function] [call site] 01337
58 RedisServer::stop [function] [call site] 01338
59 ClusterClientBuilder::max_retry_wait [function] [call site] 01340
59 RedisServer::client_addr [function] [call site] 01341
59 fs::remove_file [function] [call site] 01342
59 wait_for_status_ok [function] [call site] 01343
60 RedisServer::log_file [function] [call site] 01344
60 std::fs::read_to_string [function] [call site] 01345
60 Option::contains [function] [call site] 01347
60 std::thread::sleep [function] [call site] 01348
60 Duration::from_millis [function] [call site] 01349
57 ClusterConnection::route_command [function] [call site] 01351
58 Msg::get_channel [function] [call site] 01352
58 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01353
58 RedisServer::new [function] [call site] 01354
58 RouteBy::into [function] [call site] 01355
58 RedisError::from [function] [call site] 01357
59 io::Error::from [function] [call site] 01358
60 io::Error::from [function] [call site] 01359
60 Self::into [function] [call site] 01360
59 Self::into [function] [call site] 01361
58 io::Error::new [function] [call site] 01362
59 RedisServer::with_modules [function] [call site] 01363
58 unwrap_or_else [function] [call site] 01364
58 RedisError::from [function] [call site] 01366
58 io::Error::new [function] [call site] 01367
58 types::test_hashmap [function] [call site] 01368
58 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 01369
59 TestSentinelContext::new [function] [call site] 01370
59 SentinelClient::build [function] [call site] 01371
60 Sentinel::build_inner [function] [call site] 01372
59 TestSentinelContext::sentinels_connection_info [function] [call site] 01373
59 ClientTlsParams::clone [function] [call site] 01374
60 ClientTlsParams::clone [function] [call site] 01375
60 secret_pkcs1_der [function] [call site] 01377
60 write_command_to_vec [function] [call site] 01378
60 secret_pkcs8_der [function] [call site] 01381
60 write_command_to_vec [function] [call site] 01382
60 secret_sec1_der [function] [call site] 01385
60 write_command_to_vec [function] [call site] 01386
59 String::from [function] [call site] 01388
59 TestSentinelContext::sentinel_node_connection_info [function] [call site] 01390
60 TestSentinelContext::tls_mode [function] [call site] 01391
61 RedisServer::client_addr [function] [call site] 01392
60 &SentinelNodeConnectionInfo::default [function] [call site] 01395
60 SentinelNodeConnectionInfo::set_tls_mode [function] [call site] 01396
60 &SentinelNodeConnectionInfo::default [function] [call site] 01398
59 RedisResult::unwrap [function] [call site] 01399
59 SentinelClient::build [function] [call site] 01400
59 TestSentinelContext::sentinels_connection_info [function] [call site] 01401
59 ClientTlsParams::clone [function] [call site] 01402
59 String::from [function] [call site] 01403
59 TestSentinelContext::sentinel_node_connection_info [function] [call site] 01405
59 RedisResult::unwrap [function] [call site] 01406
59 AsyncConnectionConfig::new [function] [call site] 01407
59 AsyncConnectionConfig::set_connection_timeout [function] [call site] 01408
59 Duration::from_secs [function] [call site] 01410
59 SentinelClient::get_async_connection_with_config [function] [call site] 01411
60 SentinelClient::async_get_client [function] [call site] 01412
61 Sentinel::async_master_for [function] [call site] 01413
62 Sentinel::async_find_master_address [function] [call site] 01414
63 Sentinel::async_get_sentinel_masters [function] [call site] 01415
64 Sentinel::async_try_all_sentinels [function] [call site] 01416
65 basic::test_tuple_decoding_from_iter [function] [call site] 01417
65 iter_mut [function] [call site] 01419
65 async_try_single_sentinel [function] [call site] 01420
66 &mut [call site] 01421
66 async_reconnect [function] [call site] 01422
67 Client::open [function] [call site] 01423
68 ConnectionInfo::into_connection_info [function] [call site] 01425
67 redis::ConnectionInfo::clone [function] [call site] 01426
68 ClientTlsParams::clone [function] [call site] 01427
68 secret_pkcs1_der [function] [call site] 01429
68 write_command_to_vec [function] [call site] 01430
68 secret_pkcs8_der [function] [call site] 01433
68 write_command_to_vec [function] [call site] 01434
68 secret_sec1_der [function] [call site] 01437
68 write_command_to_vec [function] [call site] 01438
67 Client::get_multiplexed_async_connection [function] [call site] 01440
68 Client::get_multiplexed_async_connection_with_config [function] [call site] 01441
69 Runtime::locate [function] [call site] 01442
69 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::tokio::Tokio> [function] [call site] 01443
69 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::smol::Smol> [function] [call site] 01444
68 AsyncConnectionConfig::new [function] [call site] 01445
67 CopyOptions::replace [function] [call site] 01446
66 Cmd::query_async [function] [call site] 01448
67 &mut [call site] 01449
67 RedisResult::from_redis_value [function] [call site] 01451
67 Value::extract_error [function] [call site] 01452
66 &mut [call site] 01453
66 RedisError::is_unrecoverable_error [function] [call site] 01455
66 types::test_is_io_error [function] [call site] 01456
67 RedisError::from [function] [call site] 01457
66 async_reconnect [function] [call site] 01458
66 Cmd::query_async [function] [call site] 01459
66 &mut [call site] 01460
65 ClientTlsParams::clone [function] [call site] 01463
66 ClientTlsParams::clone [function] [call site] 01464
66 secret_pkcs1_der [function] [call site] 01466
66 write_command_to_vec [function] [call site] 01467
66 secret_pkcs8_der [function] [call site] 01470
66 write_command_to_vec [function] [call site] 01471
66 secret_sec1_der [function] [call site] 01474
66 write_command_to_vec [function] [call site] 01475
65 None::expect [function] [call site] 01480
64 sentinel_masters_cmd [function] [call site] 01481
65 crate::cmd [function] [call site] 01482
66 redis::cmd [function] [call site] 01483
66 Cmd::set_cache_config [function] [call site] 01484
66 CommandCacheConfig::new [function] [call site] 01485
66 CommandCacheConfig::set_enable_cache [function] [call site] 01486
65 Cmd::arg [function] [call site] 01487
63 async_find_valid_master [function] [call site] 01488
64 valid_addrs [function] [call site] 01489
65 &'a [call site] 01490
66 std::iter::once [function] [call site] 01491
66 basic::test_tuple_decoding_from_iter [function] [call site] 01493
65 std::iter::Chain::filter [function] [call site] 01494
65 types::test_hashmap [function] [call site] 01495
65 redis::ConnectionInfo::remove [function] [call site] 01496
65 parse::<u16> [function] [call site] 01498
64 is_master_valid [function] [call site] 01500
65 &HashMap<String, [call site] 01501
66 TestContext::new [function] [call site] 01502
66 ProtocolVersion::supports_resp3 [function] [call site] 01503
66 TestContext::async_connection_with_cache [function] [call site] 01504
66 get_pipe [function] [call site] 01506
66 redis::Pipeline::cmd [function] [call site] 01507
66 redis::Cmd::arg [function] [call site] 01508
66 types::test_is_single_arg [function] [call site] 01509
66 types::test_is_single_arg [function] [call site] 01512
66 types::test_is_single_arg [function] [call site] 01513
66 Cmd::query_async [function] [call site] 01515
66 redis::cmd [function] [call site] 01517
66 redis::Cmd::arg [function] [call site] 01518
66 types::test_is_single_arg [function] [call site] 01519
66 Cmd::query_async [function] [call site] 01520
66 assert_hit [function] [call site] 01522
66 assert_miss [function] [call site] 01523
66 redis::cmd [function] [call site] 01524
66 redis::Cmd::arg [function] [call site] 01525
66 types::test_is_single_arg [function] [call site] 01526
66 types::test_is_single_arg [function] [call site] 01527
66 Cmd::query_async [function] [call site] 01528
66 assert_hit [function] [call site] 01530
66 assert_miss [function] [call site] 01531
66 redis::cmd [function] [call site] 01532
66 redis::Cmd::arg [function] [call site] 01533
66 Cmd::query_async [function] [call site] 01534
66 assert_hit [function] [call site] 01536
66 assert_miss [function] [call site] 01537
65 types::test_hashmap [function] [call site] 01538
65 TlsFilePaths::as_str [function] [call site] 01539
65 InfoDict::contains_key [function] [call site] 01541
66 InfoDict::find [function] [call site] 01542
67 cache_mget [function] [call site] 01543
66 Option::is_some [function] [call site] 01544
65 InfoDict::contains_key [function] [call site] 01545
65 &HashMap<String, [call site] 01546
65 is_some_and [function] [call site] 01547
65 contains [function] [call site] 01548
65 contains [function] [call site] 01549
65 contains [function] [call site] 01550
65 parse::<u16> [function] [call site] 01551
64 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01553
65 crate::ConnectionAddr::Tcp [function] [call site] 01554
65 ClusterClientBuilder::as_ref [function] [call site] 01555
65 types::test_hashmap [function] [call site] 01556
65 transpose [function] [call site] 01557
65 ClientTlsParams::clone [function] [call site] 01559
65 unwrap_or_default [function] [call site] 01560
65 RedisServer::default [function] [call site] 01561
64 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01562
64 async_determine_master_from_role_or_info_replication [function] [call site] 01563
65 Client::open [function] [call site] 01564
65 redis::ConnectionInfo::clone [function] [call site] 01565
65 Client::get_multiplexed_async_connection [function] [call site] 01566
65 async_check_role [function] [call site] 01567
66 crate::cmd [function] [call site] 01568
66 redis::Cmd::query_async [function] [call site] 01569
67 &mut [call site] 01570
67 RedisResult::from_redis_value [function] [call site] 01572
67 Value::extract_error [function] [call site] 01573
65 async_check_info_replication [function] [call site] 01575
66 crate::cmd [function] [call site] 01576
66 redis::Cmd::arg [function] [call site] 01577
66 Cmd::query_async [function] [call site] 01578
66 parse_replication_info [function] [call site] 01579
67 impl [call site] 01580
68 TestContext::new [function] [call site] 01581
68 TestContext::async_pubsub [function] [call site] 01582
69 Client::get_async_pubsub [function] [call site] 01583
70 Client::get_simple_async_connection_dynamically [function] [call site] 01584
71 Runtime::locate [function] [call site] 01585
71 get_simple_async_connection::<crate::aio::tokio::Tokio> [function] [call site] 01586
71 get_simple_async_connection::<crate::aio::smol::Smol> [function] [call site] 01587
70 crate::aio::PubSub::new [function] [call site] 01588
71 RedisServer::default [function] [call site] 01589
72 RedisServer::new [function] [call site] 01590
71 Self::framed [function] [call site] 01591
71 super::setup_connection [function] [call site] 01592
72 execute_connection_pipeline [function] [call site] 01593
73 basic::test_pipeline_len [function] [call site] 01594
73 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01596
73 Pipeline::get_packed_pipeline [function] [call site] 01597
74 encode_pipeline [function] [call site] 01598
75 write_pipeline [function] [call site] 01599
76 basic::test_tuple_decoding_from_iter [function] [call site] 01600
77 TestContext::new [function] [call site] 01601
77 TestContext::connection [function] [call site] 01602
77 ValueType::from [function] [call site] 01603
77 basic::test_tuple_decoding_from_iter [function] [call site] 01604
77 hscan::<_, [call site] 01605
76 types::test_hashmap [function] [call site] 01608
76 cmd::cmd [function] [call site] 01610
77 redis::cmd [function] [call site] 01611
77 Cmd::set_cache_config [function] [call site] 01612
77 CommandCacheConfig::new [function] [call site] 01613
77 CommandCacheConfig::set_enable_cache [function] [call site] 01614
76 cmd::cmd [function] [call site] 01615
76 &mut [call site] 01616
76 cmd::cmd_len [function] [call site] 01617
77 args_len [function] [call site] 01618
77 Cmd::args_iter [function] [call site] 01619
77 unwrap_or [function] [call site] 01620
76 cmd::cmd_len [function] [call site] 01621
76 Cmd::write_packed_command_preallocated [function] [call site] 01622
77 write_command [function] [call site] 01623
77 Cmd::args_iter [function] [call site] 01624
77 unwrap_or [function] [call site] 01625
77 io::Result::unwrap [function] [call site] 01626
76 Cmd::write_packed_command_preallocated [function] [call site] 01627
77 write_command [function] [call site] 01628
77 Cmd::args_iter [function] [call site] 01629
77 unwrap_or [function] [call site] 01630
77 io::Result::unwrap [function] [call site] 01631
76 Cmd::write_packed_command_preallocated [function] [call site] 01632
76 &mut [call site] 01633
76 Cmd::write_packed_command_preallocated [function] [call site] 01634
73 Cmd::with_capacity [function] [call site] 01635
73 MapIter::next [function] [call site] 01636
74 MapIter::next [function] [call site] 01638
74 MapIter::next [function] [call site] 01639
74 MapIter::next [function] [call site] 01640
73 ok_or_else [function] [call site] 01642
73 cluster_async::get_push [function] [call site] 01643
74 Pipeline::send_recv [function] [call site] 01644
74 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 01645
74 futures_time::time::Duration::from_millis [function] [call site] 01646
73 connection::check_connection_setup [function] [call site] 01649
74 RedisResult::get [function] [call site] 01650
75 TestContext::new [function] [call site] 01651
75 ProtocolVersion::supports_resp3 [function] [call site] 01652
75 TestContext::async_connection_with_cache [function] [call site] 01653
75 get_pipe [function] [call site] 01655
75 redis::Pipeline::cmd [function] [call site] 01656
75 redis::Cmd::arg [function] [call site] 01657
75 types::test_is_single_arg [function] [call site] 01658
75 types::test_is_single_arg [function] [call site] 01661
75 types::test_is_single_arg [function] [call site] 01662
75 Cmd::query_async [function] [call site] 01664
75 redis::cmd [function] [call site] 01666
75 redis::Cmd::arg [function] [call site] 01667
75 types::test_is_single_arg [function] [call site] 01668
75 Cmd::query_async [function] [call site] 01669
75 assert_hit [function] [call site] 01671
75 assert_miss [function] [call site] 01672
75 redis::cmd [function] [call site] 01673
75 redis::Cmd::arg [function] [call site] 01674
75 types::test_is_single_arg [function] [call site] 01675
75 types::test_is_single_arg [function] [call site] 01676
75 Cmd::query_async [function] [call site] 01677
75 assert_hit [function] [call site] 01679
75 assert_miss [function] [call site] 01680
75 redis::cmd [function] [call site] 01681
75 redis::Cmd::arg [function] [call site] 01682
75 Cmd::query_async [function] [call site] 01683
75 assert_hit [function] [call site] 01685
75 assert_miss [function] [call site] 01686
74 check_resp3_auth [function] [call site] 01689
75 get_resp3_hello_command_error [function] [call site] 01691
76 RedisError::detail [function] [call site] 01692
77 Option::as_ref [function] [call site] 01693
77 types::test_hashmap [function] [call site] 01694
77 Option::as_str [function] [call site] 01695
77 ServerError::details [function] [call site] 01697
78 Option::as_ref [function] [call site] 01698
78 types::test_hashmap [function] [call site] 01699
78 Option::as_ref [function] [call site] 01701
78 types::test_hashmap [function] [call site] 01702
76 Option::starts_with [function] [call site] 01704
75 ClientTlsParams::clone [function] [call site] 01706
75 Self::into [function] [call site] 01707
74 RedisResult::get [function] [call site] 01709
74 RedisResult::get [function] [call site] 01724
74 check_db_select [function] [call site] 01727
74 RedisResult::get [function] [call site] 01737
72 connection_setup_pipeline [function] [call site] 01746
73 cmd::pipe [function] [call site] 01747
74 redis::pipe [function] [call site] 01748
74 Pipeline::atomic [function] [call site] 01749
74 redis::pipe [function] [call site] 01750
73 ProtocolVersion::supports_resp3 [function] [call site] 01751
73 add_command [function] [call site] 01752
73 commands::resp3_hello [function] [call site] 01753
74 cmd::cmd [function] [call site] 01754
74 Cmd::arg [function] [call site] 01755
74 Cmd::arg [function] [call site] 01757
74 types::test_is_single_arg [function] [call site] 01758
74 types::test_is_single_arg [function] [call site] 01759
74 &'static [call site] 01760
73 add_command [function] [call site] 01763
73 authenticate_cmd [function] [call site] 01764
74 cmd::cmd [function] [call site] 01765
74 types::test_is_single_arg [function] [call site] 01766
74 types::test_is_single_arg [function] [call site] 01767
73 bool::then [function] [call site] 01768
73 redis::ConnectionInfo::username [function] [call site] 01769
74 as_deref [function] [call site] 01770
73 basic::test_pipeline_len [function] [call site] 01774
73 cmd::cmd [function] [call site] 01776
73 Cmd::arg [function] [call site] 01777
73 types::test_hashmap [function] [call site] 01778
74 parse_redis_value [function] [call site] 01779
74 Value::Array [function] [call site] 01780
74 RedisServer::new [function] [call site] 01781
74 PathBuf::insert [function] [call site] 01782
74 &str::into [function] [call site] 01783
74 PathBuf::insert [function] [call site] 01784
74 &str::into [function] [call site] 01785
74 PathBuf::insert [function] [call site] 01786
74 &str::into [function] [call site] 01787
74 parse_redis_value [function] [call site] 01788
74 Value::Array [function] [call site] 01789
74 RedisServer::default [function] [call site] 01790
74 HashMap::with_hasher [function] [call site] 01791
74 PathBuf::insert [function] [call site] 01792
74 &str::into [function] [call site] 01793
74 PathBuf::insert [function] [call site] 01794
74 &str::into [function] [call site] 01795
74 PathBuf::insert [function] [call site] 01796
74 &str::into [function] [call site] 01797
74 parse_redis_value [function] [call site] 01798
74 Value::Array [function] [call site] 01799
73 cmd::cmd [function] [call site] 01800
73 Cmd::arg [function] [call site] 01801
73 types::test_is_single_arg [function] [call site] 01802
73 types::test_is_single_arg [function] [call site] 01803
73 basic::test_pipeline_len [function] [call site] 01804
73 cmd::cmd [function] [call site] 01805
73 Cmd::arg [function] [call site] 01806
73 types::test_is_single_arg [function] [call site] 01807
73 types::test_is_single_arg [function] [call site] 01808
73 cmd::cmd [function] [call site] 01810
73 Cmd::arg [function] [call site] 01811
73 types::test_is_single_arg [function] [call site] 01812
73 types::test_is_single_arg [function] [call site] 01813
72 execute_connection_pipeline [function] [call site] 01815
72 connection_setup_pipeline [function] [call site] 01816
71 tokio::sync::mpsc::unbounded_channel [function] [call site] 01818
71 PubSubSink::new [function] [call site] 01819
72 tokio::sync::mpsc::unbounded_channel [function] [call site] 01820
72 PipelineSink::new [function] [call site] 01821
73 RedisServer::new [function] [call site] 01822
74 RedisServer::with_modules [function] [call site] 01823
72 stream::poll_fn [function] [call site] 01824
72 ( [call site] 01825
4 PendingRequest::poll_recv [function] [call site] 01826
72 types::test_hashmap [function] [call site] 01827
72 types::test_hashmap [function] [call site] 01829
71 Runtime::locate [function] [call site] 01830
71 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] 01831
72 tokio::runtime::Handle::try_current [function] [call site] 01832
72 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] 01833
72 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] 01834
72 TaskHandle::detach [function] [call site] 01835
71 Some [function] [call site] 01836
71 SharedHandleContainer::new [function] [call site] 01837
72 RedisServer::new [function] [call site] 01839
72 HandleContainer::new [function] [call site] 01840
71 Ok [function] [call site] 01843
68 unwrap [function] [call site] 01844
68 basic_async::automatic_unsubscription_on_split [function] [call site] 01845
69 TestContext::new [function] [call site] 01846
69 TestContext::async_pubsub [function] [call site] 01847
69 basic_async::automatic_unsubscription_on_split [function] [call site] 01849
69 basic::test_pubsub_unsubscribe [function] [call site] 01850
70 TestContext::new [function] [call site] 01851
70 TestContext::connection [function] [call site] 01852
70 std::sync::mpsc::channel [function] [call site] 01853
71 from_redis_value_ref [function] [call site] 01855
70 redis::Connection::set_push_sender [function] [call site] 01856
70 redis::Connection::as_pubsub [function] [call site] 01858
71 PubSub::new [function] [call site] 01859
72 RedisServer::default [function] [call site] 01860
72 Self::framed [function] [call site] 01861
72 super::setup_connection [function] [call site] 01862
72 tokio::sync::mpsc::unbounded_channel [function] [call site] 01863
72 PubSubSink::new [function] [call site] 01864
72 Runtime::locate [function] [call site] 01865
72 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] 01866
72 SharedHandleContainer::new [function] [call site] 01868
70 basic::test_pubsub_unsubscribe [function] [call site] 01870
70 basic::test_pubsub_unsubscribe [function] [call site] 01872
70 basic::test_pubsub_unsubscribe [function] [call site] 01874
70 PubSub::psubscribe [function] [call site] 01876
71 PubSub::psubscribe [function] [call site] 01877
70 RedisResult::unwrap [function] [call site] 01878
70 PubSub::psubscribe [function] [call site] 01879
70 RedisResult::unwrap [function] [call site] 01880
70 PubSub::psubscribe [function] [call site] 01881
70 RedisResult::unwrap [function] [call site] 01882
70 redis::Connection::set [function] [call site] 01883
71 parse_redis_value [function] [call site] 01884
71 Value::Array [function] [call site] 01885
71 RedisServer::new [function] [call site] 01886
72 RedisServer::with_modules [function] [call site] 01887
71 RedisServer::insert [function] [call site] 01888
71 ValueComparison::arg_to_string [function] [call site] 01889
71 RedisServer::insert [function] [call site] 01890
71 ValueComparison::arg_to_string [function] [call site] 01891
71 RedisServer::insert [function] [call site] 01892
71 ValueComparison::arg_to_string [function] [call site] 01893
71 parse_redis_value [function] [call site] 01894
71 Value::Int [function] [call site] 01895
71 RedisServer::new [function] [call site] 01896
71 test_module_json_arr_insert [function] [call site] 01897
71 ValueComparison::arg_to_string [function] [call site] 01898
71 test_module_json_arr_insert [function] [call site] 01899
71 ValueComparison::arg_to_string [function] [call site] 01900
71 test_module_json_arr_insert [function] [call site] 01901
71 ValueComparison::arg_to_string [function] [call site] 01902
71 types::test_std_types_to_redis_args [function] [call site] 01903
71 &'a [call site] 01904
71 std::iter::Chain::collect [function] [call site] 01905
70 redis::Connection::get [function] [call site] 01907
71 TestContext::new [function] [call site] 01908
71 ProtocolVersion::supports_resp3 [function] [call site] 01909
71 TestContext::async_connection_with_cache [function] [call site] 01910
71 get_pipe [function] [call site] 01912
71 redis::Pipeline::cmd [function] [call site] 01913
71 redis::Cmd::arg [function] [call site] 01914
71 types::test_is_single_arg [function] [call site] 01915
71 types::test_is_single_arg [function] [call site] 01918
71 types::test_is_single_arg [function] [call site] 01919
71 Cmd::query_async [function] [call site] 01921
71 redis::cmd [function] [call site] 01923
71 redis::Cmd::arg [function] [call site] 01924
71 types::test_is_single_arg [function] [call site] 01925
71 Cmd::query_async [function] [call site] 01926
71 assert_hit [function] [call site] 01928
71 assert_miss [function] [call site] 01929
71 redis::cmd [function] [call site] 01930
71 redis::Cmd::arg [function] [call site] 01931
71 types::test_is_single_arg [function] [call site] 01932
71 types::test_is_single_arg [function] [call site] 01933
71 Cmd::query_async [function] [call site] 01934
71 assert_hit [function] [call site] 01936
71 assert_miss [function] [call site] 01937
71 redis::cmd [function] [call site] 01938
71 redis::Cmd::arg [function] [call site] 01939
71 Cmd::query_async [function] [call site] 01940
71 assert_hit [function] [call site] 01942
71 assert_miss [function] [call site] 01943
70 ProtocolVersion::supports_resp3 [function] [call site] 01946
70 try_recv [function] [call site] 01947
70 RedisResult::from_redis_value_ref [function] [call site] 01949
71 ClientTlsParams::clone [function] [call site] 01952
71 Self::into [function] [call site] 01953
71 from_redis_value_ref [function] [call site] 01954
71 types::test_hashmap [function] [call site] 01955
70 Result::unwrap [function] [call site] 01959
70 cluster_async::get_push [function] [call site] 01960
69 TestContext::async_connection [function] [call site] 01962
70 Client::get_multiplexed_async_connection [function] [call site] 01963
69 Runtime::sleep [function] [call site] 01965
70 tokio::time::sleep [function] [call site] 01966
70 smol::Timer::after [function] [call site] 01967
69 Duration::from_millis [function] [call site] 01968
69 redis::cmd [function] [call site] 01970
69 redis::Cmd::arg [function] [call site] 01971
69 types::test_is_single_arg [function] [call site] 01972
69 Cmd::query_async [function] [call site] 01973
69 cache_mget [function] [call site] 01975
69 RedisServer::drop [function] [call site] 01977
69 redis::cmd [function] [call site] 01978
69 redis::Cmd::arg [function] [call site] 01979
69 types::test_is_single_arg [function] [call site] 01980
69 Cmd::query_async [function] [call site] 01981
69 cache_mget [function] [call site] 01983
69 Runtime::sleep [function] [call site] 01985
69 Duration::from_millis [function] [call site] 01986
69 basic::test_pubsub_unsubscribe [function] [call site] 01988
69 unwrap_err [function] [call site] 01989
68 basic::test_pubsub_unsubscribe [function] [call site] 01990
68 unwrap [function] [call site] 01991
68 TestContext::async_connection [function] [call site] 01992
68 unwrap [function] [call site] 01993
68 Runtime::sleep [function] [call site] 01994
68 Duration::from_millis [function] [call site] 01995
68 into [function] [call site] 01996
68 redis::cmd [function] [call site] 01997
68 redis::Cmd::arg [function] [call site] 01998
68 types::test_is_single_arg [function] [call site] 01999
68 Cmd::query_async [function] [call site] 02000
68 unwrap [function] [call site] 02001
68 cache_mget [function] [call site] 02002
68 unwrap [function] [call site] 02003
68 RedisServer::drop [function] [call site] 02004
68 redis::cmd [function] [call site] 02005
68 redis::Cmd::arg [function] [call site] 02006
68 types::test_is_single_arg [function] [call site] 02007
68 Cmd::query_async [function] [call site] 02008
68 unwrap [function] [call site] 02009
68 cache_mget [function] [call site] 02010
68 unwrap [function] [call site] 02011
68 Runtime::sleep [function] [call site] 02012
68 Duration::from_millis [function] [call site] 02013
68 into [function] [call site] 02014
68 basic::test_pubsub_unsubscribe [function] [call site] 02015
68 unwrap_err [function] [call site] 02016
67 filter [function] [call site] 02017
67 trim_start [function] [call site] 02018
67 starts_with [function] [call site] 02019
67 filter_map [function] [call site] 02020
67 split_once [function] [call site] 02021
67 types::test_hashmap [function] [call site] 02022
67 ValueComparison::arg_to_string [function] [call site] 02023
67 ValueComparison::arg_to_string [function] [call site] 02024
67 collect [function] [call site] 02025
66 HashMap::get [function] [call site] 02026
67 TestContext::new [function] [call site] 02027
67 ProtocolVersion::supports_resp3 [function] [call site] 02028
67 TestContext::async_connection_with_cache [function] [call site] 02029
67 get_pipe [function] [call site] 02031
67 redis::Pipeline::cmd [function] [call site] 02032
67 redis::Cmd::arg [function] [call site] 02033
67 types::test_is_single_arg [function] [call site] 02034
67 types::test_is_single_arg [function] [call site] 02037
67 types::test_is_single_arg [function] [call site] 02038
67 Cmd::query_async [function] [call site] 02040
67 redis::cmd [function] [call site] 02042
67 redis::Cmd::arg [function] [call site] 02043
67 types::test_is_single_arg [function] [call site] 02044
67 Cmd::query_async [function] [call site] 02045
67 assert_hit [function] [call site] 02047
67 assert_miss [function] [call site] 02048
67 redis::cmd [function] [call site] 02049
67 redis::Cmd::arg [function] [call site] 02050
67 types::test_is_single_arg [function] [call site] 02051
67 types::test_is_single_arg [function] [call site] 02052
67 Cmd::query_async [function] [call site] 02053
67 assert_hit [function] [call site] 02055
67 assert_miss [function] [call site] 02056
67 redis::cmd [function] [call site] 02057
67 redis::Cmd::arg [function] [call site] 02058
67 Cmd::query_async [function] [call site] 02059
67 assert_hit [function] [call site] 02061
67 assert_miss [function] [call site] 02062
66 Ok [function] [call site] 02063
66 ClientTlsParams::clone [function] [call site] 02064
66 Err [function] [call site] 02065
66 RedisError::from [function] [call site] 02066
65 Ok [function] [call site] 02067
65 evaluate_role_check_errors [function] [call site] 02068
66 RedisError::kind [function] [call site] 02069
65 unwrap_err [function] [call site] 02073
65 unwrap_err [function] [call site] 02074
64 Ok [function] [call site] 02075
62 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02076
62 Client::open [function] [call site] 02077
61 as_str [function] [call site] 02078
61 Some [function] [call site] 02079
61 Sentinel::async_replica_for [function] [call site] 02080
62 Sentinel::async_find_valid_replica_addresses [function] [call site] 02081
63 Sentinel::async_get_sentinel_replicas [function] [call site] 02082
64 Sentinel::async_try_all_sentinels [function] [call site] 02083
64 sentinel_replicas_cmd [function] [call site] 02084
65 crate::cmd [function] [call site] 02085
65 Cmd::arg [function] [call site] 02086
65 Cmd::arg [function] [call site] 02087
63 async_get_valid_replicas_addresses [function] [call site] 02088
64 valid_addrs [function] [call site] 02089
64 types::test_hashmap [function] [call site] 02090
64 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02091
64 map(|(ip, [call site] 02092
4 .collect::<RedisResult<Vec<_>>> [function] [call site] 02093
64 futures_util::stream::iter [function] [call site] 02095
65 TestContext::new [function] [call site] 02096
65 TestContext::connection [function] [call site] 02097
65 ValueType::from [function] [call site] 02098
65 basic::test_tuple_decoding_from_iter [function] [call site] 02099
65 hscan::<_, [call site] 02100
64 filter_map [function] [call site] 02103
62 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02105
62 RedisServer::new [function] [call site] 02106
62 basic::test_pipeline_len [function] [call site] 02107
63 redis::pipe [function] [call site] 02108
63 types::test_is_single_arg [function] [call site] 02111
62 types::test_hashmap [function] [call site] 02112
63 parse_redis_value [function] [call site] 02113
63 Value::Array [function] [call site] 02114
63 RedisServer::new [function] [call site] 02115
63 PathBuf::insert [function] [call site] 02116
63 &str::into [function] [call site] 02117
63 PathBuf::insert [function] [call site] 02118
63 &str::into [function] [call site] 02119
63 PathBuf::insert [function] [call site] 02120
63 &str::into [function] [call site] 02121
63 parse_redis_value [function] [call site] 02122
63 Value::Array [function] [call site] 02123
63 RedisServer::default [function] [call site] 02124
63 HashMap::with_hasher [function] [call site] 02125
63 PathBuf::insert [function] [call site] 02126
63 &str::into [function] [call site] 02127
63 PathBuf::insert [function] [call site] 02128
63 &str::into [function] [call site] 02129
63 PathBuf::insert [function] [call site] 02130
63 &str::into [function] [call site] 02131
63 parse_redis_value [function] [call site] 02132
63 Value::Array [function] [call site] 02133
62 try_connect_to_first_replica [function] [call site] 02134
63 MockRedisConnection::is_empty [function] [call site] 02135
64 StreamReadOptions::block [function] [call site] 02136
64 MockRedisConnection::is_empty [function] [call site] 02138
63 Option<usize>::unwrap_or [function] [call site] 02140
63 basic::test_pipeline_len [function] [call site] 02141
63 basic::test_pipeline_len [function] [call site] 02142
63 Client::open [function] [call site] 02143
63 ClientTlsParams::clone [function] [call site] 02144
63 None::expect [function] [call site] 02148
61 as_str [function] [call site] 02149
61 Some [function] [call site] 02150
60 Client::get_multiplexed_async_connection_with_config [function] [call site] 02151
59 unwrap [function] [call site] 02152
59 async_tests::async_assert_is_connection_to_master [function] [call site] 02153
60 redis::cmd [function] [call site] 02154
60 redis::Cmd::arg [function] [call site] 02155
60 Cmd::query_async [function] [call site] 02156
60 assert_is_master_role [function] [call site] 02158
61 parse_replication_info [function] [call site] 02159
59 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02160
59 TestSentinelContext::sentinel_mut [function] [call site] 02161
59 &redis::sentinel::Sentinel::async_master_for [function] [call site] 02162
60 Sentinel::async_find_master_address [function] [call site] 02163
60 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02164
60 Client::open [function] [call site] 02165
59 Some [function] [call site] 02166
59 unwrap [function] [call site] 02167
59 SentinelClient::get_async_connection_with_config [function] [call site] 02168
59 unwrap [function] [call site] 02169
59 async_tests::async_assert_connection_is_replica_of_correct_master [function] [call site] 02170
60 redis::cmd [function] [call site] 02171
60 redis::Cmd::arg [function] [call site] 02172
60 Cmd::query_async [function] [call site] 02173
60 assert_replica_role_and_master_addr [function] [call site] 02175
61 parse_replication_info [function] [call site] 02176
61 RedisServer::get_addr [function] [call site] 02177
62 ServerType::get_intended [function] [call site] 02178
62 ValueComparison::arg_to_string [function] [call site] 02179
62 redis::ConnectionAddr::Tcp [function] [call site] 02180
62 ValueComparison::arg_to_string [function] [call site] 02181
62 rand::random::<(u64, [call site] 02182
62 redis::ConnectionAddr::Unix [function] [call site] 02183
62 ValueType::from [function] [call site] 02184
63 TlsFilePaths::as_ref [function] [call site] 02185
63 ValueType::Unknown [function] [call site] 02186
63 ValueComparison::arg_to_string [function] [call site] 02187
60 Client::get_connection_info [function] [call site] 02188
57 RoutingInfo::SingleNode [function] [call site] 02189
57 MockRedisConnection::req_packed_command [function] [call site] 02190
58 Cmd::get_packed_command [function] [call site] 02191
58 MockRedisConnection::req_packed_command [function] [call site] 02192
58 as_slice [function] [call site] 02193
58 PipelineSink::poll_ready [function] [call site] 02194
58 types::test_parse_boxed [function] [call site] 02195
57 Cmd::get_packed_command [function] [call site] 02196
57 RedisCluster::new [function] [call site] 02197
57 RedisServer::default [function] [call site] 02198
57 ClusterConnection::route_command [function] [call site] 02199
57 RoutingInfo::SingleNode [function] [call site] 02200
57 RedisResult::unwrap [function] [call site] 02201
56 Some [function] [call site] 02202
56 cmd::cmd [function] [call site] 02203
56 Cmd::exec [function] [call site] 02204
57 query::<()> [function] [call site] 02205
56 MockConnection::set_read_timeout [function] [call site] 02206
56 borrow [function] [call site] 02208
56 MockConnection::set_write_timeout [function] [call site] 02209
56 borrow [function] [call site] 02211
56 Ok [function] [call site] 02212
55 MockRedisConnection::check_connection [function] [call site] 02213
55 RedisResult::insert [function] [call site] 02214
56 TestContext::with_modules [function] [call site] 02215
56 TestContext::connection [function] [call site] 02216
56 redis::Connection::json_set [function] [call site] 02217
56 redis::Connection::json_arr_insert [function] [call site] 02218
56 redis::Connection::json_set [function] [call site] 02219
56 redis::Connection::json_arr_insert [function] [call site] 02220
55 cluster_async::get_push [function] [call site] 02221
56 Pipeline::send_recv [function] [call site] 02222
56 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 02223
56 futures_time::time::Duration::from_millis [function] [call site] 02224
55 RedisError::from [function] [call site] 02227
55 cluster_async::get_push [function] [call site] 02228
55 MockRedisConnection::is_empty [function] [call site] 02229
55 MockRedisConnection::is_empty [function] [call site] 02230
56 StreamReadOptions::block [function] [call site] 02231
56 MockRedisConnection::is_empty [function] [call site] 02233
55 ValueComparison::arg_to_string [function] [call site] 02234
55 ValueComparison::arg_to_string [function] [call site] 02235
55 &'a [call site] 02236
55 std::iter::Chain::enumerate [function] [call site] 02237
55 Err [function] [call site] 02238
55 RedisError::from [function] [call site] 02239
55 borrow_mut [function] [call site] 02240
55 ClusterConnection::refresh_slots [function] [call site] 02241
56 borrow_mut [function] [call site] 02242
56 ClusterConnection::create_new_slots [function] [call site] 02243
57 borrow_mut [function] [call site] 02244
57 RedisResult::iter_mut [function] [call site] 02245
57 ConnectionLike::req_command [function] [call site] 02246
58 Cmd::get_packed_command [function] [call site] 02247
58 MockRedisConnection::req_packed_command [function] [call site] 02248
57 cluster_handling::slot_cmd [function] [call site] 02249
58 Cmd::new [function] [call site] 02250
58 Cmd::arg [function] [call site] 02251
58 types::test_is_single_arg [function] [call site] 02252
57 super::topology::parse_slots [function] [call site] 02253
58 Cmd::with_capacity [function] [call site] 02254
58 &'a [call site] 02255
58 MapIter::next [function] [call site] 02256
58 basic::test_pipeline_len [function] [call site] 02257
59 redis::pipe [function] [call site] 02258
59 types::test_is_single_arg [function] [call site] 02261
58 basic::test_pipeline_len [function] [call site] 02262
58 String::from_utf8_lossy [function] [call site] 02263
58 MockRedisConnection::is_empty [function] [call site] 02264
58 is_wildcard_address [function] [call site] 02265
58 &str::into [function] [call site] 02266
58 &str::into [function] [call site] 02267
58 MockRedisConnection::is_empty [function] [call site] 02268
58 &'a [call site] 02271
59 std::iter::once [function] [call site] 02272
59 basic::test_tuple_decoding_from_iter [function] [call site] 02274
58 std::iter::Chain::skip [function] [call site] 02275
58 MapIter::next [function] [call site] 02277
58 try_to_address [function] [call site] 02278
58 filter_map [function] [call site] 02279
58 cluster_async::get_push [function] [call site] 02281
58 Slot::new [function] [call site] 02282
57 ConnectionAddr::rsplit_once [function] [call site] 02284
57 SlotMap::from_slots [function] [call site] 02287
58 &'a [call site] 02288
58 std::iter::Chain::map [function] [call site] 02289
58 SlotMapValue::from_slot [function] [call site] 02290
59 SlotAddrs::from_slot [function] [call site] 02291
60 SlotAddrs::new [function] [call site] 02292
57 RedisError::from [function] [call site] 02296
56 MockCmd::with_values [function] [call site] 02297
57 Cmd::into_redis_cmd_bytes [function] [call site] 02298
58 Cmd::get_packed_command [function] [call site] 02299
57 types::test_hashmap [function] [call site] 02300
58 parse_redis_value [function] [call site] 02301
58 Value::Array [function] [call site] 02302
58 RedisServer::new [function] [call site] 02303
58 PathBuf::insert [function] [call site] 02304
58 &str::into [function] [call site] 02305
58 PathBuf::insert [function] [call site] 02306
58 &str::into [function] [call site] 02307
58 PathBuf::insert [function] [call site] 02308
58 &str::into [function] [call site] 02309
58 parse_redis_value [function] [call site] 02310
58 Value::Array [function] [call site] 02311
58 RedisServer::default [function] [call site] 02312
58 HashMap::with_hasher [function] [call site] 02313
58 PathBuf::insert [function] [call site] 02314
58 &str::into [function] [call site] 02315
58 PathBuf::insert [function] [call site] 02316
58 &str::into [function] [call site] 02317
58 PathBuf::insert [function] [call site] 02318
58 &str::into [function] [call site] 02319
58 parse_redis_value [function] [call site] 02320
58 Value::Array [function] [call site] 02321
57 &'a [call site] 02322
57 types::test_hashmap [function] [call site] 02323
57 String::into_redis_value [function] [call site] 02324
58 Value::BulkString [function] [call site] 02325
58 String::as_bytes [function] [call site] 02326
58 write_command_to_vec [function] [call site] 02327
56 Self::flatten [function] [call site] 02329
56 values().flatten().collect::<Vec<_>> [function] [call site] 02330
56 sort_unstable [function] [call site] 02331
56 borrow_mut [function] [call site] 02333
56 &'a [call site] 02334
56 std::iter::Chain::filter_map [function] [call site] 02335
56 RedisResult::remove [function] [call site] 02336
56 MockRedisConnection::check_connection [function] [call site] 02337
56 ClientTlsParams::clone [function] [call site] 02339
57 ClientTlsParams::clone [function] [call site] 02340
57 secret_pkcs1_der [function] [call site] 02342
57 write_command_to_vec [function] [call site] 02343
57 secret_pkcs8_der [function] [call site] 02346
57 write_command_to_vec [function] [call site] 02347
57 secret_sec1_der [function] [call site] 02350
57 write_command_to_vec [function] [call site] 02351
56 ClusterConnection::connect [function] [call site] 02353
56 MockRedisConnection::check_connection [function] [call site] 02354
56 ClientTlsParams::clone [function] [call site] 02356
55 Ok [function] [call site] 02359
54 Tokio::poll_write [function] [call site] 02360
54 SlotMap::new [function] [call site] 02361
54 ClusterConnection::refresh_slots [function] [call site] 02362
55 borrow_mut [function] [call site] 02363
55 ClusterConnection::create_new_slots [function] [call site] 02364
55 MockCmd::with_values [function] [call site] 02365
55 Self::flatten [function] [call site] 02366
55 values().flatten().collect::<Vec<_>> [function] [call site] 02367
55 sort_unstable [function] [call site] 02368
55 borrow_mut [function] [call site] 02370
55 &'a [call site] 02371
55 std::iter::Chain::filter_map [function] [call site] 02372
55 RedisResult::remove [function] [call site] 02373
55 MockRedisConnection::check_connection [function] [call site] 02374
55 ClientTlsParams::clone [function] [call site] 02376
55 ClusterConnection::connect [function] [call site] 02377
55 MockRedisConnection::check_connection [function] [call site] 02378
55 ClientTlsParams::clone [function] [call site] 02380
54 Ok [function] [call site] 02383
52 oneshot::channel::<RedisResult<()>> [function] [call site] 02384
52 mpsc::channel::<Message<_>> [function] [call site] 02385
52 ClusterConnInner::wait_for_initial_connection [function] [call site] 02386
53 std::mem::replace [function] [call site] 02387
52 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 02389
52 stream::poll_fn [function] [call site] 02390
52 ( [call site] 02391
4 PendingRequest::poll_recv [function] [call site] 02392
52 types::test_hashmap [function] [call site] 02393
52 HandleContainer::new [function] [call site] 02395
52 tokio::runtime::Runtime::spawn [function] [call site] 02396
53 crate_tokio::Tokio::spawn [function] [call site] 02397
54 TaskHandle::Tokio [function] [call site] 02398
54 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 02399
55 tokio::runtime::Handle::try_current [function] [call site] 02400
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] 02401
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] 02402
55 TaskHandle::detach [function] [call site] 02403
53 crate_smol::Smol::spawn [function] [call site] 02404
54 TaskHandle::Smol [function] [call site] 02405
54 b::a::s::i::c::_::a::s::y::n::c::::::::t::e::s::t::_::b::l::o::c::k::_::o::n::_::a::l::l::_::p::a::n::i::c::s::_::f::r::o::m::_::s::p::a::w::n::s::spawn [function] [call site] 02406
52 RedisServer::new [function] [call site] 02407
51 map_err [function] [call site] 02408
51 RedisError::from [function] [call site] 02409
51 Ok [function] [call site] 02410
50 ClientTlsParams::clone [function] [call site] 02411
50 ClientTlsParams::clone [function] [call site] 02412
49 RedisResult::unwrap [function] [call site] 02413
49 tokio::runtime::Runtime::block_on [function] [call site] 02414
49 ClusterClient::get_async_generic_connection [function] [call site] 02415
50 cluster_async::ClusterConnection::new [function] [call site] 02416
51 ClusterConnection::new_inner [function] [call site] 02417
51 RedisError::from [function] [call site] 02419
50 ClientTlsParams::clone [function] [call site] 02421
49 unwrap [function] [call site] 02422
49 RemoveHandler [function] [call site] 02423
48 ClusterClient::builder [function] [call site] 02424
49 ClusterClientBuilder::new [function] [call site] 02425
50 &'a [call site] 02426
50 std::iter::Chain::map [function] [call site] 02427
50 ConnectionInfo::into_connection_info [function] [call site] 02428
50 RedisServer::default [function] [call site] 02430
48 ClusterClientBuilder::retries [function] [call site] 02431
48 respond_startup [function] [call site] 02432
49 contains_slice [function] [call site] 02433
50 basic::test_pipeline_len [function] [call site] 02434
51 redis::pipe [function] [call site] 02435
51 types::test_is_single_arg [function] [call site] 02438
50 starts_with [function] [call site] 02439
49 Value::SimpleString [function] [call site] 02442
49 &str::into [function] [call site] 02443
49 contains_slice [function] [call site] 02444
49 contains_slice [function] [call site] 02445
49 Value::Array [function] [call site] 02448
49 contains_slice [function] [call site] 02449
49 Value::SimpleString [function] [call site] 02452
49 &str::into [function] [call site] 02453
48 fetch_add [function] [call site] 02455
48 Err [function] [call site] 02456
48 parse_redis_value [function] [call site] 02457
48 Err [function] [call site] 02458
48 Ok [function] [call site] 02459
48 Value::BulkString [function] [call site] 02460
48 &str::to_vec [function] [call site] 02461
49 args_len [function] [call site] 02462
49 ClientTlsParams::clone [function] [call site] 02463
49 Cmd::reserve [function] [call site] 02464
49 write_command [function] [call site] 02465
49 io::Result::unwrap [function] [call site] 02466
48 cmd [function] [call site] 02467
48 Cmd::arg [function] [call site] 02468
48 arg("test").query::<Option<i32>> [function] [call site] 02469
47 TestClusterContext::get_ports [function] [call site] 02470
47 MockRedisConnection::check_connection [function] [call site] 02471
47 RedisServer::drop [function] [call site] 02472
47 RedisCluster::new [function] [call site] 02473
47 RedisServer::default [function] [call site] 02474
47 cmd [function] [call site] 02475
47 ClusterConnection::route_command [function] [call site] 02476
47 RoutingInfo::MultiNode [function] [call site] 02477
47 Some [function] [call site] 02478
47 RedisResult::unwrap [function] [call site] 02479
46 redis::ConnectionInfo::redis_settings [function] [call site] 02480
46 resize_with [function] [call site] 02481
46 basic::test_pipeline_len [function] [call site] 02482
47 redis::pipe [function] [call site] 02483
47 types::test_is_single_arg [function] [call site] 02486
46 resize_with [function] [call site] 02487
46 basic::test_pipeline_len [function] [call site] 02488
46 Ok [function] [call site] 02489
46 random_replica_index [function] [call site] 02490
47 rand::rng [function] [call site] 02491
47 random_range [function] [call site] 02492
47 NonZeroUsize::into [function] [call site] 02493
46 RedisServer::new [function] [call site] 02494
46 RedisServer::unwrap [function] [call site] 02495
46 resize_with [function] [call site] 02496
46 basic::test_pipeline_len [function] [call site] 02497
46 Ok [function] [call site] 02498
46 random_replica_index [function] [call site] 02499
46 RedisServer::new [function] [call site] 02500
46 RedisServer::unwrap [function] [call site] 02501
46 Ok [function] [call site] 02502
46 random_replica_index [function] [call site] 02503
46 RedisServer::new [function] [call site] 02504
46 RedisServer::unwrap [function] [call site] 02505
46 Ok [function] [call site] 02506
46 random_replica_index [function] [call site] 02507
46 RedisServer::new [function] [call site] 02508
46 RedisServer::unwrap [function] [call site] 02509
44 ClientTlsParams::clone [function] [call site] 02510
44 &redis::sentinel::Sentinel::unwrap [function] [call site] 02511
44 TestSentinelContext::wait_for_cluster_up [function] [call site] 02512
45 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02513
45 TestSentinelContext::sentinel_mut [function] [call site] 02514
45 redis_test::sentinel::wait_for_master_server [function] [call site] 02515
46 redis::cmd [function] [call site] 02516
46 Client::get_connection [function] [call site] 02517
46 redis::Cmd::query [function] [call site] 02518
46 RedisResult::unwrap [function] [call site] 02519
46 String::from_redis_value_ref [function] [call site] 02520
46 ConnectionAddr::first [function] [call site] 02521
46 Result::unwrap [function] [call site] 02523
46 starts_with [function] [call site] 02524
46 std::thread::sleep [function] [call site] 02526
46 Duration::from_millis [function] [call site] 02527
45 &mut [call site] 02529
46 Sentinel::find_master_address [function] [call site] 02530
47 Sentinel::get_sentinel_masters [function] [call site] 02531
48 Sentinel::try_all_sentinels [function] [call site] 02532
49 basic::test_tuple_decoding_from_iter [function] [call site] 02533
49 iter_mut [function] [call site] 02535
49 try_single_sentinel [function] [call site] 02536
50 &mut [call site] 02537
50 reconnect [function] [call site] 02538
51 Client::open [function] [call site] 02539
51 redis::ConnectionInfo::clone [function] [call site] 02540
51 Client::get_connection [function] [call site] 02541
51 CopyOptions::replace [function] [call site] 02542
50 Cmd::query [function] [call site] 02544
51 ConnectionLike::req_command [function] [call site] 02545
51 RedisResult::from_redis_value [function] [call site] 02547
51 Value::extract_error [function] [call site] 02548
50 &mut [call site] 02550
50 RedisError::is_unrecoverable_error [function] [call site] 02552
50 types::test_is_io_error [function] [call site] 02553
50 reconnect [function] [call site] 02554
50 Cmd::query [function] [call site] 02555
50 &mut [call site] 02556
49 ClientTlsParams::clone [function] [call site] 02559
49 None::expect [function] [call site] 02563
48 sentinel_masters_cmd [function] [call site] 02564
47 find_valid_master [function] [call site] 02565
48 valid_addrs [function] [call site] 02566
48 is_master_valid [function] [call site] 02567
48 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02568
48 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02569
48 determine_master_from_role_or_info_replication [function] [call site] 02570
49 Client::open [function] [call site] 02571
49 redis::ConnectionInfo::clone [function] [call site] 02572
49 Client::get_connection [function] [call site] 02573
49 check_role [function] [call site] 02574
50 crate::cmd [function] [call site] 02575
50 redis::Cmd::query [function] [call site] 02576
49 check_info_replication [function] [call site] 02578
50 crate::cmd [function] [call site] 02579
50 redis::Cmd::arg [function] [call site] 02580
50 basic::test_pipeline_reuse_query [function] [call site] 02581
51 TestContext::new [function] [call site] 02582
51 TestContext::connection [function] [call site] 02583
51 redis::pipe [function] [call site] 02584
51 types::test_is_single_arg [function] [call site] 02586
51 types::test_is_single_arg [function] [call site] 02587
51 types::test_is_single_arg [function] [call site] 02590
51 basic::test_pipeline_reuse_query [function] [call site] 02591
52 TestContext::new [function] [call site] 02592
52 TestContext::connection [function] [call site] 02593
52 redis::pipe [function] [call site] 02594
52 types::test_is_single_arg [function] [call site] 02596
52 types::test_is_single_arg [function] [call site] 02597
52 types::test_is_single_arg [function] [call site] 02600
52 basic::test_pipeline_reuse_query [function] [call site] 02601
52 redis::cmd [function] [call site] 02603
52 redis::Cmd::arg [function] [call site] 02604
52 Cmd::exec [function] [call site] 02605
53 query::<()> [function] [call site] 02606
52 RedisResult::unwrap [function] [call site] 02607
52 types::test_is_single_arg [function] [call site] 02609
52 types::test_is_single_arg [function] [call site] 02610
52 types::test_is_single_arg [function] [call site] 02613
52 types::test_is_single_arg [function] [call site] 02614
52 basic::test_pipeline_reuse_query [function] [call site] 02615
51 redis::cmd [function] [call site] 02618
51 redis::Cmd::arg [function] [call site] 02619
51 Cmd::exec [function] [call site] 02620
51 RedisResult::unwrap [function] [call site] 02621
51 types::test_is_single_arg [function] [call site] 02623
51 types::test_is_single_arg [function] [call site] 02624
51 types::test_is_single_arg [function] [call site] 02627
51 types::test_is_single_arg [function] [call site] 02628
51 basic::test_pipeline_reuse_query [function] [call site] 02629
50 parse_replication_info [function] [call site] 02631
50 HashMap::get [function] [call site] 02632
50 ClientTlsParams::clone [function] [call site] 02634
50 RedisError::from [function] [call site] 02636
49 evaluate_role_check_errors [function] [call site] 02638
49 RedisResult::unwrap_err [function] [call site] 02639
49 RedisResult::unwrap_err [function] [call site] 02640
46 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02642
46 Client::open [function] [call site] 02643
45 ConnectionAddr::is_err [function] [call site] 02645
45 redis_test::sentinel::wait_for_replica [function] [call site] 02646
46 redis::cmd [function] [call site] 02647
46 Client::get_connection [function] [call site] 02648
46 redis::Cmd::query [function] [call site] 02649
46 RedisResult::unwrap [function] [call site] 02650
46 String::from_redis_value_ref [function] [call site] 02651
46 ConnectionAddr::first [function] [call site] 02652
46 Result::unwrap [function] [call site] 02654
46 String::from_redis_value_ref [function] [call site] 02655
46 ConnectionAddr::get [function] [call site] 02656
46 Result::unwrap [function] [call site] 02658
46 starts_with [function] [call site] 02659
46 std::thread::sleep [function] [call site] 02661
46 Duration::from_millis [function] [call site] 02662
45 &mut [call site] 02664
46 Sentinel::find_valid_replica_addresses [function] [call site] 02665
47 Sentinel::get_sentinel_replicas [function] [call site] 02666
48 Sentinel::try_all_sentinels [function] [call site] 02667
48 sentinel_replicas_cmd [function] [call site] 02668
47 get_valid_replicas_addresses [function] [call site] 02669
48 valid_addrs [function] [call site] 02670
48 types::test_hashmap [function] [call site] 02671
48 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02672
48 map(|(ip, [call site] 02673
4 .collect::<RedisResult<Vec<ConnectionInfo>>> [function] [call site] 02674
48 &'a [call site] 02676
48 std::iter::Chain::filter [function] [call site] 02677
48 get_node_role [function] [call site] 02678
49 Client::open [function] [call site] 02679
49 redis::ConnectionInfo::clone [function] [call site] 02680
49 Client::get_connection [function] [call site] 02681
49 crate::cmd [function] [call site] 02682
49 redis::Cmd::query [function] [call site] 02683
48 RedisResult::is_ok_and [function] [call site] 02684
46 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02686
46 RedisServer::new [function] [call site] 02687
46 basic::test_pipeline_len [function] [call site] 02688
46 types::test_hashmap [function] [call site] 02689
46 try_connect_to_first_replica [function] [call site] 02690
45 Some [function] [call site] 02691
45 ConnectionAddr::is_err [function] [call site] 02692
42 SentinelClient::build [function] [call site] 02693
42 TestSentinelContext::sentinels_connection_info [function] [call site] 02694
42 ClientTlsParams::clone [function] [call site] 02695
42 String::from [function] [call site] 02696
42 Some [function] [call site] 02697
42 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02698
42 RedisResult::unwrap [function] [call site] 02699
42 SentinelClient::build [function] [call site] 02700
42 TestSentinelContext::sentinels_connection_info [function] [call site] 02701
42 ClientTlsParams::clone [function] [call site] 02702
42 String::from [function] [call site] 02703
42 Some [function] [call site] 02704
42 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02705
42 RedisResult::unwrap [function] [call site] 02706
42 AsyncConnectionConfig::new [function] [call site] 02707
42 AsyncConnectionConfig::set_connection_timeout [function] [call site] 02708
42 Some [function] [call site] 02709
42 Duration::from_secs [function] [call site] 02710
42 SentinelClient::get_async_connection_with_config [function] [call site] 02711
42 unwrap [function] [call site] 02712
42 async_tests::async_assert_is_connection_to_master [function] [call site] 02713
42 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02714
42 TestSentinelContext::sentinel_mut [function] [call site] 02715
42 &redis::sentinel::Sentinel::async_master_for [function] [call site] 02716
42 Some [function] [call site] 02717
42 unwrap [function] [call site] 02718
42 SentinelClient::get_async_connection_with_config [function] [call site] 02719
42 unwrap [function] [call site] 02720
42 async_tests::async_assert_connection_is_replica_of_correct_master [function] [call site] 02721
41 futures_time::time::Duration::from_millis [function] [call site] 02722
41 unwrap [function] [call site] 02723
41 unwrap [function] [call site] 02724
40 Some [function] [call site] 02725
40 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 02726
40 ClusterType::build_addr [function] [call site] 02727
41 ClusterType::get_intended [function] [call site] 02728
41 redis::ConnectionAddr::Tcp [function] [call site] 02729
41 &str::into [function] [call site] 02730
41 &str::into [function] [call site] 02731
40 ClientTlsParams::clone [function] [call site] 02732
41 ClientTlsParams::clone [function] [call site] 02733
41 secret_pkcs1_der [function] [call site] 02735
41 write_command_to_vec [function] [call site] 02736
41 secret_pkcs8_der [function] [call site] 02739
41 write_command_to_vec [function] [call site] 02740
41 secret_sec1_der [function] [call site] 02743
41 write_command_to_vec [function] [call site] 02744
40 tempfile::Builder::new [function] [call site] 02746
40 RedisResult::prefix [function] [call site] 02747
40 tempdir [function] [call site] 02748
40 expect [function] [call site] 02749
40 tests_routing::test_multi_shard_keys_and_path [function] [call site] 02750
41 Cmd::arg [function] [call site] 02752
41 types::test_is_single_arg [function] [call site] 02753
41 types::test_is_single_arg [function] [call site] 02754
41 types::test_is_single_arg [function] [call site] 02755
41 types::test_is_single_arg [function] [call site] 02756
41 RoutingInfo::for_routable [function] [call site] 02757
42 MockRedisConnection::req_packed_command [function] [call site] 02758
43 Cmd::get_packed_command [function] [call site] 02759
43 MockRedisConnection::req_packed_command [function] [call site] 02760
43 as_slice [function] [call site] 02761
43 PipelineSink::poll_ready [function] [call site] 02762
43 types::test_parse_boxed [function] [call site] 02763
42 base_routing [function] [call site] 02764
43 RouteBy::MultiShard [function] [call site] 02765
43 RouteBy::MultiShard [function] [call site] 02766
43 RouteBy::MultiShard [function] [call site] 02767
43 RouteBy::MultiShard [function] [call site] 02768
42 RoutingInfo::MultiNode [function] [call site] 02770
42 ResponsePolicy::for_command [function] [call site] 02771
43 ResponsePolicy::AggregateLogical [function] [call site] 02773
43 ResponsePolicy::Aggregate [function] [call site] 02775
43 ResponsePolicy::Aggregate [function] [call site] 02777
42 RoutingInfo::MultiNode [function] [call site] 02788
42 ResponsePolicy::for_command [function] [call site] 02789
42 multi_shard [function] [call site] 02790
43 commands::is_readonly_cmd [function] [call site] 02791
43 RedisServer::new [function] [call site] 02792
43 Cmd::arg_idx [function] [call site] 02793
44 Cmd::arg_idx [function] [call site] 02794
45 Cmd::arg_idx [function] [call site] 02795
43 cluster_async::get_push [function] [call site] 02796
43 Cmd::arg_idx [function] [call site] 02798
43 get_route [function] [call site] 02799
44 get_slot [function] [call site] 02800
45 get_hashtag [function] [call site] 02801
46 basic::test_tuple_decoding_from_iter [function] [call site] 02802
46 Cmd::position [function] [call site] 02803
47 Cmd::args_iter [function] [call site] 02804
47 Cmd::position [function] [call site] 02805
48 Cmd::args_iter [function] [call site] 02806
48 Cmd::position [function] [call site] 02807
48 ServerType::eq_ignore_ascii_case [function] [call site] 02808
47 ServerType::eq_ignore_ascii_case [function] [call site] 02809
46 basic::test_tuple_decoding_from_iter [function] [call site] 02810
46 Cmd::position [function] [call site] 02811
46 MockRedisConnection::is_empty [function] [call site] 02812
46 then_some [function] [call site] 02813
45 slot [function] [call site] 02814
46 crc16::State::<crc16::XMODEM>::calculate [function] [call site] 02815
44 Route::new [function] [call site] 02818
43 RedisServer::entry [function] [call site] 02819
44 TestContext::new [function] [call site] 02820
44 TestContext::connection [function] [call site] 02821
44 redis::Connection::xgroup_create_mkstream [function] [call site] 02822
44 redis::Connection::xadd_maxlen [function] [call site] 02823
44 StreamMaxlen::Equals [function] [call site] 02824
44 redis::Connection::xread_options [function] [call site] 02825
44 RedisServer::default [function] [call site] 02826
45 RedisServer::new [function] [call site] 02827
44 Self::group [function] [call site] 02828
45 TestContext::new [function] [call site] 02829
45 TestContext::connection [function] [call site] 02830
45 redis::Connection::xgroup_create_mkstream [function] [call site] 02831
45 redis::Connection::xgroup_destroy [function] [call site] 02832
45 redis::Connection::xgroup_create [function] [call site] 02834
45 redis::Connection::xread_options [function] [call site] 02835
45 RedisServer::default [function] [call site] 02836
45 Self::group [function] [call site] 02837
45 redis::Connection::xgroup_delconsumer [function] [call site] 02840
45 redis::Connection::xgroup_destroy [function] [call site] 02841
44 redis::Connection::xadd_maxlen [function] [call site] 02844
44 StreamMaxlen::Equals [function] [call site] 02845
44 redis::Connection::xread_options [function] [call site] 02846
44 RedisServer::default [function] [call site] 02847
44 Self::group [function] [call site] 02848
43 or_insert [function] [call site] 02851
43 RedisServer::new [function] [call site] 02852
43 cluster_async::get_push [function] [call site] 02853
43 incr_add_next_arg [function] [call site] 02854
43 Cmd::arg_idx [function] [call site] 02855
43 Option::is_none [function] [call site] 02856
43 RedisServer::iter_mut [function] [call site] 02857
43 cluster_async::get_push [function] [call site] 02858
43 incr_add_next_arg [function] [call site] 02859
43 incr_add_next_arg [function] [call site] 02860
43 &'a [call site] 02861
43 std::iter::Chain::collect [function] [call site] 02862
43 MockRedisConnection::is_empty [function] [call site] 02863
43 basic::test_pipeline_len [function] [call site] 02865
43 RoutingInfo::SingleNode [function] [call site] 02866
43 SingleNodeRoutingInfo::SpecificNode [function] [call site] 02867
43 RedisServer::pop [function] [call site] 02868
43 RoutingInfo::MultiNode [function] [call site] 02870
43 MultipleNodeRoutingInfo::MultiSlot [function] [call site] 02871
43 ResponsePolicy::for_command [function] [call site] 02872
42 RoutingInfo::SingleNode [function] [call site] 02874
42 Cmd::arg_idx [function] [call site] 02875
43 Cmd::arg_idx [function] [call site] 02876
42 Option::and_then [function] [call site] 02877
42 std::str::from_utf8 [function] [call site] 02878
42 wait_for_status_ok [function] [call site] 02879
42 and_then [function] [call site] 02880
42 parse::<u64> [function] [call site] 02881
42 wait_for_status_ok [function] [call site] 02882
42 RoutingInfo::SingleNode [function] [call site] 02884
42 Cmd::arg_idx [function] [call site] 02885
42 types::test_hashmap [function] [call site] 02886
42 RoutingInfo::for_key [function] [call site] 02887
43 RoutingInfo::SingleNode [function] [call site] 02888
43 SingleNodeRoutingInfo::SpecificNode [function] [call site] 02889
43 get_route [function] [call site] 02890
43 commands::is_readonly_cmd [function] [call site] 02891
42 Cmd::arg_idx [function] [call site] 02892
42 types::test_hashmap [function] [call site] 02893
42 RoutingInfo::for_key [function] [call site] 02894
42 Cmd::arg_idx [function] [call site] 02895
42 Option::and_then [function] [call site] 02896
42 std::str::from_utf8 [function] [call site] 02897
42 wait_for_status_ok [function] [call site] 02898
42 and_then [function] [call site] 02899
42 parse::<u64> [function] [call site] 02900
42 wait_for_status_ok [function] [call site] 02901
42 RoutingInfo::SingleNode [function] [call site] 02903
42 Cmd::arg_idx [function] [call site] 02904
42 types::test_hashmap [function] [call site] 02905
42 RoutingInfo::for_key [function] [call site] 02906
42 Cmd::position [function] [call site] 02907
43 Cmd::args_iter [function] [call site] 02908
43 Cmd::position [function] [call site] 02909
43 ServerType::eq_ignore_ascii_case [function] [call site] 02910
42 Cmd::arg_idx [function] [call site] 02911
42 types::test_hashmap [function] [call site] 02912
42 RoutingInfo::for_key [function] [call site] 02913
42 Cmd::arg_idx [function] [call site] 02914
42 Option::and_then [function] [call site] 02915
42 std::str::from_utf8 [function] [call site] 02916
42 wait_for_status_ok [function] [call site] 02917
42 and_then [function] [call site] 02918
42 parse::<u16> [function] [call site] 02919
42 wait_for_status_ok [function] [call site] 02920
42 types::test_hashmap [function] [call site] 02921
42 RoutingInfo::SingleNode [function] [call site] 02922
42 SingleNodeRoutingInfo::SpecificNode [function] [call site] 02923
42 Route::new [function] [call site] 02924
42 Cmd::arg_idx [function] [call site] 02925
42 RoutingInfo::for_key [function] [call site] 02927
42 RoutingInfo::SingleNode [function] [call site] 02929
41 std::collections::HashMap::new [function] [call site] 02930
42 RedisServer::with_modules [function] [call site] 02931
41 RedisServer::insert [function] [call site] 02932
41 RedisServer::insert [function] [call site] 02934
41 RedisServer::insert [function] [call site] 02936
40 join [function] [call site] 02938
40 std::fs::write [function] [call site] 02939
41 RedisServer::new [function] [call site] 02940
41 Tokio::poll_write [function] [call site] 02941
41 RedisServer::new [function] [call site] 02942
41 Tokio::poll_write [function] [call site] 02943
41 RedisServer::new [function] [call site] 02944
41 Tokio::poll_write [function] [call site] 02945
40 Poll::expect [function] [call site] 02946
40 Cmd::arg [function] [call site] 02947
40 types::test_is_single_arg [function] [call site] 02948
40 types::test_is_single_arg [function] [call site] 02949
40 types::test_is_single_arg [function] [call site] 02950
40 tests_routing::test_multi_shard_keys_and_path [function] [call site] 02951
40 join [function] [call site] 02952
40 types::test_is_single_arg [function] [call site] 02953
40 types::test_is_single_arg [function] [call site] 02954
40 types::test_is_single_arg [function] [call site] 02955
40 types::test_is_single_arg [function] [call site] 02956
40 types::test_is_single_arg [function] [call site] 02957
40 types::test_is_single_arg [function] [call site] 02958
40 Cmd::arg [function] [call site] 02959
40 types::test_is_single_arg [function] [call site] 02960
40 Cmd::arg [function] [call site] 02961
40 types::test_is_single_arg [function] [call site] 02962
40 Cmd::current_dir [function] [call site] 02963
40 tests_routing::test_multi_shard_keys_and_path [function] [call site] 02964
40 cluster_async::get_push [function] [call site] 02965
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] 02966
40 unwrap [function] [call site] 02967
40 ClusterClientBuilder::max_retry_wait [function] [call site] 02968
40 RedisServer::log_file_contents [function] [call site] 02969
41 std::fs::read_to_string [function] [call site] 02970
41 ClientTlsParams::clone [function] [call site] 02971
41 wait_for_status_ok [function] [call site] 02972
40 Err [function] [call site] 02973
40 RedisServer::log_file_contents [function] [call site] 02974
40 Err [function] [call site] 02975
40 port_in_use [function] [call site] 02976
41 ConnectionAddr::parse [function] [call site] 02977
41 socket2::Socket::new [function] [call site] 02979
42 RedisServer::with_modules [function] [call site] 02980
41 socket2::Domain::for_address [function] [call site] 02981
41 RedisServer::expect [function] [call site] 02982
40 ValueComparison::arg_to_string [function] [call site] 02986
40 Ok [function] [call site] 02987
40 std::thread::sleep [function] [call site] 02988
40 Duration::from_millis [function] [call site] 02989
40 &'a [call site] 02990
40 types::test_hashmap [function] [call site] 02991
40 get_random_available_port [function] [call site] 02992
40 RedisServer::contains [function] [call site] 02993
40 RedisServer::insert [function] [call site] 02994
40 make_server [function] [call site] 02995
40 std::thread::sleep [function] [call site] 02996
40 Duration::from_millis [function] [call site] 02997
40 verify_server [function] [call site] 02998
40 cluster_async::get_push [function] [call site] 02999
40 ClientTlsParams::clone [function] [call site] 03000
40 collect [function] [call site] 03001
40 process::Command::new [function] [call site] 03002
40 Cmd::stdout [function] [call site] 03003
40 process::Stdio::piped [function] [call site] 03004
40 types::test_is_single_arg [function] [call site] 03005
40 types::test_is_single_arg [function] [call site] 03006
40 types::test_std_types_to_redis_args [function] [call site] 03007
40 Cmd::arg [function] [call site] 03008
40 types::test_is_single_arg [function] [call site] 03009
40 ValueComparison::arg_to_string [function] [call site] 03010
40 Cmd::arg [function] [call site] 03011
40 Cmd::arg [function] [call site] 03012
40 Cmd::arg [function] [call site] 03013
40 Cmd::arg [function] [call site] 03014
40 Cmd::arg [function] [call site] 03015
40 Cmd::arg [function] [call site] 03016
40 Cmd::arg [function] [call site] 03017
40 Cmd::arg [function] [call site] 03018
40 None::is_some [function] [call site] 03019
40 None::as_ref [function] [call site] 03020
40 unwrap [function] [call site] 03021
40 Cmd::arg [function] [call site] 03022
40 types::test_is_single_arg [function] [call site] 03023
40 types::test_is_single_arg [function] [call site] 03024
40 Cmd::arg [function] [call site] 03025
40 types::test_is_single_arg [function] [call site] 03026
40 Cmd::output [function] [call site] 03027
40 unwrap [function] [call site] 03028
40 test_get_replica_clients_success [function] [call site] 03029
41 TestSentinelContext::new [function] [call site] 03030
41 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03031
41 TestSentinelContext::sentinel_mut [function] [call site] 03032
41 &redis::sentinel::Sentinel::get_replica_clients [function] [call site] 03033
42 Sentinel::find_valid_replica_addresses [function] [call site] 03034
42 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 03035
42 build_replica_clients [function] [call site] 03036
43 MockRedisConnection::is_empty [function] [call site] 03037
43 basic::test_tuple_decoding_from_iter [function] [call site] 03039
43 types::test_hashmap [function] [call site] 03040
43 Client::open [function] [call site] 03041
43 ClientTlsParams::clone [function] [call site] 03042
41 RedisResult::unwrap [function] [call site] 03045
40 std::thread::sleep [function] [call site] 03046
40 Duration::from_millis [function] [call site] 03047
40 RedisCluster::wait_for_replicas [function] [call site] 03048
41 RedisServer::connection_info [function] [call site] 03049
42 RedisServer::client_addr [function] [call site] 03050
42 &redis::ConnectionAddr::clone [function] [call site] 03051
42 ConnectionInfo::into_connection_info [function] [call site] 03052
42 RedisResult::unwrap [function] [call site] 03053
42 ConnectionInfo::set_redis_settings [function] [call site] 03054
42 redis_settings [function] [call site] 03055
41 redis::Client::open [function] [call site] 03056
41 RedisServer::connection_info [function] [call site] 03057
41 RedisResult::unwrap [function] [call site] 03058
41 Client::get_connection [function] [call site] 03059
41 RedisResult::unwrap [function] [call site] 03060
41 redis::cmd [function] [call site] 03061
41 redis::Cmd::arg [function] [call site] 03062
41 basic::test_pipeline_reuse_query [function] [call site] 03063
41 RedisResult::from_redis_value [function] [call site] 03065
41 Result::unwrap [function] [call site] 03072
41 basic::test_tuple_decoding_from_iter [function] [call site] 03073
41 block_on_all [function] [call site] 03074
42 panic::set_hook [function] [call site] 03075
42 RedisServer::new [function] [call site] 03076
42 RadiusOptions::store [function] [call site] 03077
43 ToRedisArgs::to_redis_args [function] [call site] 03079
44 RedisServer::new [function] [call site] 03080
44 SetExpiry::write_redis_args [function] [call site] 03081
45 Vec::write_arg [function] [call site] 03082
45 Vec::write_arg [function] [call site] 03083
45 as_bytes [function] [call site] 03084
45 Vec::write_arg [function] [call site] 03085
45 Vec::write_arg [function] [call site] 03086
45 as_bytes [function] [call site] 03087
45 Vec::write_arg [function] [call site] 03088
45 Vec::write_arg [function] [call site] 03089
45 as_bytes [function] [call site] 03090
45 Vec::write_arg [function] [call site] 03091
45 Vec::write_arg [function] [call site] 03092
45 as_bytes [function] [call site] 03093
45 Vec::write_arg [function] [call site] 03094
42 futures_util::FutureExt::fuse [function] [call site] 03095
42 script::test_script_load [function] [call site] 03096
43 TestContext::new [function] [call site] 03097
43 TestContext::connection [function] [call site] 03098
43 redis::Script::new [function] [call site] 03099
44 RedisServer::new [function] [call site] 03100
45 RedisServer::with_modules [function] [call site] 03101
44 SortedSetAddOptions::add_or_update [function] [call site] 03102
45 RedisServer::default [function] [call site] 03103
44 Option::as_bytes [function] [call site] 03104
44 ValueComparison::arg_to_string [function] [call site] 03105
45 impl [call site] 03106
45 String::from_utf8_lossy [function] [call site] 03107
45 into_owned [function] [call site] 03108
44 calculate_value_digest [function] [call site] 03109
45 impl [call site] 03110
45 RedisServer::new [function] [call site] 03111
45 RedisServer::extend_from_slice [function] [call site] 03112
44 ValueComparison::arg_to_string [function] [call site] 03114
45 impl [call site] 03115
45 String::from_utf8_lossy [function] [call site] 03116
45 into_owned [function] [call site] 03117
43 script::test_script_load [function] [call site] 03118
42 futures_time::task::sleep [function] [call site] 03119
43 tokio::time::sleep [function] [call site] 03120
43 smol::Timer::after [function] [call site] 03121
42 futures_time::time::Duration::from_millis [function] [call site] 03122
42 futures_util::FutureExt::fuse [function] [call site] 03123
42 block_on_all_using_tokio [function] [call site] 03124
43 redis::aio::prefer_tokio [function] [call site] 03125
44 set_runtime [function] [call site] 03126
45 types::test_hashbrown_hashset [function] [call site] 03127
46 parse_redis_value [function] [call site] 03128
46 Value::Array [function] [call site] 03129
46 RedisServer::new [function] [call site] 03130
46 RedisServer::insert [function] [call site] 03131
46 ValueComparison::arg_to_string [function] [call site] 03132
46 RedisServer::insert [function] [call site] 03133
46 ValueComparison::arg_to_string [function] [call site] 03134
46 RedisServer::insert [function] [call site] 03135
46 ValueComparison::arg_to_string [function] [call site] 03136
46 parse_redis_value [function] [call site] 03137
46 Value::Int [function] [call site] 03138
46 RedisServer::new [function] [call site] 03139
46 test_module_json_arr_insert [function] [call site] 03140
46 ValueComparison::arg_to_string [function] [call site] 03141
46 test_module_json_arr_insert [function] [call site] 03142
46 ValueComparison::arg_to_string [function] [call site] 03143
46 test_module_json_arr_insert [function] [call site] 03144
46 ValueComparison::arg_to_string [function] [call site] 03145
46 types::test_std_types_to_redis_args [function] [call site] 03146
46 &'a [call site] 03147
46 std::iter::Chain::collect [function] [call site] 03148
45 RedisError::from [function] [call site] 03150
43 Result::unwrap [function] [call site] 03151
43 current_thread_runtime [function] [call site] 03152
44 tokio::runtime::Builder::new_current_thread [function] [call site] 03153
44 enable_io [function] [call site] 03154
44 enable_time [function] [call site] 03155
44 Sentinel::build [function] [call site] 03156
44 RedisResult::unwrap [function] [call site] 03157
43 tokio::runtime::Runtime::block_on [function] [call site] 03158
42 block_on_all_using_smol [function] [call site] 03159
43 redis::aio::prefer_smol [function] [call site] 03160
44 set_runtime [function] [call site] 03161
43 Result::unwrap [function] [call site] 03162
43 smol::block_on [function] [call site] 03163
42 panic::take_hook [function] [call site] 03164
41 basic::test_pipeline_len [function] [call site] 03167
42 redis::pipe [function] [call site] 03168
42 types::test_is_single_arg [function] [call site] 03171
41 std::thread::sleep [function] [call site] 03172
41 Duration::from_millis [function] [call site] 03173
40 wait_for_status_ok [function] [call site] 03174
41 RedisServer::log_file [function] [call site] 03175
41 std::fs::read_to_string [function] [call site] 03176
41 Option::contains [function] [call site] 03178
41 std::thread::sleep [function] [call site] 03179
41 Duration::from_millis [function] [call site] 03180
39 RedisCluster::iter_servers [function] [call site] 03181
40 basic::test_tuple_decoding_from_iter [function] [call site] 03182
39 types::test_hashmap [function] [call site] 03183
39 collect [function] [call site] 03184
39 redis::cluster::ClusterClientBuilder::new [function] [call site] 03185
40 &'a [call site] 03186
40 std::iter::Chain::map [function] [call site] 03187
40 ConnectionInfo::into_connection_info [function] [call site] 03188
40 RedisServer::default [function] [call site] 03190
39 ClientTlsParams::clone [function] [call site] 03191
39 ClusterClientBuilder::use_protocol [function] [call site] 03192
39 redis_test::server::use_protocol [function] [call site] 03194
40 entra_id_tests::get_env_var [function] [call site] 03195
40 String::unwrap_or_default [function] [call site] 03196
39 ClusterType::get_intended [function] [call site] 03197
39 ClusterClientBuilder::certs [function] [call site] 03198
39 super::load_certs_from_file [function] [call site] 03202
40 MockRedisConnection::is_open [function] [call site] 03203
40 bool::expect [function] [call site] 03204
40 RedisServer::new [function] [call site] 03205
40 RedisServer::new [function] [call site] 03206
41 RedisServer::with_modules [function] [call site] 03207
40 RedisServer::read_to_end [function] [call site] 03208
40 MockRedisConnection::is_open [function] [call site] 03210
40 bool::expect [function] [call site] 03211
40 RedisServer::new [function] [call site] 03212
40 RedisServer::new [function] [call site] 03213
40 RedisServer::read_to_end [function] [call site] 03214
40 MockRedisConnection::is_open [function] [call site] 03216
40 bool::expect [function] [call site] 03217
40 RedisServer::new [function] [call site] 03218
40 RedisServer::new [function] [call site] 03219
40 RedisServer::read_to_end [function] [call site] 03220
39 initializer [function] [call site] 03224
39 Sentinel::build [function] [call site] 03225
39 RedisResult::unwrap [function] [call site] 03226
39 redis_test::server::use_protocol [function] [call site] 03227
38 RedisClusterConfiguration::default [function] [call site] 03228
37 cluster::test_cluster_retries [function] [call site] 03229
37 TestClusterContext::get_ports [function] [call site] 03230
37 MockRedisConnection::check_connection [function] [call site] 03231
37 RedisServer::drop [function] [call site] 03232
37 cmd [function] [call site] 03233
37 ClusterConnection::route_command [function] [call site] 03234
37 RoutingInfo::SingleNode [function] [call site] 03235
37 MockRedisConnection::req_packed_command [function] [call site] 03236
37 Cmd::get_packed_command [function] [call site] 03237
37 RedisCluster::new [function] [call site] 03238
37 RedisServer::default [function] [call site] 03239
37 ClusterConnection::route_command [function] [call site] 03240
37 RoutingInfo::SingleNode [function] [call site] 03241
37 RedisResult::unwrap [function] [call site] 03242
36 into [function] [call site] 03243
36 Arc::into_inner [function] [call site] 03244
36 unwrap [function] [call site] 03245
36 into_inner [function] [call site] 03246
36 crate::io::tcp::stream_with_settings [function] [call site] 03247
37 TcpSettings::set_nodelay [function] [call site] 03248
37 TcpStream::into [function] [call site] 03249
37 set_tcp_keepalive [function] [call site] 03250
37 set_tcp_user_timeout [function] [call site] 03251
36 try_into [function] [call site] 03255
35 ConnectionAddr::to_socket_addrs [function] [call site] 03256
35 connect_tcp_timeout [function] [call site] 03257
36 TcpStream::connect_timeout [function] [call site] 03258
36 io::tcp::stream_with_settings [function] [call site] 03259
37 TcpSettings::set_nodelay [function] [call site] 03260
37 TcpStream::into [function] [call site] 03261
37 set_tcp_keepalive [function] [call site] 03262
37 set_tcp_user_timeout [function] [call site] 03263
35 Some [function] [call site] 03267
35 Some [function] [call site] 03268
35 fail [function] [call site] 03269
35 fail [function] [call site] 03270
35 ActualConnection::Tcp [function] [call site] 03271
35 TlsConnector::builder [function] [call site] 03272
36 TestSentinelContext::new [function] [call site] 03273
36 TestSentinelContext::sentinels_connection_info [function] [call site] 03274
36 Client::open [function] [call site] 03275
36 &redis::sentinel::Sentinel::clone [function] [call site] 03276
37 ClientTlsParams::clone [function] [call site] 03277
37 secret_pkcs1_der [function] [call site] 03279
37 write_command_to_vec [function] [call site] 03280
37 secret_pkcs8_der [function] [call site] 03283
37 write_command_to_vec [function] [call site] 03284
37 secret_sec1_der [function] [call site] 03287
37 write_command_to_vec [function] [call site] 03288
36 RedisResult::unwrap [function] [call site] 03290
36 Client::get_connection [function] [call site] 03291
36 redis::cmd [function] [call site] 03293
36 redis::Cmd::query [function] [call site] 03294
36 RedisResult::unwrap [function] [call site] 03295
36 SentinelClientBuilder::new [function] [call site] 03296
37 &'a [call site] 03298
37 into_iter().collect::<Vec<_>> [function] [call site] 03299
37 impl [call site] 03300
36 basic::test_tuple_decoding_from_iter [function] [call site] 03302
36 types::test_hashmap [function] [call site] 03303
36 &redis::sentinel::Sentinel::addr [function] [call site] 03304
37 ServerType::get_intended [function] [call site] 03305
37 ValueComparison::arg_to_string [function] [call site] 03306
37 redis::ConnectionAddr::Tcp [function] [call site] 03307
37 ValueComparison::arg_to_string [function] [call site] 03308
37 rand::random::<(u64, [call site] 03309
37 redis::ConnectionAddr::Unix [function] [call site] 03310
37 ValueType::from [function] [call site] 03311
36 ClientTlsParams::clone [function] [call site] 03312
36 String::from [function] [call site] 03313
36 RedisResult::unwrap [function] [call site] 03314
36 SentinelClientBuilder::new [function] [call site] 03315
36 basic::test_tuple_decoding_from_iter [function] [call site] 03316
36 types::test_hashmap [function] [call site] 03317
36 &redis::sentinel::Sentinel::addr [function] [call site] 03318
36 ClientTlsParams::clone [function] [call site] 03319
36 String::from [function] [call site] 03320
36 RedisResult::unwrap [function] [call site] 03321
36 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 03322
36 redis_test::server::use_protocol [function] [call site] 03324
36 TestSentinelContext::tls_mode [function] [call site] 03325
36 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03326
36 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03328
36 Sentinel::build [function] [call site] 03329
36 Sentinel::build [function] [call site] 03331
36 Client::get_connection [function] [call site] 03333
36 redis::cmd [function] [call site] 03335
36 redis::Cmd::query [function] [call site] 03336
36 RedisResult::unwrap [function] [call site] 03337
36 assert_is_connection_to_master [function] [call site] 03338
37 redis::cmd [function] [call site] 03339
37 redis::Cmd::arg [function] [call site] 03340
37 basic::test_pipeline_reuse_query [function] [call site] 03341
37 assert_is_master_role [function] [call site] 03343
36 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03344
36 TestSentinelContext::sentinel_mut [function] [call site] 03345
36 &redis::sentinel::Sentinel::master_for [function] [call site] 03346
37 Sentinel::find_master_address [function] [call site] 03347
37 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 03348
37 Client::open [function] [call site] 03349
36 RedisResult::unwrap [function] [call site] 03351
36 Client::get_connection [function] [call site] 03352
36 redis::cmd [function] [call site] 03354
36 redis::Cmd::query [function] [call site] 03355
36 RedisResult::unwrap [function] [call site] 03356
36 assert_connection_is_replica_of_correct_master [function] [call site] 03357
37 redis::cmd [function] [call site] 03358
37 redis::Cmd::arg [function] [call site] 03359
37 basic::test_pipeline_reuse_query [function] [call site] 03360
37 assert_replica_role_and_master_addr [function] [call site] 03362
37 Client::get_connection_info [function] [call site] 03363
35 danger_accept_invalid_certs [function] [call site] 03364
35 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03365
36 ClusterType::get_intended [function] [call site] 03366
36 TestClusterContext::new_with_config_and_builder [function] [call site] 03367
37 support::start_tls_crypto_provider [function] [call site] 03368
37 RedisCluster::new [function] [call site] 03369
37 RedisCluster::iter_servers [function] [call site] 03370
37 types::test_hashmap [function] [call site] 03371
37 redis::cluster::ClusterClientBuilder::new [function] [call site] 03373
37 ClientTlsParams::clone [function] [call site] 03374
37 ClusterClientBuilder::use_protocol [function] [call site] 03375
37 redis_test::server::use_protocol [function] [call site] 03376
37 ClusterType::get_intended [function] [call site] 03377
37 ClusterClientBuilder::certs [function] [call site] 03378
37 super::load_certs_from_file [function] [call site] 03379
37 initializer [function] [call site] 03380
37 Sentinel::build [function] [call site] 03381
37 RedisResult::unwrap [function] [call site] 03382
37 redis_test::server::use_protocol [function] [call site] 03383
36 RedisServer::default [function] [call site] 03384
36 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03385
36 cluster::smoke_test_connection [function] [call site] 03386
37 redis::cmd [function] [call site] 03387
37 redis::Cmd::arg [function] [call site] 03388
37 types::test_is_single_arg [function] [call site] 03389
37 Cmd::exec [function] [call site] 03390
38 query::<()> [function] [call site] 03391
37 RedisResult::unwrap [function] [call site] 03392
37 redis::cmd [function] [call site] 03393
37 redis::Cmd::arg [function] [call site] 03394
37 Cmd::exec [function] [call site] 03395
37 RedisResult::unwrap [function] [call site] 03396
36 MockRedisConnection::check_connection [function] [call site] 03397
35 use_sni [function] [call site] 03398
35 Sentinel::build [function] [call site] 03399
35 TlsConnector::builder [function] [call site] 03400
35 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03401
35 Sentinel::build [function] [call site] 03402
35 RedisServer::new [function] [call site] 03403
36 RedisServer::with_modules [function] [call site] 03404
35 as_str [function] [call site] 03405
35 connect_tcp [function] [call site] 03406
35 connect [function] [call site] 03407
35 fail [function] [call site] 03408
35 as_str [function] [call site] 03409
35 to_socket_addrs [function] [call site] 03410
35 connect_tcp_timeout [function] [call site] 03411
35 Some [function] [call site] 03412
35 Some [function] [call site] 03413
35 connect [function] [call site] 03414
35 unwrap [function] [call site] 03415
35 fail [function] [call site] 03416
35 fail [function] [call site] 03417
35 ActualConnection::TcpNativeTls [function] [call site] 03418
35 RedisServer::new [function] [call site] 03419
35 create_rustls_config [function] [call site] 03420
36 MockRedisConnection::is_empty [function] [call site] 03421
37 StreamReadOptions::block [function] [call site] 03422
37 MockRedisConnection::is_empty [function] [call site] 03424
36 bool::extend [function] [call site] 03425
36 basic::test_tuple_decoding_from_iter [function] [call site] 03426
36 rustls_native_certs::load_native_certs [function] [call site] 03428
36 test_module_json_arr_pop [function] [call site] 03429
37 TestContext::with_modules [function] [call site] 03430
37 TestContext::connection [function] [call site] 03431
37 redis::Connection::json_set [function] [call site] 03432
37 redis::Connection::json_arr_pop [function] [call site] 03433
37 redis::Connection::json_set [function] [call site] 03434
37 redis::Connection::json_arr_pop [function] [call site] 03435
36 bool::add [function] [call site] 03438
37 &mut [call site] 03439
37 &mut [call site] 03441
37 &mut [call site] 03443
37 &mut [call site] 03445
36 rustls::ClientConfig::builder [function] [call site] 03447
37 TestSentinelContext::new [function] [call site] 03448
37 TestSentinelContext::sentinels_connection_info [function] [call site] 03449
37 Client::open [function] [call site] 03450
37 &redis::sentinel::Sentinel::clone [function] [call site] 03451
37 RedisResult::unwrap [function] [call site] 03452
37 Client::get_connection [function] [call site] 03453
37 redis::cmd [function] [call site] 03455
37 redis::Cmd::query [function] [call site] 03456
37 RedisResult::unwrap [function] [call site] 03457
37 SentinelClientBuilder::new [function] [call site] 03458
37 basic::test_tuple_decoding_from_iter [function] [call site] 03459
37 types::test_hashmap [function] [call site] 03460
37 &redis::sentinel::Sentinel::addr [function] [call site] 03461
37 ClientTlsParams::clone [function] [call site] 03462
37 String::from [function] [call site] 03463
37 RedisResult::unwrap [function] [call site] 03464
37 SentinelClientBuilder::new [function] [call site] 03465
37 basic::test_tuple_decoding_from_iter [function] [call site] 03466
37 types::test_hashmap [function] [call site] 03467
37 &redis::sentinel::Sentinel::addr [function] [call site] 03468
37 ClientTlsParams::clone [function] [call site] 03469
37 String::from [function] [call site] 03470
37 RedisResult::unwrap [function] [call site] 03471
37 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 03472
37 redis_test::server::use_protocol [function] [call site] 03473
37 TestSentinelContext::tls_mode [function] [call site] 03474
37 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03475
37 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03476
37 Sentinel::build [function] [call site] 03477
37 Sentinel::build [function] [call site] 03479
37 Client::get_connection [function] [call site] 03481
37 redis::cmd [function] [call site] 03483
37 redis::Cmd::query [function] [call site] 03484
37 RedisResult::unwrap [function] [call site] 03485
37 assert_is_connection_to_master [function] [call site] 03486
37 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03487
37 TestSentinelContext::sentinel_mut [function] [call site] 03488
37 &redis::sentinel::Sentinel::master_for [function] [call site] 03489
37 RedisResult::unwrap [function] [call site] 03491
37 Client::get_connection [function] [call site] 03492
37 redis::cmd [function] [call site] 03494
37 redis::Cmd::query [function] [call site] 03495
37 RedisResult::unwrap [function] [call site] 03496
37 assert_connection_is_replica_of_correct_master [function] [call site] 03497
36 unwrap_or [function] [call site] 03498
36 Self::with_root_certificates [function] [call site] 03499
36 ClientTlsParams::clone [function] [call site] 03500
36 with_client_auth_cert [function] [call site] 03501
36 RedisError::from [function] [call site] 03503
36 ValueComparison::arg_to_string [function] [call site] 03504
36 with_no_client_auth [function] [call site] 03505
36 Self::dangerous [function] [call site] 03507
36 set_certificate_verifier [function] [call site] 03508
36 RedisServer::new [function] [call site] 03509
36 rustls::client::WebPkiServerVerifier::builder [function] [call site] 03510
37 TestSentinelContext::new [function] [call site] 03511
37 TestSentinelContext::sentinels_connection_info [function] [call site] 03512
37 Client::open [function] [call site] 03513
37 &redis::sentinel::Sentinel::clone [function] [call site] 03514
37 RedisResult::unwrap [function] [call site] 03515
37 Client::get_connection [function] [call site] 03516
37 redis::cmd [function] [call site] 03518
37 redis::Cmd::query [function] [call site] 03519
37 RedisResult::unwrap [function] [call site] 03520
37 SentinelClientBuilder::new [function] [call site] 03521
37 basic::test_tuple_decoding_from_iter [function] [call site] 03522
37 types::test_hashmap [function] [call site] 03523
37 &redis::sentinel::Sentinel::addr [function] [call site] 03524
37 ClientTlsParams::clone [function] [call site] 03525
37 String::from [function] [call site] 03526
37 RedisResult::unwrap [function] [call site] 03527
37 SentinelClientBuilder::new [function] [call site] 03528
37 basic::test_tuple_decoding_from_iter [function] [call site] 03529
37 types::test_hashmap [function] [call site] 03530
37 &redis::sentinel::Sentinel::addr [function] [call site] 03531
37 ClientTlsParams::clone [function] [call site] 03532
37 String::from [function] [call site] 03533
37 RedisResult::unwrap [function] [call site] 03534
37 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 03535
37 redis_test::server::use_protocol [function] [call site] 03536
37 TestSentinelContext::tls_mode [function] [call site] 03537
37 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03538
37 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03539
37 Sentinel::build [function] [call site] 03540
37 Sentinel::build [function] [call site] 03542
37 Client::get_connection [function] [call site] 03544
37 redis::cmd [function] [call site] 03546
37 redis::Cmd::query [function] [call site] 03547
37 RedisResult::unwrap [function] [call site] 03548
37 assert_is_connection_to_master [function] [call site] 03549
37 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03550
37 TestSentinelContext::sentinel_mut [function] [call site] 03551
37 &redis::sentinel::Sentinel::master_for [function] [call site] 03552
37 RedisResult::unwrap [function] [call site] 03554
37 Client::get_connection [function] [call site] 03555
37 redis::cmd [function] [call site] 03557
37 redis::Cmd::query [function] [call site] 03558
37 RedisResult::unwrap [function] [call site] 03559
37 assert_connection_is_replica_of_correct_master [function] [call site] 03560
36 RedisServer::new [function] [call site] 03561
36 Sentinel::build [function] [call site] 03562
36 RedisResult::map_err [function] [call site] 03563
36 rustls::Error::from [function] [call site] 03564
37 io::Error::from [function] [call site] 03565
37 Self::into [function] [call site] 03566
36 rustls::OtherError [function] [call site] 03567
36 RedisServer::new [function] [call site] 03568
36 Self::with_root_certificates [function] [call site] 03569
36 with_no_client_auth [function] [call site] 03570
36 rustls::crypto::CryptoProvider::get_default [function] [call site] 03571
36 RedisError::from [function] [call site] 03573
36 Self::dangerous [function] [call site] 03574
36 set_certificate_verifier [function] [call site] 03575
36 RedisServer::new [function] [call site] 03576
35 ClientTlsParams::clone [function] [call site] 03580
35 rustls::ClientConnection::new [function] [call site] 03581
36 RedisServer::with_modules [function] [call site] 03582
35 RedisServer::new [function] [call site] 03583
35 rustls::pki_types::ServerName::try_from [function] [call site] 03584
35 to_owned [function] [call site] 03587
35 connect_tcp [function] [call site] 03588
35 RedisServer::new [function] [call site] 03589
36 RedisServer::with_modules [function] [call site] 03590
35 to_socket_addrs [function] [call site] 03591
35 connect_tcp_timeout [function] [call site] 03592
35 Some [function] [call site] 03593
35 Some [function] [call site] 03594
35 RedisServer::new [function] [call site] 03595
35 fail [function] [call site] 03596
35 fail [function] [call site] 03597
35 ActualConnection::TcpRustls [function] [call site] 03598
35 RedisServer::new [function] [call site] 03599
35 fail [function] [call site] 03600
35 ActualConnection::Unix [function] [call site] 03601
35 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 03602
36 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 03603
36 cluster::test_cluster_retries [function] [call site] 03604
36 TestClusterContext::get_ports [function] [call site] 03605
36 MockRedisConnection::check_connection [function] [call site] 03606
36 RedisServer::drop [function] [call site] 03607
36 ClusterConnection::route_command [function] [call site] 03609
36 RoutingInfo::SingleNode [function] [call site] 03610
36 MockRedisConnection::req_packed_command [function] [call site] 03611
36 Cmd::get_packed_command [function] [call site] 03612
36 RedisCluster::new [function] [call site] 03613
36 RedisServer::default [function] [call site] 03614
36 ClusterConnection::route_command [function] [call site] 03615
36 RoutingInfo::SingleNode [function] [call site] 03616
36 RedisResult::unwrap [function] [call site] 03617
35 fail [function] [call site] 03618
34 and_then [function] [call site] 03619
34 checked_sub [function] [call site] 03620
34 elapsed [function] [call site] 03621
34 is_some [function] [call site] 03622
34 is_none [function] [call site] 03623
34 Err [function] [call site] 03624
34 RedisError::from [function] [call site] 03625
34 std::io::Error::new [function] [call site] 03626
35 RedisServer::with_modules [function] [call site] 03627
34 MockConnection::set_read_timeout [function] [call site] 03628
34 MockConnection::set_write_timeout [function] [call site] 03630
34 setup_connection [function] [call site] 03632
35 execute_connection_pipeline [function] [call site] 03633
35 connection_setup_pipeline [function] [call site] 03634
35 execute_connection_pipeline [function] [call site] 03635
35 connection_setup_pipeline [function] [call site] 03636
34 MockConnection::set_read_timeout [function] [call site] 03638
34 MockConnection::set_write_timeout [function] [call site] 03639
34 Ok [function] [call site] 03640
32 unwrap [function] [call site] 03641
31 ValueType::from [function] [call site] 03642
31 basic::test_tuple_decoding_from_iter [function] [call site] 03643
31 hscan::<_, [call site] 03644
31 unwrap [function] [call site] 03645
31 unwrap [function] [call site] 03646
29 into_iter().collect::<Vec<_>> [function] [call site] 03647
29 impl [call site] 03648
29 into [function] [call site] 03649
28 RedisResult::prefix [function] [call site] 03650
28 tempdir [function] [call site] 03651
28 expect [function] [call site] 03652
28 RedisServer::log_file [function] [call site] 03653
29 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03654
28 types::test_is_single_arg [function] [call site] 03656
28 types::test_is_single_arg [function] [call site] 03657
28 ClientTlsParams::clone [function] [call site] 03658
29 ClientTlsParams::clone [function] [call site] 03659
29 secret_pkcs1_der [function] [call site] 03661
29 write_command_to_vec [function] [call site] 03662
29 secret_pkcs8_der [function] [call site] 03665
29 write_command_to_vec [function] [call site] 03666
29 secret_sec1_der [function] [call site] 03669
29 write_command_to_vec [function] [call site] 03670
28 get_major_version [function] [call site] 03672
29 String::from_utf8 [function] [call site] 03673
29 process::Command::new [function] [call site] 03674
29 types::test_is_single_arg [function] [call site] 03675
29 split_once [function] [call site] 03679
29 split_once [function] [call site] 03681
28 types::test_is_single_arg [function] [call site] 03685
28 types::test_is_single_arg [function] [call site] 03686
28 types::test_is_single_arg [function] [call site] 03687
28 types::test_is_single_arg [function] [call site] 03688
28 ValueComparison::arg_to_string [function] [call site] 03689
28 types::test_is_single_arg [function] [call site] 03690
28 types::test_is_single_arg [function] [call site] 03691
28 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 03692
29 process::Command::new [function] [call site] 03693
29 types::test_is_single_arg [function] [call site] 03694
29 types::test_is_single_arg [function] [call site] 03695
29 types::test_is_single_arg [function] [call site] 03696
29 entra_id_tests::get_env_var [function] [call site] 03697
29 String::expect [function] [call site] 03698
29 RedisServer::stdout [function] [call site] 03699
29 process::Stdio::piped [function] [call site] 03700
29 process::Stdio::piped [function] [call site] 03702
29 tempfile::Builder::new [function] [call site] 03703
29 RedisResult::prefix [function] [call site] 03704
29 RedisServer::log_file [function] [call site] 03707
29 types::test_is_single_arg [function] [call site] 03708
29 types::test_is_single_arg [function] [call site] 03709
29 ClientTlsParams::clone [function] [call site] 03710
29 get_major_version [function] [call site] 03711
29 types::test_is_single_arg [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 types::test_is_single_arg [function] [call site] 03715
29 ValueComparison::arg_to_string [function] [call site] 03716
29 types::test_is_single_arg [function] [call site] 03717
29 types::test_is_single_arg [function] [call site] 03718
29 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 03719
29 Option<TlsFilePaths>::unwrap_or_else [function] [call site] 03720
29 utils::build_keys_and_certs_for_tls [function] [call site] 03721
30 build_keys_and_certs_for_tls_ext [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 ValueComparison::arg_to_string [function] [call site] 03725
30 impl [call site] 03726
30 String::from_utf8_lossy [function] [call site] 03727
30 into_owned [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 types::test_is_single_arg [function] [call site] 03731
29 types::test_is_single_arg [function] [call site] 03732
29 types::test_is_single_arg [function] [call site] 03733
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 types::test_is_single_arg [function] [call site] 03738
29 types::test_is_single_arg [function] [call site] 03739
29 types::test_is_single_arg [function] [call site] 03740
29 ClientTlsParams::clone [function] [call site] 03741
29 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 03742
29 types::test_is_single_arg [function] [call site] 03744
29 types::test_is_single_arg [function] [call site] 03745
29 types::test_is_single_arg [function] [call site] 03746
29 types::test_is_single_arg [function] [call site] 03747
29 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 03748
28 Option<TlsFilePaths>::unwrap_or_else [function] [call site] 03749
28 utils::build_keys_and_certs_for_tls [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 ValueComparison::arg_to_string [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 types::test_is_single_arg [function] [call site] 03756
28 types::test_is_single_arg [function] [call site] 03757
28 types::test_is_single_arg [function] [call site] 03758
28 types::test_is_single_arg [function] [call site] 03759
28 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 types::test_is_single_arg [function] [call site] 03763
28 types::test_is_single_arg [function] [call site] 03764
28 types::test_is_single_arg [function] [call site] 03765
28 ClientTlsParams::clone [function] [call site] 03766
28 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 03767
28 Some [function] [call site] 03768
28 types::test_is_single_arg [function] [call site] 03769
28 types::test_is_single_arg [function] [call site] 03770
28 types::test_is_single_arg [function] [call site] 03771
28 types::test_is_single_arg [function] [call site] 03772
28 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 03773
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] 03774
27 unwrap_or_else [function] [call site] 03775
27 build_single_client [function] [call site] 03776
28 redis::Client::open [function] [call site] 03777
27 RedisServer::connection_info [function] [call site] 03778
27 RedisResult::unwrap [function] [call site] 03779
27 Duration::from_millis [function] [call site] 03780
27 Client::get_connection [function] [call site] 03781
27 RedisError::is_connection_refusal [function] [call site] 03782
28 RedisError::as_io_error [function] [call site] 03783
28 Option::is_some_and [function] [call site] 03784
28 get_push_kind [function] [call site] 03785
27 std::thread::sleep [function] [call site] 03786
27 flushdb::<()> [function] [call site] 03787
27 unwrap [function] [call site] 03788
27 redis_test::server::use_protocol [function] [call site] 03789
24 TestContext::connection [function] [call site] 03790
24 redis::Connection::json_set [function] [call site] 03791
24 redis::Connection::json_arr_insert [function] [call site] 03792
24 redis::Connection::json_set [function] [call site] 03793
24 redis::Connection::json_arr_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
23 RedisServer::default [function] [call site] 03802
23 HashMap::with_hasher [function] [call site] 03803
23 PathBuf::insert [function] [call site] 03804
23 &str::into [function] [call site] 03805
23 PathBuf::insert [function] [call site] 03806
23 &str::into [function] [call site] 03807
23 PathBuf::insert [function] [call site] 03808
23 &str::into [function] [call site] 03809
23 parse_redis_value [function] [call site] 03810
23 Value::Array [function] [call site] 03811
22 Ok [function] [call site] 03812
20 types::test_hashmap [function] [call site] 03813
20 Ok [function] [call site] 03814
19 ClientTlsParams::clone [function] [call site] 03815
20 ClientTlsParams::clone [function] [call site] 03816
20 secret_pkcs1_der [function] [call site] 03818
20 write_command_to_vec [function] [call site] 03819
20 secret_pkcs8_der [function] [call site] 03822
20 write_command_to_vec [function] [call site] 03823
20 secret_sec1_der [function] [call site] 03826
20 write_command_to_vec [function] [call site] 03827
16 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 03829
16 Some [function] [call site] 03830
16 map_err [function] [call site] 03831
16 map_err [function] [call site] 03832
16 and_then [function] [call site] 03833
16 map_err [function] [call site] 03834
16 Runtime::locate [function] [call site] 03835
16 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 03836
17 TestSentinelContext::new [function] [call site] 03837
17 SentinelClient::build [function] [call site] 03838
17 TestSentinelContext::sentinels_connection_info [function] [call site] 03839
17 ClientTlsParams::clone [function] [call site] 03840
17 String::from [function] [call site] 03841
17 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03843
17 RedisResult::unwrap [function] [call site] 03844
17 SentinelClient::build [function] [call site] 03845
17 TestSentinelContext::sentinels_connection_info [function] [call site] 03846
17 ClientTlsParams::clone [function] [call site] 03847
17 String::from [function] [call site] 03848
17 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03850
17 RedisResult::unwrap [function] [call site] 03851
17 AsyncConnectionConfig::new [function] [call site] 03852
17 AsyncConnectionConfig::set_connection_timeout [function] [call site] 03853
17 Duration::from_secs [function] [call site] 03855
17 SentinelClient::get_async_connection_with_config [function] [call site] 03856
17 async_tests::async_assert_is_connection_to_master [function] [call site] 03858
17 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03859
17 TestSentinelContext::sentinel_mut [function] [call site] 03860
17 &redis::sentinel::Sentinel::async_master_for [function] [call site] 03861
17 SentinelClient::get_async_connection_with_config [function] [call site] 03864
17 async_tests::async_assert_connection_is_replica_of_correct_master [function] [call site] 03866
16 Err [function] [call site] 03867
16 Some [function] [call site] 03868
16 into [function] [call site] 03869
16 map_err [function] [call site] 03870
16 unwrap_or_else [function] [call site] 03871
15 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 03872
15 futures_time::time::Duration::from_millis [function] [call site] 03873
15 unwrap [function] [call site] 03874
15 unwrap [function] [call site] 03875
14 to_owned [function] [call site] 03876
13 Vec::write_arg [function] [call site] 03877
13 as_bytes [function] [call site] 03878
13 Vec::write_arg [function] [call site] 03879
13 Vec::write_arg [function] [call site] 03880
13 as_bytes [function] [call site] 03881
13 Vec::write_arg [function] [call site] 03882
13 Vec::write_arg [function] [call site] 03883
13 as_bytes [function] [call site] 03884
13 Vec::write_arg [function] [call site] 03885
13 Vec::write_arg [function] [call site] 03886
13 as_bytes [function] [call site] 03887
13 Vec::write_arg [function] [call site] 03888
10 Cmd::arg [function] [call site] 03889
10 types::test_is_single_arg [function] [call site] 03890
10 types::test_is_single_arg [function] [call site] 03891
10 types::test_is_single_arg [function] [call site] 03892
10 types::test_is_single_arg [function] [call site] 03893
10 RoutingInfo::for_routable [function] [call site] 03894
10 std::collections::HashMap::new [function] [call site] 03895
10 RedisServer::insert [function] [call site] 03896
10 Route [function] [call site] 03897
10 RedisServer::insert [function] [call site] 03898
10 Route [function] [call site] 03899
10 RedisServer::insert [function] [call site] 03900
10 Route [function] [call site] 03901
9 join [function] [call site] 03902
8 std::fs::read_to_string [function] [call site] 03903
8 expect [function] [call site] 03904
8 Option::contains [function] [call site] 03905
8 std::thread::sleep [function] [call site] 03906
8 Duration::from_millis [function] [call site] 03907
7 as_ref [function] [call site] 03908
7 types::test_hashmap [function] [call site] 03909
6 ValueComparison::arg_to_string [function] [call site] 03910
6 redis::ConnectionAddr::Tcp [function] [call site] 03911
6 ValueComparison::arg_to_string [function] [call site] 03912
6 rand::random::<(u64, [call site] 03913
6 redis::ConnectionAddr::Unix [function] [call site] 03914
6 ValueType::from [function] [call site] 03915
5 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 03916
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] 03917
5 unwrap_or_else [function] [call site] 03918
2 Parser::parse_value [function] [call site] 03919