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
2332 1138 get_push_kind call site: 01138 cluster::test_cluster_reconnect_after_complete_server_disconnect
1035 3 Parser::new call site: 00003 cluster::test_cluster_reconnect_after_complete_server_disconnect
513 3556 Cmd::position call site: 03556 port_in_use
96 1040 parse_redis_value call site: 01040 RedisError::is_unrecoverable_error
77 3476 Cmd::position call site: 03476 basic_async::test_lazy_connection_manager_with_resp3_push
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 unwrap [function] [call site] 00008
7 into [function] [call site] 00009
7 RedisServer::new [function] [call site] 00010
8 RedisServer::with_modules [function] [call site] 00011
7 Self::unwrap [function] [call site] 00012
7 set_reuse_address [function] [call site] 00013
7 unwrap [function] [call site] 00014
7 bind [function] [call site] 00015
7 unwrap [function] [call site] 00016
7 listen [function] [call site] 00017
7 unwrap [function] [call site] 00018
7 ComponentMatcher::from [function] [call site] 00019
8 ComponentMatcher::from [function] [call site] 00020
9 ComponentMatcher::from [function] [call site] 00021
9 impl [call site] 00022
8 impl [call site] 00023
6 TcpListener::local_addr [function] [call site] 00024
6 unwrap [function] [call site] 00025
6 get_listener_on_free_port [function] [call site] 00026
7 0.0.1:0".parse::<SocketAddr> [function] [call site] 00027
7 unwrap [function] [call site] 00028
7 into [function] [call site] 00029
7 RedisServer::new [function] [call site] 00030
7 Self::unwrap [function] [call site] 00031
7 set_reuse_address [function] [call site] 00032
7 unwrap [function] [call site] 00033
7 bind [function] [call site] 00034
7 unwrap [function] [call site] 00035
7 listen [function] [call site] 00036
7 unwrap [function] [call site] 00037
7 ComponentMatcher::from [function] [call site] 00038
5 RedisServer::get_addr [function] [call site] 00039
6 ServerType::get_intended [function] [call site] 00040
7 entra_id_tests::get_env_var [function] [call site] 00041
8 std::env::var [function] [call site] 00042
9 std::env::var [function] [call site] 00043
9 String::unwrap_or_else [function] [call site] 00044
8 String::unwrap_or_else [function] [call site] 00045
7 tests::redis_ok [function] [call site] 00046
7 as_ref [function] [call site] 00047
7 tests::into_redis_value_hashmap [function] [call site] 00048
8 ComponentMatcher::from [function] [call site] 00049
9 ComponentMatcher::from [function] [call site] 00050
9 impl [call site] 00051
8 String::into_redis_value [function] [call site] 00052
9 Value::BulkString [function] [call site] 00053
9 String::as_bytes [function] [call site] 00054
9 write_command_to_vec [function] [call site] 00055
10 args_len [function] [call site] 00056
11 countdigits [function] [call site] 00057
11 basic::test_pipeline_len [function] [call site] 00058
12 redis::pipe [function] [call site] 00059
13 redis::pipe [function] [call site] 00060
13 Pipeline::atomic [function] [call site] 00061
13 redis::pipe [function] [call site] 00062
12 cmd [function] [call site] 00063
13 Cmd::new [function] [call site] 00064
13 types::test_is_single_arg [function] [call site] 00065
12 cmd [function] [call site] 00066
12 types::test_is_single_arg [function] [call site] 00067
11 bulklen [function] [call site] 00068
12 countdigits [function] [call site] 00069
11 countdigits [function] [call site] 00070
11 basic::test_pipeline_len [function] [call site] 00071
10 ClientTlsParams::clone [function] [call site] 00072
11 ClientTlsParams::clone [function] [call site] 00073
11 Pkcs1 [function] [call site] 00074
11 secret_pkcs1_der [function] [call site] 00075
11 write_command_to_vec [function] [call site] 00076
11 into [function] [call site] 00077
11 Pkcs8 [function] [call site] 00078
11 secret_pkcs8_der [function] [call site] 00079
11 write_command_to_vec [function] [call site] 00080
11 into [function] [call site] 00081
11 Sec1 [function] [call site] 00082
11 secret_sec1_der [function] [call site] 00083
11 write_command_to_vec [function] [call site] 00084
11 into [function] [call site] 00085
10 Cmd::reserve [function] [call site] 00086
10 write_command [function] [call site] 00087
11 ::itoa::Buffer::new [function] [call site] 00088
12 RedisServer::with_modules [function] [call site] 00089
11 Cmd::extend_from_slice [function] [call site] 00090
11 Cmd::extend_from_slice [function] [call site] 00091
11 Self::format [function] [call site] 00092
11 basic::test_pipeline_len [function] [call site] 00093
11 as_bytes [function] [call site] 00094
11 Cmd::extend_from_slice [function] [call site] 00095
11 itoa::Buffer::new [function] [call site] 00096
12 RedisServer::with_modules [function] [call site] 00097
11 Self::format [function] [call site] 00098
11 as_bytes [function] [call site] 00099
11 Cmd::extend_from_slice [function] [call site] 00100
11 Cmd::extend_from_slice [function] [call site] 00101
11 Self::format [function] [call site] 00102
11 basic::test_pipeline_len [function] [call site] 00103
12 redis::pipe [function] [call site] 00104
12 cmd [function] [call site] 00105
12 cmd [function] [call site] 00106
12 types::test_is_single_arg [function] [call site] 00107
11 as_bytes [function] [call site] 00108
11 Cmd::extend_from_slice [function] [call site] 00109
11 Cmd::extend_from_slice [function] [call site] 00110
11 Cmd::extend_from_slice [function] [call site] 00111
8 Value::into_map_iter [function] [call site] 00112
9 basic::test_pipeline_len [function] [call site] 00113
9 Ok [function] [call site] 00114
9 OwnedMapIter::Array [function] [call site] 00115
9 &'a [call site] 00116
10 std::iter::once [function] [call site] 00117
10 chain [function] [call site] 00118
10 basic::test_tuple_decoding_from_iter [function] [call site] 00119
11 TestContext::new [function] [call site] 00120
12 RedisServer::with_modules [function] [call site] 00121
11 MockRedisConnection::check_connection [function] [call site] 00122
11 ComponentMatcher::from [function] [call site] 00123
11 basic::test_tuple_decoding_from_iter [function] [call site] 00124
11 hscan::<_, [call site] 00125
11 unwrap [function] [call site] 00126
11 Option::unwrap [function] [call site] 00127
9 Err [function] [call site] 00128
9 Self::Array [function] [call site] 00129
9 Ok [function] [call site] 00130
9 OwnedMapIter::Map [function] [call site] 00131
9 &'a [call site] 00132
9 Err [function] [call site] 00133
8 Result::expect [function] [call site] 00134
8 into_map_iter() [call site] 00135
6 .expect("extracting [call site] 00136
6 .collect::<Vec<(Value, [call site] 00137
8 sort_by [function] [call site] 00138
8 cmp [function] [call site] 00139
6 get_default_host [function] [call site] 00140
7 ValueComparison::arg_to_string [function] [call site] 00141
8 impl [call site] 00142
8 String::from_utf8_lossy [function] [call site] 00143
8 into_owned [function] [call site] 00144
6 redis::ConnectionAddr::Tcp [function] [call site] 00145
6 get_default_host [function] [call site] 00146
6 rand::random::<(u64, [call site] 00147
6 redis::ConnectionAddr::Unix [function] [call site] 00148
6 ComponentMatcher::from [function] [call site] 00149
7 ComponentMatcher::from [function] [call site] 00150
7 impl [call site] 00151
5 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00152
6 entra_id_tests::get_env_var [function] [call site] 00153
6 String::unwrap_or_else [function] [call site] 00154
6 ValueComparison::arg_to_string [function] [call site] 00155
6 process::Command::new [function] [call site] 00156
7 RedisServer::with_modules [function] [call site] 00157
6 types::test_is_single_arg [function] [call site] 00158
6 types::test_is_single_arg [function] [call site] 00159
6 types::test_is_single_arg [function] [call site] 00160
6 entra_id_tests::get_env_var [function] [call site] 00161
6 entra_id_tests::get_env_var [function] [call site] 00162
6 types::test_is_single_arg [function] [call site] 00163
6 types::test_is_single_arg [function] [call site] 00164
6 entra_id_tests::get_env_var [function] [call site] 00165
6 String::expect [function] [call site] 00166
6 types::test_is_single_arg [function] [call site] 00167
6 types::test_is_single_arg [function] [call site] 00168
6 Self::stdout [function] [call site] 00169
6 process::Stdio::piped [function] [call site] 00170
6 stderr [function] [call site] 00171
6 process::Stdio::piped [function] [call site] 00172
6 tempfile::Builder::new [function] [call site] 00173
7 Ok [function] [call site] 00174
7 &'a [call site] 00175
8 std::iter::once [function] [call site] 00176
8 chain [function] [call site] 00177
8 basic::test_tuple_decoding_from_iter [function] [call site] 00178
7 into_iter().collect::<Vec<_>> [function] [call site] 00179
7 impl [call site] 00180
7 into [function] [call site] 00181
7 TcpSettings::default [function] [call site] 00182
7 TcpSettings::default [function] [call site] 00183
6 RedisResult::prefix [function] [call site] 00184
6 tempdir [function] [call site] 00185
6 expect [function] [call site] 00186
6 RedisServer::log_file [function] [call site] 00187
7 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00188
8 cmd [function] [call site] 00189
8 Cmd::arg [function] [call site] 00190
9 SetExpiry::write_redis_args [function] [call site] 00191
10 ::itoa::Buffer::new [function] [call site] 00192
10 Vec::write_arg [function] [call site] 00193
11 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 00194
12 TestContext::new [function] [call site] 00195
12 ProtocolVersion::supports_resp3 [function] [call site] 00196
12 tokio::sync::mpsc::unbounded_channel [function] [call site] 00197
12 redis::aio::ConnectionManagerConfig::new [function] [call site] 00198
13 RedisServer::default [function] [call site] 00199
14 RedisServer::new [function] [call site] 00200
15 RedisServer::with_modules [function] [call site] 00201
12 AsyncConnectionConfig::set_push_sender [function] [call site] 00202
13 AsyncConnectionConfig::set_push_sender_internal [function] [call site] 00203
14 Some [function] [call site] 00204
13 std::sync::Arc::new [function] [call site] 00205
14 RedisServer::with_modules [function] [call site] 00206
12 Client::get_connection_manager_lazy [function] [call site] 00207
13 crate::aio::ConnectionManager::new_lazy_with_config [function] [call site] 00208
14 Runtime::locate [function] [call site] 00209
15 hotkeys_cluster::setup_cluster_and_target [function] [call site] 00210
16 TestClusterContext::new [function] [call site] 00211
17 TestClusterContext::new_with_config [function] [call site] 00212
18 TestClusterContext::new_with_config_and_builder [function] [call site] 00213
19 support::start_tls_crypto_provider [function] [call site] 00214
20 rustls::crypto::CryptoProvider::get_default [function] [call site] 00215
20 is_none [function] [call site] 00216
20 rustls::crypto::ring::default_provider [function] [call site] 00217
20 install_default [function] [call site] 00218
19 RedisCluster::new [function] [call site] 00219
20 MockRedisConnection::is_empty [function] [call site] 00220
21 StreamReadOptions::block [function] [call site] 00221
22 Some [function] [call site] 00222
21 unwrap [function] [call site] 00223
21 MockRedisConnection::is_empty [function] [call site] 00224
22 StreamReadOptions::block [function] [call site] 00225
22 unwrap [function] [call site] 00226
22 MockRedisConnection::is_empty [function] [call site] 00227
20 &'a [call site] 00228
21 std::iter::once [function] [call site] 00229
21 chain [function] [call site] 00230
21 basic::test_tuple_decoding_from_iter [function] [call site] 00231
20 std::iter::Chain::map [function] [call site] 00232
21 ComponentMatcher::from [function] [call site] 00233
21 String::into_redis_value [function] [call site] 00234
21 Value::into_map_iter [function] [call site] 00235
21 Result::expect [function] [call site] 00236
21 into_map_iter() [call site] 00237
6 .expect("extracting [call site] 00238
6 .collect::<Vec<(Value, [call site] 00239
21 sort_by [function] [call site] 00240
21 cmp [function] [call site] 00241
20 collect [function] [call site] 00242
20 std::collections::HashSet::new [function] [call site] 00243
21 RedisServer::with_modules [function] [call site] 00244
20 ClusterType::get_intended [function] [call site] 00245
21 entra_id_tests::get_env_var [function] [call site] 00246
21 tests::redis_ok [function] [call site] 00247
21 as_ref [function] [call site] 00248
21 tests::into_redis_value_hashmap [function] [call site] 00249
20 tempfile::Builder::new [function] [call site] 00250
20 RedisResult::prefix [function] [call site] 00251
20 tempdir [function] [call site] 00252
20 expect [function] [call site] 00253
20 { [call site] 00254
0 server::build_keys_and_certs_for_tls_with_hostname [function] [call site] 00255
21 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00256
21 join [function] [call site] 00257
21 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00258
21 join [function] [call site] 00259
21 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00260
21 join [function] [call site] 00261
21 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00262
21 join [function] [call site] 00263
21 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00264
21 join [function] [call site] 00265
21 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00266
21 join [function] [call site] 00267
21 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::w::i::t::h::_::h::o::s::t::n::a::m::e::make_key [function] [call site] 00268
22 process::Command::new [function] [call site] 00269
22 types::test_is_single_arg [function] [call site] 00270
22 types::test_is_single_arg [function] [call site] 00271
22 types::test_is_single_arg [function] [call site] 00272
22 types::test_is_single_arg [function] [call site] 00273
22 stdout [function] [call site] 00274
22 process::Stdio::piped [function] [call site] 00275
22 stderr [function] [call site] 00276
22 process::Stdio::piped [function] [call site] 00277
22 spawn [function] [call site] 00278
23 tokio::runtime::Handle::try_current [function] [call site] 00279
23 spawn [function] [call site] 00280
23 smol::spawn [function] [call site] 00281
24 tokio::runtime::Handle::try_current [function] [call site] 00282
24 spawn [function] [call site] 00283
24 smol::spawn [function] [call site] 00284
24 TaskHandle::detach [function] [call site] 00285
25 TaskHandle::detach [function] [call site] 00286
23 TaskHandle::detach [function] [call site] 00287
22 expect [function] [call site] 00288
22 ClusterClientBuilder::max_retry_wait [function] [call site] 00289
22 expect [function] [call site] 00290
21 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::w::i::t::h::_::h::o::s::t::n::a::m::e::make_key [function] [call site] 00291
21 process::Command::new [function] [call site] 00292
21 types::test_is_single_arg [function] [call site] 00293
21 types::test_is_single_arg [function] [call site] 00294
21 types::test_is_single_arg [function] [call site] 00295
21 types::test_is_single_arg [function] [call site] 00296
21 types::test_is_single_arg [function] [call site] 00297
21 types::test_is_single_arg [function] [call site] 00298
21 types::test_is_single_arg [function] [call site] 00299
21 types::test_is_single_arg [function] [call site] 00300
21 types::test_is_single_arg [function] [call site] 00301
21 types::test_is_single_arg [function] [call site] 00302
21 types::test_is_single_arg [function] [call site] 00303
21 types::test_is_single_arg [function] [call site] 00304
21 types::test_is_single_arg [function] [call site] 00305
21 stdout [function] [call site] 00306
21 process::Stdio::piped [function] [call site] 00307
21 stderr [function] [call site] 00308
21 process::Stdio::piped [function] [call site] 00309
21 spawn [function] [call site] 00310
21 expect [function] [call site] 00311
21 ClusterClientBuilder::max_retry_wait [function] [call site] 00312
21 expect [function] [call site] 00313
21 Option<&str>::unwrap_or [function] [call site] 00314
21 ValueComparison::arg_to_string [function] [call site] 00315
21 Tokio::poll_write [function] [call site] 00316
22 RedisServer::new [function] [call site] 00317
23 RedisServer::with_modules [function] [call site] 00318
22 Tokio::poll_write [function] [call site] 00319
23 RedisServer::new [function] [call site] 00320
23 Tokio::poll_write [function] [call site] 00321
23 RedisServer::new [function] [call site] 00322
23 Tokio::poll_write [function] [call site] 00323
23 RedisServer::new [function] [call site] 00324
23 Tokio::poll_write [function] [call site] 00325
22 RedisServer::new [function] [call site] 00326
22 Tokio::poll_write [function] [call site] 00327
22 RedisServer::new [function] [call site] 00328
22 Tokio::poll_write [function] [call site] 00329
21 Poll::expect [function] [call site] 00330
21 process::Command::new [function] [call site] 00331
21 types::test_is_single_arg [function] [call site] 00332
21 types::test_is_single_arg [function] [call site] 00333
21 types::test_is_single_arg [function] [call site] 00334
21 types::test_is_single_arg [function] [call site] 00335
21 types::test_is_single_arg [function] [call site] 00336
21 types::test_is_single_arg [function] [call site] 00337
21 types::test_is_single_arg [function] [call site] 00338
21 stdout [function] [call site] 00339
21 process::Stdio::piped [function] [call site] 00340
21 stderr [function] [call site] 00341
21 process::Stdio::piped [function] [call site] 00342
21 spawn [function] [call site] 00343
21 expect [function] [call site] 00344
21 process::Command::new [function] [call site] 00345
21 types::test_is_single_arg [function] [call site] 00346
21 types::test_is_single_arg [function] [call site] 00347
21 types::test_is_single_arg [function] [call site] 00348
21 types::test_is_single_arg [function] [call site] 00349
21 types::test_is_single_arg [function] [call site] 00350
21 types::test_is_single_arg [function] [call site] 00351
21 types::test_is_single_arg [function] [call site] 00352
21 types::test_is_single_arg [function] [call site] 00353
21 types::test_is_single_arg [function] [call site] 00354
21 types::test_is_single_arg [function] [call site] 00355
21 types::test_is_single_arg [function] [call site] 00356
21 types::test_is_single_arg [function] [call site] 00357
21 types::test_is_single_arg [function] [call site] 00358
21 types::test_is_single_arg [function] [call site] 00359
21 types::test_is_single_arg [function] [call site] 00360
21 types::test_is_single_arg [function] [call site] 00361
21 types::test_is_single_arg [function] [call site] 00362
21 types::test_is_single_arg [function] [call site] 00363
21 stdin [function] [call site] 00364
21 Cmd::take [function] [call site] 00365
22 std::mem::take [function] [call site] 00366
23 std::mem::take [function] [call site] 00367
21 expect [function] [call site] 00368
21 spawn [function] [call site] 00369
21 expect [function] [call site] 00370
21 ClusterClientBuilder::max_retry_wait [function] [call site] 00371
21 expect [function] [call site] 00372
21 ClusterClientBuilder::max_retry_wait [function] [call site] 00373
21 expect [function] [call site] 00374
20 as_deref [function] [call site] 00375
20 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 00376
21 TestContext::new [function] [call site] 00377
21 ProtocolVersion::supports_resp3 [function] [call site] 00378
21 tokio::sync::mpsc::unbounded_channel [function] [call site] 00379
21 redis::aio::ConnectionManagerConfig::new [function] [call site] 00380
21 AsyncConnectionConfig::set_push_sender [function] [call site] 00381
21 Client::get_connection_manager_lazy [function] [call site] 00382
21 unwrap [function] [call site] 00383
21 tests::into_redis_value_hashset [function] [call site] 00384
22 ComponentMatcher::from [function] [call site] 00385
23 ComponentMatcher::from [function] [call site] 00386
23 impl [call site] 00387
22 String::into_redis_value [function] [call site] 00388
22 Value::into_sequence [function] [call site] 00389
23 Ok [function] [call site] 00390
23 Ok [function] [call site] 00391
23 Err [function] [call site] 00392
22 Result::expect [function] [call site] 00393
22 sort_by [function] [call site] 00394
22 cmp [function] [call site] 00395
21 unwrap [function] [call site] 00396
21 MockConnection::send_packed_command [function] [call site] 00397
22 Ok [function] [call site] 00398
21 cmd [function] [call site] 00399
21 Cmd::arg [function] [call site] 00400
21 types::test_is_single_arg [function] [call site] 00401
21 unwrap [function] [call site] 00402
21 hotkeys_cluster::setup_cluster_and_target [function] [call site] 00403
21 unwrap [function] [call site] 00404
21 tests::into_redis_value_hashset [function] [call site] 00405
21 unwrap [function] [call site] 00406
21 Pipeline::send_recv [function] [call site] 00407
22 MockRedisConnection::is_empty [function] [call site] 00408
23 StreamReadOptions::block [function] [call site] 00409
23 unwrap [function] [call site] 00410
23 MockRedisConnection::is_empty [function] [call site] 00411
22 Err [function] [call site] 00412
22 RedisError::make_empty_command [function] [call site] 00413
23 ErrorRepr::General [function] [call site] 00414
22 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 00415
22 map_err [function] [call site] 00416
22 Ok [function] [call site] 00417
22 Msg::get_channel [function] [call site] 00418
23 Ok [function] [call site] 00419
23 from_redis_value_ref [function] [call site] 00420
24 FromRedisValue::from_redis_value_ref [function] [call site] 00421
25 RedisResult::from_redis_value [function] [call site] 00422
26 Ok [function] [call site] 00423
26 Err [function] [call site] 00424
26 into [function] [call site] 00425
26 from_redis_value [function] [call site] 00426
27 RedisResult::from_redis_value [function] [call site] 00427
28 Ok [function] [call site] 00428
28 Err [function] [call site] 00429
28 into [function] [call site] 00430
28 from_redis_value [function] [call site] 00431
28 tests::into_redis_value_hashmap [function] [call site] 00432
29 ComponentMatcher::from [function] [call site] 00433
29 String::into_redis_value [function] [call site] 00434
29 Value::into_map_iter [function] [call site] 00435
29 Result::expect [function] [call site] 00436
29 into_map_iter() [call site] 00437
6 .expect("extracting [call site] 00438
6 .collect::<Vec<(Value, [call site] 00439
29 sort_by [function] [call site] 00440
29 cmp [function] [call site] 00441
28 Ok [function] [call site] 00442
26 tests::into_redis_value_hashmap [function] [call site] 00443
26 Ok [function] [call site] 00444
25 ClientTlsParams::clone [function] [call site] 00445
26 ClientTlsParams::clone [function] [call site] 00446
26 Pkcs1 [function] [call site] 00447
26 secret_pkcs1_der [function] [call site] 00448
26 write_command_to_vec [function] [call site] 00449
26 into [function] [call site] 00450
26 Pkcs8 [function] [call site] 00451
26 secret_pkcs8_der [function] [call site] 00452
26 write_command_to_vec [function] [call site] 00453
26 into [function] [call site] 00454
26 Sec1 [function] [call site] 00455
26 secret_sec1_der [function] [call site] 00456
26 write_command_to_vec [function] [call site] 00457
26 into [function] [call site] 00458
22 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 00459
22 Some [function] [call site] 00460
22 map_err [function] [call site] 00461
22 map_err [function] [call site] 00462
22 and_then [function] [call site] 00463
22 map_err [function] [call site] 00464
22 Runtime::locate [function] [call site] 00465
22 async_tests::test_sentinel_client_async_with_connection_timeout [function] [call site] 00466
23 TestSentinelContext::new [function] [call site] 00467
24 TestSentinelContext::new_with_cluster_client_builder [function] [call site] 00468
25 support::start_tls_crypto_provider [function] [call site] 00469
25 RedisSentinelCluster::new [function] [call site] 00470
26 RedisServer::with_modules [function] [call site] 00471
25 RedisSentinelCluster::iter_sentinel_servers [function] [call site] 00472
26 basic::test_tuple_decoding_from_iter [function] [call site] 00473
25 tests::into_redis_value_hashmap [function] [call site] 00474
26 ComponentMatcher::from [function] [call site] 00475
26 String::into_redis_value [function] [call site] 00476
26 Value::into_map_iter [function] [call site] 00477
26 Result::expect [function] [call site] 00478
26 into_map_iter() [call site] 00479
6 .expect("extracting [call site] 00480
6 .collect::<Vec<(Value, [call site] 00481
26 sort_by [function] [call site] 00482
26 cmp [function] [call site] 00483
25 collect [function] [call site] 00484
25 redis::sentinel::Sentinel::build [function] [call site] 00485
26 Sentinel::build_inner [function] [call site] 00486
27 MockRedisConnection::is_empty [function] [call site] 00487
28 StreamReadOptions::block [function] [call site] 00488
28 unwrap [function] [call site] 00489
28 MockRedisConnection::is_empty [function] [call site] 00490
27 fail [function] [call site] 00491
28 Err [function] [call site] 00492
28 ::std::convert::From::from [function] [call site] 00493
27 &'a [call site] 00494
28 std::iter::once [function] [call site] 00495
28 chain [function] [call site] 00496
28 basic::test_tuple_decoding_from_iter [function] [call site] 00497
27 std::iter::Chain::map [function] [call site] 00498
27 ConnectionInfo::into_connection_info [function] [call site] 00499
28 Ok [function] [call site] 00500
27 into_iter() [call site] 00501
6 .map(|p| [call site] 00502
6 .collect::<RedisResult<Vec<ConnectionInfo>>> [function] [call site] 00503
27 basic::test_tuple_decoding_from_iter [function] [call site] 00504
28 TestContext::new [function] [call site] 00505
28 MockRedisConnection::check_connection [function] [call site] 00506
28 ComponentMatcher::from [function] [call site] 00507
28 basic::test_tuple_decoding_from_iter [function] [call site] 00508
28 hscan::<_, [call site] 00509
28 unwrap [function] [call site] 00510
28 Option::unwrap [function] [call site] 00511
27 cluster::test_cluster_reconnect_after_complete_server_disconnect_route_to_many [function] [call site] 00512
28 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 00513
29 TestClusterContext::new_with_config_and_builder [function] [call site] 00514
29 RedisClusterConfiguration::default [function] [call site] 00515
28 cluster::test_cluster_retries [function] [call site] 00516
29 atomic::AtomicUsize::new [function] [call site] 00517
30 RedisServer::with_modules [function] [call site] 00518
29 MockEnv::with_client_builder [function] [call site] 00519
30 tokio::runtime::Builder::new_current_thread [function] [call site] 00520
30 enable_io [function] [call site] 00521
30 enable_time [function] [call site] 00522
30 Sentinel::build [function] [call site] 00523
31 Sentinel::build_inner [function] [call site] 00524
30 unwrap [function] [call site] 00525
30 ValueComparison::arg_to_string [function] [call site] 00526
31 impl [call site] 00527
31 String::from_utf8_lossy [function] [call site] 00528
31 into_owned [function] [call site] 00529
30 Tokio::poll_write [function] [call site] 00530
31 RedisServer::new [function] [call site] 00531
31 Tokio::poll_write [function] [call site] 00532
31 RedisServer::new [function] [call site] 00533
31 Tokio::poll_write [function] [call site] 00534
31 RedisServer::new [function] [call site] 00535
31 Tokio::poll_write [function] [call site] 00536
30 unwrap [function] [call site] 00537
30 test_module_json_arr_insert [function] [call site] 00538
31 TestContext::with_modules [function] [call site] 00539
32 TestContext::with_modules_and_tls [function] [call site] 00540
33 start_tls_crypto_provider [function] [call site] 00541
34 rustls::crypto::CryptoProvider::get_default [function] [call site] 00542
34 is_none [function] [call site] 00543
34 rustls::crypto::ring::default_provider [function] [call site] 00544
34 install_default [function] [call site] 00545
33 redis_test::utils::get_random_available_port [function] [call site] 00546
34 get_listener_on_free_port [function] [call site] 00547
34 TcpListener::local_addr [function] [call site] 00548
34 unwrap [function] [call site] 00549
34 get_listener_on_free_port [function] [call site] 00550
33 RedisServer::get_addr [function] [call site] 00551
34 ServerType::get_intended [function] [call site] 00552
34 get_default_host [function] [call site] 00553
34 redis::ConnectionAddr::Tcp [function] [call site] 00554
34 get_default_host [function] [call site] 00555
34 rand::random::<(u64, [call site] 00556
34 redis::ConnectionAddr::Unix [function] [call site] 00557
34 ComponentMatcher::from [function] [call site] 00558
33 TestContext::with_modules_addr_and_tls [function] [call site] 00559
34 TestContext::with_modules_addr_tls_and_cert_auth [function] [call site] 00560
35 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00561
36 entra_id_tests::get_env_var [function] [call site] 00562
36 String::unwrap_or_else [function] [call site] 00563
36 ValueComparison::arg_to_string [function] [call site] 00564
36 process::Command::new [function] [call site] 00565
36 types::test_is_single_arg [function] [call site] 00566
36 types::test_is_single_arg [function] [call site] 00567
36 types::test_is_single_arg [function] [call site] 00568
36 entra_id_tests::get_env_var [function] [call site] 00569
36 entra_id_tests::get_env_var [function] [call site] 00570
36 types::test_is_single_arg [function] [call site] 00571
36 types::test_is_single_arg [function] [call site] 00572
36 entra_id_tests::get_env_var [function] [call site] 00573
36 String::expect [function] [call site] 00574
36 types::test_is_single_arg [function] [call site] 00575
36 types::test_is_single_arg [function] [call site] 00576
36 Self::stdout [function] [call site] 00577
36 process::Stdio::piped [function] [call site] 00578
36 stderr [function] [call site] 00579
36 process::Stdio::piped [function] [call site] 00580
36 tempfile::Builder::new [function] [call site] 00581
36 RedisResult::prefix [function] [call site] 00582
36 tempdir [function] [call site] 00583
36 expect [function] [call site] 00584
36 RedisServer::log_file [function] [call site] 00585
36 types::test_is_single_arg [function] [call site] 00586
36 types::test_is_single_arg [function] [call site] 00587
36 ClientTlsParams::clone [function] [call site] 00588
37 ClientTlsParams::clone [function] [call site] 00589
37 Pkcs1 [function] [call site] 00590
37 secret_pkcs1_der [function] [call site] 00591
37 write_command_to_vec [function] [call site] 00592
37 into [function] [call site] 00593
37 Pkcs8 [function] [call site] 00594
37 secret_pkcs8_der [function] [call site] 00595
37 write_command_to_vec [function] [call site] 00596
37 into [function] [call site] 00597
37 Sec1 [function] [call site] 00598
37 secret_sec1_der [function] [call site] 00599
37 write_command_to_vec [function] [call site] 00600
37 into [function] [call site] 00601
36 get_major_version [function] [call site] 00602
37 String::from_utf8 [function] [call site] 00603
37 process::Command::new [function] [call site] 00604
37 types::test_is_single_arg [function] [call site] 00605
37 output [function] [call site] 00606
37 unwrap [function] [call site] 00607
37 unwrap [function] [call site] 00608
37 split_once [function] [call site] 00609
37 unwrap [function] [call site] 00610
37 split_once [function] [call site] 00611
37 unwrap [function] [call site] 00612
37 parse [function] [call site] 00613
37 unwrap [function] [call site] 00614
36 types::test_is_single_arg [function] [call site] 00615
36 types::test_is_single_arg [function] [call site] 00616
36 types::test_is_single_arg [function] [call site] 00617
36 types::test_is_single_arg [function] [call site] 00618
36 ValueComparison::arg_to_string [function] [call site] 00619
36 types::test_is_single_arg [function] [call site] 00620
36 types::test_is_single_arg [function] [call site] 00621
36 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00622
37 entra_id_tests::get_env_var [function] [call site] 00623
37 String::unwrap_or_else [function] [call site] 00624
37 ValueComparison::arg_to_string [function] [call site] 00625
37 process::Command::new [function] [call site] 00626
37 types::test_is_single_arg [function] [call site] 00627
37 types::test_is_single_arg [function] [call site] 00628
37 types::test_is_single_arg [function] [call site] 00629
37 entra_id_tests::get_env_var [function] [call site] 00630
37 entra_id_tests::get_env_var [function] [call site] 00631
37 types::test_is_single_arg [function] [call site] 00632
37 types::test_is_single_arg [function] [call site] 00633
37 entra_id_tests::get_env_var [function] [call site] 00634
37 String::expect [function] [call site] 00635
37 types::test_is_single_arg [function] [call site] 00636
37 types::test_is_single_arg [function] [call site] 00637
37 Self::stdout [function] [call site] 00638
37 process::Stdio::piped [function] [call site] 00639
37 stderr [function] [call site] 00640
37 process::Stdio::piped [function] [call site] 00641
37 tempfile::Builder::new [function] [call site] 00642
37 RedisResult::prefix [function] [call site] 00643
37 tempdir [function] [call site] 00644
37 expect [function] [call site] 00645
37 RedisServer::log_file [function] [call site] 00646
37 types::test_is_single_arg [function] [call site] 00647
37 types::test_is_single_arg [function] [call site] 00648
37 ClientTlsParams::clone [function] [call site] 00649
37 get_major_version [function] [call site] 00650
37 types::test_is_single_arg [function] [call site] 00651
37 types::test_is_single_arg [function] [call site] 00652
37 types::test_is_single_arg [function] [call site] 00653
37 types::test_is_single_arg [function] [call site] 00654
37 ValueComparison::arg_to_string [function] [call site] 00655
37 types::test_is_single_arg [function] [call site] 00656
37 types::test_is_single_arg [function] [call site] 00657
37 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00658
37 Option<TlsFilePaths>::unwrap_or_else [function] [call site] 00659
37 utils::build_keys_and_certs_for_tls [function] [call site] 00660
38 build_keys_and_certs_for_tls_ext [function] [call site] 00661
39 build_keys_and_certs_for_tls_with_hostname [function] [call site] 00662
40 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00663
40 join [function] [call site] 00664
40 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00665
40 join [function] [call site] 00666
40 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00667
40 join [function] [call site] 00668
40 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00669
40 join [function] [call site] 00670
40 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00671
40 join [function] [call site] 00672
40 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00673
40 join [function] [call site] 00674
40 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::w::i::t::h::_::h::o::s::t::n::a::m::e::make_key [function] [call site] 00675
40 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::w::i::t::h::_::h::o::s::t::n::a::m::e::make_key [function] [call site] 00676
40 process::Command::new [function] [call site] 00677
40 types::test_is_single_arg [function] [call site] 00678
40 types::test_is_single_arg [function] [call site] 00679
40 types::test_is_single_arg [function] [call site] 00680
40 types::test_is_single_arg [function] [call site] 00681
40 types::test_is_single_arg [function] [call site] 00682
40 types::test_is_single_arg [function] [call site] 00683
40 types::test_is_single_arg [function] [call site] 00684
40 types::test_is_single_arg [function] [call site] 00685
40 types::test_is_single_arg [function] [call site] 00686
40 types::test_is_single_arg [function] [call site] 00687
40 types::test_is_single_arg [function] [call site] 00688
40 types::test_is_single_arg [function] [call site] 00689
40 types::test_is_single_arg [function] [call site] 00690
40 stdout [function] [call site] 00691
40 process::Stdio::piped [function] [call site] 00692
40 stderr [function] [call site] 00693
40 process::Stdio::piped [function] [call site] 00694
40 spawn [function] [call site] 00695
40 expect [function] [call site] 00696
40 ClusterClientBuilder::max_retry_wait [function] [call site] 00697
40 expect [function] [call site] 00698
40 Option<&str>::unwrap_or [function] [call site] 00699
40 ValueComparison::arg_to_string [function] [call site] 00700
40 Tokio::poll_write [function] [call site] 00701
40 Poll::expect [function] [call site] 00702
40 process::Command::new [function] [call site] 00703
40 types::test_is_single_arg [function] [call site] 00704
40 types::test_is_single_arg [function] [call site] 00705
40 types::test_is_single_arg [function] [call site] 00706
40 types::test_is_single_arg [function] [call site] 00707
40 types::test_is_single_arg [function] [call site] 00708
40 types::test_is_single_arg [function] [call site] 00709
40 types::test_is_single_arg [function] [call site] 00710
40 stdout [function] [call site] 00711
40 process::Stdio::piped [function] [call site] 00712
40 stderr [function] [call site] 00713
40 process::Stdio::piped [function] [call site] 00714
40 spawn [function] [call site] 00715
40 expect [function] [call site] 00716
40 process::Command::new [function] [call site] 00717
40 types::test_is_single_arg [function] [call site] 00718
40 types::test_is_single_arg [function] [call site] 00719
40 types::test_is_single_arg [function] [call site] 00720
40 types::test_is_single_arg [function] [call site] 00721
40 types::test_is_single_arg [function] [call site] 00722
40 types::test_is_single_arg [function] [call site] 00723
40 types::test_is_single_arg [function] [call site] 00724
40 types::test_is_single_arg [function] [call site] 00725
40 types::test_is_single_arg [function] [call site] 00726
40 types::test_is_single_arg [function] [call site] 00727
40 types::test_is_single_arg [function] [call site] 00728
40 types::test_is_single_arg [function] [call site] 00729
40 types::test_is_single_arg [function] [call site] 00730
40 types::test_is_single_arg [function] [call site] 00731
40 types::test_is_single_arg [function] [call site] 00732
40 types::test_is_single_arg [function] [call site] 00733
40 types::test_is_single_arg [function] [call site] 00734
40 types::test_is_single_arg [function] [call site] 00735
40 stdin [function] [call site] 00736
40 Cmd::take [function] [call site] 00737
40 expect [function] [call site] 00738
40 spawn [function] [call site] 00739
40 expect [function] [call site] 00740
40 ClusterClientBuilder::max_retry_wait [function] [call site] 00741
40 expect [function] [call site] 00742
40 ClusterClientBuilder::max_retry_wait [function] [call site] 00743
40 expect [function] [call site] 00744
37 types::test_is_single_arg [function] [call site] 00745
37 types::test_is_single_arg [function] [call site] 00746
37 ValueComparison::arg_to_string [function] [call site] 00747
38 impl [call site] 00748
38 String::from_utf8_lossy [function] [call site] 00749
38 into_owned [function] [call site] 00750
37 types::test_is_single_arg [function] [call site] 00751
37 types::test_is_single_arg [function] [call site] 00752
37 types::test_is_single_arg [function] [call site] 00753
37 types::test_is_single_arg [function] [call site] 00754
37 types::test_is_single_arg [function] [call site] 00755
37 types::test_is_single_arg [function] [call site] 00756
37 types::test_is_single_arg [function] [call site] 00757
37 types::test_is_single_arg [function] [call site] 00758
37 types::test_is_single_arg [function] [call site] 00759
37 types::test_is_single_arg [function] [call site] 00760
37 types::test_is_single_arg [function] [call site] 00761
37 types::test_is_single_arg [function] [call site] 00762
37 types::test_is_single_arg [function] [call site] 00763
37 types::test_is_single_arg [function] [call site] 00764
37 ClientTlsParams::clone [function] [call site] 00765
38 ClientTlsParams::clone [function] [call site] 00766
38 Pkcs1 [function] [call site] 00767
38 secret_pkcs1_der [function] [call site] 00768
38 write_command_to_vec [function] [call site] 00769
38 into [function] [call site] 00770
38 Pkcs8 [function] [call site] 00771
38 secret_pkcs8_der [function] [call site] 00772
38 write_command_to_vec [function] [call site] 00773
38 into [function] [call site] 00774
38 Sec1 [function] [call site] 00775
38 secret_sec1_der [function] [call site] 00776
38 write_command_to_vec [function] [call site] 00777
38 into [function] [call site] 00778
37 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00779
37 Some [function] [call site] 00780
37 types::test_is_single_arg [function] [call site] 00781
37 types::test_is_single_arg [function] [call site] 00782
37 types::test_is_single_arg [function] [call site] 00783
37 types::test_is_single_arg [function] [call site] 00784
37 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00785
36 Option<TlsFilePaths>::unwrap_or_else [function] [call site] 00786
36 utils::build_keys_and_certs_for_tls [function] [call site] 00787
36 types::test_is_single_arg [function] [call site] 00788
36 types::test_is_single_arg [function] [call site] 00789
36 ValueComparison::arg_to_string [function] [call site] 00790
36 types::test_is_single_arg [function] [call site] 00791
36 types::test_is_single_arg [function] [call site] 00792
36 types::test_is_single_arg [function] [call site] 00793
36 types::test_is_single_arg [function] [call site] 00794
36 types::test_is_single_arg [function] [call site] 00795
36 types::test_is_single_arg [function] [call site] 00796
36 types::test_is_single_arg [function] [call site] 00797
36 types::test_is_single_arg [function] [call site] 00798
36 types::test_is_single_arg [function] [call site] 00799
36 types::test_is_single_arg [function] [call site] 00800
36 types::test_is_single_arg [function] [call site] 00801
36 types::test_is_single_arg [function] [call site] 00802
36 types::test_is_single_arg [function] [call site] 00803
36 types::test_is_single_arg [function] [call site] 00804
36 ClientTlsParams::clone [function] [call site] 00805
36 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00806
36 Some [function] [call site] 00807
36 types::test_is_single_arg [function] [call site] 00808
36 types::test_is_single_arg [function] [call site] 00809
36 types::test_is_single_arg [function] [call site] 00810
36 types::test_is_single_arg [function] [call site] 00811
36 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00812
35 Cmd::spawn [function] [call site] 00813
36 tokio::runtime::Handle::try_current [function] [call site] 00814
36 spawn [function] [call site] 00815
36 smol::spawn [function] [call site] 00816
36 TaskHandle::detach [function] [call site] 00817
35 unwrap_or_else [function] [call site] 00818
35 build_single_client [function] [call site] 00819
36 redis::Client::open [function] [call site] 00820
37 Ok [function] [call site] 00821
37 ConnectionInfo::into_connection_info [function] [call site] 00822
38 Ok [function] [call site] 00823
35 RedisServer::connection_info [function] [call site] 00824
36 RedisServer::client_addr [function] [call site] 00825
36 &redis::ConnectionAddr::clone [function] [call site] 00826
37 ClientTlsParams::clone [function] [call site] 00827
37 Pkcs1 [function] [call site] 00828
37 secret_pkcs1_der [function] [call site] 00829
37 write_command_to_vec [function] [call site] 00830
37 into [function] [call site] 00831
37 Pkcs8 [function] [call site] 00832
37 secret_pkcs8_der [function] [call site] 00833
37 write_command_to_vec [function] [call site] 00834
37 into [function] [call site] 00835
37 Sec1 [function] [call site] 00836
37 secret_sec1_der [function] [call site] 00837
37 write_command_to_vec [function] [call site] 00838
37 into [function] [call site] 00839
36 ConnectionInfo::into_connection_info [function] [call site] 00840
37 Ok [function] [call site] 00841
36 RedisResult::unwrap [function] [call site] 00842
36 ConnectionInfo::set_redis_settings [function] [call site] 00843
36 redis_settings [function] [call site] 00844
37 RedisServer::default [function] [call site] 00845
38 RedisServer::new [function] [call site] 00846
37 RedisConnectionInfo::set_protocol [function] [call site] 00847
37 use_protocol [function] [call site] 00848
38 entra_id_tests::get_env_var [function] [call site] 00849
38 String::unwrap_or_default [function] [call site] 00850
35 RedisResult::unwrap [function] [call site] 00851
35 Duration::from_millis [function] [call site] 00852
35 Client::get_connection [function] [call site] 00853
36 connect [function] [call site] 00854
37 Instant::now [function] [call site] 00855
37 ActualConnection::new [function] [call site] 00856
38 Ok [function] [call site] 00857
38 is_wildcard_address [function] [call site] 00858
38 fail [function] [call site] 00859
38 String::as_str [function] [call site] 00860
38 connect_tcp [function] [call site] 00861
39 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 00862
40 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 00863
40 cluster::test_cluster_retries [function] [call site] 00864
40 TestClusterContext::get_ports [function] [call site] 00865
41 basic::test_tuple_decoding_from_iter [function] [call site] 00866
41 tests::into_redis_value_hashmap [function] [call site] 00867
41 redis::ConnectionInfo::addr [function] [call site] 00868
41 collect [function] [call site] 00869
40 MockRedisConnection::check_connection [function] [call site] 00870
40 RedisServer::drop [function] [call site] 00871
41 RedisServer::stop [function] [call site] 00872
42 kill [function] [call site] 00873
42 ClusterClientBuilder::max_retry_wait [function] [call site] 00874
42 RedisServer::client_addr [function] [call site] 00875
42 fs::remove_file [function] [call site] 00876
42 tests::redis_ok [function] [call site] 00877
40 cmd [function] [call site] 00878
40 ClusterConnection::route_command [function] [call site] 00879
41 Msg::get_channel [function] [call site] 00880
41 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 00881
41 RedisServer::new [function] [call site] 00882
42 RedisServer::with_modules [function] [call site] 00883
41 into [function] [call site] 00884
41 ResultExpectation::External [function] [call site] 00885
41 map_err [function] [call site] 00886
41 RedisError::from [function] [call site] 00887
42 io::Error::from [function] [call site] 00888
43 io::Error::from [function] [call site] 00889
43 Self::into [function] [call site] 00890
42 Self::into [function] [call site] 00891
41 io::Error::new [function] [call site] 00892
42 RedisServer::with_modules [function] [call site] 00893
41 unwrap_or_else [function] [call site] 00894
41 Err [function] [call site] 00895
41 RedisError::from [function] [call site] 00896
41 io::Error::new [function] [call site] 00897
41 tests::into_redis_value_hashmap [function] [call site] 00898
41 async_tests::test_sentinel_client_async_with_connection_timeout [function] [call site] 00899
42 TestSentinelContext::new [function] [call site] 00900
42 SentinelClient::build [function] [call site] 00901
43 Sentinel::build_inner [function] [call site] 00902
42 TestSentinelContext::sentinels_connection_info [function] [call site] 00903
42 ClientTlsParams::clone [function] [call site] 00904
43 ClientTlsParams::clone [function] [call site] 00905
43 Pkcs1 [function] [call site] 00906
43 secret_pkcs1_der [function] [call site] 00907
43 write_command_to_vec [function] [call site] 00908
43 into [function] [call site] 00909
43 Pkcs8 [function] [call site] 00910
43 secret_pkcs8_der [function] [call site] 00911
43 write_command_to_vec [function] [call site] 00912
43 into [function] [call site] 00913
43 Sec1 [function] [call site] 00914
43 secret_sec1_der [function] [call site] 00915
43 write_command_to_vec [function] [call site] 00916
43 into [function] [call site] 00917
42 String::from [function] [call site] 00918
43 ValueComparison::arg_to_string [function] [call site] 00919
43 ValueComparison::arg_to_string [function] [call site] 00920
43 ValueComparison::arg_to_string [function] [call site] 00921
43 ValueComparison::arg_to_string [function] [call site] 00922
43 ValueComparison::arg_to_string [function] [call site] 00923
43 ValueComparison::arg_to_string [function] [call site] 00924
43 ValueComparison::arg_to_string [function] [call site] 00925
43 ValueComparison::arg_to_string [function] [call site] 00926
43 ValueComparison::arg_to_string [function] [call site] 00927
43 ValueComparison::arg_to_string [function] [call site] 00928
43 ValueComparison::arg_to_string [function] [call site] 00929
43 ValueComparison::arg_to_string [function] [call site] 00930
43 ValueComparison::arg_to_string [function] [call site] 00931
43 ValueComparison::arg_to_string [function] [call site] 00932
43 ValueComparison::arg_to_string [function] [call site] 00933
43 ValueComparison::arg_to_string [function] [call site] 00934
43 ValueComparison::arg_to_string [function] [call site] 00935
42 Some [function] [call site] 00936
42 TestSentinelContext::sentinel_node_connection_info [function] [call site] 00937
43 TestSentinelContext::tls_mode [function] [call site] 00938
44 RedisServer::client_addr [function] [call site] 00939
44 Some [function] [call site] 00940
44 Some [function] [call site] 00941
43 &SentinelNodeConnectionInfo::default [function] [call site] 00942
43 SentinelNodeConnectionInfo::set_tls_mode [function] [call site] 00943
44 Some [function] [call site] 00944
43 &SentinelNodeConnectionInfo::default [function] [call site] 00945
42 RedisResult::unwrap [function] [call site] 00946
42 SentinelClient::build [function] [call site] 00947
42 TestSentinelContext::sentinels_connection_info [function] [call site] 00948
42 ClientTlsParams::clone [function] [call site] 00949
42 String::from [function] [call site] 00950
42 Some [function] [call site] 00951
42 TestSentinelContext::sentinel_node_connection_info [function] [call site] 00952
42 RedisResult::unwrap [function] [call site] 00953
42 AsyncConnectionConfig::new [function] [call site] 00954
43 RedisServer::default [function] [call site] 00955
42 AsyncConnectionConfig::set_connection_timeout [function] [call site] 00956
42 Some [function] [call site] 00957
42 Duration::from_secs [function] [call site] 00958
42 SentinelClient::get_async_connection_with_config [function] [call site] 00959
43 SentinelClient::async_get_client [function] [call site] 00960
44 Sentinel::async_master_for [function] [call site] 00961
45 Sentinel::async_find_master_address [function] [call site] 00962
46 Sentinel::async_get_sentinel_masters [function] [call site] 00963
47 Sentinel::async_try_all_sentinels [function] [call site] 00964
48 basic::test_tuple_decoding_from_iter [function] [call site] 00965
48 zip [function] [call site] 00966
48 iter_mut [function] [call site] 00967
48 async_try_single_sentinel [function] [call site] 00968
49 &mut [call site] 00969
49 async_reconnect [function] [call site] 00970
50 Client::open [function] [call site] 00971
51 Ok [function] [call site] 00972
51 ConnectionInfo::into_connection_info [function] [call site] 00973
50 redis::ConnectionInfo::clone [function] [call site] 00974
51 ClientTlsParams::clone [function] [call site] 00975
51 Pkcs1 [function] [call site] 00976
51 secret_pkcs1_der [function] [call site] 00977
51 write_command_to_vec [function] [call site] 00978
51 into [function] [call site] 00979
51 Pkcs8 [function] [call site] 00980
51 secret_pkcs8_der [function] [call site] 00981
51 write_command_to_vec [function] [call site] 00982
51 into [function] [call site] 00983
51 Sec1 [function] [call site] 00984
51 secret_sec1_der [function] [call site] 00985
51 write_command_to_vec [function] [call site] 00986
51 into [function] [call site] 00987
50 Client::get_multiplexed_async_connection [function] [call site] 00988
51 Client::get_multiplexed_async_connection_with_config [function] [call site] 00989
52 Runtime::locate [function] [call site] 00990
52 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::tokio::Tokio> [function] [call site] 00991
52 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::smol::Smol> [function] [call site] 00992
51 AsyncConnectionConfig::new [function] [call site] 00993
50 CopyOptions::replace [function] [call site] 00994
50 crate::cmd [function] [call site] 00995
51 redis::cmd [function] [call site] 00996
52 redis::cmd [function] [call site] 00997
52 Cmd::set_cache_config [function] [call site] 00998
53 Some [function] [call site] 00999
52 CommandCacheConfig::new [function] [call site] 01000
52 CommandCacheConfig::set_enable_cache [function] [call site] 01001
51 Cmd::set_cache_config [function] [call site] 01002
51 CommandCacheConfig::new [function] [call site] 01003
51 CommandCacheConfig::set_enable_cache [function] [call site] 01004
50 redis::Cmd::query_async [function] [call site] 01005
51 &mut [call site] 01006
52 Cmd::get_packed_command [function] [call site] 01007
53 RedisServer::new [function] [call site] 01008
54 RedisServer::with_modules [function] [call site] 01009
53 Cmd::is_empty [function] [call site] 01010
54 MockRedisConnection::is_empty [function] [call site] 01011
53 Cmd::write_packed_command [function] [call site] 01012
54 write_command_to_vec [function] [call site] 01013
55 args_len [function] [call site] 01014
55 ClientTlsParams::clone [function] [call site] 01015
55 Cmd::reserve [function] [call site] 01016
55 write_command [function] [call site] 01017
54 Cmd::args_iter [function] [call site] 01018
55 basic::test_tuple_decoding_from_iter [function] [call site] 01019
55 tests::into_redis_value_hashmap [function] [call site] 01020
55 Arg::Simple [function] [call site] 01021
54 unwrap_or [function] [call site] 01022
52 MockRedisConnection::req_packed_command [function] [call site] 01023
53 Cmd::get_packed_command [function] [call site] 01024
53 MockRedisConnection::req_packed_command [function] [call site] 01025
53 as_slice [function] [call site] 01026
53 PipelineSink::poll_ready [function] [call site] 01027
54 PipelineSink::as_mut [function] [call site] 01028
54 project [function] [call site] 01029
54 PipelineSink::poll_ready [function] [call site] 01030
55 PipelineSink::as_mut [function] [call site] 01031
55 project [function] [call site] 01032
55 PipelineSink::poll_ready [function] [call site] 01033
55 map_err [function] [call site] 01034
54 map_err [function] [call site] 01035
53 types::test_parse_boxed [function] [call site] 01036
54 ValueComparison::arg_to_string [function] [call site] 01037
54 parse_redis_value [function] [call site] 01038
55 Parser::new [function] [call site] 01039
55 Parser::parse_value [function] [call site] 01040
56 Err [function] [call site] 01041
56 to_redis_err [function] [call site] 01042
57 into [function] [call site] 01043
57 is_unexpected_end_of_input [function] [call site] 01044
57 RedisError::from [function] [call site] 01045
57 io::Error::from [function] [call site] 01046
57 map_range [function] [call site] 01047
57 map_position [function] [call site] 01048
57 translate_position [function] [call site] 01049
57 buffer [function] [call site] 01050
57 to_string [function] [call site] 01051
57 RedisError::from [function] [call site] 01052
57 ParsingError::from [function] [call site] 01053
56 Ok [function] [call site] 01054
54 Value::SimpleString [function] [call site] 01055
54 ClientTlsParams::clone [function] [call site] 01056
52 as_slice [function] [call site] 01057
52 PipelineSink::poll_ready [function] [call site] 01058
52 types::test_parse_boxed [function] [call site] 01059
51 Ok [function] [call site] 01060
51 RedisResult::from_redis_value [function] [call site] 01061
52 Ok [function] [call site] 01062
52 Err [function] [call site] 01063
52 into [function] [call site] 01064
52 from_redis_value [function] [call site] 01065
52 tests::into_redis_value_hashmap [function] [call site] 01066
52 Ok [function] [call site] 01067
51 Value::extract_error [function] [call site] 01068
52 Ok [function] [call site] 01069
52 Self::Array [function] [call site] 01070
52 Value::extract_error_vec [function] [call site] 01071
53 &'a [call site] 01072
53 std::iter::Chain::map [function] [call site] 01073
53 into_iter() [call site] 01074
6 .map(Self::extract_error) [call site] 01075
6 .collect::<RedisResult<Vec<_>>> [function] [call site] 01076
52 Ok [function] [call site] 01077
52 Self::Map [function] [call site] 01078
52 Value::extract_error_map [function] [call site] 01079
53 Cmd::with_capacity [function] [call site] 01080
54 Cmd::with_capacity [function] [call site] 01081
54 Cmd::with_capacity [function] [call site] 01082
53 basic::test_pipeline_len [function] [call site] 01083
53 &'a [call site] 01084
53 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 01085
53 Value::extract_error [function] [call site] 01086
53 impl [call site] 01087
54 Ok [function] [call site] 01088
54 Self::Array [function] [call site] 01089
54 Value::extract_error_vec [function] [call site] 01090
54 Ok [function] [call site] 01091
54 Self::Map [function] [call site] 01092
54 Value::extract_error_map [function] [call site] 01093
54 RedisServer::new [function] [call site] 01094
55 RedisServer::with_modules [function] [call site] 01095
54 Value::extract_error [function] [call site] 01096
54 Value::extract_error_map [function] [call site] 01097
54 Ok [function] [call site] 01098
54 Ok [function] [call site] 01099
54 Self::Set [function] [call site] 01100
54 Value::extract_error_vec [function] [call site] 01101
54 Ok [function] [call site] 01102
54 Value::extract_error_vec [function] [call site] 01103
54 Err [function] [call site] 01104
54 into [function] [call site] 01105
54 Ok [function] [call site] 01106
53 Ok [function] [call site] 01107
52 RedisServer::new [function] [call site] 01108
52 Value::extract_error [function] [call site] 01109
52 Value::extract_error_map [function] [call site] 01110
52 Ok [function] [call site] 01111
52 Ok [function] [call site] 01112
52 Self::Set [function] [call site] 01113
52 Value::extract_error_vec [function] [call site] 01114
52 Ok [function] [call site] 01115
52 Value::extract_error_vec [function] [call site] 01116
52 Err [function] [call site] 01117
52 into [function] [call site] 01118
52 Ok [function] [call site] 01119
50 bool::as_mut [function] [call site] 01120
50 unwrap [function] [call site] 01121
50 Err [function] [call site] 01122
50 not_a_sentinel_error [function] [call site] 01123
51 RedisError::from [function] [call site] 01124
50 Ok [function] [call site] 01125
49 Cmd::query_async [function] [call site] 01126
50 &mut [call site] 01127
50 Ok [function] [call site] 01128
50 RedisResult::from_redis_value [function] [call site] 01129
50 Value::extract_error [function] [call site] 01130
49 &mut [call site] 01131
49 unwrap [function] [call site] 01132
49 RedisError::is_unrecoverable_error [function] [call site] 01133
50 RedisError::retry_method [function] [call site] 01134
51 RedisError::kind [function] [call site] 01135
52 get_push_kind [function] [call site] 01136
53 PushKind::as_str [function] [call site] 01137
53 PushKind::Other [function] [call site] 01138
52 ErrorKind::Server [function] [call site] 01139
52 Replicas::first [function] [call site] 01140
52 and_then [function] [call site] 01141
52 get_push_kind [function] [call site] 01142
52 tests::into_redis_value_hashmap [function] [call site] 01143
52 PushKind::into [function] [call site] 01144
52 unwrap_or [function] [call site] 01145
52 ErrorKind::Server [function] [call site] 01146
51 RedisError::retry_method [function] [call site] 01147
52 RedisError::kind [function] [call site] 01148
52 RedisError::retry_method [function] [call site] 01149
52 RedisError::is_connection_dropped [function] [call site] 01150
53 RedisError::as_io_error [function] [call site] 01151
54 downcast_ref [function] [call site] 01152
53 Option::is_some_and [function] [call site] 01153
52 RedisError::as_io_error [function] [call site] 01154
52 tests::into_redis_value_hashmap [function] [call site] 01155
53 ComponentMatcher::from [function] [call site] 01156
53 String::into_redis_value [function] [call site] 01157
53 Value::into_map_iter [function] [call site] 01158
53 Result::expect [function] [call site] 01159
53 into_map_iter() [call site] 01160
6 .expect("extracting [call site] 01161
6 .collect::<Vec<(Value, [call site] 01162
53 sort_by [function] [call site] 01163
53 cmp [function] [call site] 01164
52 get_push_kind [function] [call site] 01165
52 unwrap_or [function] [call site] 01166
51 RedisError::is_connection_dropped [function] [call site] 01167
51 RedisError::as_io_error [function] [call site] 01168
51 tests::into_redis_value_hashmap [function] [call site] 01169
51 get_push_kind [function] [call site] 01170
51 unwrap_or [function] [call site] 01171
49 types::test_is_io_error [function] [call site] 01172
50 RedisError::from [function] [call site] 01173
49 async_reconnect [function] [call site] 01174
49 Cmd::query_async [function] [call site] 01175
49 &mut [call site] 01176
49 unwrap [function] [call site] 01177
49 Err [function] [call site] 01178
48 ClientTlsParams::clone [function] [call site] 01179
49 ClientTlsParams::clone [function] [call site] 01180
49 Pkcs1 [function] [call site] 01181
49 secret_pkcs1_der [function] [call site] 01182
49 write_command_to_vec [function] [call site] 01183
49 into [function] [call site] 01184
49 Pkcs8 [function] [call site] 01185
49 secret_pkcs8_der [function] [call site] 01186
49 write_command_to_vec [function] [call site] 01187
49 into [function] [call site] 01188
49 Sec1 [function] [call site] 01189
49 secret_sec1_der [function] [call site] 01190
49 write_command_to_vec [function] [call site] 01191
49 into [function] [call site] 01192
48 Ok [function] [call site] 01193
48 Some [function] [call site] 01194
48 Err [function] [call site] 01195
48 None::expect [function] [call site] 01196
47 sentinel_masters_cmd [function] [call site] 01197
48 crate::cmd [function] [call site] 01198
48 Cmd::arg [function] [call site] 01199
46 async_find_valid_master [function] [call site] 01200
47 valid_addrs [function] [call site] 01201
48 &'a [call site] 01202
49 std::iter::once [function] [call site] 01203
49 chain [function] [call site] 01204
49 basic::test_tuple_decoding_from_iter [function] [call site] 01205
48 std::iter::Chain::filter [function] [call site] 01206
48 tests::into_redis_value_hashmap [function] [call site] 01207
48 redis::ConnectionInfo::remove [function] [call site] 01208
48 unwrap [function] [call site] 01209
48 parse::<u16> [function] [call site] 01210
48 unwrap [function] [call site] 01211
47 is_master_valid [function] [call site] 01212
48 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01213
49 TestClusterContext::new [function] [call site] 01214
49 TestSentinelContext::wait_for_cluster_up [function] [call site] 01215
50 TestSentinelContext::sentinel_node_connection_info [function] [call site] 01216
51 TestSentinelContext::tls_mode [function] [call site] 01217
51 &SentinelNodeConnectionInfo::default [function] [call site] 01218
51 SentinelNodeConnectionInfo::set_tls_mode [function] [call site] 01219
51 &SentinelNodeConnectionInfo::default [function] [call site] 01220
50 TestSentinelContext::sentinel_mut [function] [call site] 01221
50 redis_test::sentinel::wait_for_master_server [function] [call site] 01222
51 redis::cmd [function] [call site] 01223
51 Client::get_connection [function] [call site] 01224
51 redis::Cmd::query [function] [call site] 01225
52 basic::test_object_freq_command [function] [call site] 01226
53 TestContext::new [function] [call site] 01227
53 MockRedisConnection::check_connection [function] [call site] 01228
53 redis::cmd [function] [call site] 01229
53 redis::Cmd::arg [function] [call site] 01230
54 SetExpiry::write_redis_args [function] [call site] 01231
53 types::test_is_single_arg [function] [call site] 01232
53 types::test_is_single_arg [function] [call site] 01233
53 Cmd::exec [function] [call site] 01234
54 query::<()> [function] [call site] 01235
53 RedisResult::unwrap [function] [call site] 01236
53 tests::into_redis_value_hashset [function] [call site] 01237
54 ComponentMatcher::from [function] [call site] 01238
54 String::into_redis_value [function] [call site] 01239
54 Value::into_sequence [function] [call site] 01240
54 Result::expect [function] [call site] 01241
54 sort_by [function] [call site] 01242
54 cmp [function] [call site] 01243
53 unwrap [function] [call site] 01244
53 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01245
54 TestClusterContext::new [function] [call site] 01246
54 TestSentinelContext::wait_for_cluster_up [function] [call site] 01247
54 RedisCluster::iter_servers [function] [call site] 01248
55 basic::test_tuple_decoding_from_iter [function] [call site] 01249
54 MapIter::next [function] [call site] 01250
55 Some [function] [call site] 01251
55 MapIter::next [function] [call site] 01252
55 MapIter::next [function] [call site] 01253
55 MapIter::next [function] [call site] 01254
55 Some [function] [call site] 01255
54 unwrap [function] [call site] 01256
54 RedisServer::connection_info [function] [call site] 01257
54 hotkeys_cluster::port_of [function] [call site] 01258
54 redis::ConnectionInfo::addr [function] [call site] 01259
54 hotkeys_cluster::direct_connection [function] [call site] 01260
55 redis::ConnectionInfo::set_redis_settings [function] [call site] 01261
55 RedisServer::default [function] [call site] 01262
55 RedisConnectionInfo::set_protocol [function] [call site] 01263
55 redis::Client::open [function] [call site] 01264
55 RedisResult::unwrap [function] [call site] 01265
55 Client::get_connection [function] [call site] 01266
55 unwrap [function] [call site] 01267
54 redis::ConnectionInfo::clone [function] [call site] 01268
54 skip_if_context_does_not_support [function] [call site] 01269
55 supports [function] [call site] 01270
54 hotkeys_cluster::first_owned_slot_range [function] [call site] 01271
55 cmd [function] [call site] 01272
55 Cmd::arg [function] [call site] 01273
55 basic::test_pipeline_reuse_query [function] [call site] 01274
56 TestContext::new [function] [call site] 01275
56 MockRedisConnection::check_connection [function] [call site] 01276
56 redis::pipe [function] [call site] 01277
56 cmd [function] [call site] 01278
56 types::test_is_single_arg [function] [call site] 01279
56 types::test_is_single_arg [function] [call site] 01280
56 ignore [function] [call site] 01281
56 cmd [function] [call site] 01282
56 types::test_is_single_arg [function] [call site] 01283
56 basic::test_pipeline_reuse_query [function] [call site] 01284
57 TestContext::new [function] [call site] 01285
57 MockRedisConnection::check_connection [function] [call site] 01286
57 redis::pipe [function] [call site] 01287
57 cmd [function] [call site] 01288
57 types::test_is_single_arg [function] [call site] 01289
57 types::test_is_single_arg [function] [call site] 01290
57 ignore [function] [call site] 01291
57 cmd [function] [call site] 01292
57 types::test_is_single_arg [function] [call site] 01293
57 basic::test_pipeline_reuse_query [function] [call site] 01294
57 unwrap [function] [call site] 01295
57 redis::cmd [function] [call site] 01296
57 redis::Cmd::arg [function] [call site] 01297
57 Cmd::exec [function] [call site] 01298
58 query::<()> [function] [call site] 01299
57 RedisResult::unwrap [function] [call site] 01300
57 cmd [function] [call site] 01301
57 types::test_is_single_arg [function] [call site] 01302
57 types::test_is_single_arg [function] [call site] 01303
57 ignore [function] [call site] 01304
57 cmd [function] [call site] 01305
57 types::test_is_single_arg [function] [call site] 01306
57 types::test_is_single_arg [function] [call site] 01307
57 basic::test_pipeline_reuse_query [function] [call site] 01308
57 unwrap [function] [call site] 01309
56 unwrap [function] [call site] 01310
56 redis::cmd [function] [call site] 01311
56 redis::Cmd::arg [function] [call site] 01312
56 Cmd::exec [function] [call site] 01313
56 RedisResult::unwrap [function] [call site] 01314
56 cmd [function] [call site] 01315
56 types::test_is_single_arg [function] [call site] 01316
56 types::test_is_single_arg [function] [call site] 01317
56 ignore [function] [call site] 01318
56 cmd [function] [call site] 01319
56 types::test_is_single_arg [function] [call site] 01320
56 types::test_is_single_arg [function] [call site] 01321
56 basic::test_pipeline_reuse_query [function] [call site] 01322
56 unwrap [function] [call site] 01323
55 unwrap [function] [call site] 01324
55 basic::test_pipeline_len [function] [call site] 01325
55 from_redis_value [function] [call site] 01326
55 ClientTlsParams::clone [function] [call site] 01327
55 Result::unwrap [function] [call site] 01328
55 from_redis_value [function] [call site] 01329
55 ClientTlsParams::clone [function] [call site] 01330
55 Result::unwrap [function] [call site] 01331
55 basic::test_pipeline_len [function] [call site] 01332
55 from_redis_value [function] [call site] 01333
55 ClientTlsParams::clone [function] [call site] 01334
55 Result::unwrap [function] [call site] 01335
54 hotkeys_cluster::find_key_in_range [function] [call site] 01336
55 cmd [function] [call site] 01337
55 Cmd::arg [function] [call site] 01338
55 types::test_is_single_arg [function] [call site] 01339
55 basic::test_pipeline_reuse_query [function] [call site] 01340
55 unwrap [function] [call site] 01341
54 Some [function] [call site] 01342
53 Option::unwrap [function] [call site] 01343
52 Ok [function] [call site] 01344
52 RedisResult::from_redis_value [function] [call site] 01345
52 Value::extract_error [function] [call site] 01346
52 Err [function] [call site] 01347
51 RedisResult::unwrap [function] [call site] 01348
51 String::from_redis_value_ref [function] [call site] 01349
52 get_inner_value [function] [call site] 01350
53 as_ref [function] [call site] 01351
52 Ok [function] [call site] 01352
52 std::str::from_utf8 [function] [call site] 01353
52 ValueComparison::arg_to_string [function] [call site] 01354
52 Ok [function] [call site] 01355
52 ValueComparison::arg_to_string [function] [call site] 01356
52 Ok [function] [call site] 01357
52 ValueComparison::arg_to_string [function] [call site] 01358
52 Ok [function] [call site] 01359
52 ValueComparison::arg_to_string [function] [call site] 01360
52 Ok [function] [call site] 01361
52 ValueComparison::arg_to_string [function] [call site] 01362
52 Ok [function] [call site] 01363
52 ValueComparison::arg_to_string [function] [call site] 01364
51 Replicas::first [function] [call site] 01365
51 &'a [call site] 01366
51 Result::unwrap [function] [call site] 01367
51 starts_with [function] [call site] 01368
51 Ok [function] [call site] 01369
51 get_connection_info [function] [call site] 01370
52 as_ref [function] [call site] 01371
52 and_then [function] [call site] 01372
52 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01373
52 ConnectionAddr::host [function] [call site] 01374
53 ValueComparison::arg_to_string [function] [call site] 01375
52 ValueComparison::arg_to_string [function] [call site] 01376
53 impl [call site] 01377
53 String::from_utf8_lossy [function] [call site] 01378
53 into_owned [function] [call site] 01379
52 ConnectionAddr::port [function] [call site] 01380
53 0.0.1:0".parse::<SocketAddr> [function] [call site] 01381
53 unwrap [function] [call site] 01382
53 into [function] [call site] 01383
53 RedisServer::new [function] [call site] 01384
53 Self::unwrap [function] [call site] 01385
53 set_reuse_address [function] [call site] 01386
53 unwrap [function] [call site] 01387
53 bind [function] [call site] 01388
53 unwrap [function] [call site] 01389
53 listen [function] [call site] 01390
53 unwrap [function] [call site] 01391
53 ComponentMatcher::from [function] [call site] 01392
52 get_default_host [function] [call site] 01393
53 ValueComparison::arg_to_string [function] [call site] 01394
52 ValueComparison::arg_to_string [function] [call site] 01395
52 get_listener_on_free_port [function] [call site] 01396
52 get_connection_addr [function] [call site] 01397
53 ConnectionAddr::Tcp [function] [call site] 01398
52 ClientTlsParams::clone [function] [call site] 01399
52 unwrap_or [function] [call site] 01400
52 ClientTlsParams::clone [function] [call site] 01401
52 ClientTlsParams::clone [function] [call site] 01402
52 unwrap_or_default [function] [call site] 01403
52 RedisServer::default [function] [call site] 01404
53 RedisServer::new [function] [call site] 01405
52 ClientTlsParams::clone [function] [call site] 01406
51 ConnectionInfo::addr [function] [call site] 01407
51 RedisSentinelCluster::log_redis_state_via_cli [function] [call site] 01408
52 RedisServer::new [function] [call site] 01409
53 RedisServer::with_modules [function] [call site] 01410
52 types::test_std_types_to_redis_args [function] [call site] 01411
52 ValueComparison::arg_to_string [function] [call site] 01412
52 output [function] [call site] 01413
52 MockRedisConnection::is_empty [function] [call site] 01414
51 std::thread::sleep [function] [call site] 01415
52 tokio::time::sleep [function] [call site] 01416
53 tokio::time::sleep [function] [call site] 01417
53 smol::Timer::after [function] [call site] 01418
52 smol::Timer::after [function] [call site] 01419
51 Duration::from_millis [function] [call site] 01420
51 Err [function] [call site] 01421
50 &mut [call site] 01422
51 Sentinel::find_master_address [function] [call site] 01423
52 Sentinel::get_sentinel_masters [function] [call site] 01424
53 Sentinel::try_all_sentinels [function] [call site] 01425
54 basic::test_tuple_decoding_from_iter [function] [call site] 01426
54 zip [function] [call site] 01427
54 iter_mut [function] [call site] 01428
54 try_single_sentinel [function] [call site] 01429
55 &mut [call site] 01430
55 reconnect [function] [call site] 01431
56 Client::open [function] [call site] 01432
56 redis::ConnectionInfo::clone [function] [call site] 01433
56 Client::get_connection [function] [call site] 01434
56 CopyOptions::replace [function] [call site] 01435
56 crate::cmd [function] [call site] 01436
56 redis::Cmd::query [function] [call site] 01437
56 bool::as_mut [function] [call site] 01438
56 unwrap [function] [call site] 01439
56 Err [function] [call site] 01440
56 not_a_sentinel_error [function] [call site] 01441
56 Ok [function] [call site] 01442
55 Cmd::query [function] [call site] 01443
56 basic::test_object_freq_command [function] [call site] 01444
56 Ok [function] [call site] 01445
56 RedisResult::from_redis_value [function] [call site] 01446
56 Value::extract_error [function] [call site] 01447
56 Err [function] [call site] 01448
55 &mut [call site] 01449
55 unwrap [function] [call site] 01450
55 RedisError::is_unrecoverable_error [function] [call site] 01451
55 types::test_is_io_error [function] [call site] 01452
55 reconnect [function] [call site] 01453
55 Cmd::query [function] [call site] 01454
55 &mut [call site] 01455
55 unwrap [function] [call site] 01456
55 Err [function] [call site] 01457
54 ClientTlsParams::clone [function] [call site] 01458
54 Ok [function] [call site] 01459
54 Some [function] [call site] 01460
54 Err [function] [call site] 01461
54 None::expect [function] [call site] 01462
53 sentinel_masters_cmd [function] [call site] 01463
52 find_valid_master [function] [call site] 01464
53 valid_addrs [function] [call site] 01465
53 is_master_valid [function] [call site] 01466
53 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01467
54 crate::ConnectionAddr::Tcp [function] [call site] 01468
54 Self::as_ref [function] [call site] 01469
54 tests::into_redis_value_hashmap [function] [call site] 01470
54 transpose [function] [call site] 01471
54 Ok [function] [call site] 01472
54 ClientTlsParams::clone [function] [call site] 01473
54 unwrap_or_default [function] [call site] 01474
54 ClientTlsParams::clone [function] [call site] 01475
54 unwrap_or_default [function] [call site] 01476
53 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01477
53 determine_master_from_role_or_info_replication [function] [call site] 01478
54 Client::open [function] [call site] 01479
54 redis::ConnectionInfo::clone [function] [call site] 01480
54 Client::get_connection [function] [call site] 01481
54 check_role [function] [call site] 01482
55 crate::cmd [function] [call site] 01483
55 redis::Cmd::query [function] [call site] 01484
54 Ok [function] [call site] 01485
54 check_info_replication [function] [call site] 01486
55 crate::cmd [function] [call site] 01487
55 redis::Cmd::arg [function] [call site] 01488
55 basic::test_pipeline_reuse_query [function] [call site] 01489
55 parse_replication_info [function] [call site] 01490
56 impl [call site] 01491
57 TestContext::new [function] [call site] 01492
57 TestContext::async_pubsub [function] [call site] 01493
58 Client::get_async_pubsub [function] [call site] 01494
59 Client::get_simple_async_connection_dynamically [function] [call site] 01495
60 Runtime::locate [function] [call site] 01496
60 get_simple_async_connection::<crate::aio::tokio::Tokio> [function] [call site] 01497
60 get_simple_async_connection::<crate::aio::smol::Smol> [function] [call site] 01498
59 crate::aio::PubSub::new [function] [call site] 01499
60 RedisServer::default [function] [call site] 01500
61 RedisServer::new [function] [call site] 01501
60 Self::framed [function] [call site] 01502
60 CertAuthTestContext::setup_connection [function] [call site] 01503
61 MockRedisConnection::check_connection [function] [call site] 01504
60 tokio::sync::mpsc::unbounded_channel [function] [call site] 01505
60 PubSubSink::new [function] [call site] 01506
61 tokio::sync::mpsc::unbounded_channel [function] [call site] 01507
61 PipelineSink::new [function] [call site] 01508
62 RedisServer::new [function] [call site] 01509
63 RedisServer::with_modules [function] [call site] 01510
61 stream::poll_fn [function] [call site] 01511
61 ( [call site] 01512
4 PendingRequest::poll_recv [function] [call site] 01513
61 tests::into_redis_value_hashmap [function] [call site] 01514
61 forward [function] [call site] 01515
61 tests::into_redis_value_hashmap [function] [call site] 01516
60 Runtime::locate [function] [call site] 01517
60 Self::spawn [function] [call site] 01518
61 tokio::runtime::Handle::try_current [function] [call site] 01519
61 spawn [function] [call site] 01520
61 smol::spawn [function] [call site] 01521
61 TaskHandle::detach [function] [call site] 01522
60 Some [function] [call site] 01523
60 SharedHandleContainer::new [function] [call site] 01524
61 Self [function] [call site] 01525
61 RedisServer::new [function] [call site] 01526
61 HandleContainer::new [function] [call site] 01527
62 Self [function] [call site] 01528
62 Some [function] [call site] 01529
60 Ok [function] [call site] 01530
57 unwrap [function] [call site] 01531
57 basic_async::test_automatic_unsubscription_on_split [function] [call site] 01532
58 TestContext::new [function] [call site] 01533
58 TestContext::async_pubsub [function] [call site] 01534
58 unwrap [function] [call site] 01535
58 basic_async::test_automatic_unsubscription_on_split [function] [call site] 01536
58 basic::test_pubsub_unsubscribe [function] [call site] 01537
59 TestContext::new [function] [call site] 01538
59 MockRedisConnection::check_connection [function] [call site] 01539
59 std::sync::mpsc::channel [function] [call site] 01540
60 Ok [function] [call site] 01541
60 from_redis_value_ref [function] [call site] 01542
59 AsyncConnectionConfig::set_push_sender [function] [call site] 01543
60 AsyncConnectionConfig::set_push_sender_internal [function] [call site] 01544
60 std::sync::Arc::new [function] [call site] 01545
59 Connection::as_pubsub [function] [call site] 01546
60 PubSub::new [function] [call site] 01547
61 RedisServer::default [function] [call site] 01548
61 Self::framed [function] [call site] 01549
61 CertAuthTestContext::setup_connection [function] [call site] 01550
61 tokio::sync::mpsc::unbounded_channel [function] [call site] 01551
61 PubSubSink::new [function] [call site] 01552
61 Runtime::locate [function] [call site] 01553
61 Self::spawn [function] [call site] 01554
61 Some [function] [call site] 01555
61 SharedHandleContainer::new [function] [call site] 01556
61 Ok [function] [call site] 01557
59 basic::test_pubsub_unsubscribe [function] [call site] 01558
59 unwrap [function] [call site] 01559
59 basic::test_pubsub_unsubscribe [function] [call site] 01560
59 unwrap [function] [call site] 01561
59 basic::test_pubsub_unsubscribe [function] [call site] 01562
59 unwrap [function] [call site] 01563
59 PubSub::psubscribe [function] [call site] 01564
60 PubSub::psubscribe [function] [call site] 01565
59 RedisResult::unwrap [function] [call site] 01566
59 PubSub::psubscribe [function] [call site] 01567
59 RedisResult::unwrap [function] [call site] 01568
59 PubSub::psubscribe [function] [call site] 01569
59 RedisResult::unwrap [function] [call site] 01570
59 tests::into_redis_value_hashset [function] [call site] 01571
59 unwrap [function] [call site] 01572
59 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01573
59 Option::unwrap [function] [call site] 01574
59 unwrap [function] [call site] 01575
59 ProtocolVersion::supports_resp3 [function] [call site] 01576
59 try_recv [function] [call site] 01577
59 unwrap [function] [call site] 01578
59 RedisResult::from_redis_value_ref [function] [call site] 01579
60 Ok [function] [call site] 01580
60 Err [function] [call site] 01581
60 ClientTlsParams::clone [function] [call site] 01582
60 Self::into [function] [call site] 01583
60 from_redis_value_ref [function] [call site] 01584
60 tests::into_redis_value_hashmap [function] [call site] 01585
60 Ok [function] [call site] 01586
59 Replicas::first [function] [call site] 01587
59 &'a [call site] 01588
59 Result::unwrap [function] [call site] 01589
59 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 01590
58 unwrap [function] [call site] 01591
58 TestContext::async_connection [function] [call site] 01592
59 Client::get_multiplexed_async_connection [function] [call site] 01593
58 unwrap [function] [call site] 01594
58 Runtime::sleep [function] [call site] 01595
59 tokio::time::sleep [function] [call site] 01596
59 smol::Timer::after [function] [call site] 01597
58 Duration::from_millis [function] [call site] 01598
58 into [function] [call site] 01599
58 redis::cmd [function] [call site] 01600
58 redis::Cmd::arg [function] [call site] 01601
58 types::test_is_single_arg [function] [call site] 01602
58 Cmd::query_async [function] [call site] 01603
59 &mut [call site] 01604
59 Ok [function] [call site] 01605
59 RedisResult::from_redis_value [function] [call site] 01606
59 Value::extract_error [function] [call site] 01607
58 unwrap [function] [call site] 01608
58 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01609
58 unwrap [function] [call site] 01610
58 RedisServer::drop [function] [call site] 01611
58 redis::cmd [function] [call site] 01612
58 redis::Cmd::arg [function] [call site] 01613
58 types::test_is_single_arg [function] [call site] 01614
58 Cmd::query_async [function] [call site] 01615
58 unwrap [function] [call site] 01616
58 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01617
58 unwrap [function] [call site] 01618
58 Runtime::sleep [function] [call site] 01619
58 Duration::from_millis [function] [call site] 01620
58 into [function] [call site] 01621
58 basic::test_pubsub_unsubscribe [function] [call site] 01622
58 unwrap_err [function] [call site] 01623
57 basic::test_pubsub_unsubscribe [function] [call site] 01624
57 unwrap [function] [call site] 01625
57 TestContext::async_connection [function] [call site] 01626
57 unwrap [function] [call site] 01627
57 Runtime::sleep [function] [call site] 01628
57 Duration::from_millis [function] [call site] 01629
57 into [function] [call site] 01630
57 redis::cmd [function] [call site] 01631
57 redis::Cmd::arg [function] [call site] 01632
57 types::test_is_single_arg [function] [call site] 01633
57 Cmd::query_async [function] [call site] 01634
57 unwrap [function] [call site] 01635
57 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01636
57 unwrap [function] [call site] 01637
57 RedisServer::drop [function] [call site] 01638
57 redis::cmd [function] [call site] 01639
57 redis::Cmd::arg [function] [call site] 01640
57 types::test_is_single_arg [function] [call site] 01641
57 Cmd::query_async [function] [call site] 01642
57 unwrap [function] [call site] 01643
57 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01644
57 unwrap [function] [call site] 01645
57 Runtime::sleep [function] [call site] 01646
57 Duration::from_millis [function] [call site] 01647
57 into [function] [call site] 01648
57 basic::test_pubsub_unsubscribe [function] [call site] 01649
57 unwrap_err [function] [call site] 01650
56 filter [function] [call site] 01651
56 trim_start [function] [call site] 01652
56 starts_with [function] [call site] 01653
56 filter_map [function] [call site] 01654
56 split_once [function] [call site] 01655
56 tests::into_redis_value_hashmap [function] [call site] 01656
56 ValueComparison::arg_to_string [function] [call site] 01657
56 ValueComparison::arg_to_string [function] [call site] 01658
56 collect [function] [call site] 01659
55 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01660
56 TestClusterContext::new [function] [call site] 01661
56 TestSentinelContext::wait_for_cluster_up [function] [call site] 01662
56 RedisCluster::iter_servers [function] [call site] 01663
56 MapIter::next [function] [call site] 01664
56 unwrap [function] [call site] 01665
56 RedisServer::connection_info [function] [call site] 01666
56 hotkeys_cluster::port_of [function] [call site] 01667
56 redis::ConnectionInfo::addr [function] [call site] 01668
56 hotkeys_cluster::direct_connection [function] [call site] 01669
56 redis::ConnectionInfo::clone [function] [call site] 01670
56 skip_if_context_does_not_support [function] [call site] 01671
56 hotkeys_cluster::first_owned_slot_range [function] [call site] 01672
56 hotkeys_cluster::find_key_in_range [function] [call site] 01673
56 Some [function] [call site] 01674
55 Ok [function] [call site] 01675
55 ClientTlsParams::clone [function] [call site] 01676
55 Err [function] [call site] 01677
55 RedisError::from [function] [call site] 01678
54 Ok [function] [call site] 01679
54 evaluate_role_check_errors [function] [call site] 01680
55 RedisError::kind [function] [call site] 01681
55 into [function] [call site] 01682
55 Err [function] [call site] 01683
55 Err [function] [call site] 01684
54 RedisResult::unwrap_err [function] [call site] 01685
54 RedisResult::unwrap_err [function] [call site] 01686
53 Ok [function] [call site] 01687
51 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 01688
51 Client::open [function] [call site] 01689
50 Some [function] [call site] 01690
50 ConnectionAddr::is_err [function] [call site] 01691
51 into [function] [call site] 01692
51 is_unexpected_end_of_input [function] [call site] 01693
51 RedisError::from [function] [call site] 01694
51 io::Error::from [function] [call site] 01695
51 map_range [function] [call site] 01696
51 map_position [function] [call site] 01697
51 translate_position [function] [call site] 01698
51 buffer [function] [call site] 01699
51 to_string [function] [call site] 01700
51 RedisError::from [function] [call site] 01701
51 ParsingError::from [function] [call site] 01702
50 redis_test::sentinel::wait_for_replica [function] [call site] 01703
51 redis::cmd [function] [call site] 01704
51 Client::get_connection [function] [call site] 01705
51 redis::Cmd::query [function] [call site] 01706
51 RedisResult::unwrap [function] [call site] 01707
51 String::from_redis_value_ref [function] [call site] 01708
51 Replicas::first [function] [call site] 01709
51 &'a [call site] 01710
51 Result::unwrap [function] [call site] 01711
51 String::from_redis_value_ref [function] [call site] 01712
51 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01713
52 TestClusterContext::new [function] [call site] 01714
52 TestSentinelContext::wait_for_cluster_up [function] [call site] 01715
52 RedisCluster::iter_servers [function] [call site] 01716
52 MapIter::next [function] [call site] 01717
52 unwrap [function] [call site] 01718
52 RedisServer::connection_info [function] [call site] 01719
52 hotkeys_cluster::port_of [function] [call site] 01720
52 redis::ConnectionInfo::addr [function] [call site] 01721
52 hotkeys_cluster::direct_connection [function] [call site] 01722
52 redis::ConnectionInfo::clone [function] [call site] 01723
52 skip_if_context_does_not_support [function] [call site] 01724
52 hotkeys_cluster::first_owned_slot_range [function] [call site] 01725
52 hotkeys_cluster::find_key_in_range [function] [call site] 01726
52 Some [function] [call site] 01727
51 Option::unwrap [function] [call site] 01728
51 Result::unwrap [function] [call site] 01729
51 starts_with [function] [call site] 01730
51 Ok [function] [call site] 01731
51 get_connection_info [function] [call site] 01732
51 ConnectionInfo::addr [function] [call site] 01733
51 RedisSentinelCluster::log_redis_state_via_cli [function] [call site] 01734
51 std::thread::sleep [function] [call site] 01735
51 Duration::from_millis [function] [call site] 01736
51 Err [function] [call site] 01737
50 &mut [call site] 01738
51 Sentinel::find_valid_replica_addresses [function] [call site] 01739
52 Sentinel::get_sentinel_replicas [function] [call site] 01740
53 Sentinel::try_all_sentinels [function] [call site] 01741
53 sentinel_replicas_cmd [function] [call site] 01742
54 crate::cmd [function] [call site] 01743
54 Cmd::arg [function] [call site] 01744
54 Cmd::arg [function] [call site] 01745
52 get_valid_replicas_addresses [function] [call site] 01746
53 valid_addrs [function] [call site] 01747
53 tests::into_redis_value_hashmap [function] [call site] 01748
53 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01749
53 map(|(ip, [call site] 01750
4 .collect::<RedisResult<Vec<ConnectionInfo>>> [function] [call site] 01751
53 Ok [function] [call site] 01752
53 &'a [call site] 01753
53 std::iter::Chain::filter [function] [call site] 01754
53 get_node_role [function] [call site] 01755
54 Client::open [function] [call site] 01756
54 redis::ConnectionInfo::clone [function] [call site] 01757
54 Client::get_connection [function] [call site] 01758
54 crate::cmd [function] [call site] 01759
54 redis::Cmd::query [function] [call site] 01760
53 RedisResult::is_ok_and [function] [call site] 01761
53 collect [function] [call site] 01762
51 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 01763
51 RedisServer::new [function] [call site] 01764
52 RedisServer::with_modules [function] [call site] 01765
51 basic::test_pipeline_len [function] [call site] 01766
52 redis::pipe [function] [call site] 01767
52 cmd [function] [call site] 01768
52 cmd [function] [call site] 01769
52 types::test_is_single_arg [function] [call site] 01770
51 tests::into_redis_value_hashmap [function] [call site] 01771
52 ComponentMatcher::from [function] [call site] 01772
52 String::into_redis_value [function] [call site] 01773
52 Value::into_map_iter [function] [call site] 01774
52 Result::expect [function] [call site] 01775
52 into_map_iter() [call site] 01776
6 .expect("extracting [call site] 01777
6 .collect::<Vec<(Value, [call site] 01778
52 sort_by [function] [call site] 01779
52 cmp [function] [call site] 01780
51 try_connect_to_first_replica [function] [call site] 01781
52 MockRedisConnection::is_empty [function] [call site] 01782
53 StreamReadOptions::block [function] [call site] 01783
53 unwrap [function] [call site] 01784
53 MockRedisConnection::is_empty [function] [call site] 01785
52 fail [function] [call site] 01786
52 Option<usize>::unwrap_or [function] [call site] 01787
52 basic::test_pipeline_len [function] [call site] 01788
52 basic::test_pipeline_len [function] [call site] 01789
52 Client::open [function] [call site] 01790
52 ClientTlsParams::clone [function] [call site] 01791
52 Ok [function] [call site] 01792
52 Some [function] [call site] 01793
52 Err [function] [call site] 01794
52 None::expect [function] [call site] 01795
50 Some [function] [call site] 01796
50 ConnectionAddr::is_err [function] [call site] 01797
49 RedisCluster::iter_servers [function] [call site] 01798
49 MapIter::next [function] [call site] 01799
49 unwrap [function] [call site] 01800
49 RedisServer::connection_info [function] [call site] 01801
49 hotkeys_cluster::port_of [function] [call site] 01802
49 redis::ConnectionInfo::addr [function] [call site] 01803
49 hotkeys_cluster::direct_connection [function] [call site] 01804
49 redis::ConnectionInfo::clone [function] [call site] 01805
49 skip_if_context_does_not_support [function] [call site] 01806
49 hotkeys_cluster::first_owned_slot_range [function] [call site] 01807
49 hotkeys_cluster::find_key_in_range [function] [call site] 01808
49 Some [function] [call site] 01809
48 tests::into_redis_value_hashmap [function] [call site] 01810
48 TlsFilePaths::as_str [function] [call site] 01811
48 Some [function] [call site] 01812
48 InfoDict::contains_key [function] [call site] 01813
49 InfoDict::find [function] [call site] 01814
50 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01815
49 Option::is_some [function] [call site] 01816
48 InfoDict::contains_key [function] [call site] 01817
48 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01818
48 Option::is_some_and [function] [call site] 01819
48 contains [function] [call site] 01820
48 contains [function] [call site] 01821
48 contains [function] [call site] 01822
48 parse::<u16> [function] [call site] 01823
48 tests::redis_ok [function] [call site] 01824
47 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01825
47 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01826
47 async_determine_master_from_role_or_info_replication [function] [call site] 01827
48 Client::open [function] [call site] 01828
48 redis::ConnectionInfo::clone [function] [call site] 01829
48 Client::get_multiplexed_async_connection [function] [call site] 01830
48 async_check_role [function] [call site] 01831
49 crate::cmd [function] [call site] 01832
49 redis::Cmd::query_async [function] [call site] 01833
48 Ok [function] [call site] 01834
48 async_check_info_replication [function] [call site] 01835
49 crate::cmd [function] [call site] 01836
49 redis::Cmd::arg [function] [call site] 01837
49 Cmd::query_async [function] [call site] 01838
50 &mut [call site] 01839
50 Ok [function] [call site] 01840
50 RedisResult::from_redis_value [function] [call site] 01841
50 Value::extract_error [function] [call site] 01842
49 parse_replication_info [function] [call site] 01843
49 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01844
49 Ok [function] [call site] 01845
49 ClientTlsParams::clone [function] [call site] 01846
49 Err [function] [call site] 01847
49 RedisError::from [function] [call site] 01848
48 Ok [function] [call site] 01849
48 evaluate_role_check_errors [function] [call site] 01850
48 unwrap_err [function] [call site] 01851
48 unwrap_err [function] [call site] 01852
47 Ok [function] [call site] 01853
45 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 01854
45 Client::open [function] [call site] 01855
44 as_str [function] [call site] 01856
44 Some [function] [call site] 01857
44 Sentinel::async_replica_for [function] [call site] 01858
45 Sentinel::async_find_valid_replica_addresses [function] [call site] 01859
46 Sentinel::async_get_sentinel_replicas [function] [call site] 01860
47 Sentinel::async_try_all_sentinels [function] [call site] 01861
47 sentinel_replicas_cmd [function] [call site] 01862
46 async_get_valid_replicas_addresses [function] [call site] 01863
47 valid_addrs [function] [call site] 01864
47 tests::into_redis_value_hashmap [function] [call site] 01865
47 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01866
47 map(|(ip, [call site] 01867
4 .collect::<RedisResult<Vec<_>>> [function] [call site] 01868
47 Ok [function] [call site] 01869
47 futures_util::stream::iter [function] [call site] 01870
48 TestContext::new [function] [call site] 01871
48 MockRedisConnection::check_connection [function] [call site] 01872
48 ComponentMatcher::from [function] [call site] 01873
48 basic::test_tuple_decoding_from_iter [function] [call site] 01874
48 hscan::<_, [call site] 01875
48 unwrap [function] [call site] 01876
48 Option::unwrap [function] [call site] 01877
47 filter_map [function] [call site] 01878
47 collect [function] [call site] 01879
45 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 01880
45 RedisServer::new [function] [call site] 01881
45 basic::test_pipeline_len [function] [call site] 01882
45 tests::into_redis_value_hashmap [function] [call site] 01883
45 try_connect_to_first_replica [function] [call site] 01884
44 as_str [function] [call site] 01885
44 Some [function] [call site] 01886
43 Client::get_multiplexed_async_connection_with_config [function] [call site] 01887
44 Runtime::locate [function] [call site] 01888
44 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::tokio::Tokio> [function] [call site] 01889
44 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::smol::Smol> [function] [call site] 01890
42 unwrap [function] [call site] 01891
42 async_tests::async_assert_is_connection_to_master [function] [call site] 01892
43 redis::cmd [function] [call site] 01893
43 redis::Cmd::arg [function] [call site] 01894
43 Cmd::query_async [function] [call site] 01895
43 unwrap [function] [call site] 01896
43 assert_is_master_role [function] [call site] 01897
44 parse_replication_info [function] [call site] 01898
42 TestSentinelContext::sentinel_node_connection_info [function] [call site] 01899
42 TestSentinelContext::sentinel_mut [function] [call site] 01900
42 Sentinel::async_master_for [function] [call site] 01901
42 Some [function] [call site] 01902
42 unwrap [function] [call site] 01903
42 SentinelClient::get_async_connection_with_config [function] [call site] 01904
42 unwrap [function] [call site] 01905
42 async_tests::async_assert_connection_is_replica_of_correct_master [function] [call site] 01906
43 redis::cmd [function] [call site] 01907
43 redis::Cmd::arg [function] [call site] 01908
43 Cmd::query_async [function] [call site] 01909
43 unwrap [function] [call site] 01910
43 assert_replica_role_and_master_addr [function] [call site] 01911
44 parse_replication_info [function] [call site] 01912
44 RedisServer::get_addr [function] [call site] 01913
45 ServerType::get_intended [function] [call site] 01914
45 get_default_host [function] [call site] 01915
45 redis::ConnectionAddr::Tcp [function] [call site] 01916
45 get_default_host [function] [call site] 01917
45 rand::random::<(u64, [call site] 01918
45 redis::ConnectionAddr::Unix [function] [call site] 01919
45 ComponentMatcher::from [function] [call site] 01920
43 Client::get_connection_info [function] [call site] 01921
40 RoutingInfo::SingleNode [function] [call site] 01922
40 MockRedisConnection::req_packed_command [function] [call site] 01923
41 Cmd::get_packed_command [function] [call site] 01924
41 MockRedisConnection::req_packed_command [function] [call site] 01925
41 as_slice [function] [call site] 01926
41 PipelineSink::poll_ready [function] [call site] 01927
41 types::test_parse_boxed [function] [call site] 01928
40 Cmd::get_packed_command [function] [call site] 01929
40 RedisCluster::new [function] [call site] 01930
40 RedisServer::default [function] [call site] 01931
40 ClusterConnection::route_command [function] [call site] 01932
40 RoutingInfo::SingleNode [function] [call site] 01933
40 RedisResult::unwrap [function] [call site] 01934
39 into [function] [call site] 01935
39 Arc::into_inner [function] [call site] 01936
39 unwrap [function] [call site] 01937
39 into_inner [function] [call site] 01938
39 crate::io::tcp::stream_with_settings [function] [call site] 01939
40 TcpSettings::set_nodelay [function] [call site] 01940
40 TcpStream::into [function] [call site] 01941
40 set_tcp_keepalive [function] [call site] 01942
40 set_linger [function] [call site] 01943
40 Some [function] [call site] 01944
40 set_tcp_user_timeout [function] [call site] 01945
40 Ok [function] [call site] 01946
40 into [function] [call site] 01947
40 Ok [function] [call site] 01948
39 try_into [function] [call site] 01949
38 ConnectionAddr::to_socket_addrs [function] [call site] 01950
38 connect_tcp_timeout [function] [call site] 01951
39 TcpStream::connect_timeout [function] [call site] 01952
39 io::tcp::stream_with_settings [function] [call site] 01953
40 TcpSettings::set_nodelay [function] [call site] 01954
40 TcpStream::into [function] [call site] 01955
40 set_tcp_keepalive [function] [call site] 01956
40 set_linger [function] [call site] 01957
40 Some [function] [call site] 01958
40 set_tcp_user_timeout [function] [call site] 01959
40 Ok [function] [call site] 01960
40 into [function] [call site] 01961
40 Ok [function] [call site] 01962
38 Some [function] [call site] 01963
38 Some [function] [call site] 01964
38 fail [function] [call site] 01965
38 fail [function] [call site] 01966
38 Self::Tcp [function] [call site] 01967
38 TlsConnector::builder [function] [call site] 01968
39 TestSentinelContext::new [function] [call site] 01969
39 TestSentinelContext::sentinels_connection_info [function] [call site] 01970
39 Client::open [function] [call site] 01971
39 ClientTlsParams::clone [function] [call site] 01972
39 RedisResult::inspect_err [function] [call site] 01973
39 log_connection_error [function] [call site] 01974
40 RedisServer::get_addr [function] [call site] 01975
41 ServerType::get_intended [function] [call site] 01976
41 get_default_host [function] [call site] 01977
41 redis::ConnectionAddr::Tcp [function] [call site] 01978
41 get_default_host [function] [call site] 01979
41 rand::random::<(u64, [call site] 01980
41 redis::ConnectionAddr::Unix [function] [call site] 01981
41 ComponentMatcher::from [function] [call site] 01982
40 RedisSentinelCluster::log_redis_state_via_cli [function] [call site] 01983
39 unwrap [function] [call site] 01984
39 Client::get_connection [function] [call site] 01985
39 inspect_err [function] [call site] 01986
39 log_connection_error [function] [call site] 01987
39 unwrap [function] [call site] 01988
39 redis::cmd [function] [call site] 01989
39 redis::Cmd::query [function] [call site] 01990
39 RedisResult::unwrap [function] [call site] 01991
39 SentinelClientBuilder::new [function] [call site] 01992
40 Ok [function] [call site] 01993
40 &'a [call site] 01994
40 into_iter().collect::<Vec<_>> [function] [call site] 01995
40 impl [call site] 01996
40 into [function] [call site] 01997
40 TcpSettings::default [function] [call site] 01998
40 TcpSettings::default [function] [call site] 01999
39 basic::test_tuple_decoding_from_iter [function] [call site] 02000
39 tests::into_redis_value_hashmap [function] [call site] 02001
39 RedisServer::get_addr [function] [call site] 02002
39 ClientTlsParams::clone [function] [call site] 02003
40 ClientTlsParams::clone [function] [call site] 02004
40 Pkcs1 [function] [call site] 02005
40 secret_pkcs1_der [function] [call site] 02006
40 write_command_to_vec [function] [call site] 02007
40 into [function] [call site] 02008
40 Pkcs8 [function] [call site] 02009
40 secret_pkcs8_der [function] [call site] 02010
40 write_command_to_vec [function] [call site] 02011
40 into [function] [call site] 02012
40 Sec1 [function] [call site] 02013
40 secret_sec1_der [function] [call site] 02014
40 write_command_to_vec [function] [call site] 02015
40 into [function] [call site] 02016
39 String::from [function] [call site] 02017
39 RedisResult::unwrap [function] [call site] 02018
39 SentinelClientBuilder::new [function] [call site] 02019
39 basic::test_tuple_decoding_from_iter [function] [call site] 02020
39 tests::into_redis_value_hashmap [function] [call site] 02021
39 RedisServer::get_addr [function] [call site] 02022
39 ClientTlsParams::clone [function] [call site] 02023
39 String::from [function] [call site] 02024
39 RedisResult::unwrap [function] [call site] 02025
39 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 02026
40 Some [function] [call site] 02027
39 redis_test::server::use_protocol [function] [call site] 02028
40 entra_id_tests::get_env_var [function] [call site] 02029
40 String::unwrap_or_default [function] [call site] 02030
39 TestSentinelContext::tls_mode [function] [call site] 02031
40 RedisServer::client_addr [function] [call site] 02032
40 Some [function] [call site] 02033
40 Some [function] [call site] 02034
39 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 02035
40 Some [function] [call site] 02036
39 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 02037
39 Sentinel::build [function] [call site] 02038
39 unwrap [function] [call site] 02039
39 Sentinel::build [function] [call site] 02040
39 unwrap [function] [call site] 02041
39 Client::get_connection [function] [call site] 02042
39 unwrap [function] [call site] 02043
39 redis::cmd [function] [call site] 02044
39 redis::Cmd::query [function] [call site] 02045
39 RedisResult::unwrap [function] [call site] 02046
39 assert_is_connection_to_master [function] [call site] 02047
40 redis::cmd [function] [call site] 02048
40 redis::Cmd::arg [function] [call site] 02049
40 basic::test_pipeline_reuse_query [function] [call site] 02050
40 unwrap [function] [call site] 02051
40 assert_is_master_role [function] [call site] 02052
39 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02053
39 TestSentinelContext::sentinel_mut [function] [call site] 02054
39 Sentinel::master_for [function] [call site] 02055
40 Sentinel::find_master_address [function] [call site] 02056
40 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02057
40 Client::open [function] [call site] 02058
39 Some [function] [call site] 02059
39 RedisResult::unwrap [function] [call site] 02060
39 Client::get_connection [function] [call site] 02061
39 unwrap [function] [call site] 02062
39 redis::cmd [function] [call site] 02063
39 redis::Cmd::query [function] [call site] 02064
39 RedisResult::unwrap [function] [call site] 02065
39 assert_connection_is_replica_of_correct_master [function] [call site] 02066
40 redis::cmd [function] [call site] 02067
40 redis::Cmd::arg [function] [call site] 02068
40 basic::test_pipeline_reuse_query [function] [call site] 02069
40 unwrap [function] [call site] 02070
40 assert_replica_role_and_master_addr [function] [call site] 02071
40 Client::get_connection_info [function] [call site] 02072
38 danger_accept_invalid_certs [function] [call site] 02073
38 cluster::test_danger_accept_invalid_hostnames [function] [call site] 02074
39 ClusterType::get_intended [function] [call site] 02075
39 TestClusterContext::new_with_config_and_builder [function] [call site] 02076
40 support::start_tls_crypto_provider [function] [call site] 02077
40 RedisCluster::new [function] [call site] 02078
40 RedisCluster::iter_servers [function] [call site] 02079
40 tests::into_redis_value_hashmap [function] [call site] 02080
40 collect [function] [call site] 02081
40 redis::cluster::ClusterClientBuilder::new [function] [call site] 02082
41 &'a [call site] 02083
41 std::iter::Chain::map [function] [call site] 02084
41 ConnectionInfo::into_connection_info [function] [call site] 02085
41 collect [function] [call site] 02086
41 RedisServer::default [function] [call site] 02087
40 ClientTlsParams::clone [function] [call site] 02088
40 Self::use_protocol [function] [call site] 02089
41 entra_id_tests::get_env_var [function] [call site] 02090
41 String::unwrap_or_default [function] [call site] 02091
40 redis_test::server::use_protocol [function] [call site] 02092
40 ClusterType::get_intended [function] [call site] 02093
40 ClusterClientBuilder::certs [function] [call site] 02094
41 is_none [function] [call site] 02095
41 Some [function] [call site] 02096
41 Some [function] [call site] 02097
40 super::load_certs_from_file [function] [call site] 02098
41 MockRedisConnection::is_open [function] [call site] 02099
41 bool::expect [function] [call site] 02100
41 RedisServer::new [function] [call site] 02101
41 RedisServer::new [function] [call site] 02102
42 RedisServer::with_modules [function] [call site] 02103
41 Self::read_to_end [function] [call site] 02104
41 expect [function] [call site] 02105
41 MockRedisConnection::is_open [function] [call site] 02106
41 bool::expect [function] [call site] 02107
41 RedisServer::new [function] [call site] 02108
41 RedisServer::new [function] [call site] 02109
41 Self::read_to_end [function] [call site] 02110
41 expect [function] [call site] 02111
41 MockRedisConnection::is_open [function] [call site] 02112
41 bool::expect [function] [call site] 02113
41 RedisServer::new [function] [call site] 02114
41 RedisServer::new [function] [call site] 02115
41 Self::read_to_end [function] [call site] 02116
41 expect [function] [call site] 02117
41 Some [function] [call site] 02118
41 Some [function] [call site] 02119
40 initializer [function] [call site] 02120
40 Sentinel::build [function] [call site] 02121
40 RedisResult::unwrap [function] [call site] 02122
40 redis_test::server::use_protocol [function] [call site] 02123
39 RedisServer::default [function] [call site] 02124
39 cluster::test_danger_accept_invalid_hostnames [function] [call site] 02125
39 cluster::smoke_test_connection [function] [call site] 02126
40 redis::cmd [function] [call site] 02127
40 redis::Cmd::arg [function] [call site] 02128
40 types::test_is_single_arg [function] [call site] 02129
40 Cmd::exec [function] [call site] 02130
40 RedisResult::unwrap [function] [call site] 02131
40 redis::cmd [function] [call site] 02132
40 redis::Cmd::arg [function] [call site] 02133
40 Cmd::exec [function] [call site] 02134
40 RedisResult::unwrap [function] [call site] 02135
39 MockRedisConnection::check_connection [function] [call site] 02136
38 use_sni [function] [call site] 02137
38 Sentinel::build [function] [call site] 02138
38 TlsConnector::builder [function] [call site] 02139
38 cluster::test_danger_accept_invalid_hostnames [function] [call site] 02140
38 Sentinel::build [function] [call site] 02141
38 RedisServer::new [function] [call site] 02142
39 RedisServer::with_modules [function] [call site] 02143
38 String::as_str [function] [call site] 02144
38 connect_tcp [function] [call site] 02145
38 connect [function] [call site] 02146
38 fail [function] [call site] 02147
38 String::as_str [function] [call site] 02148
38 to_socket_addrs [function] [call site] 02149
38 connect_tcp_timeout [function] [call site] 02150
38 Some [function] [call site] 02151
38 Some [function] [call site] 02152
38 connect [function] [call site] 02153
38 unwrap [function] [call site] 02154
38 fail [function] [call site] 02155
38 fail [function] [call site] 02156
38 ActualConnection::TcpNativeTls [function] [call site] 02157
38 RedisServer::new [function] [call site] 02158
38 create_rustls_config [function] [call site] 02159
39 MockRedisConnection::is_empty [function] [call site] 02160
40 StreamReadOptions::block [function] [call site] 02161
40 unwrap [function] [call site] 02162
40 MockRedisConnection::is_empty [function] [call site] 02163
39 bool::extend [function] [call site] 02164
39 basic::test_tuple_decoding_from_iter [function] [call site] 02165
39 cloned [function] [call site] 02166
39 rustls_native_certs::load_native_certs [function] [call site] 02167
39 test_module_json_arr_pop [function] [call site] 02168
40 TestContext::with_modules [function] [call site] 02169
40 MockRedisConnection::check_connection [function] [call site] 02170
40 bool::json_set [function] [call site] 02171
41 TestContext::with_modules [function] [call site] 02172
41 MockRedisConnection::check_connection [function] [call site] 02173
41 bool::json_set [function] [call site] 02174
40 bool::json_arr_pop [function] [call site] 02175
41 TestContext::with_modules [function] [call site] 02176
41 MockRedisConnection::check_connection [function] [call site] 02177
41 bool::json_set [function] [call site] 02178
41 bool::json_arr_pop [function] [call site] 02179
41 bool::json_set [function] [call site] 02180
41 bool::json_arr_pop [function] [call site] 02181
40 bool::json_set [function] [call site] 02182
40 bool::json_arr_pop [function] [call site] 02183
39 Err [function] [call site] 02184
39 into [function] [call site] 02185
39 bool::add [function] [call site] 02186
40 &mut [call site] 02187
41 &mut [call site] 02188
41 unwrap [function] [call site] 02189
41 &mut [call site] 02190
41 unwrap [function] [call site] 02191
41 &mut [call site] 02192
41 unwrap [function] [call site] 02193
41 &mut [call site] 02194
41 unwrap [function] [call site] 02195
40 unwrap [function] [call site] 02196
40 &mut [call site] 02197
40 unwrap [function] [call site] 02198
40 &mut [call site] 02199
40 unwrap [function] [call site] 02200
40 &mut [call site] 02201
40 unwrap [function] [call site] 02202
39 rustls::ClientConfig::builder [function] [call site] 02203
40 TestSentinelContext::new [function] [call site] 02204
40 TestSentinelContext::sentinels_connection_info [function] [call site] 02205
40 Client::open [function] [call site] 02206
40 ClientTlsParams::clone [function] [call site] 02207
40 RedisResult::inspect_err [function] [call site] 02208
40 log_connection_error [function] [call site] 02209
40 unwrap [function] [call site] 02210
40 Client::get_connection [function] [call site] 02211
40 inspect_err [function] [call site] 02212
40 log_connection_error [function] [call site] 02213
40 unwrap [function] [call site] 02214
40 redis::cmd [function] [call site] 02215
40 redis::Cmd::query [function] [call site] 02216
40 RedisResult::unwrap [function] [call site] 02217
40 SentinelClientBuilder::new [function] [call site] 02218
40 basic::test_tuple_decoding_from_iter [function] [call site] 02219
40 tests::into_redis_value_hashmap [function] [call site] 02220
40 RedisServer::get_addr [function] [call site] 02221
40 ClientTlsParams::clone [function] [call site] 02222
40 String::from [function] [call site] 02223
40 RedisResult::unwrap [function] [call site] 02224
40 SentinelClientBuilder::new [function] [call site] 02225
40 basic::test_tuple_decoding_from_iter [function] [call site] 02226
40 tests::into_redis_value_hashmap [function] [call site] 02227
40 RedisServer::get_addr [function] [call site] 02228
40 ClientTlsParams::clone [function] [call site] 02229
40 String::from [function] [call site] 02230
40 RedisResult::unwrap [function] [call site] 02231
40 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 02232
40 redis_test::server::use_protocol [function] [call site] 02233
40 TestSentinelContext::tls_mode [function] [call site] 02234
40 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 02235
40 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 02236
40 Sentinel::build [function] [call site] 02237
40 unwrap [function] [call site] 02238
40 Sentinel::build [function] [call site] 02239
40 unwrap [function] [call site] 02240
40 Client::get_connection [function] [call site] 02241
40 unwrap [function] [call site] 02242
40 redis::cmd [function] [call site] 02243
40 redis::Cmd::query [function] [call site] 02244
40 RedisResult::unwrap [function] [call site] 02245
40 assert_is_connection_to_master [function] [call site] 02246
40 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02247
40 TestSentinelContext::sentinel_mut [function] [call site] 02248
40 Sentinel::master_for [function] [call site] 02249
40 Some [function] [call site] 02250
40 RedisResult::unwrap [function] [call site] 02251
40 Client::get_connection [function] [call site] 02252
40 unwrap [function] [call site] 02253
40 redis::cmd [function] [call site] 02254
40 redis::Cmd::query [function] [call site] 02255
40 RedisResult::unwrap [function] [call site] 02256
40 assert_connection_is_replica_of_correct_master [function] [call site] 02257
39 unwrap_or [function] [call site] 02258
39 Self::with_root_certificates [function] [call site] 02259
39 ClientTlsParams::clone [function] [call site] 02260
39 with_client_auth_cert [function] [call site] 02261
39 map_err [function] [call site] 02262
39 RedisError::from [function] [call site] 02263
39 ValueComparison::arg_to_string [function] [call site] 02264
39 with_no_client_auth [function] [call site] 02265
39 fail [function] [call site] 02266
39 Self::dangerous [function] [call site] 02267
39 set_certificate_verifier [function] [call site] 02268
39 RedisServer::new [function] [call site] 02269
39 rustls::client::WebPkiServerVerifier::builder [function] [call site] 02270
40 TestSentinelContext::new [function] [call site] 02271
40 TestSentinelContext::sentinels_connection_info [function] [call site] 02272
40 Client::open [function] [call site] 02273
40 ClientTlsParams::clone [function] [call site] 02274
40 RedisResult::inspect_err [function] [call site] 02275
40 log_connection_error [function] [call site] 02276
40 unwrap [function] [call site] 02277
40 Client::get_connection [function] [call site] 02278
40 inspect_err [function] [call site] 02279
40 log_connection_error [function] [call site] 02280
40 unwrap [function] [call site] 02281
40 redis::cmd [function] [call site] 02282
40 redis::Cmd::query [function] [call site] 02283
40 RedisResult::unwrap [function] [call site] 02284
40 SentinelClientBuilder::new [function] [call site] 02285
40 basic::test_tuple_decoding_from_iter [function] [call site] 02286
40 tests::into_redis_value_hashmap [function] [call site] 02287
40 RedisServer::get_addr [function] [call site] 02288
40 ClientTlsParams::clone [function] [call site] 02289
40 String::from [function] [call site] 02290
40 RedisResult::unwrap [function] [call site] 02291
40 SentinelClientBuilder::new [function] [call site] 02292
40 basic::test_tuple_decoding_from_iter [function] [call site] 02293
40 tests::into_redis_value_hashmap [function] [call site] 02294
40 RedisServer::get_addr [function] [call site] 02295
40 ClientTlsParams::clone [function] [call site] 02296
40 String::from [function] [call site] 02297
40 RedisResult::unwrap [function] [call site] 02298
40 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 02299
40 redis_test::server::use_protocol [function] [call site] 02300
40 TestSentinelContext::tls_mode [function] [call site] 02301
40 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 02302
40 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 02303
40 Sentinel::build [function] [call site] 02304
40 unwrap [function] [call site] 02305
40 Sentinel::build [function] [call site] 02306
40 unwrap [function] [call site] 02307
40 Client::get_connection [function] [call site] 02308
40 unwrap [function] [call site] 02309
40 redis::cmd [function] [call site] 02310
40 redis::Cmd::query [function] [call site] 02311
40 RedisResult::unwrap [function] [call site] 02312
40 assert_is_connection_to_master [function] [call site] 02313
40 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02314
40 TestSentinelContext::sentinel_mut [function] [call site] 02315
40 Sentinel::master_for [function] [call site] 02316
40 Some [function] [call site] 02317
40 RedisResult::unwrap [function] [call site] 02318
40 Client::get_connection [function] [call site] 02319
40 unwrap [function] [call site] 02320
40 redis::cmd [function] [call site] 02321
40 redis::Cmd::query [function] [call site] 02322
40 RedisResult::unwrap [function] [call site] 02323
40 assert_connection_is_replica_of_correct_master [function] [call site] 02324
39 RedisServer::new [function] [call site] 02325
39 Sentinel::build [function] [call site] 02326
39 RedisResult::map_err [function] [call site] 02327
39 rustls::Error::from [function] [call site] 02328
40 io::Error::from [function] [call site] 02329
40 Self::into [function] [call site] 02330
39 rustls::OtherError [function] [call site] 02331
39 RedisServer::new [function] [call site] 02332
39 Self::with_root_certificates [function] [call site] 02333
39 with_no_client_auth [function] [call site] 02334
39 rustls::crypto::CryptoProvider::get_default [function] [call site] 02335
39 Err [function] [call site] 02336
39 RedisError::from [function] [call site] 02337
39 Self::dangerous [function] [call site] 02338
39 set_certificate_verifier [function] [call site] 02339
39 RedisServer::new [function] [call site] 02340
39 Ok [function] [call site] 02341
39 fail [function] [call site] 02342
39 Ok [function] [call site] 02343
38 ClientTlsParams::clone [function] [call site] 02344
38 rustls::ClientConnection::new [function] [call site] 02345
39 RedisServer::with_modules [function] [call site] 02346
38 RedisServer::new [function] [call site] 02347
38 rustls::pki_types::ServerName::try_from [function] [call site] 02348
39 Ok [function] [call site] 02349
39 Err [function] [call site] 02350
38 to_owned [function] [call site] 02351
38 connect_tcp [function] [call site] 02352
38 RedisServer::new [function] [call site] 02353
39 RedisServer::with_modules [function] [call site] 02354
38 to_socket_addrs [function] [call site] 02355
38 connect_tcp_timeout [function] [call site] 02356
38 Some [function] [call site] 02357
38 Some [function] [call site] 02358
38 RedisServer::new [function] [call site] 02359
38 fail [function] [call site] 02360
38 fail [function] [call site] 02361
38 Self::TcpRustls [function] [call site] 02362
38 RedisServer::new [function] [call site] 02363
38 fail [function] [call site] 02364
38 Self::Unix [function] [call site] 02365
38 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 02366
39 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 02367
39 cluster::test_cluster_retries [function] [call site] 02368
39 TestClusterContext::get_ports [function] [call site] 02369
39 MockRedisConnection::check_connection [function] [call site] 02370
39 RedisServer::drop [function] [call site] 02371
39 cmd [function] [call site] 02372
39 ClusterConnection::route_command [function] [call site] 02373
39 RoutingInfo::SingleNode [function] [call site] 02374
39 MockRedisConnection::req_packed_command [function] [call site] 02375
39 Cmd::get_packed_command [function] [call site] 02376
39 RedisCluster::new [function] [call site] 02377
39 RedisServer::default [function] [call site] 02378
39 ClusterConnection::route_command [function] [call site] 02379
39 RoutingInfo::SingleNode [function] [call site] 02380
39 RedisResult::unwrap [function] [call site] 02381
38 fail [function] [call site] 02382
37 and_then [function] [call site] 02383
37 checked_sub [function] [call site] 02384
37 elapsed [function] [call site] 02385
37 is_some [function] [call site] 02386
37 is_none [function] [call site] 02387
37 Err [function] [call site] 02388
37 RedisError::from [function] [call site] 02389
37 std::io::Error::new [function] [call site] 02390
38 RedisServer::with_modules [function] [call site] 02391
37 MockConnection::set_read_timeout [function] [call site] 02392
38 Ok [function] [call site] 02393
37 MockConnection::set_write_timeout [function] [call site] 02394
38 Ok [function] [call site] 02395
37 setup_connection [function] [call site] 02396
38 execute_connection_pipeline [function] [call site] 02397
39 basic::test_pipeline_len [function] [call site] 02398
39 Ok [function] [call site] 02399
39 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 02400
39 Pipeline::get_packed_pipeline [function] [call site] 02401
40 encode_pipeline [function] [call site] 02402
41 write_pipeline [function] [call site] 02403
42 basic::test_tuple_decoding_from_iter [function] [call site] 02404
43 TestContext::new [function] [call site] 02405
43 MockRedisConnection::check_connection [function] [call site] 02406
43 ComponentMatcher::from [function] [call site] 02407
43 basic::test_tuple_decoding_from_iter [function] [call site] 02408
43 hscan::<_, [call site] 02409
43 unwrap [function] [call site] 02410
43 Option::unwrap [function] [call site] 02411
42 tests::into_redis_value_hashmap [function] [call site] 02412
42 sum [function] [call site] 02413
42 cmd::cmd [function] [call site] 02414
43 redis::cmd [function] [call site] 02415
43 Cmd::set_cache_config [function] [call site] 02416
43 CommandCacheConfig::new [function] [call site] 02417
43 CommandCacheConfig::set_enable_cache [function] [call site] 02418
42 cmd::cmd [function] [call site] 02419
42 &mut [call site] 02420
42 cmd::cmd_len [function] [call site] 02421
43 args_len [function] [call site] 02422
43 Cmd::args_iter [function] [call site] 02423
43 unwrap_or [function] [call site] 02424
42 cmd::cmd_len [function] [call site] 02425
42 Cmd::write_packed_command_preallocated [function] [call site] 02426
43 write_command [function] [call site] 02427
43 Cmd::args_iter [function] [call site] 02428
43 unwrap_or [function] [call site] 02429
42 Cmd::write_packed_command_preallocated [function] [call site] 02430
43 write_command [function] [call site] 02431
43 Cmd::args_iter [function] [call site] 02432
43 unwrap_or [function] [call site] 02433
42 Cmd::write_packed_command_preallocated [function] [call site] 02434
42 &mut [call site] 02435
42 Cmd::write_packed_command_preallocated [function] [call site] 02436
39 Cmd::with_capacity [function] [call site] 02437
39 MapIter::next [function] [call site] 02438
40 Some [function] [call site] 02439
40 MapIter::next [function] [call site] 02440
40 MapIter::next [function] [call site] 02441
40 MapIter::next [function] [call site] 02442
40 Some [function] [call site] 02443
39 ok_or_else [function] [call site] 02444
39 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 02445
40 TestContext::new [function] [call site] 02446
40 ProtocolVersion::supports_resp3 [function] [call site] 02447
40 tokio::sync::mpsc::unbounded_channel [function] [call site] 02448
40 redis::aio::ConnectionManagerConfig::new [function] [call site] 02449
40 AsyncConnectionConfig::set_push_sender [function] [call site] 02450
40 Client::get_connection_manager_lazy [function] [call site] 02451
40 unwrap [function] [call site] 02452
40 tests::into_redis_value_hashset [function] [call site] 02453
40 unwrap [function] [call site] 02454
40 MockConnection::send_packed_command [function] [call site] 02455
40 cmd [function] [call site] 02456
40 Cmd::arg [function] [call site] 02457
40 types::test_is_single_arg [function] [call site] 02458
40 unwrap [function] [call site] 02459
40 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02460
40 unwrap [function] [call site] 02461
40 tests::into_redis_value_hashset [function] [call site] 02462
40 unwrap [function] [call site] 02463
40 Pipeline::send_recv [function] [call site] 02464
40 unwrap [function] [call site] 02465
39 connection::check_connection_setup [function] [call site] 02466
40 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02467
41 TestClusterContext::new [function] [call site] 02468
41 TestSentinelContext::wait_for_cluster_up [function] [call site] 02469
41 RedisCluster::iter_servers [function] [call site] 02470
41 MapIter::next [function] [call site] 02471
41 unwrap [function] [call site] 02472
41 RedisServer::connection_info [function] [call site] 02473
41 hotkeys_cluster::port_of [function] [call site] 02474
41 redis::ConnectionInfo::addr [function] [call site] 02475
41 hotkeys_cluster::direct_connection [function] [call site] 02476
41 redis::ConnectionInfo::clone [function] [call site] 02477
41 skip_if_context_does_not_support [function] [call site] 02478
41 hotkeys_cluster::first_owned_slot_range [function] [call site] 02479
41 hotkeys_cluster::find_key_in_range [function] [call site] 02480
41 Some [function] [call site] 02481
40 Err [function] [call site] 02482
40 into [function] [call site] 02483
40 check_resp3_auth [function] [call site] 02484
41 Err [function] [call site] 02485
41 get_resp3_hello_command_error [function] [call site] 02486
42 RedisError::detail [function] [call site] 02487
43 Option::as_ref [function] [call site] 02488
43 tests::into_redis_value_hashmap [function] [call site] 02489
43 Option::as_str [function] [call site] 02490
43 Some [function] [call site] 02491
43 ServerError::details [function] [call site] 02492
44 Option::as_ref [function] [call site] 02493
44 tests::into_redis_value_hashmap [function] [call site] 02494
44 as_str [function] [call site] 02495
44 Option::as_ref [function] [call site] 02496
44 tests::into_redis_value_hashmap [function] [call site] 02497
44 as_str [function] [call site] 02498
42 Option::starts_with [function] [call site] 02499
42 into [function] [call site] 02500
41 ClientTlsParams::clone [function] [call site] 02501
41 Self::into [function] [call site] 02502
41 Ok [function] [call site] 02503
40 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02504
40 Err [function] [call site] 02505
40 into [function] [call site] 02506
40 check_resp2_auth [function] [call site] 02507
41 Ok [function] [call site] 02508
41 Err [function] [call site] 02509
41 into [function] [call site] 02510
41 into [function] [call site] 02511
41 ServerError::details [function] [call site] 02512
41 Option::ok_or [function] [call site] 02513
41 contains [function] [call site] 02514
41 Err [function] [call site] 02515
41 into [function] [call site] 02516
41 Ok [function] [call site] 02517
40 Ok [function] [call site] 02518
40 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02519
40 Err [function] [call site] 02520
40 into [function] [call site] 02521
40 check_db_select [function] [call site] 02522
41 Ok [function] [call site] 02523
41 ServerError::details [function] [call site] 02524
41 Err [function] [call site] 02525
41 into [function] [call site] 02526
41 ValueComparison::arg_to_string [function] [call site] 02527
41 into [function] [call site] 02528
41 Err [function] [call site] 02529
41 into [function] [call site] 02530
41 into [function] [call site] 02531
40 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02532
40 Err [function] [call site] 02533
40 into [function] [call site] 02534
40 check_caching [function] [call site] 02535
41 Ok [function] [call site] 02536
41 Err [function] [call site] 02537
41 into [function] [call site] 02538
41 into [function] [call site] 02539
40 Ok [function] [call site] 02540
38 connection_setup_pipeline [function] [call site] 02541
39 cmd::pipe [function] [call site] 02542
40 redis::pipe [function] [call site] 02543
40 Pipeline::atomic [function] [call site] 02544
40 redis::pipe [function] [call site] 02545
39 ProtocolVersion::supports_resp3 [function] [call site] 02546
39 add_command [function] [call site] 02547
39 commands::resp3_hello [function] [call site] 02548
40 cmd::cmd [function] [call site] 02549
40 Cmd::arg [function] [call site] 02550
40 as_ref [function] [call site] 02551
40 Cmd::arg [function] [call site] 02552
40 types::test_is_single_arg [function] [call site] 02553
40 types::test_is_single_arg [function] [call site] 02554
40 &'static [call site] 02555
39 Some [function] [call site] 02556
39 as_ref [function] [call site] 02557
39 add_command [function] [call site] 02558
39 authenticate_cmd [function] [call site] 02559
40 cmd::cmd [function] [call site] 02560
40 types::test_is_single_arg [function] [call site] 02561
40 types::test_is_single_arg [function] [call site] 02562
39 bool::then [function] [call site] 02563
39 redis::ConnectionInfo::username [function] [call site] 02564
40 as_deref [function] [call site] 02565
39 flatten [function] [call site] 02566
39 Some [function] [call site] 02567
39 then [function] [call site] 02568
39 basic::test_pipeline_len [function] [call site] 02569
39 inspect [function] [call site] 02570
39 cmd::cmd [function] [call site] 02571
39 Cmd::arg [function] [call site] 02572
39 tests::into_redis_value_hashmap [function] [call site] 02573
40 ComponentMatcher::from [function] [call site] 02574
40 String::into_redis_value [function] [call site] 02575
40 Value::into_map_iter [function] [call site] 02576
40 Result::expect [function] [call site] 02577
40 into_map_iter() [call site] 02578
6 .expect("extracting [call site] 02579
6 .collect::<Vec<(Value, [call site] 02580
40 sort_by [function] [call site] 02581
40 cmp [function] [call site] 02582
39 cmd::cmd [function] [call site] 02583
39 Cmd::arg [function] [call site] 02584
39 types::test_is_single_arg [function] [call site] 02585
39 types::test_is_single_arg [function] [call site] 02586
39 basic::test_pipeline_len [function] [call site] 02587
39 cmd::cmd [function] [call site] 02588
39 Cmd::arg [function] [call site] 02589
39 types::test_is_single_arg [function] [call site] 02590
39 types::test_is_single_arg [function] [call site] 02591
39 as_ref [function] [call site] 02592
39 map_or [function] [call site] 02593
39 ignore [function] [call site] 02594
39 cmd::cmd [function] [call site] 02595
39 Cmd::arg [function] [call site] 02596
39 types::test_is_single_arg [function] [call site] 02597
39 types::test_is_single_arg [function] [call site] 02598
39 as_ref [function] [call site] 02599
39 map_or [function] [call site] 02600
39 ignore [function] [call site] 02601
38 execute_connection_pipeline [function] [call site] 02602
38 connection_setup_pipeline [function] [call site] 02603
38 Ok [function] [call site] 02604
37 MockConnection::set_read_timeout [function] [call site] 02605
37 MockConnection::set_write_timeout [function] [call site] 02606
37 Ok [function] [call site] 02607
35 RedisError::is_connection_refusal [function] [call site] 02608
36 RedisError::as_io_error [function] [call site] 02609
36 Option::is_some_and [function] [call site] 02610
36 get_push_kind [function] [call site] 02611
35 std::thread::sleep [function] [call site] 02612
35 flushdb::<()> [function] [call site] 02613
35 std::thread::sleep [function] [call site] 02614
35 redis_test::server::use_protocol [function] [call site] 02615
31 MockRedisConnection::check_connection [function] [call site] 02616
31 bool::json_set [function] [call site] 02617
31 bool::json_arr_insert [function] [call site] 02618
32 TestContext::with_modules [function] [call site] 02619
32 MockRedisConnection::check_connection [function] [call site] 02620
32 bool::json_set [function] [call site] 02621
32 bool::json_arr_insert [function] [call site] 02622
32 bool::json_set [function] [call site] 02623
32 bool::json_arr_insert [function] [call site] 02624
31 bool::json_set [function] [call site] 02625
31 bool::json_arr_insert [function] [call site] 02626
30 ClientTlsParams::clone [function] [call site] 02627
30 RedisServer::new [function] [call site] 02628
30 Sentinel::build [function] [call site] 02629
30 RedisResult::unwrap [function] [call site] 02630
30 ClusterClient::get_generic_connection [function] [call site] 02631
31 cluster::ClusterConnection::new [function] [call site] 02632
32 ClusterConnection::new_inner [function] [call site] 02633
33 unwrap_or_default [function] [call site] 02634
33 ClientTlsParams::clone [function] [call site] 02635
33 Runtime::locate [function] [call site] 02636
33 futures_channel::mpsc::unbounded [function] [call site] 02637
33 Cmd::take [function] [call site] 02638
33 is_some [function] [call site] 02639
33 mpsc::channel::<Message<_>> [function] [call site] 02640
33 Self::downgrade [function] [call site] 02641
33 ClusterConnInner::new [function] [call site] 02642
34 bool::then [function] [call site] 02643
34 RedisServer::new [function] [call site] 02644
35 RedisServer::with_modules [function] [call site] 02645
34 RedisServer::default [function] [call site] 02646
35 RedisServer::new [function] [call site] 02647
34 as_ref [function] [call site] 02648
34 tests::into_redis_value_hashmap [function] [call site] 02649
34 T::create_strategy [function] [call site] 02650
35 RedisServer::new [function] [call site] 02651
35 RedisServer::default [function] [call site] 02652
36 RedisServer::new [function] [call site] 02653
34 mpsc::unbounded_channel [function] [call site] 02654
34 RedisServer::new [function] [call site] 02655
34 RedisServer::new [function] [call site] 02656
35 RedisServer::with_modules [function] [call site] 02657
34 RedisServer::default [function] [call site] 02658
34 SlotMap::new [function] [call site] 02659
35 RedisServer::default [function] [call site] 02660
34 write_command_to_vec [function] [call site] 02661
34 Core [function] [call site] 02662
34 RedisServer::default [function] [call site] 02663
34 RedisServer::default [function] [call site] 02664
34 ConnectionState::Recover [function] [call site] 02665
34 RecoverFuture::ReconnectInitial [function] [call site] 02666
34 Box::pin [function] [call site] 02667
34 ClusterConnInner::reconnect_to_initial_nodes [function] [call site] 02668
35 ClientTlsParams::clone [function] [call site] 02669
35 ClusterConnection::create_initial_connections [function] [call site] 02670
36 Cmd::with_capacity [function] [call site] 02671
37 Cmd::with_capacity [function] [call site] 02672
37 Cmd::with_capacity [function] [call site] 02673
36 basic::test_pipeline_len [function] [call site] 02674
36 RedisServer::new [function] [call site] 02675
36 basic::test_tuple_decoding_from_iter [function] [call site] 02676
36 NodeAddress::try_from [function] [call site] 02677
37 Ok [function] [call site] 02678
37 RedisServer::new [function] [call site] 02679
37 String::as_str [function] [call site] 02680
37 Err [function] [call site] 02681
37 RedisError::from [function] [call site] 02682
36 ClusterConnection::connect [function] [call site] 02683
37 Client::get_connection_info [function] [call site] 02684
37 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 02685
38 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 02686
38 cluster::test_cluster_retries [function] [call site] 02687
38 TestClusterContext::get_ports [function] [call site] 02688
38 MockRedisConnection::check_connection [function] [call site] 02689
38 RedisServer::drop [function] [call site] 02690
38 cmd [function] [call site] 02691
38 ClusterConnection::route_command [function] [call site] 02692
38 RoutingInfo::SingleNode [function] [call site] 02693
38 MockRedisConnection::req_packed_command [function] [call site] 02694
38 Cmd::get_packed_command [function] [call site] 02695
38 RedisCluster::new [function] [call site] 02696
38 RedisServer::default [function] [call site] 02697
38 ClusterConnection::route_command [function] [call site] 02698
38 RoutingInfo::SingleNode [function] [call site] 02699
38 RedisResult::unwrap [function] [call site] 02700
37 Some [function] [call site] 02701
37 cmd::cmd [function] [call site] 02702
37 Cmd::exec [function] [call site] 02703
38 query::<()> [function] [call site] 02704
37 MockConnection::set_read_timeout [function] [call site] 02705
38 Ok [function] [call site] 02706
37 borrow [function] [call site] 02707
37 MockConnection::set_write_timeout [function] [call site] 02708
38 Ok [function] [call site] 02709
37 borrow [function] [call site] 02710
37 Ok [function] [call site] 02711
36 MockRedisConnection::check_connection [function] [call site] 02712
36 test_module_json_arr_insert [function] [call site] 02713
36 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 02714
37 TestContext::new [function] [call site] 02715
37 ProtocolVersion::supports_resp3 [function] [call site] 02716
37 tokio::sync::mpsc::unbounded_channel [function] [call site] 02717
37 redis::aio::ConnectionManagerConfig::new [function] [call site] 02718
37 AsyncConnectionConfig::set_push_sender [function] [call site] 02719
37 Client::get_connection_manager_lazy [function] [call site] 02720
37 unwrap [function] [call site] 02721
37 tests::into_redis_value_hashset [function] [call site] 02722
37 unwrap [function] [call site] 02723
37 MockConnection::send_packed_command [function] [call site] 02724
37 cmd [function] [call site] 02725
37 Cmd::arg [function] [call site] 02726
37 types::test_is_single_arg [function] [call site] 02727
37 unwrap [function] [call site] 02728
37 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02729
37 unwrap [function] [call site] 02730
37 tests::into_redis_value_hashset [function] [call site] 02731
37 unwrap [function] [call site] 02732
37 Pipeline::send_recv [function] [call site] 02733
37 unwrap [function] [call site] 02734
36 RedisError::from [function] [call site] 02735
36 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 02736
36 MockRedisConnection::is_empty [function] [call site] 02737
36 MockRedisConnection::is_empty [function] [call site] 02738
37 StreamReadOptions::block [function] [call site] 02739
37 unwrap [function] [call site] 02740
37 MockRedisConnection::is_empty [function] [call site] 02741
36 ValueComparison::arg_to_string [function] [call site] 02742
36 ValueComparison::arg_to_string [function] [call site] 02743
36 &'a [call site] 02744
37 std::iter::once [function] [call site] 02745
37 chain [function] [call site] 02746
37 basic::test_tuple_decoding_from_iter [function] [call site] 02747
36 std::iter::Chain::enumerate [function] [call site] 02748
36 Err [function] [call site] 02749
36 RedisError::from [function] [call site] 02750
36 borrow_mut [function] [call site] 02751
36 ClusterConnection::refresh_slots [function] [call site] 02752
37 borrow_mut [function] [call site] 02753
37 ClusterConnection::create_new_slots [function] [call site] 02754
38 borrow_mut [function] [call site] 02755
38 iter_mut [function] [call site] 02756
38 basic::test_object_freq_command [function] [call site] 02757
39 TestContext::new [function] [call site] 02758
39 MockRedisConnection::check_connection [function] [call site] 02759
39 redis::cmd [function] [call site] 02760
39 redis::Cmd::arg [function] [call site] 02761
39 types::test_is_single_arg [function] [call site] 02762
39 types::test_is_single_arg [function] [call site] 02763
39 Cmd::exec [function] [call site] 02764
39 RedisResult::unwrap [function] [call site] 02765
39 tests::into_redis_value_hashset [function] [call site] 02766
39 unwrap [function] [call site] 02767
39 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02768
39 Option::unwrap [function] [call site] 02769
38 cluster_handling::slot_cmd [function] [call site] 02770
39 Cmd::new [function] [call site] 02771
39 Cmd::arg [function] [call site] 02772
39 types::test_is_single_arg [function] [call site] 02773
38 super::topology::parse_slots [function] [call site] 02774
39 Cmd::with_capacity [function] [call site] 02775
39 HashSet::<ArcStr>::new [function] [call site] 02776
40 RedisServer::with_modules [function] [call site] 02777
39 &'a [call site] 02778
39 MapIter::next [function] [call site] 02779
39 basic::test_pipeline_len [function] [call site] 02780
40 redis::pipe [function] [call site] 02781
40 cmd [function] [call site] 02782
40 cmd [function] [call site] 02783
40 types::test_is_single_arg [function] [call site] 02784
39 basic::test_pipeline_len [function] [call site] 02785
39 String::from_utf8_lossy [function] [call site] 02786
39 MockRedisConnection::is_empty [function] [call site] 02787
40 StreamReadOptions::block [function] [call site] 02788
40 unwrap [function] [call site] 02789
40 MockRedisConnection::is_empty [function] [call site] 02790
39 is_wildcard_address [function] [call site] 02791
39 &str::into [function] [call site] 02792
39 &str::into [function] [call site] 02793
39 MockRedisConnection::is_empty [function] [call site] 02794
39 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02795
40 TestClusterContext::new [function] [call site] 02796
40 TestSentinelContext::wait_for_cluster_up [function] [call site] 02797
40 RedisCluster::iter_servers [function] [call site] 02798
40 MapIter::next [function] [call site] 02799
40 unwrap [function] [call site] 02800
40 RedisServer::connection_info [function] [call site] 02801
40 hotkeys_cluster::port_of [function] [call site] 02802
40 redis::ConnectionInfo::addr [function] [call site] 02803
40 hotkeys_cluster::direct_connection [function] [call site] 02804
40 redis::ConnectionInfo::clone [function] [call site] 02805
40 skip_if_context_does_not_support [function] [call site] 02806
40 hotkeys_cluster::first_owned_slot_range [function] [call site] 02807
40 hotkeys_cluster::find_key_in_range [function] [call site] 02808
40 Some [function] [call site] 02809
39 TlsFilePaths::as_ref [function] [call site] 02810
39 ClientTlsParams::clone [function] [call site] 02811
39 TlsFilePaths::into [function] [call site] 02812
39 Self::insert [function] [call site] 02813
40 TestContext::with_modules [function] [call site] 02814
40 MockRedisConnection::check_connection [function] [call site] 02815
40 bool::json_set [function] [call site] 02816
40 bool::json_arr_insert [function] [call site] 02817
40 bool::json_set [function] [call site] 02818
40 bool::json_arr_insert [function] [call site] 02819
39 ClientTlsParams::clone [function] [call site] 02820
40 ClientTlsParams::clone [function] [call site] 02821
40 Pkcs1 [function] [call site] 02822
40 secret_pkcs1_der [function] [call site] 02823
40 write_command_to_vec [function] [call site] 02824
40 into [function] [call site] 02825
40 Pkcs8 [function] [call site] 02826
40 secret_pkcs8_der [function] [call site] 02827
40 write_command_to_vec [function] [call site] 02828
40 into [function] [call site] 02829
40 Sec1 [function] [call site] 02830
40 secret_sec1_der [function] [call site] 02831
40 write_command_to_vec [function] [call site] 02832
40 into [function] [call site] 02833
39 Some [function] [call site] 02834
39 NodeAddress::new [function] [call site] 02835
40 NodeAddress::from_parts [function] [call site] 02836
40 String::into [function] [call site] 02837
39 &'a [call site] 02838
40 std::iter::once [function] [call site] 02839
40 chain [function] [call site] 02840
40 basic::test_tuple_decoding_from_iter [function] [call site] 02841
39 std::iter::Chain::skip [function] [call site] 02842
39 is_none [function] [call site] 02843
39 MapIter::next [function] [call site] 02844
39 try_to_address [function] [call site] 02845
39 filter_map [function] [call site] 02846
39 collect [function] [call site] 02847
39 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 02848
39 SlotRange::new [function] [call site] 02849
39 Ok [function] [call site] 02850
38 ConnectionAddr::host [function] [call site] 02851
38 Some [function] [call site] 02852
38 SlotMap::from_slots [function] [call site] 02853
39 SlotRangeMap::new [function] [call site] 02854
40 RedisServer::new [function] [call site] 02855
41 RedisServer::with_modules [function] [call site] 02856
39 test_module_json_arr_insert [function] [call site] 02857
39 SlotAddrs::from_slot [function] [call site] 02858
40 RedisServer::new [function] [call site] 02859
38 Ok [function] [call site] 02860
38 Err [function] [call site] 02861
38 RedisError::from [function] [call site] 02862
37 RoundRobinReplicaStrategy::on_topology_changed [function] [call site] 02863
38 SlotRangeMap::new [function] [call site] 02864
38 ClusterTopology::shards [function] [call site] 02865
39 std::collections::HashSet::new [function] [call site] 02866
39 MockCmd::with_values [function] [call site] 02867
40 Cmd::into_redis_cmd_bytes [function] [call site] 02868
41 Cmd::get_packed_command [function] [call site] 02869
40 tests::into_redis_value_hashmap [function] [call site] 02870
41 ComponentMatcher::from [function] [call site] 02871
41 String::into_redis_value [function] [call site] 02872
41 Value::into_map_iter [function] [call site] 02873
41 Result::expect [function] [call site] 02874
41 into_map_iter() [call site] 02875
6 .expect("extracting [call site] 02876
6 .collect::<Vec<(Value, [call site] 02877
41 sort_by [function] [call site] 02878
41 cmp [function] [call site] 02879
40 &'a [call site] 02880
40 tests::into_redis_value_hashmap [function] [call site] 02881
40 String::into_redis_value [function] [call site] 02882
41 Value::BulkString [function] [call site] 02883
41 String::as_bytes [function] [call site] 02884
41 write_command_to_vec [function] [call site] 02885
40 collect [function] [call site] 02886
39 filter [function] [call site] 02887
39 Self::insert [function] [call site] 02888
39 Arc::as_ptr [function] [call site] 02889
39 tests::into_redis_value_hashmap [function] [call site] 02890
39 as_ref [function] [call site] 02891
38 RedisServer::new [function] [call site] 02892
38 RedisServer::new [function] [call site] 02893
39 RedisServer::with_modules [function] [call site] 02894
38 cluster::test_cluster_fan_out_out_once_even_if_primary_has_multiple_slot_ranges [function] [call site] 02895
39 cluster::test_cluster_fan_out [function] [call site] 02896
40 RedisServer::new [function] [call site] 02897
40 std::sync::Mutex::new [function] [call site] 02898
41 RedisServer::with_modules [function] [call site] 02899
40 RedisServer::new [function] [call site] 02900
40 ClientTlsParams::clone [function] [call site] 02901
41 ClientTlsParams::clone [function] [call site] 02902
41 Pkcs1 [function] [call site] 02903
41 secret_pkcs1_der [function] [call site] 02904
41 write_command_to_vec [function] [call site] 02905
41 into [function] [call site] 02906
41 Pkcs8 [function] [call site] 02907
41 secret_pkcs8_der [function] [call site] 02908
41 write_command_to_vec [function] [call site] 02909
41 into [function] [call site] 02910
41 Sec1 [function] [call site] 02911
41 secret_sec1_der [function] [call site] 02912
41 write_command_to_vec [function] [call site] 02913
41 into [function] [call site] 02914
40 redis::Cmd::new [function] [call site] 02915
41 Cmd::into_redis_cmd_bytes [function] [call site] 02916
41 tests::into_redis_value_hashmap [function] [call site] 02917
40 RedisFuture::split_whitespace [function] [call site] 02918
40 Cmd::arg [function] [call site] 02919
40 Cmd::get_packed_command [function] [call site] 02920
40 MockEnv::with_client_builder [function] [call site] 02921
40 ClusterClient::builder [function] [call site] 02922
41 ClusterClientBuilder::new [function] [call site] 02923
42 &'a [call site] 02924
42 std::iter::Chain::map [function] [call site] 02925
42 ConnectionInfo::into_connection_info [function] [call site] 02926
42 collect [function] [call site] 02927
42 RedisServer::default [function] [call site] 02928
40 ClusterClientBuilder::retries [function] [call site] 02929
40 ClusterClientBuilder::read_routing_strategy [function] [call site] 02930
41 Some [function] [call site] 02931
41 RedisServer::new [function] [call site] 02932
40 respond_startup_with_replica_using_config [function] [call site] 02933
41 Option<Vec<MockSlotRange>>::unwrap_or_else [function] [call site] 02934
41 is_connection_check [function] [call site] 02935
42 contains_slice [function] [call site] 02936
43 basic::test_pipeline_len [function] [call site] 02937
44 redis::pipe [function] [call site] 02938
44 cmd [function] [call site] 02939
44 cmd [function] [call site] 02940
44 types::test_is_single_arg [function] [call site] 02941
43 starts_with [function] [call site] 02942
42 contains_slice [function] [call site] 02943
41 Err [function] [call site] 02944
41 Ok [function] [call site] 02945
41 Value::SimpleString [function] [call site] 02946
41 &str::into [function] [call site] 02947
41 contains_slice [function] [call site] 02948
41 contains_slice [function] [call site] 02949
41 &'a [call site] 02950
42 std::iter::once [function] [call site] 02951
42 chain [function] [call site] 02952
42 basic::test_tuple_decoding_from_iter [function] [call site] 02953
41 std::iter::Chain::map [function] [call site] 02954
41 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 02955
41 Value::Array [function] [call site] 02956
41 Value::Array [function] [call site] 02957
41 collect [function] [call site] 02958
41 Err [function] [call site] 02959
41 Ok [function] [call site] 02960
41 Value::Array [function] [call site] 02961
41 Ok [function] [call site] 02962
40 ClientTlsParams::clone [function] [call site] 02963
41 ClientTlsParams::clone [function] [call site] 02964
41 Pkcs1 [function] [call site] 02965
41 secret_pkcs1_der [function] [call site] 02966
41 write_command_to_vec [function] [call site] 02967
41 into [function] [call site] 02968
41 Pkcs8 [function] [call site] 02969
41 secret_pkcs8_der [function] [call site] 02970
41 write_command_to_vec [function] [call site] 02971
41 into [function] [call site] 02972
41 Sec1 [function] [call site] 02973
41 secret_sec1_der [function] [call site] 02974
41 write_command_to_vec [function] [call site] 02975
41 into [function] [call site] 02976
40 StreamReadOptions::block [function] [call site] 02977
41 Some [function] [call site] 02978
40 Self::unwrap [function] [call site] 02979
40 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 02980
40 Err [function] [call site] 02981
40 Ok [function] [call site] 02982
40 redis_value [function] [call site] 02983
41 $crate::IntoRedisValue::into_redis_value [function] [call site] 02984
40 Ok [function] [call site] 02985
40 query::<Option<()>> [function] [call site] 02986
40 StreamReadOptions::block [function] [call site] 02987
40 Self::unwrap [function] [call site] 02988
40 sort [function] [call site] 02989
39 Some [function] [call site] 02990
38 RedisResult::insert [function] [call site] 02991
39 TestContext::with_modules [function] [call site] 02992
39 MockRedisConnection::check_connection [function] [call site] 02993
39 bool::json_set [function] [call site] 02994
39 bool::json_arr_insert [function] [call site] 02995
39 bool::json_set [function] [call site] 02996
39 bool::json_arr_insert [function] [call site] 02997
38 ClientTlsParams::clone [function] [call site] 02998
39 ClientTlsParams::clone [function] [call site] 02999
39 Pkcs1 [function] [call site] 03000
39 secret_pkcs1_der [function] [call site] 03001
39 write_command_to_vec [function] [call site] 03002
39 into [function] [call site] 03003
39 Pkcs8 [function] [call site] 03004
39 secret_pkcs8_der [function] [call site] 03005
39 write_command_to_vec [function] [call site] 03006
39 into [function] [call site] 03007
39 Sec1 [function] [call site] 03008
39 secret_sec1_der [function] [call site] 03009
39 write_command_to_vec [function] [call site] 03010
39 into [function] [call site] 03011
38 Tokio::poll_write [function] [call site] 03012
38 expect [function] [call site] 03013
37 SlotMap::topology [function] [call site] 03014
38 RedisServer::new [function] [call site] 03015
38 basic::test_tuple_decoding_from_iter [function] [call site] 03016
38 Self::iter_mut [function] [call site] 03017
38 InfoDict::find [function] [call site] 03018
39 hotkeys_cluster::setup_cluster_and_target [function] [call site] 03019
38 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 03020
38 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 03021
38 ClientTlsParams::clone [function] [call site] 03022
38 ClientTlsParams::clone [function] [call site] 03023
38 ClusterTopology::from_shards [function] [call site] 03024
39 SlotRangeMap::new [function] [call site] 03025
39 RedisServer::new [function] [call site] 03026
39 cluster::test_cluster_fan_out_out_once_even_if_primary_has_multiple_slot_ranges [function] [call site] 03027
39 RedisResult::insert [function] [call site] 03028
39 ClientTlsParams::clone [function] [call site] 03029
38 &'a [call site] 03030
38 std::iter::Chain::map [function] [call site] 03031
38 Shard::new [function] [call site] 03032
39 into [function] [call site] 03033
39 into [function] [call site] 03034
38 collect [function] [call site] 03035
37 MockCmd::with_values [function] [call site] 03036
38 Cmd::into_redis_cmd_bytes [function] [call site] 03037
38 tests::into_redis_value_hashmap [function] [call site] 03038
38 &'a [call site] 03039
38 tests::into_redis_value_hashmap [function] [call site] 03040
38 String::into_redis_value [function] [call site] 03041
38 collect [function] [call site] 03042
37 Self::flatten [function] [call site] 03043
37 values().flatten().collect::<Vec<_>> [function] [call site] 03044
37 sort_unstable [function] [call site] 03045
37 dedup [function] [call site] 03046
37 borrow_mut [function] [call site] 03047
37 &'a [call site] 03048
37 std::iter::Chain::filter_map [function] [call site] 03049
37 remove [function] [call site] 03050
37 MockRedisConnection::check_connection [function] [call site] 03051
37 Some [function] [call site] 03052
37 ClientTlsParams::clone [function] [call site] 03053
37 ClusterConnection::connect [function] [call site] 03054
37 MockRedisConnection::check_connection [function] [call site] 03055
37 Some [function] [call site] 03056
37 ClientTlsParams::clone [function] [call site] 03057
37 collect [function] [call site] 03058
37 Ok [function] [call site] 03059
36 Ok [function] [call site] 03060
35 Tokio::poll_write [function] [call site] 03061
35 SlotMap::new [function] [call site] 03062
35 ClusterConnection::refresh_slots [function] [call site] 03063
36 borrow_mut [function] [call site] 03064
36 ClusterConnection::create_new_slots [function] [call site] 03065
36 RoundRobinReplicaStrategy::on_topology_changed [function] [call site] 03066
36 SlotMap::topology [function] [call site] 03067
36 MockCmd::with_values [function] [call site] 03068
36 Self::flatten [function] [call site] 03069
36 values().flatten().collect::<Vec<_>> [function] [call site] 03070
36 sort_unstable [function] [call site] 03071
36 dedup [function] [call site] 03072
36 borrow_mut [function] [call site] 03073
36 &'a [call site] 03074
36 std::iter::Chain::filter_map [function] [call site] 03075
36 remove [function] [call site] 03076
36 MockRedisConnection::check_connection [function] [call site] 03077
36 Some [function] [call site] 03078
36 ClientTlsParams::clone [function] [call site] 03079
36 ClusterConnection::connect [function] [call site] 03080
36 MockRedisConnection::check_connection [function] [call site] 03081
36 Some [function] [call site] 03082
36 ClientTlsParams::clone [function] [call site] 03083
36 collect [function] [call site] 03084
36 Ok [function] [call site] 03085
35 Ok [function] [call site] 03086
33 ProtocolVersion::supports_resp3 [function] [call site] 03087
33 MapIter::next [function] [call site] 03088
33 upgrade [function] [call site] 03089
33 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 03090
33 CmdArg::Reconnect [function] [call site] 03091
33 ClientTlsParams::clone [function] [call site] 03092
33 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 03093
33 types::test_parse_boxed [function] [call site] 03094
34 ValueComparison::arg_to_string [function] [call site] 03095
34 parse_redis_value [function] [call site] 03096
34 Value::SimpleString [function] [call site] 03097
34 ClientTlsParams::clone [function] [call site] 03098
33 xnack_tests::xnack_setup_pending [function] [call site] 03099
34 &mut [call site] 03100
34 unwrap [function] [call site] 03101
34 xadd_keyrange [function] [call site] 03102
35 &mut [call site] 03103
35 unwrap [function] [call site] 03104
34 &mut [call site] 03105
34 RedisServer::default [function] [call site] 03106
35 RedisServer::new [function] [call site] 03107
34 Self::group [function] [call site] 03108
35 TestContext::new [function] [call site] 03109
35 MockRedisConnection::check_connection [function] [call site] 03110
35 bool::xgroup_create_mkstream [function] [call site] 03111
35 bool::xgroup_destroy [function] [call site] 03112
35 xadd [function] [call site] 03113
36 &mut [call site] 03114
36 unwrap [function] [call site] 03115
36 &mut [call site] 03116
36 unwrap [function] [call site] 03117
36 &mut [call site] 03118
36 unwrap [function] [call site] 03119
36 &mut [call site] 03120
36 unwrap [function] [call site] 03121
35 bool::xgroup_create [function] [call site] 03122
36 TestContext::new [function] [call site] 03123
36 MockRedisConnection::check_connection [function] [call site] 03124
36 xadd [function] [call site] 03125
36 bool::xinfo_stream [function] [call site] 03126
36 MockRedisConnection::check_connection [function] [call site] 03127
36 bool::xinfo_stream [function] [call site] 03128
36 unwrap [function] [call site] 03129
36 bool::xgroup_create [function] [call site] 03130
36 bool::xinfo_groups [function] [call site] 03131
36 unwrap [function] [call site] 03132
35 bool::xread_options [function] [call site] 03133
35 RedisServer::default [function] [call site] 03134
35 Self::group [function] [call site] 03135
35 unwrap [function] [call site] 03136
35 unwrap [function] [call site] 03137
35 bool::xgroup_delconsumer [function] [call site] 03138
35 bool::xgroup_destroy [function] [call site] 03139
34 hotkeys::test_hotkeys_options_with_duration_and_count [function] [call site] 03140
35 run_test_if_version_supported [function] [call site] 03141
36 $crate::support::TestContext::with_modules [function] [call site] 03142
35 hotkeys::setup_connection_with_protocol [function] [call site] 03143
36 RedisServer::connection_info [function] [call site] 03144
37 RedisServer::client_addr [function] [call site] 03145
37 &redis::ConnectionAddr::clone [function] [call site] 03146
37 ConnectionInfo::into_connection_info [function] [call site] 03147
37 RedisResult::unwrap [function] [call site] 03148
37 ConnectionInfo::set_redis_settings [function] [call site] 03149
37 redis_settings [function] [call site] 03150
36 ConnectionInfo::set_redis_settings [function] [call site] 03151
36 RedisServer::default [function] [call site] 03152
36 RedisConnectionInfo::set_protocol [function] [call site] 03153
36 redis::Client::open [function] [call site] 03154
36 RedisResult::unwrap [function] [call site] 03155
36 Client::get_connection [function] [call site] 03156
36 RedisResult::unwrap [function] [call site] 03157
35 redis::Connection::hotkeys_start [function] [call site] 03158
36 cmd::cmd [function] [call site] 03159
36 Cmd::arg [function] [call site] 03160
36 types::test_is_single_arg [function] [call site] 03161
36 basic::test_pipeline_reuse_query [function] [call site] 03162
35 HotkeysOptions::new_with_cpu [function] [call site] 03163
35 HotkeysOptions::with_count [function] [call site] 03164
36 contains [function] [call site] 03165
36 Err [function] [call site] 03166
36 Some [function] [call site] 03167
36 Ok [function] [call site] 03168
35 Result::unwrap [function] [call site] 03169
35 HotkeysOptions::with_duration_secs [function] [call site] 03170
36 Some [function] [call site] 03171
35 RedisResult::unwrap [function] [call site] 03172
35 hotkeys::setup_test_keys_and_make_hot_keys [function] [call site] 03173
36 basic::test_tuple_decoding_from_iter [function] [call site] 03174
36 enumerate [function] [call site] 03175
36 &mut [call site] 03176
37 ComponentMatcher::from [function] [call site] 03177
37 String::into_redis_value [function] [call site] 03178
37 Value::into_sequence [function] [call site] 03179
37 Result::expect [function] [call site] 03180
37 sort_by [function] [call site] 03181
37 cmp [function] [call site] 03182
36 unwrap [function] [call site] 03183
36 &mut [call site] 03184
37 TestClusterContext::new [function] [call site] 03185
37 TestSentinelContext::wait_for_cluster_up [function] [call site] 03186
37 RedisCluster::iter_servers [function] [call site] 03187
37 MapIter::next [function] [call site] 03188
37 unwrap [function] [call site] 03189
37 RedisServer::connection_info [function] [call site] 03190
37 hotkeys_cluster::port_of [function] [call site] 03191
37 redis::ConnectionInfo::addr [function] [call site] 03192
37 hotkeys_cluster::direct_connection [function] [call site] 03193
37 redis::ConnectionInfo::clone [function] [call site] 03194
37 skip_if_context_does_not_support [function] [call site] 03195
37 hotkeys_cluster::first_owned_slot_range [function] [call site] 03196
37 hotkeys_cluster::find_key_in_range [function] [call site] 03197
37 Some [function] [call site] 03198
36 Option::unwrap [function] [call site] 03199
35 redis::Connection::hotkeys_get [function] [call site] 03200
36 cmd::cmd [function] [call site] 03201
36 Cmd::arg [function] [call site] 03202
36 basic::test_pipeline_reuse_query [function] [call site] 03203
35 RedisResult::unwrap [function] [call site] 03204
35 unwrap [function] [call site] 03205
35 Runtime::sleep [function] [call site] 03206
35 Duration::from_secs [function] [call site] 03207
35 redis::Connection::hotkeys_get [function] [call site] 03208
35 RedisResult::unwrap [function] [call site] 03209
35 unwrap [function] [call site] 03210
34 unwrap [function] [call site] 03211
34 unwrap [function] [call site] 03212
34 basic::test_tuple_decoding_from_iter [function] [call site] 03213
34 tests::into_redis_value_hashmap [function] [call site] 03214
34 ClientTlsParams::clone [function] [call site] 03215
34 collect [function] [call site] 03216
33 types::test_parse_boxed [function] [call site] 03217
34 ValueComparison::arg_to_string [function] [call site] 03218
34 parse_redis_value [function] [call site] 03219
34 Value::SimpleString [function] [call site] 03220
34 ClientTlsParams::clone [function] [call site] 03221
33 oneshot::channel::<RedisResult<()>> [function] [call site] 03222
33 ClusterConnInner::wait_for_initial_connection [function] [call site] 03223
34 std::mem::replace [function] [call site] 03224
34 Ok [function] [call site] 03225
33 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 03226
33 inspect_err [function] [call site] 03227
33 stream::poll_fn [function] [call site] 03228
33 ( [call site] 03229
4 PendingRequest::poll_recv [function] [call site] 03230
33 tests::into_redis_value_hashmap [function] [call site] 03231
33 forward [function] [call site] 03232
33 HandleContainer::new [function] [call site] 03233
33 tokio::runtime::Runtime::spawn [function] [call site] 03234
34 crate_tokio::Tokio::spawn [function] [call site] 03235
35 TaskHandle::Tokio [function] [call site] 03236
35 tokio::spawn [function] [call site] 03237
36 tokio::runtime::Handle::try_current [function] [call site] 03238
36 spawn [function] [call site] 03239
36 smol::spawn [function] [call site] 03240
36 TaskHandle::detach [function] [call site] 03241
34 crate_smol::Smol::spawn [function] [call site] 03242
35 TaskHandle::Smol [function] [call site] 03243
35 smol::spawn [function] [call site] 03244
33 futures_util:: [call site] 03245
0 future::select [function] [call site] 03246
34 Ok [function] [call site] 03247
34 ServerError::details [function] [call site] 03248
34 Err [function] [call site] 03249
34 into [function] [call site] 03250
34 ValueComparison::arg_to_string [function] [call site] 03251
34 into [function] [call site] 03252
34 Err [function] [call site] 03253
34 into [function] [call site] 03254
34 into [function] [call site] 03255
33 RedisServer::new [function] [call site] 03256
32 map_err [function] [call site] 03257
32 RedisError::from [function] [call site] 03258
32 Ok [function] [call site] 03259
31 ClientTlsParams::clone [function] [call site] 03260
31 ClientTlsParams::clone [function] [call site] 03261
30 RedisResult::unwrap [function] [call site] 03262
30 tokio::runtime::Runtime::block_on [function] [call site] 03263
30 ClusterClient::get_async_generic_connection [function] [call site] 03264
31 cluster_async::ClusterConnection::new [function] [call site] 03265
32 ClusterConnection::new_inner [function] [call site] 03266
32 map_err [function] [call site] 03267
32 RedisError::from [function] [call site] 03268
32 Ok [function] [call site] 03269
31 ClientTlsParams::clone [function] [call site] 03270
30 unwrap [function] [call site] 03271
30 RemoveHandler [function] [call site] 03272
29 ClusterClient::builder [function] [call site] 03273
29 ClusterClientBuilder::retries [function] [call site] 03274
29 respond_startup [function] [call site] 03275
30 is_connection_check [function] [call site] 03276
30 Err [function] [call site] 03277
30 Ok [function] [call site] 03278
30 Value::SimpleString [function] [call site] 03279
30 &str::into [function] [call site] 03280
30 contains_slice [function] [call site] 03281
30 contains_slice [function] [call site] 03282
30 Err [function] [call site] 03283
30 Ok [function] [call site] 03284
30 Value::Array [function] [call site] 03285
30 Ok [function] [call site] 03286
29 fetch_add [function] [call site] 03287
29 Err [function] [call site] 03288
29 parse_redis_value [function] [call site] 03289
29 Err [function] [call site] 03290
29 Ok [function] [call site] 03291
29 redis_value [function] [call site] 03292
29 cmd [function] [call site] 03293
29 Cmd::arg [function] [call site] 03294
29 arg("test").query::<Option<i32>> [function] [call site] 03295
28 TestClusterContext::get_ports [function] [call site] 03296
28 MockRedisConnection::check_connection [function] [call site] 03297
28 RedisServer::drop [function] [call site] 03298
28 RedisCluster::new [function] [call site] 03299
28 RedisServer::default [function] [call site] 03300
28 cmd [function] [call site] 03301
28 ClusterConnection::route_command [function] [call site] 03302
28 RoutingInfo::MultiNode [function] [call site] 03303
28 Some [function] [call site] 03304
28 RedisResult::unwrap [function] [call site] 03305
27 redis::ConnectionInfo::redis_settings [function] [call site] 03306
27 resize_with [function] [call site] 03307
27 basic::test_pipeline_len [function] [call site] 03308
28 redis::pipe [function] [call site] 03309
28 cmd [function] [call site] 03310
28 cmd [function] [call site] 03311
28 types::test_is_single_arg [function] [call site] 03312
27 resize_with [function] [call site] 03313
27 basic::test_pipeline_len [function] [call site] 03314
27 Ok [function] [call site] 03315
27 random_replica_index [function] [call site] 03316
28 rand::rng [function] [call site] 03317
28 random_range [function] [call site] 03318
28 into [function] [call site] 03319
27 RedisServer::new [function] [call site] 03320
27 Self::unwrap [function] [call site] 03321
27 resize_with [function] [call site] 03322
27 basic::test_pipeline_len [function] [call site] 03323
27 Ok [function] [call site] 03324
27 random_replica_index [function] [call site] 03325
27 RedisServer::new [function] [call site] 03326
27 Self::unwrap [function] [call site] 03327
27 Ok [function] [call site] 03328
27 random_replica_index [function] [call site] 03329
27 RedisServer::new [function] [call site] 03330
27 Self::unwrap [function] [call site] 03331
27 Ok [function] [call site] 03332
27 random_replica_index [function] [call site] 03333
27 RedisServer::new [function] [call site] 03334
27 Self::unwrap [function] [call site] 03335
25 ClientTlsParams::clone [function] [call site] 03336
25 unwrap [function] [call site] 03337
25 TestSentinelContext::wait_for_cluster_up [function] [call site] 03338
26 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03339
26 TestSentinelContext::sentinel_mut [function] [call site] 03340
26 redis_test::sentinel::wait_for_master_server [function] [call site] 03341
26 &mut [call site] 03342
26 Some [function] [call site] 03343
26 ConnectionAddr::is_err [function] [call site] 03344
26 redis_test::sentinel::wait_for_replica [function] [call site] 03345
26 &mut [call site] 03346
26 Some [function] [call site] 03347
26 ConnectionAddr::is_err [function] [call site] 03348
23 SentinelClient::build [function] [call site] 03349
23 TestSentinelContext::sentinels_connection_info [function] [call site] 03350
23 ClientTlsParams::clone [function] [call site] 03351
23 String::from [function] [call site] 03352
23 Some [function] [call site] 03353
23 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03354
23 RedisResult::unwrap [function] [call site] 03355
23 SentinelClient::build [function] [call site] 03356
23 TestSentinelContext::sentinels_connection_info [function] [call site] 03357
23 ClientTlsParams::clone [function] [call site] 03358
23 String::from [function] [call site] 03359
23 Some [function] [call site] 03360
23 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03361
23 RedisResult::unwrap [function] [call site] 03362
23 AsyncConnectionConfig::new [function] [call site] 03363
23 AsyncConnectionConfig::set_connection_timeout [function] [call site] 03364
23 Some [function] [call site] 03365
23 Duration::from_secs [function] [call site] 03366
23 SentinelClient::get_async_connection_with_config [function] [call site] 03367
23 unwrap [function] [call site] 03368
23 async_tests::async_assert_is_connection_to_master [function] [call site] 03369
23 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03370
23 TestSentinelContext::sentinel_mut [function] [call site] 03371
23 Sentinel::async_master_for [function] [call site] 03372
23 Some [function] [call site] 03373
23 unwrap [function] [call site] 03374
23 SentinelClient::get_async_connection_with_config [function] [call site] 03375
23 unwrap [function] [call site] 03376
23 async_tests::async_assert_connection_is_replica_of_correct_master [function] [call site] 03377
22 Err [function] [call site] 03378
22 Some [function] [call site] 03379
22 into [function] [call site] 03380
22 map_err [function] [call site] 03381
22 unwrap_or_else [function] [call site] 03382
21 unwrap [function] [call site] 03383
20 Some [function] [call site] 03384
20 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 03385
20 ClusterType::build_addr [function] [call site] 03386
21 ServerType::get_intended [function] [call site] 03387
22 entra_id_tests::get_env_var [function] [call site] 03388
22 tests::redis_ok [function] [call site] 03389
22 as_ref [function] [call site] 03390
22 tests::into_redis_value_hashmap [function] [call site] 03391
21 redis::ConnectionAddr::Tcp [function] [call site] 03392
21 &str::into [function] [call site] 03393
21 &str::into [function] [call site] 03394
20 ClientTlsParams::clone [function] [call site] 03395
21 ClientTlsParams::clone [function] [call site] 03396
21 Pkcs1 [function] [call site] 03397
21 secret_pkcs1_der [function] [call site] 03398
21 write_command_to_vec [function] [call site] 03399
21 into [function] [call site] 03400
21 Pkcs8 [function] [call site] 03401
21 secret_pkcs8_der [function] [call site] 03402
21 write_command_to_vec [function] [call site] 03403
21 into [function] [call site] 03404
21 Sec1 [function] [call site] 03405
21 secret_sec1_der [function] [call site] 03406
21 write_command_to_vec [function] [call site] 03407
21 into [function] [call site] 03408
20 tempfile::Builder::new [function] [call site] 03409
20 RedisResult::prefix [function] [call site] 03410
20 tempdir [function] [call site] 03411
20 expect [function] [call site] 03412
20 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03413
21 cmd [function] [call site] 03414
21 Cmd::arg [function] [call site] 03415
21 types::test_is_single_arg [function] [call site] 03416
21 types::test_is_single_arg [function] [call site] 03417
21 types::test_is_single_arg [function] [call site] 03418
21 types::test_is_single_arg [function] [call site] 03419
21 RoutingInfo::for_routable [function] [call site] 03420
22 MockRedisConnection::req_packed_command [function] [call site] 03421
23 Cmd::get_packed_command [function] [call site] 03422
23 MockRedisConnection::req_packed_command [function] [call site] 03423
23 as_slice [function] [call site] 03424
23 PipelineSink::poll_ready [function] [call site] 03425
23 types::test_parse_boxed [function] [call site] 03426
22 base_routing [function] [call site] 03427
23 RouteBy::MultiShard [function] [call site] 03428
23 RouteBy::MultiShard [function] [call site] 03429
23 RouteBy::MultiShard [function] [call site] 03430
23 RouteBy::MultiShard [function] [call site] 03431
22 Some [function] [call site] 03432
22 Self::MultiNode [function] [call site] 03433
22 ResponsePolicy::for_command [function] [call site] 03434
23 Some [function] [call site] 03435
23 Self::AggregateLogical [function] [call site] 03436
23 Some [function] [call site] 03437
23 Self::Aggregate [function] [call site] 03438
23 Some [function] [call site] 03439
23 Self::Aggregate [function] [call site] 03440
23 Some [function] [call site] 03441
23 Some [function] [call site] 03442
23 Some [function] [call site] 03443
23 Some [function] [call site] 03444
23 Some [function] [call site] 03445
23 Some [function] [call site] 03446
22 Some [function] [call site] 03447
22 Self::MultiNode [function] [call site] 03448
22 ResponsePolicy::for_command [function] [call site] 03449
22 multi_shard [function] [call site] 03450
23 commands::is_readonly_cmd [function] [call site] 03451
23 RedisServer::new [function] [call site] 03452
24 RedisServer::with_modules [function] [call site] 03453
23 Cmd::arg_idx [function] [call site] 03454
24 Cmd::arg_idx [function] [call site] 03455
25 Cmd::arg_idx [function] [call site] 03456
23 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 03457
23 Some [function] [call site] 03458
23 Cmd::arg_idx [function] [call site] 03459
23 get_route [function] [call site] 03460
24 Route::with_key [function] [call site] 03461
25 Route::with_slot [function] [call site] 03462
26 Self [function] [call site] 03463
25 Slot::for_key [function] [call site] 03464
26 S::l::o::t::::::::f::o::r::_::k::e::y::impl_ [function] [call site] 03465
27 Slot [function] [call site] 03466
27 crc16::State::<crc16::XMODEM>::calculate [function] [call site] 03467
27 get_hashtag [function] [call site] 03468
28 basic::test_tuple_decoding_from_iter [function] [call site] 03469
28 Cmd::position [function] [call site] 03470
29 Cmd::args_iter [function] [call site] 03471
29 Cmd::position [function] [call site] 03472
30 Cmd::args_iter [function] [call site] 03473
30 Cmd::position [function] [call site] 03474
30 Self::eq_ignore_ascii_case [function] [call site] 03475
29 Self::eq_ignore_ascii_case [function] [call site] 03476
28 basic::test_tuple_decoding_from_iter [function] [call site] 03477
28 Cmd::position [function] [call site] 03478
28 MockRedisConnection::is_empty [function] [call site] 03479
28 then_some [function] [call site] 03480
27 Option::unwrap_or [function] [call site] 03481
26 as_ref [function] [call site] 03482
24 Route::with_key [function] [call site] 03483
23 tests::redis_array_single_entry [function] [call site] 03484
24 redis_value [function] [call site] 03485
24 Value::Array [function] [call site] 03486
23 or_insert [function] [call site] 03487
23 RedisServer::new [function] [call site] 03488
23 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 03489
23 incr_add_next_arg [function] [call site] 03490
23 Cmd::arg_idx [function] [call site] 03491
23 Option::is_none [function] [call site] 03492
23 Self::values_mut [function] [call site] 03493
23 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 03494
23 incr_add_next_arg [function] [call site] 03495
23 incr_add_next_arg [function] [call site] 03496
23 &'a [call site] 03497
23 std::iter::Chain::collect [function] [call site] 03498
23 MockRedisConnection::is_empty [function] [call site] 03499
23 Some [function] [call site] 03500
23 basic::test_pipeline_len [function] [call site] 03501
24 redis::pipe [function] [call site] 03502
24 cmd [function] [call site] 03503
24 cmd [function] [call site] 03504
24 types::test_is_single_arg [function] [call site] 03505
23 RoutingInfo::SingleNode [function] [call site] 03506
23 SingleNodeRoutingInfo::SpecificNode [function] [call site] 03507
23 Self::pop [function] [call site] 03508
24 TestContext::with_modules [function] [call site] 03509
24 MockRedisConnection::check_connection [function] [call site] 03510
24 bool::json_set [function] [call site] 03511
24 bool::json_arr_pop [function] [call site] 03512
24 bool::json_set [function] [call site] 03513
24 bool::json_arr_pop [function] [call site] 03514
23 unwrap [function] [call site] 03515
23 RoutingInfo::MultiNode [function] [call site] 03516
23 MultipleNodeRoutingInfo::MultiSlot [function] [call site] 03517
23 ResponsePolicy::for_command [function] [call site] 03518
22 Some [function] [call site] 03519
22 Self::SingleNode [function] [call site] 03520
22 Cmd::arg_idx [function] [call site] 03521
23 Cmd::arg_idx [function] [call site] 03522
22 Option::and_then [function] [call site] 03523
22 std::str::from_utf8 [function] [call site] 03524
22 tests::redis_ok [function] [call site] 03525
22 and_then [function] [call site] 03526
22 parse::<u64> [function] [call site] 03527
22 tests::redis_ok [function] [call site] 03528
22 Some [function] [call site] 03529
22 Self::SingleNode [function] [call site] 03530
22 Cmd::arg_idx [function] [call site] 03531
22 tests::into_redis_value_hashmap [function] [call site] 03532
22 RoutingInfo::for_key [function] [call site] 03533
23 Self::SingleNode [function] [call site] 03534
23 SingleNodeRoutingInfo::SpecificNode [function] [call site] 03535
23 get_route [function] [call site] 03536
23 commands::is_readonly_cmd [function] [call site] 03537
22 Cmd::arg_idx [function] [call site] 03538
22 tests::into_redis_value_hashmap [function] [call site] 03539
22 RoutingInfo::for_key [function] [call site] 03540
22 Cmd::arg_idx [function] [call site] 03541
22 Option::and_then [function] [call site] 03542
22 std::str::from_utf8 [function] [call site] 03543
22 tests::redis_ok [function] [call site] 03544
22 and_then [function] [call site] 03545
22 parse::<u64> [function] [call site] 03546
22 tests::redis_ok [function] [call site] 03547
22 Some [function] [call site] 03548
22 Self::SingleNode [function] [call site] 03549
22 Cmd::arg_idx [function] [call site] 03550
22 tests::into_redis_value_hashmap [function] [call site] 03551
22 RoutingInfo::for_key [function] [call site] 03552
22 Cmd::position [function] [call site] 03553
23 Cmd::args_iter [function] [call site] 03554
23 Cmd::position [function] [call site] 03555
23 Self::eq_ignore_ascii_case [function] [call site] 03556
22 Cmd::arg_idx [function] [call site] 03557
22 tests::into_redis_value_hashmap [function] [call site] 03558
22 RoutingInfo::for_key [function] [call site] 03559
22 Cmd::arg_idx [function] [call site] 03560
22 Option::and_then [function] [call site] 03561
22 std::str::from_utf8 [function] [call site] 03562
22 tests::redis_ok [function] [call site] 03563
22 and_then [function] [call site] 03564
22 parse::<u16> [function] [call site] 03565
22 tests::redis_ok [function] [call site] 03566
22 and_then [function] [call site] 03567
22 tests::into_redis_value_hashmap [function] [call site] 03568
22 Self::SingleNode [function] [call site] 03569
22 SingleNodeRoutingInfo::SpecificNode [function] [call site] 03570
22 Route::with_slot [function] [call site] 03571
23 Self [function] [call site] 03572
22 Cmd::arg_idx [function] [call site] 03573
22 Some [function] [call site] 03574
22 RoutingInfo::for_key [function] [call site] 03575
22 Some [function] [call site] 03576
22 Self::SingleNode [function] [call site] 03577
21 std::collections::HashMap::new [function] [call site] 03578
22 RedisServer::with_modules [function] [call site] 03579
21 Self::insert [function] [call site] 03580
21 Route [function] [call site] 03581
21 Self::insert [function] [call site] 03582
21 Route [function] [call site] 03583
21 Self::insert [function] [call site] 03584
21 Route [function] [call site] 03585
20 join [function] [call site] 03586
20 std::fs::write [function] [call site] 03587
21 RedisServer::new [function] [call site] 03588
21 Tokio::poll_write [function] [call site] 03589
21 RedisServer::new [function] [call site] 03590
21 Tokio::poll_write [function] [call site] 03591
21 RedisServer::new [function] [call site] 03592
21 Tokio::poll_write [function] [call site] 03593
20 Poll::expect [function] [call site] 03594
20 Cmd::arg [function] [call site] 03595
20 types::test_is_single_arg [function] [call site] 03596
20 types::test_is_single_arg [function] [call site] 03597
20 types::test_is_single_arg [function] [call site] 03598
20 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03599
20 join [function] [call site] 03600
20 types::test_is_single_arg [function] [call site] 03601
20 types::test_is_single_arg [function] [call site] 03602
20 types::test_is_single_arg [function] [call site] 03603
20 types::test_is_single_arg [function] [call site] 03604
20 Cmd::arg [function] [call site] 03605
20 types::test_is_single_arg [function] [call site] 03606
20 ValueComparison::arg_to_string [function] [call site] 03607
20 Cmd::arg [function] [call site] 03608
20 types::test_is_single_arg [function] [call site] 03609
20 Cmd::arg [function] [call site] 03610
20 types::test_is_single_arg [function] [call site] 03611
20 Cmd::current_dir [function] [call site] 03612
20 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03613
20 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 03614
20 Cmd::spawn [function] [call site] 03615
20 unwrap [function] [call site] 03616
20 ClusterClientBuilder::max_retry_wait [function] [call site] 03617
20 RedisServer::log_file_contents [function] [call site] 03618
21 std::fs::read_to_string [function] [call site] 03619
21 ClientTlsParams::clone [function] [call site] 03620
21 tests::redis_ok [function] [call site] 03621
20 Err [function] [call site] 03622
20 RedisServer::log_file_contents [function] [call site] 03623
20 Err [function] [call site] 03624
20 port_in_use [function] [call site] 03625
21 ConnectionAddr::parse [function] [call site] 03626
21 expect [function] [call site] 03627
21 socket2::Socket::new [function] [call site] 03628
22 RedisServer::with_modules [function] [call site] 03629
21 socket2::Domain::for_address [function] [call site] 03630
21 Self::expect [function] [call site] 03631
21 connect [function] [call site] 03632
21 into [function] [call site] 03633
21 tests::redis_ok [function] [call site] 03634
20 ValueComparison::arg_to_string [function] [call site] 03635
20 Ok [function] [call site] 03636
20 std::thread::sleep [function] [call site] 03637
20 Duration::from_millis [function] [call site] 03638
20 &'a [call site] 03639
20 tests::into_redis_value_hashmap [function] [call site] 03640
20 get_random_available_port [function] [call site] 03641
21 get_listener_on_free_port [function] [call site] 03642
21 TcpListener::local_addr [function] [call site] 03643
21 unwrap [function] [call site] 03644
21 get_listener_on_free_port [function] [call site] 03645
20 Self::contains [function] [call site] 03646
20 Self::insert [function] [call site] 03647
20 make_server [function] [call site] 03648
20 std::thread::sleep [function] [call site] 03649
20 Duration::from_millis [function] [call site] 03650
20 verify_server [function] [call site] 03651
20 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 03652
21 TestContext::new [function] [call site] 03653
21 ProtocolVersion::supports_resp3 [function] [call site] 03654
21 tokio::sync::mpsc::unbounded_channel [function] [call site] 03655
21 redis::aio::ConnectionManagerConfig::new [function] [call site] 03656
21 AsyncConnectionConfig::set_push_sender [function] [call site] 03657
21 Client::get_connection_manager_lazy [function] [call site] 03658
21 unwrap [function] [call site] 03659
21 tests::into_redis_value_hashset [function] [call site] 03660
21 unwrap [function] [call site] 03661
21 MockConnection::send_packed_command [function] [call site] 03662
21 cmd [function] [call site] 03663
21 Cmd::arg [function] [call site] 03664
21 types::test_is_single_arg [function] [call site] 03665
21 unwrap [function] [call site] 03666
21 hotkeys_cluster::setup_cluster_and_target [function] [call site] 03667
21 unwrap [function] [call site] 03668
21 tests::into_redis_value_hashset [function] [call site] 03669
21 unwrap [function] [call site] 03670
21 Pipeline::send_recv [function] [call site] 03671
21 unwrap [function] [call site] 03672
20 collect [function] [call site] 03673
20 process::Command::new [function] [call site] 03674
20 Cmd::stdout [function] [call site] 03675
20 process::Stdio::piped [function] [call site] 03676
20 types::test_is_single_arg [function] [call site] 03677
20 types::test_is_single_arg [function] [call site] 03678
20 types::test_std_types_to_redis_args [function] [call site] 03679
20 Cmd::arg [function] [call site] 03680
20 types::test_is_single_arg [function] [call site] 03681
20 ValueComparison::arg_to_string [function] [call site] 03682
20 Cmd::arg [function] [call site] 03683
20 Cmd::arg [function] [call site] 03684
20 Cmd::arg [function] [call site] 03685
20 Cmd::arg [function] [call site] 03686
20 Cmd::arg [function] [call site] 03687
20 Cmd::arg [function] [call site] 03688
20 Cmd::arg [function] [call site] 03689
20 Cmd::arg [function] [call site] 03690
20 None::is_some [function] [call site] 03691
20 None::as_ref [function] [call site] 03692
20 unwrap [function] [call site] 03693
20 Cmd::arg [function] [call site] 03694
20 types::test_is_single_arg [function] [call site] 03695
20 types::test_is_single_arg [function] [call site] 03696
20 Cmd::arg [function] [call site] 03697
20 types::test_is_single_arg [function] [call site] 03698
20 Cmd::output [function] [call site] 03699
20 unwrap [function] [call site] 03700
20 test_get_replica_clients_success [function] [call site] 03701
21 TestSentinelContext::new [function] [call site] 03702
21 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03703
21 TestSentinelContext::sentinel_mut [function] [call site] 03704
21 Sentinel::get_replica_clients [function] [call site] 03705
22 Sentinel::find_valid_replica_addresses [function] [call site] 03706
22 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 03707
22 build_replica_clients [function] [call site] 03708
23 MockRedisConnection::is_empty [function] [call site] 03709
23 fail [function] [call site] 03710
23 basic::test_tuple_decoding_from_iter [function] [call site] 03711
23 tests::into_redis_value_hashmap [function] [call site] 03712
23 Client::open [function] [call site] 03713
23 ClientTlsParams::clone [function] [call site] 03714
23 collect [function] [call site] 03715
21 Some [function] [call site] 03716
21 RedisResult::unwrap [function] [call site] 03717
20 std::thread::sleep [function] [call site] 03718
20 Duration::from_millis [function] [call site] 03719
20 RedisCluster::wait_for_replicas [function] [call site] 03720
21 RedisServer::connection_info [function] [call site] 03721
21 redis::Client::open [function] [call site] 03722
21 RedisServer::connection_info [function] [call site] 03723
21 RedisResult::unwrap [function] [call site] 03724
21 Client::get_connection [function] [call site] 03725
21 RedisResult::unwrap [function] [call site] 03726
21 redis::cmd [function] [call site] 03727
21 redis::Cmd::arg [function] [call site] 03728
21 basic::test_pipeline_reuse_query [function] [call site] 03729
21 unwrap [function] [call site] 03730
21 RedisResult::from_redis_value [function] [call site] 03731
22 Ok [function] [call site] 03732
22 Err [function] [call site] 03733
22 into [function] [call site] 03734
22 from_redis_value [function] [call site] 03735
22 tests::into_redis_value_hashmap [function] [call site] 03736
22 Ok [function] [call site] 03737
21 Result::unwrap [function] [call site] 03738
21 basic::test_tuple_decoding_from_iter [function] [call site] 03739
21 block_on_all [function] [call site] 03740
22 panic::set_hook [function] [call site] 03741
22 RedisServer::new [function] [call site] 03742
22 RadiusOptions::store [function] [call site] 03743
23 Some [function] [call site] 03744
23 ToRedisArgs::to_redis_args [function] [call site] 03745
24 RedisServer::new [function] [call site] 03746
24 SetExpiry::write_redis_args [function] [call site] 03747
25 ::itoa::Buffer::new [function] [call site] 03748
25 Vec::write_arg [function] [call site] 03749
25 Vec::write_arg [function] [call site] 03750
25 Self::format [function] [call site] 03751
25 as_bytes [function] [call site] 03752
25 Vec::write_arg [function] [call site] 03753
25 Vec::write_arg [function] [call site] 03754
25 Self::format [function] [call site] 03755
25 as_bytes [function] [call site] 03756
25 Vec::write_arg [function] [call site] 03757
25 Vec::write_arg [function] [call site] 03758
25 Self::format [function] [call site] 03759
25 as_bytes [function] [call site] 03760
25 Vec::write_arg [function] [call site] 03761
25 Vec::write_arg [function] [call site] 03762
25 Self::format [function] [call site] 03763
25 as_bytes [function] [call site] 03764
25 Vec::write_arg [function] [call site] 03765
22 futures_util::FutureExt::fuse [function] [call site] 03766
22 load [function] [call site] 03767
23 &mut [call site] 03768
23 Ok [function] [call site] 03769
22 futures_time::task::sleep [function] [call site] 03770
23 tokio::time::sleep [function] [call site] 03771
23 smol::Timer::after [function] [call site] 03772
22 futures_time::time::Duration::from_millis [function] [call site] 03773
22 futures_util::FutureExt::fuse [function] [call site] 03774
22 block_on_all_using_tokio [function] [call site] 03775
23 redis::aio::prefer_tokio [function] [call site] 03776
24 set_runtime [function] [call site] 03777
25 tests::into_redis_value_hashset [function] [call site] 03778
25 map_err [function] [call site] 03779
25 RedisError::from [function] [call site] 03780
23 Result::unwrap [function] [call site] 03781
23 current_thread_runtime [function] [call site] 03782
24 tokio::runtime::Builder::new_current_thread [function] [call site] 03783
24 enable_io [function] [call site] 03784
24 enable_time [function] [call site] 03785
24 Sentinel::build [function] [call site] 03786
24 RedisResult::unwrap [function] [call site] 03787
23 tokio::runtime::Runtime::block_on [function] [call site] 03788
22 block_on_all_using_smol [function] [call site] 03789
23 redis::aio::prefer_smol [function] [call site] 03790
24 set_runtime [function] [call site] 03791
23 Result::unwrap [function] [call site] 03792
23 smol::block_on [function] [call site] 03793
22 panic::take_hook [function] [call site] 03794
22 swap [function] [call site] 03795
22 unwrap [function] [call site] 03796
21 basic::test_pipeline_len [function] [call site] 03797
21 std::thread::sleep [function] [call site] 03798
21 Duration::from_millis [function] [call site] 03799
20 wait_for_status_ok [function] [call site] 03800
21 RedisServer::log_file [function] [call site] 03801
22 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03802
22 join [function] [call site] 03803
21 std::fs::read_to_string [function] [call site] 03804
21 expect [function] [call site] 03805
21 Option::contains [function] [call site] 03806
21 std::thread::sleep [function] [call site] 03807
21 Duration::from_millis [function] [call site] 03808
19 RedisCluster::iter_servers [function] [call site] 03809
19 tests::into_redis_value_hashmap [function] [call site] 03810
19 collect [function] [call site] 03811
19 redis::cluster::ClusterClientBuilder::new [function] [call site] 03812
19 ClientTlsParams::clone [function] [call site] 03813
19 Self::use_protocol [function] [call site] 03814
19 redis_test::server::use_protocol [function] [call site] 03815
19 ClusterType::get_intended [function] [call site] 03816
19 ClusterClientBuilder::certs [function] [call site] 03817
19 super::load_certs_from_file [function] [call site] 03818
19 initializer [function] [call site] 03819
19 Sentinel::build [function] [call site] 03820
19 RedisResult::unwrap [function] [call site] 03821
19 redis_test::server::use_protocol [function] [call site] 03822
17 RedisServer::default [function] [call site] 03823
16 TestSentinelContext::wait_for_cluster_up [function] [call site] 03824
16 RedisCluster::iter_servers [function] [call site] 03825
16 MapIter::next [function] [call site] 03826
16 unwrap [function] [call site] 03827
16 RedisServer::connection_info [function] [call site] 03828
16 hotkeys_cluster::port_of [function] [call site] 03829
16 redis::ConnectionInfo::addr [function] [call site] 03830
16 hotkeys_cluster::direct_connection [function] [call site] 03831
16 redis::ConnectionInfo::clone [function] [call site] 03832
16 skip_if_context_does_not_support [function] [call site] 03833
16 hotkeys_cluster::first_owned_slot_range [function] [call site] 03834
16 hotkeys_cluster::find_key_in_range [function] [call site] 03835
16 Some [function] [call site] 03836
14 is_none [function] [call site] 03837
14 Err [function] [call site] 03838
14 into [function] [call site] 03839
14 RedisServer::default [function] [call site] 03840
15 RedisServer::new [function] [call site] 03841
14 Self::with_factor [function] [call site] 03842
14 with_min_delay [function] [call site] 03843
14 with_max_times [function] [call site] 03844
14 with_jitter [function] [call site] 03845
14 with_max_delay [function] [call site] 03846
14 AsyncConnectionConfig::new [function] [call site] 03847
14 AsyncConnectionConfig::set_connection_timeout [function] [call site] 03848
14 AsyncConnectionConfig::set_response_timeout [function] [call site] 03849
14 as_ref [function] [call site] 03850
14 tests::into_redis_value_hashmap [function] [call site] 03851
14 CacheManager::new [function] [call site] 03852
15 RedisServer::new [function] [call site] 03853
15 ShardedLRU::new [function] [call site] 03854
16 hotkeys_cluster::setup_cluster_and_target [function] [call site] 03855
17 TestClusterContext::new [function] [call site] 03856
17 TestSentinelContext::wait_for_cluster_up [function] [call site] 03857
17 RedisCluster::iter_servers [function] [call site] 03858
17 MapIter::next [function] [call site] 03859
17 unwrap [function] [call site] 03860
17 RedisServer::connection_info [function] [call site] 03861
17 hotkeys_cluster::port_of [function] [call site] 03862
17 redis::ConnectionInfo::addr [function] [call site] 03863
17 hotkeys_cluster::direct_connection [function] [call site] 03864
17 redis::ConnectionInfo::clone [function] [call site] 03865
17 skip_if_context_does_not_support [function] [call site] 03866
17 hotkeys_cluster::first_owned_slot_range [function] [call site] 03867
17 hotkeys_cluster::find_key_in_range [function] [call site] 03868
17 Some [function] [call site] 03869
16 hotkeys_cluster::setup_cluster_and_target [function] [call site] 03870
16 hotkeys_cluster::setup_cluster_and_target [function] [call site] 03871
16 Cmd::with_capacity [function] [call site] 03872
16 RedisServer::new [function] [call site] 03873
17 RedisServer::with_modules [function] [call site] 03874
16 RedisServer::new [function] [call site] 03875
16 Self::unwrap [function] [call site] 03876
16 basic_async::test_lazy_connection_manager_with_resp3_push [function] [call site] 03877
16 std::sync::Mutex::new [function] [call site] 03878
16 RedisServer::new [function] [call site] 03879
16 RedisServer::default [function] [call site] 03880
17 RedisServer::new [function] [call site] 03881
16 RedisServer::new [function] [call site] 03882
15 CacheManager::clone_and_increase_epoch [function] [call site] 03883
16 ClientTlsParams::clone [function] [call site] 03884
16 CacheManager::clone_and_increase_epoch [function] [call site] 03885
17 ClientTlsParams::clone [function] [call site] 03886
17 CacheManager::clone_and_increase_epoch [function] [call site] 03887
14 Self::as_ref [function] [call site] 03888
14 AsyncConnectionConfig::set_cache_manager [function] [call site] 03889
15 Some [function] [call site] 03890
15 Cache::Manager [function] [call site] 03891
14 ClientTlsParams::clone [function] [call site] 03892
14 Some [function] [call site] 03893
14 Msg::get_channel [function] [call site] 03894
14 HandleContainer::new [function] [call site] 03895
14 tokio::runtime::Runtime::spawn [function] [call site] 03896
14 ConnectionManager::check_for_disconnect_pushes [function] [call site] 03897
15 Pipeline::send_recv [function] [call site] 03898
15 upgrade [function] [call site] 03899
15 Self::reconnect [function] [call site] 03900
16 Client::open [function] [call site] 03901
16 redis::ConnectionInfo::clone [function] [call site] 03902
16 Client::get_multiplexed_async_connection [function] [call site] 03903
16 CopyOptions::replace [function] [call site] 03904
16 crate::cmd [function] [call site] 03905
16 redis::Cmd::query_async [function] [call site] 03906
16 bool::as_mut [function] [call site] 03907
16 unwrap [function] [call site] 03908
16 Err [function] [call site] 03909
16 not_a_sentinel_error [function] [call site] 03910
16 Ok [function] [call site] 03911
15 Arc::downgrade [function] [call site] 03912
15 load [function] [call site] 03913
15 as_ref [function] [call site] 03914
15 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 03915
14 ClientTlsParams::clone [function] [call site] 03916
14 check_resp3 [function] [call site] 03917
15 supports_resp3 [function] [call site] 03918
15 Err [function] [call site] 03919
15 RedisError::from [function] [call site] 03920
14 tokio::sync::mpsc::unbounded_channel [function] [call site] 03921
14 Some [function] [call site] 03922
14 Some [function] [call site] 03923
14 AsyncConnectionConfig::set_push_sender_internal [function] [call site] 03924
15 Some [function] [call site] 03925
14 RedisServer::new [function] [call site] 03926
14 ProtocolVersion::supports_resp3 [function] [call site] 03927
14 tokio::sync::mpsc::unbounded_channel [function] [call site] 03928
14 Some [function] [call site] 03929
14 AsyncConnectionConfig::set_push_sender_internal [function] [call site] 03930
14 RedisServer::new [function] [call site] 03931
14 then [function] [call site] 03932
14 RedisServer::new [function] [call site] 03933
14 RedisServer::default [function] [call site] 03934
14 ClientTlsParams::clone [function] [call site] 03935
14 ClientTlsParams::clone [function] [call site] 03936
14 cluster_async::test_async_cluster_ask_save_new_connection [function] [call site] 03937
15 RedisServer::new [function] [call site] 03938
15 RedisServer::new [function] [call site] 03939
16 RedisServer::with_modules [function] [call site] 03940
15 ClientTlsParams::clone [function] [call site] 03941
15 MockEnv::with_client_builder [function] [call site] 03942
15 ClusterClient::builder [function] [call site] 03943
15 respond_startup_two_nodes [function] [call site] 03944
16 respond_startup_with_replica_using_config [function] [call site] 03945
16 Some [function] [call site] 03946
15 Err [function] [call site] 03947
15 parse_redis_value [function] [call site] 03948
15 is_connection_check [function] [call site] 03949
15 Self::fetch_add [function] [call site] 03950
15 respond_startup_two_nodes [function] [call site] 03951
15 Err [function] [call site] 03952
15 Ok [function] [call site] 03953
15 tokio::runtime::Runtime::block_on [function] [call site] 03954
15 cmd [function] [call site] 03955
15 Cmd::arg [function] [call site] 03956
15 arg("test").query_async::<Value> [function] [call site] 03957
15 unwrap [function] [call site] 03958
14 types::test_parse_boxed [function] [call site] 03959
14 shared [function] [call site] 03960
14 Self [function] [call site] 03961
14 RedisServer::new [function] [call site] 03962
14 ArcSwap::from_pointee [function] [call site] 03963
14 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 03964
14 Arc::downgrade [function] [call site] 03965
14 map_err [function] [call site] 03966
14 crate::RedisError::from [function] [call site] 03967
15 io::Error::from [function] [call site] 03968
15 Self::into [function] [call site] 03969
14 Ok [function] [call site] 03970
13 ClientTlsParams::clone [function] [call site] 03971
14 ClientTlsParams::clone [function] [call site] 03972
14 Pkcs1 [function] [call site] 03973
14 secret_pkcs1_der [function] [call site] 03974
14 write_command_to_vec [function] [call site] 03975
14 into [function] [call site] 03976
14 Pkcs8 [function] [call site] 03977
14 secret_pkcs8_der [function] [call site] 03978
14 write_command_to_vec [function] [call site] 03979
14 into [function] [call site] 03980
14 Sec1 [function] [call site] 03981
14 secret_sec1_der [function] [call site] 03982
14 write_command_to_vec [function] [call site] 03983
14 into [function] [call site] 03984
12 unwrap [function] [call site] 03985
12 tests::into_redis_value_hashset [function] [call site] 03986
12 unwrap [function] [call site] 03987
12 MockConnection::send_packed_command [function] [call site] 03988
12 cmd [function] [call site] 03989
12 Cmd::arg [function] [call site] 03990
12 types::test_is_single_arg [function] [call site] 03991
12 unwrap [function] [call site] 03992
12 hotkeys_cluster::setup_cluster_and_target [function] [call site] 03993
12 unwrap [function] [call site] 03994
12 tests::into_redis_value_hashset [function] [call site] 03995
12 unwrap [function] [call site] 03996
12 Pipeline::send_recv [function] [call site] 03997
12 unwrap [function] [call site] 03998
11 to_owned [function] [call site] 03999
10 Vec::write_arg [function] [call site] 04000
10 Self::format [function] [call site] 04001
10 as_bytes [function] [call site] 04002
10 Vec::write_arg [function] [call site] 04003
10 Vec::write_arg [function] [call site] 04004
10 Self::format [function] [call site] 04005
10 as_bytes [function] [call site] 04006
10 Vec::write_arg [function] [call site] 04007
10 Vec::write_arg [function] [call site] 04008
10 Self::format [function] [call site] 04009
10 as_bytes [function] [call site] 04010
10 Vec::write_arg [function] [call site] 04011
10 Vec::write_arg [function] [call site] 04012
10 Self::format [function] [call site] 04013
10 as_bytes [function] [call site] 04014
10 Vec::write_arg [function] [call site] 04015
8 types::test_is_single_arg [function] [call site] 04016
8 types::test_is_single_arg [function] [call site] 04017
8 types::test_is_single_arg [function] [call site] 04018
8 types::test_is_single_arg [function] [call site] 04019
8 RoutingInfo::for_routable [function] [call site] 04020
8 std::collections::HashMap::new [function] [call site] 04021
8 Self::insert [function] [call site] 04022
8 Route [function] [call site] 04023
8 Self::insert [function] [call site] 04024
8 Route [function] [call site] 04025
8 Self::insert [function] [call site] 04026
8 Route [function] [call site] 04027
7 join [function] [call site] 04028
6 types::test_is_single_arg [function] [call site] 04029
6 types::test_is_single_arg [function] [call site] 04030
6 ClientTlsParams::clone [function] [call site] 04031
6 get_major_version [function] [call site] 04032
6 types::test_is_single_arg [function] [call site] 04033
6 types::test_is_single_arg [function] [call site] 04034
6 types::test_is_single_arg [function] [call site] 04035
6 types::test_is_single_arg [function] [call site] 04036
6 ValueComparison::arg_to_string [function] [call site] 04037
6 types::test_is_single_arg [function] [call site] 04038
6 types::test_is_single_arg [function] [call site] 04039
6 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04040
6 Option<TlsFilePaths>::unwrap_or_else [function] [call site] 04041
6 utils::build_keys_and_certs_for_tls [function] [call site] 04042
6 types::test_is_single_arg [function] [call site] 04043
6 types::test_is_single_arg [function] [call site] 04044
6 ValueComparison::arg_to_string [function] [call site] 04045
6 types::test_is_single_arg [function] [call site] 04046
6 types::test_is_single_arg [function] [call site] 04047
6 types::test_is_single_arg [function] [call site] 04048
6 types::test_is_single_arg [function] [call site] 04049
6 types::test_is_single_arg [function] [call site] 04050
6 types::test_is_single_arg [function] [call site] 04051
6 types::test_is_single_arg [function] [call site] 04052
6 types::test_is_single_arg [function] [call site] 04053
6 types::test_is_single_arg [function] [call site] 04054
6 types::test_is_single_arg [function] [call site] 04055
6 types::test_is_single_arg [function] [call site] 04056
6 types::test_is_single_arg [function] [call site] 04057
6 types::test_is_single_arg [function] [call site] 04058
6 types::test_is_single_arg [function] [call site] 04059
6 ClientTlsParams::clone [function] [call site] 04060
6 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04061
6 Some [function] [call site] 04062
6 types::test_is_single_arg [function] [call site] 04063
6 types::test_is_single_arg [function] [call site] 04064
6 types::test_is_single_arg [function] [call site] 04065
6 types::test_is_single_arg [function] [call site] 04066
6 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04067
5 Cmd::spawn [function] [call site] 04068
5 unwrap_or_else [function] [call site] 04069
2 Parser::parse_value [function] [call site] 04070