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
1601 2264 RedisCluster::new call site: 02264 cluster::test_cluster_reconnect_after_complete_server_disconnect
1193 1070 get_push_kind call site: 01070 Sentinel::async_master_for
994 74 parse_redis_value call site: 00074 cluster::test_cluster_reconnect_after_complete_server_disconnect
69 3 Parser::new call site: 00003 tests_routing::test_multi_shard_keys_and_path
1 0 EP call site: 00000

Fuzzer calltree

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