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