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
4223 0 EP call site: 00000 cluster::test_cluster_reconnect_after_complete_server_disconnect

Fuzzer calltree

0 fuzz_target [function] [call site] 00000
1 redis::parse_redis_value [function] [call site] 00001
2 Parser::new [function] [call site] 00002
3 RedisServer::new [function] [call site] 00003
4 RedisServer::with_modules [function] [call site] 00004
5 utils::get_random_available_port [function] [call site] 00005
6 get_listener_on_free_port [function] [call site] 00006
7 0.0.1:0".parse::<SocketAddr> [function] [call site] 00007
7 RedisServer::new [function] [call site] 00010
8 RedisServer::with_modules [function] [call site] 00011
7 RedisServer::unwrap [function] [call site] 00012
7 set_reuse_address [function] [call site] 00013
7 ValueType::from [function] [call site] 00019
8 TlsFilePaths::as_ref [function] [call site] 00020
8 ValueType::Unknown [function] [call site] 00021
8 ValueComparison::arg_to_string [function] [call site] 00022
9 impl [call site] 00023
9 String::from_utf8_lossy [function] [call site] 00024
9 into_owned [function] [call site] 00025
6 TcpListener::local_addr [function] [call site] 00026
6 get_listener_on_free_port [function] [call site] 00028
7 0.0.1:0".parse::<SocketAddr> [function] [call site] 00029
7 RedisServer::new [function] [call site] 00032
7 RedisServer::unwrap [function] [call site] 00033
7 set_reuse_address [function] [call site] 00034
7 ValueType::from [function] [call site] 00040
5 RedisServer::get_addr [function] [call site] 00041
6 ServerType::get_intended [function] [call site] 00042
7 entra_id_tests::get_env_var [function] [call site] 00043
8 std::env::var [function] [call site] 00044
9 std::env::var [function] [call site] 00045
9 String::unwrap_or_else [function] [call site] 00046
8 String::unwrap_or_else [function] [call site] 00047
7 tests::redis_ok [function] [call site] 00048
7 tests::into_redis_value_hashmap [function] [call site] 00050
8 ValueType::from [function] [call site] 00051
9 TlsFilePaths::as_ref [function] [call site] 00052
9 ValueType::Unknown [function] [call site] 00053
9 ValueComparison::arg_to_string [function] [call site] 00054
8 String::into_redis_value [function] [call site] 00055
9 Value::BulkString [function] [call site] 00056
9 String::as_bytes [function] [call site] 00057
9 write_command_to_vec [function] [call site] 00058
10 args_len [function] [call site] 00059
11 countdigits [function] [call site] 00060
11 basic::test_pipeline_len [function] [call site] 00061
12 redis::pipe [function] [call site] 00062
13 redis::pipe [function] [call site] 00063
13 Pipeline::atomic [function] [call site] 00064
13 redis::pipe [function] [call site] 00065
12 cmd [function] [call site] 00066
13 Cmd::new [function] [call site] 00067
13 Cmd::arg [function] [call site] 00068
14 SetExpiry::write_redis_args [function] [call site] 00069
15 Vec::write_arg [function] [call site] 00070
16 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00071
17 TestContext::new [function] [call site] 00072
18 TestContext::with_modules [function] [call site] 00073
19 TestContext::with_modules_and_tls [function] [call site] 00074
20 start_tls_crypto_provider [function] [call site] 00075
21 rustls::crypto::CryptoProvider::get_default [function] [call site] 00076
21 rustls::crypto::ring::default_provider [function] [call site] 00078
21 install_default [function] [call site] 00079
20 redis_test::utils::get_random_available_port [function] [call site] 00080
21 get_listener_on_free_port [function] [call site] 00081
21 TcpListener::local_addr [function] [call site] 00082
21 get_listener_on_free_port [function] [call site] 00084
20 RedisServer::get_addr [function] [call site] 00085
20 TestContext::with_modules_addr_and_tls [function] [call site] 00086
21 TestContext::with_modules_addr_tls_and_cert_auth [function] [call site] 00087
22 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00088
23 entra_id_tests::get_env_var [function] [call site] 00089
23 String::unwrap_or_else [function] [call site] 00090
23 ValueComparison::arg_to_string [function] [call site] 00091
24 impl [call site] 00092
24 String::from_utf8_lossy [function] [call site] 00093
24 into_owned [function] [call site] 00094
23 process::Command::new [function] [call site] 00095
24 RedisServer::with_modules [function] [call site] 00096
23 types::test_is_single_arg [function] [call site] 00097
23 types::test_is_single_arg [function] [call site] 00098
23 types::test_is_single_arg [function] [call site] 00099
23 entra_id_tests::get_env_var [function] [call site] 00100
23 entra_id_tests::get_env_var [function] [call site] 00101
23 types::test_is_single_arg [function] [call site] 00102
23 types::test_is_single_arg [function] [call site] 00103
23 RedisServer::stdout [function] [call site] 00104
23 process::Stdio::piped [function] [call site] 00105
23 process::Stdio::piped [function] [call site] 00107
23 tempfile::Builder::new [function] [call site] 00108
24 &'a [call site] 00110
25 std::iter::once [function] [call site] 00111
25 basic::test_tuple_decoding_from_iter [function] [call site] 00113
26 TestContext::new [function] [call site] 00114
26 TestContext::connection [function] [call site] 00115
27 Client::get_connection [function] [call site] 00116
28 connect [function] [call site] 00117
29 Instant::now [function] [call site] 00118
29 ActualConnection::new [function] [call site] 00119
30 is_wildcard_address [function] [call site] 00121
30 fail [function] [call site] 00122
31 ::std::convert::From::from [function] [call site] 00124
30 String::as_str [function] [call site] 00125
30 connect_tcp [function] [call site] 00126
31 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 00127
32 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 00128
33 TestClusterContext::new_with_config_and_builder [function] [call site] 00129
34 support::start_tls_crypto_provider [function] [call site] 00130
35 rustls::crypto::CryptoProvider::get_default [function] [call site] 00131
35 rustls::crypto::ring::default_provider [function] [call site] 00133
35 install_default [function] [call site] 00134
34 RedisCluster::new [function] [call site] 00135
35 MockRedisConnection::is_empty [function] [call site] 00136
36 StreamReadOptions::block [function] [call site] 00137
36 MockRedisConnection::is_empty [function] [call site] 00140
37 StreamReadOptions::block [function] [call site] 00141
37 MockRedisConnection::is_empty [function] [call site] 00143
35 &'a [call site] 00144
36 std::iter::once [function] [call site] 00145
36 basic::test_tuple_decoding_from_iter [function] [call site] 00147
35 std::iter::Chain::map [function] [call site] 00148
36 ValueType::from [function] [call site] 00149
36 String::into_redis_value [function] [call site] 00150
36 Value::into_map_iter [function] [call site] 00151
37 basic::test_pipeline_len [function] [call site] 00152
37 OwnedMapIter::Array [function] [call site] 00154
37 &'a [call site] 00155
38 std::iter::once [function] [call site] 00156
38 basic::test_tuple_decoding_from_iter [function] [call site] 00158
37 Value::Array [function] [call site] 00160
37 OwnedMapIter::Map [function] [call site] 00162
37 &'a [call site] 00163
36 Result::expect [function] [call site] 00165
36 into_map_iter() [call site] 00166
6 .expect("extracting [call site] 00167
6 .collect::<Vec<(Value, [call site] 00168
35 std::collections::HashSet::new [function] [call site] 00172
36 RedisServer::with_modules [function] [call site] 00173
35 ClusterType::get_intended [function] [call site] 00174
36 entra_id_tests::get_env_var [function] [call site] 00175
36 tests::redis_ok [function] [call site] 00176
36 tests::into_redis_value_hashmap [function] [call site] 00178
35 tempfile::Builder::new [function] [call site] 00179
35 RedisResult::prefix [function] [call site] 00180
35 { [call site] 00183
0 server::build_keys_and_certs_for_tls_ext [function] [call site] 00184
36 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00185
37 Cmd::arg [function] [call site] 00187
37 types::test_is_single_arg [function] [call site] 00188
37 types::test_is_single_arg [function] [call site] 00189
37 types::test_is_single_arg [function] [call site] 00190
37 types::test_is_single_arg [function] [call site] 00191
37 RoutingInfo::for_routable [function] [call site] 00192
38 MockRedisConnection::req_packed_command [function] [call site] 00193
39 Cmd::get_packed_command [function] [call site] 00194
40 RedisServer::new [function] [call site] 00195
41 RedisServer::with_modules [function] [call site] 00196
40 Cmd::is_empty [function] [call site] 00197
41 MockRedisConnection::is_empty [function] [call site] 00198
40 Cmd::write_packed_command [function] [call site] 00199
41 write_command_to_vec [function] [call site] 00200
42 args_len [function] [call site] 00201
42 ClientTlsParams::clone [function] [call site] 00202
43 ClientTlsParams::clone [function] [call site] 00203
43 secret_pkcs1_der [function] [call site] 00205
43 write_command_to_vec [function] [call site] 00206
43 secret_pkcs8_der [function] [call site] 00209
43 write_command_to_vec [function] [call site] 00210
43 secret_sec1_der [function] [call site] 00213
43 write_command_to_vec [function] [call site] 00214
42 Cmd::reserve [function] [call site] 00216
42 write_command [function] [call site] 00217
43 ::itoa::Buffer::new [function] [call site] 00218
44 RedisServer::with_modules [function] [call site] 00219
43 Cmd::write_all [function] [call site] 00220
43 RedisServer::format [function] [call site] 00221
43 basic::test_pipeline_len [function] [call site] 00222
43 Cmd::write_all [function] [call site] 00223
43 TlsFilePaths::as_bytes [function] [call site] 00224
43 Cmd::write_all [function] [call site] 00225
43 itoa::Buffer::new [function] [call site] 00226
44 RedisServer::with_modules [function] [call site] 00227
43 RedisServer::format [function] [call site] 00228
43 as_bytes [function] [call site] 00229
43 Cmd::write_all [function] [call site] 00230
43 RedisServer::format [function] [call site] 00231
43 basic::test_pipeline_len [function] [call site] 00232
44 redis::pipe [function] [call site] 00233
44 types::test_is_single_arg [function] [call site] 00236
43 Cmd::write_all [function] [call site] 00237
43 TlsFilePaths::as_bytes [function] [call site] 00238
43 Cmd::write_all [function] [call site] 00239
43 Cmd::write_all [function] [call site] 00240
43 Cmd::write_all [function] [call site] 00241
42 io::Result::unwrap [function] [call site] 00243
41 Cmd::args_iter [function] [call site] 00244
42 basic::test_tuple_decoding_from_iter [function] [call site] 00245
42 tests::into_redis_value_hashmap [function] [call site] 00246
42 Arg::Simple [function] [call site] 00247
41 unwrap_or [function] [call site] 00248
39 MockRedisConnection::req_packed_command [function] [call site] 00249
40 Cmd::get_packed_command [function] [call site] 00250
40 MockRedisConnection::req_packed_command [function] [call site] 00251
40 as_slice [function] [call site] 00252
40 PipelineSink::poll_ready [function] [call site] 00253
41 PipelineSink::as_mut [function] [call site] 00254
41 PipelineSink::poll_ready [function] [call site] 00256
42 PipelineSink::as_mut [function] [call site] 00257
42 PipelineSink::poll_ready [function] [call site] 00259
40 types::test_parse_boxed [function] [call site] 00262
41 ValueComparison::arg_to_string [function] [call site] 00263
41 parse_redis_value [function] [call site] 00264
42 Parser::new [function] [call site] 00265
42 Parser::parse_value [function] [call site] 00266
43 to_redis_err [function] [call site] 00268
44 is_unexpected_end_of_input [function] [call site] 00270
44 RedisError::from [function] [call site] 00271
44 io::Error::from [function] [call site] 00272
44 map_range [function] [call site] 00273
44 map_position [function] [call site] 00274
44 translate_position [function] [call site] 00275
44 to_string [function] [call site] 00277
44 RedisError::from [function] [call site] 00278
44 ParsingError::from [function] [call site] 00279
41 Value::SimpleString [function] [call site] 00281
41 ClientTlsParams::clone [function] [call site] 00282
42 ClientTlsParams::clone [function] [call site] 00283
42 secret_pkcs1_der [function] [call site] 00285
42 write_command_to_vec [function] [call site] 00286
42 secret_pkcs8_der [function] [call site] 00289
42 write_command_to_vec [function] [call site] 00290
42 secret_sec1_der [function] [call site] 00293
42 write_command_to_vec [function] [call site] 00294
39 as_slice [function] [call site] 00296
39 PipelineSink::poll_ready [function] [call site] 00297
39 types::test_parse_boxed [function] [call site] 00298
38 base_routing [function] [call site] 00299
39 RouteBy::MultiShard [function] [call site] 00300
39 RouteBy::MultiShard [function] [call site] 00301
39 RouteBy::MultiShard [function] [call site] 00302
39 RouteBy::MultiShard [function] [call site] 00303
38 RoutingInfo::MultiNode [function] [call site] 00305
38 ResponsePolicy::for_command [function] [call site] 00306
39 ResponsePolicy::AggregateLogical [function] [call site] 00308
39 ResponsePolicy::Aggregate [function] [call site] 00310
39 ResponsePolicy::Aggregate [function] [call site] 00312
38 RoutingInfo::MultiNode [function] [call site] 00323
38 ResponsePolicy::for_command [function] [call site] 00324
38 multi_shard [function] [call site] 00325
39 commands::is_readonly_cmd [function] [call site] 00326
39 RedisServer::new [function] [call site] 00327
40 RedisServer::with_modules [function] [call site] 00328
39 Cmd::arg_idx [function] [call site] 00329
40 Cmd::arg_idx [function] [call site] 00330
41 Cmd::arg_idx [function] [call site] 00331
39 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00332
40 TestContext::new [function] [call site] 00333
40 ProtocolVersion::supports_resp3 [function] [call site] 00334
40 tokio::sync::mpsc::unbounded_channel [function] [call site] 00335
40 redis::aio::ConnectionManagerConfig::new [function] [call site] 00336
41 RedisServer::default [function] [call site] 00337
42 RedisServer::new [function] [call site] 00338
43 RedisServer::with_modules [function] [call site] 00339
40 AsyncConnectionConfig::set_push_sender [function] [call site] 00340
41 AsyncConnectionConfig::set_push_sender_internal [function] [call site] 00341
41 std::sync::Arc::new [function] [call site] 00343
42 RedisServer::with_modules [function] [call site] 00344
40 Client::get_connection_manager_lazy [function] [call site] 00345
41 crate::aio::ConnectionManager::new_lazy_with_config [function] [call site] 00346
42 Runtime::locate [function] [call site] 00347
43 hotkeys_cluster::setup_cluster_and_target [function] [call site] 00348
44 TestClusterContext::new [function] [call site] 00349
45 TestClusterContext::new_with_config [function] [call site] 00350
46 TestClusterContext::new_with_config_and_builder [function] [call site] 00351
45 RedisServer::default [function] [call site] 00352
46 RedisServer::new [function] [call site] 00353
44 TestClusterContext::wait_for_cluster_up [function] [call site] 00354
45 TestClusterContext::connection [function] [call site] 00355
46 Client::get_connection [function] [call site] 00356
45 redis::cmd [function] [call site] 00358
46 redis::cmd [function] [call site] 00359
46 Cmd::set_cache_config [function] [call site] 00360
46 CommandCacheConfig::new [function] [call site] 00362
46 CommandCacheConfig::set_enable_cache [function] [call site] 00363
45 types::test_is_single_arg [function] [call site] 00364
45 query::<String> [function] [call site] 00365
45 ConnectionAddr::starts_with [function] [call site] 00367
45 std::thread::sleep [function] [call site] 00368
46 tokio::time::sleep [function] [call site] 00369
47 tokio::time::sleep [function] [call site] 00370
47 smol::Timer::after [function] [call site] 00371
46 smol::Timer::after [function] [call site] 00372
45 Duration::from_millis [function] [call site] 00373
44 RedisCluster::iter_servers [function] [call site] 00374
45 basic::test_tuple_decoding_from_iter [function] [call site] 00375
44 MapIter::next [function] [call site] 00376
45 MapIter::next [function] [call site] 00378
45 MapIter::next [function] [call site] 00379
45 MapIter::next [function] [call site] 00380
44 RedisServer::connection_info [function] [call site] 00383
45 RedisServer::client_addr [function] [call site] 00384
45 &redis::ConnectionAddr::clone [function] [call site] 00385
46 ClientTlsParams::clone [function] [call site] 00386
46 secret_pkcs1_der [function] [call site] 00388
46 write_command_to_vec [function] [call site] 00389
46 secret_pkcs8_der [function] [call site] 00392
46 write_command_to_vec [function] [call site] 00393
46 secret_sec1_der [function] [call site] 00396
46 write_command_to_vec [function] [call site] 00397
45 ConnectionInfo::into_connection_info [function] [call site] 00399
45 RedisResult::unwrap [function] [call site] 00401
45 ConnectionInfo::set_redis_settings [function] [call site] 00402
45 redis_settings [function] [call site] 00403
46 RedisServer::default [function] [call site] 00404
47 RedisServer::new [function] [call site] 00405
46 RedisConnectionInfo::set_protocol [function] [call site] 00406
46 use_protocol [function] [call site] 00407
47 entra_id_tests::get_env_var [function] [call site] 00408
47 String::unwrap_or_default [function] [call site] 00409
44 hotkeys_cluster::port_of [function] [call site] 00410
44 redis::ConnectionInfo::addr [function] [call site] 00411
44 hotkeys_cluster::direct_connection [function] [call site] 00412
45 redis::ConnectionInfo::set_redis_settings [function] [call site] 00413
45 RedisServer::default [function] [call site] 00414
45 RedisConnectionInfo::set_protocol [function] [call site] 00415
45 redis::Client::open [function] [call site] 00416
46 ConnectionInfo::into_connection_info [function] [call site] 00418
45 RedisResult::unwrap [function] [call site] 00420
45 Client::get_connection [function] [call site] 00421
44 redis::ConnectionInfo::clone [function] [call site] 00423
45 ClientTlsParams::clone [function] [call site] 00424
45 secret_pkcs1_der [function] [call site] 00426
45 write_command_to_vec [function] [call site] 00427
45 secret_pkcs8_der [function] [call site] 00430
45 write_command_to_vec [function] [call site] 00431
45 secret_sec1_der [function] [call site] 00434
45 write_command_to_vec [function] [call site] 00435
44 redis::Cmd::new [function] [call site] 00437
45 Cmd::into_redis_cmd_bytes [function] [call site] 00438
46 Cmd::get_packed_command [function] [call site] 00439
45 tests::into_redis_value_hashmap [function] [call site] 00440
44 types::test_is_single_arg [function] [call site] 00441
44 basic::test_pipeline_reuse_query [function] [call site] 00442
45 TestContext::new [function] [call site] 00443
45 TestContext::connection [function] [call site] 00444
45 redis::pipe [function] [call site] 00445
45 types::test_is_single_arg [function] [call site] 00447
45 types::test_is_single_arg [function] [call site] 00448
45 types::test_is_single_arg [function] [call site] 00451
45 basic::test_pipeline_reuse_query [function] [call site] 00452
45 redis::cmd [function] [call site] 00454
45 redis::Cmd::arg [function] [call site] 00455
46 SetExpiry::write_redis_args [function] [call site] 00456
45 Cmd::exec [function] [call site] 00457
46 query::<()> [function] [call site] 00458
45 RedisResult::unwrap [function] [call site] 00459
45 types::test_is_single_arg [function] [call site] 00461
45 types::test_is_single_arg [function] [call site] 00462
45 types::test_is_single_arg [function] [call site] 00465
45 types::test_is_single_arg [function] [call site] 00466
45 basic::test_pipeline_reuse_query [function] [call site] 00467
44 parse_version [function] [call site] 00470
45 redis::ConnectionInfo::get [function] [call site] 00471
46 TestClusterContext::new [function] [call site] 00472
46 TestClusterContext::wait_for_cluster_up [function] [call site] 00473
46 RedisCluster::iter_servers [function] [call site] 00474
46 MapIter::next [function] [call site] 00475
46 RedisServer::connection_info [function] [call site] 00477
46 hotkeys_cluster::port_of [function] [call site] 00478
46 redis::ConnectionInfo::addr [function] [call site] 00479
46 hotkeys_cluster::direct_connection [function] [call site] 00480
46 redis::ConnectionInfo::clone [function] [call site] 00481
46 redis::Cmd::new [function] [call site] 00482
46 types::test_is_single_arg [function] [call site] 00483
46 basic::test_pipeline_reuse_query [function] [call site] 00484
46 parse_version [function] [call site] 00486
46 hotkeys_cluster::first_owned_slot_range [function] [call site] 00487
47 Cmd::arg [function] [call site] 00489
47 basic::test_pipeline_reuse_query [function] [call site] 00490
48 TestContext::new [function] [call site] 00491
48 TestContext::connection [function] [call site] 00492
48 redis::pipe [function] [call site] 00493
48 types::test_is_single_arg [function] [call site] 00495
48 types::test_is_single_arg [function] [call site] 00496
48 types::test_is_single_arg [function] [call site] 00499
48 basic::test_pipeline_reuse_query [function] [call site] 00500
48 redis::cmd [function] [call site] 00502
48 redis::Cmd::arg [function] [call site] 00503
48 Cmd::exec [function] [call site] 00504
48 RedisResult::unwrap [function] [call site] 00505
48 types::test_is_single_arg [function] [call site] 00507
48 types::test_is_single_arg [function] [call site] 00508
48 types::test_is_single_arg [function] [call site] 00511
48 types::test_is_single_arg [function] [call site] 00512
48 basic::test_pipeline_reuse_query [function] [call site] 00513
47 basic::test_pipeline_len [function] [call site] 00516
47 from_redis_value [function] [call site] 00517
48 RedisResult::from_redis_value [function] [call site] 00518
49 from_redis_value [function] [call site] 00522
49 tests::into_redis_value_hashmap [function] [call site] 00523
50 ValueType::from [function] [call site] 00524
50 String::into_redis_value [function] [call site] 00525
50 Value::into_map_iter [function] [call site] 00526
50 Result::expect [function] [call site] 00527
50 into_map_iter() [call site] 00528
6 .expect("extracting [call site] 00529
6 .collect::<Vec<(Value, [call site] 00530
49 Ok [function] [call site] 00533
47 ClientTlsParams::clone [function] [call site] 00534
47 Result::unwrap [function] [call site] 00535
47 from_redis_value [function] [call site] 00536
47 ClientTlsParams::clone [function] [call site] 00537
47 Result::unwrap [function] [call site] 00538
47 basic::test_pipeline_len [function] [call site] 00539
47 from_redis_value [function] [call site] 00540
47 ClientTlsParams::clone [function] [call site] 00541
47 Result::unwrap [function] [call site] 00542
46 hotkeys_cluster::find_key_in_range [function] [call site] 00543
47 Cmd::arg [function] [call site] 00545
47 types::test_is_single_arg [function] [call site] 00546
47 basic::test_pipeline_reuse_query [function] [call site] 00547
46 Some [function] [call site] 00549
45 Option::unwrap [function] [call site] 00550
45 basic_async::automatic_unsubscription_on_split [function] [call site] 00551
46 TestContext::new [function] [call site] 00552
46 TestContext::async_pubsub [function] [call site] 00553
47 Client::get_async_pubsub [function] [call site] 00554
48 Client::get_simple_async_connection_dynamically [function] [call site] 00555
49 Runtime::locate [function] [call site] 00556
49 get_simple_async_connection::<crate::aio::tokio::Tokio> [function] [call site] 00557
49 get_simple_async_connection::<crate::aio::smol::Smol> [function] [call site] 00558
48 crate::aio::PubSub::new [function] [call site] 00559
49 RedisServer::default [function] [call site] 00560
50 RedisServer::new [function] [call site] 00561
49 Self::framed [function] [call site] 00562
49 CertAuthTestContext::setup_connection [function] [call site] 00563
50 MockRedisConnection::check_connection [function] [call site] 00564
49 tokio::sync::mpsc::unbounded_channel [function] [call site] 00565
49 PubSubSink::new [function] [call site] 00566
50 tokio::sync::mpsc::unbounded_channel [function] [call site] 00567
50 PipelineSink::new [function] [call site] 00568
51 RedisServer::new [function] [call site] 00569
52 RedisServer::with_modules [function] [call site] 00570
50 stream::poll_fn [function] [call site] 00571
50 ( [call site] 00572
4 PendingRequest::poll_recv [function] [call site] 00573
50 tests::into_redis_value_hashmap [function] [call site] 00574
50 tests::into_redis_value_hashmap [function] [call site] 00576
49 Runtime::locate [function] [call site] 00577
49 Self::spawn [function] [call site] 00578
50 tokio::runtime::Handle::try_current [function] [call site] 00579
50 spawn [function] [call site] 00580
51 tokio::runtime::Handle::try_current [function] [call site] 00581
51 smol::spawn [function] [call site] 00583
52 tokio::runtime::Handle::try_current [function] [call site] 00584
52 smol::spawn [function] [call site] 00586
52 TaskHandle::detach [function] [call site] 00587
53 TaskHandle::detach [function] [call site] 00588
51 TaskHandle::detach [function] [call site] 00589
50 smol::spawn [function] [call site] 00590
50 TaskHandle::detach [function] [call site] 00591
49 Some [function] [call site] 00592
49 SharedHandleContainer::new [function] [call site] 00593
50 RedisServer::new [function] [call site] 00595
51 RedisServer::with_modules [function] [call site] 00596
50 HandleContainer::new [function] [call site] 00597
49 Ok [function] [call site] 00600
46 unwrap [function] [call site] 00601
46 basic_async::automatic_unsubscription_on_split [function] [call site] 00602
47 TestContext::new [function] [call site] 00603
47 TestContext::async_pubsub [function] [call site] 00604
47 basic_async::automatic_unsubscription_on_split [function] [call site] 00606
47 basic::test_pubsub_unsubscribe [function] [call site] 00607
48 TestContext::new [function] [call site] 00608
48 TestContext::connection [function] [call site] 00609
48 std::sync::mpsc::channel [function] [call site] 00610
49 from_redis_value_ref [function] [call site] 00612
50 FromRedisValue::from_redis_value_ref [function] [call site] 00613
51 RedisResult::from_redis_value [function] [call site] 00614
52 from_redis_value [function] [call site] 00618
52 tests::into_redis_value_hashmap [function] [call site] 00619
51 ClientTlsParams::clone [function] [call site] 00621
52 ClientTlsParams::clone [function] [call site] 00622
52 secret_pkcs1_der [function] [call site] 00624
52 write_command_to_vec [function] [call site] 00625
52 secret_pkcs8_der [function] [call site] 00628
52 write_command_to_vec [function] [call site] 00629
52 secret_sec1_der [function] [call site] 00632
52 write_command_to_vec [function] [call site] 00633
48 redis::Connection::set_push_sender [function] [call site] 00635
48 redis::Connection::as_pubsub [function] [call site] 00637
49 PubSub::new [function] [call site] 00638
50 RedisServer::default [function] [call site] 00639
50 Self::framed [function] [call site] 00640
50 CertAuthTestContext::setup_connection [function] [call site] 00641
50 tokio::sync::mpsc::unbounded_channel [function] [call site] 00642
50 PubSubSink::new [function] [call site] 00643
50 Runtime::locate [function] [call site] 00644
50 Self::spawn [function] [call site] 00645
50 SharedHandleContainer::new [function] [call site] 00647
48 basic::test_pubsub_unsubscribe [function] [call site] 00649
48 basic::test_pubsub_unsubscribe [function] [call site] 00651
48 basic::test_pubsub_unsubscribe [function] [call site] 00653
48 PubSub::psubscribe [function] [call site] 00655
49 PubSub::psubscribe [function] [call site] 00656
48 RedisResult::unwrap [function] [call site] 00657
48 PubSub::psubscribe [function] [call site] 00658
48 RedisResult::unwrap [function] [call site] 00659
48 PubSub::psubscribe [function] [call site] 00660
48 RedisResult::unwrap [function] [call site] 00661
48 redis::Connection::set [function] [call site] 00662
49 ValueType::from [function] [call site] 00663
50 TlsFilePaths::as_ref [function] [call site] 00664
50 ValueType::Unknown [function] [call site] 00665
50 ValueComparison::arg_to_string [function] [call site] 00666
49 String::into_redis_value [function] [call site] 00667
49 Result::expect [function] [call site] 00673
48 redis::Connection::get [function] [call site] 00677
49 TestClusterContext::new [function] [call site] 00678
49 TestClusterContext::wait_for_cluster_up [function] [call site] 00679
49 RedisCluster::iter_servers [function] [call site] 00680
49 MapIter::next [function] [call site] 00681
49 RedisServer::connection_info [function] [call site] 00683
49 hotkeys_cluster::port_of [function] [call site] 00684
49 redis::ConnectionInfo::addr [function] [call site] 00685
49 hotkeys_cluster::direct_connection [function] [call site] 00686
49 redis::ConnectionInfo::clone [function] [call site] 00687
49 redis::Cmd::new [function] [call site] 00688
49 types::test_is_single_arg [function] [call site] 00689
49 basic::test_pipeline_reuse_query [function] [call site] 00690
49 parse_version [function] [call site] 00692
49 hotkeys_cluster::first_owned_slot_range [function] [call site] 00693
49 hotkeys_cluster::find_key_in_range [function] [call site] 00694
48 Option::unwrap [function] [call site] 00696
48 ProtocolVersion::supports_resp3 [function] [call site] 00698
48 try_recv [function] [call site] 00699
48 RedisResult::from_redis_value_ref [function] [call site] 00701
49 ClientTlsParams::clone [function] [call site] 00704
49 Self::into [function] [call site] 00705
49 from_redis_value_ref [function] [call site] 00706
49 tests::into_redis_value_hashmap [function] [call site] 00707
48 Replicas::first [function] [call site] 00709
48 &'a [call site] 00710
48 Result::unwrap [function] [call site] 00711
48 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00712
47 TestContext::async_connection [function] [call site] 00714
48 Client::get_multiplexed_async_connection [function] [call site] 00715
49 Client::get_multiplexed_async_connection_with_config [function] [call site] 00716
50 Runtime::locate [function] [call site] 00717
50 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::tokio::Tokio> [function] [call site] 00718
50 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::smol::Smol> [function] [call site] 00719
49 AsyncConnectionConfig::new [function] [call site] 00720
50 RedisServer::default [function] [call site] 00721
47 Runtime::sleep [function] [call site] 00723
48 tokio::time::sleep [function] [call site] 00724
48 smol::Timer::after [function] [call site] 00725
47 Duration::from_millis [function] [call site] 00726
47 redis::cmd [function] [call site] 00728
47 redis::Cmd::arg [function] [call site] 00729
47 types::test_is_single_arg [function] [call site] 00730
47 Cmd::query_async [function] [call site] 00731
48 &mut [call site] 00732
49 Cmd::get_packed_command [function] [call site] 00733
49 MockRedisConnection::req_packed_command [function] [call site] 00734
49 as_slice [function] [call site] 00735
49 PipelineSink::poll_ready [function] [call site] 00736
49 types::test_parse_boxed [function] [call site] 00737
48 RedisResult::from_redis_value [function] [call site] 00739
49 from_redis_value [function] [call site] 00743
49 tests::into_redis_value_hashmap [function] [call site] 00744
48 Value::extract_error [function] [call site] 00746
49 Self::Array [function] [call site] 00748
49 Value::extract_error_vec [function] [call site] 00749
50 &'a [call site] 00750
50 std::iter::Chain::map [function] [call site] 00751
50 into_iter() [call site] 00752
6 .map(Self::extract_error) [call site] 00753
6 .collect::<RedisResult<Vec<_>>> [function] [call site] 00754
49 Self::Map [function] [call site] 00756
49 Value::extract_error_map [function] [call site] 00757
50 Cmd::with_capacity [function] [call site] 00758
51 Cmd::with_capacity [function] [call site] 00759
51 Cmd::with_capacity [function] [call site] 00760
50 basic::test_pipeline_len [function] [call site] 00761
50 &'a [call site] 00762
50 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00763
50 Value::extract_error [function] [call site] 00764
50 impl [call site] 00765
51 Self::Array [function] [call site] 00767
51 Value::extract_error_vec [function] [call site] 00768
51 Self::Map [function] [call site] 00770
51 Value::extract_error_map [function] [call site] 00771
51 RedisServer::new [function] [call site] 00772
52 RedisServer::with_modules [function] [call site] 00773
51 Value::extract_error [function] [call site] 00774
51 Value::extract_error_map [function] [call site] 00775
51 Self::Set [function] [call site] 00778
51 Value::extract_error_vec [function] [call site] 00779
51 Value::extract_error_vec [function] [call site] 00781
49 RedisServer::new [function] [call site] 00786
49 Value::extract_error [function] [call site] 00787
49 Value::extract_error_map [function] [call site] 00788
49 Self::Set [function] [call site] 00791
49 Value::extract_error_vec [function] [call site] 00792
49 Value::extract_error_vec [function] [call site] 00794
47 unwrap [function] [call site] 00798
47 hotkeys_cluster::setup_cluster_and_target [function] [call site] 00799
47 unwrap [function] [call site] 00800
47 RedisServer::drop [function] [call site] 00801
48 RedisServer::stop [function] [call site] 00802
49 ClusterClientBuilder::max_retry_wait [function] [call site] 00804
49 RedisServer::client_addr [function] [call site] 00805
49 fs::remove_file [function] [call site] 00806
49 tests::redis_ok [function] [call site] 00807
47 redis::cmd [function] [call site] 00808
47 redis::Cmd::arg [function] [call site] 00809
47 types::test_is_single_arg [function] [call site] 00810
47 Cmd::query_async [function] [call site] 00811
47 unwrap [function] [call site] 00812
47 hotkeys_cluster::setup_cluster_and_target [function] [call site] 00813
47 unwrap [function] [call site] 00814
47 Runtime::sleep [function] [call site] 00815
47 Duration::from_millis [function] [call site] 00816
47 into [function] [call site] 00817
47 basic::test_pubsub_unsubscribe [function] [call site] 00818
47 unwrap_err [function] [call site] 00819
46 basic::test_pubsub_unsubscribe [function] [call site] 00820
46 unwrap [function] [call site] 00821
46 TestContext::async_connection [function] [call site] 00822
46 unwrap [function] [call site] 00823
46 Runtime::sleep [function] [call site] 00824
46 Duration::from_millis [function] [call site] 00825
46 into [function] [call site] 00826
46 redis::cmd [function] [call site] 00827
46 redis::Cmd::arg [function] [call site] 00828
46 types::test_is_single_arg [function] [call site] 00829
46 Cmd::query_async [function] [call site] 00830
46 unwrap [function] [call site] 00831
46 hotkeys_cluster::setup_cluster_and_target [function] [call site] 00832
46 unwrap [function] [call site] 00833
46 RedisServer::drop [function] [call site] 00834
46 redis::cmd [function] [call site] 00835
46 redis::Cmd::arg [function] [call site] 00836
46 types::test_is_single_arg [function] [call site] 00837
46 Cmd::query_async [function] [call site] 00838
46 unwrap [function] [call site] 00839
46 hotkeys_cluster::setup_cluster_and_target [function] [call site] 00840
46 unwrap [function] [call site] 00841
46 Runtime::sleep [function] [call site] 00842
46 Duration::from_millis [function] [call site] 00843
46 into [function] [call site] 00844
46 basic::test_pubsub_unsubscribe [function] [call site] 00845
46 unwrap_err [function] [call site] 00846
45 tests::into_redis_value_hashmap [function] [call site] 00847
45 parse::<u16> [function] [call site] 00848
45 unwrap [function] [call site] 00849
45 collect [function] [call site] 00850
44 hotkeys_cluster::first_owned_slot_range [function] [call site] 00851
44 hotkeys_cluster::find_key_in_range [function] [call site] 00852
44 Some [function] [call site] 00853
42 is_none [function] [call site] 00854
42 Err [function] [call site] 00855
42 into [function] [call site] 00856
42 RedisServer::default [function] [call site] 00857
43 RedisServer::new [function] [call site] 00858
42 Self::with_factor [function] [call site] 00859
42 with_min_delay [function] [call site] 00860
42 with_max_times [function] [call site] 00861
42 with_jitter [function] [call site] 00862
42 with_max_delay [function] [call site] 00863
42 AsyncConnectionConfig::new [function] [call site] 00864
42 AsyncConnectionConfig::set_connection_timeout [function] [call site] 00865
42 AsyncConnectionConfig::set_response_timeout [function] [call site] 00866
42 as_ref [function] [call site] 00867
42 tests::into_redis_value_hashmap [function] [call site] 00868
42 CacheManager::new [function] [call site] 00869
43 RedisServer::new [function] [call site] 00870
43 ShardedLRU::new [function] [call site] 00871
44 hotkeys_cluster::setup_cluster_and_target [function] [call site] 00872
45 TestClusterContext::new [function] [call site] 00873
45 TestClusterContext::wait_for_cluster_up [function] [call site] 00874
45 RedisCluster::iter_servers [function] [call site] 00875
45 MapIter::next [function] [call site] 00876
45 RedisServer::connection_info [function] [call site] 00878
45 hotkeys_cluster::port_of [function] [call site] 00879
45 redis::ConnectionInfo::addr [function] [call site] 00880
45 hotkeys_cluster::direct_connection [function] [call site] 00881
45 redis::ConnectionInfo::clone [function] [call site] 00882
45 redis::Cmd::new [function] [call site] 00883
45 types::test_is_single_arg [function] [call site] 00884
45 basic::test_pipeline_reuse_query [function] [call site] 00885
45 parse_version [function] [call site] 00887
45 hotkeys_cluster::first_owned_slot_range [function] [call site] 00888
45 hotkeys_cluster::find_key_in_range [function] [call site] 00889
44 hotkeys_cluster::setup_cluster_and_target [function] [call site] 00891
44 hotkeys_cluster::setup_cluster_and_target [function] [call site] 00892
44 Cmd::with_capacity [function] [call site] 00893
44 RedisServer::new [function] [call site] 00894
45 RedisServer::with_modules [function] [call site] 00895
44 RedisServer::new [function] [call site] 00896
45 RedisServer::with_modules [function] [call site] 00897
44 RedisServer::unwrap [function] [call site] 00898
44 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00899
45 TestContext::new [function] [call site] 00900
45 ProtocolVersion::supports_resp3 [function] [call site] 00901
45 tokio::sync::mpsc::unbounded_channel [function] [call site] 00902
45 redis::aio::ConnectionManagerConfig::new [function] [call site] 00903
45 AsyncConnectionConfig::set_push_sender [function] [call site] 00904
45 Client::get_connection_manager_lazy [function] [call site] 00905
45 tests::into_redis_value_hashset [function] [call site] 00907
46 ValueType::from [function] [call site] 00908
46 String::into_redis_value [function] [call site] 00909
46 Value::into_sequence [function] [call site] 00910
46 Result::expect [function] [call site] 00911
45 MockConnection::send_packed_command [function] [call site] 00915
45 Cmd::arg [function] [call site] 00918
45 types::test_is_single_arg [function] [call site] 00919
45 hotkeys_cluster::setup_cluster_and_target [function] [call site] 00921
45 tests::into_redis_value_hashset [function] [call site] 00923
45 Pipeline::send_recv [function] [call site] 00925
46 MockRedisConnection::is_empty [function] [call site] 00926
47 StreamReadOptions::block [function] [call site] 00927
47 MockRedisConnection::is_empty [function] [call site] 00929
46 RedisError::make_empty_command [function] [call site] 00931
47 ErrorRepr::General [function] [call site] 00932
46 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 00933
46 Msg::get_channel [function] [call site] 00936
47 from_redis_value_ref [function] [call site] 00938
46 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 00939
46 and_then [function] [call site] 00943
46 Runtime::locate [function] [call site] 00945
46 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 00946
47 TestSentinelContext::new [function] [call site] 00947
48 TestSentinelContext::new_with_cluster_client_builder [function] [call site] 00948
49 support::start_tls_crypto_provider [function] [call site] 00949
49 RedisSentinelCluster::new [function] [call site] 00950
50 RedisSentinelCluster::with_modules [function] [call site] 00951
51 tempfile::Builder::new [function] [call site] 00952
51 RedisResult::prefix [function] [call site] 00953
51 { [call site] 00956
0 server::build_keys_and_certs_for_tls [function] [call site] 00957
52 build_keys_and_certs_for_tls_ext [function] [call site] 00958
53 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00959
53 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00961
53 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00963
53 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00965
53 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00967
53 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00969
53 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::e::x::t::make_key [function] [call site] 00971
54 process::Command::new [function] [call site] 00972
54 types::test_is_single_arg [function] [call site] 00973
54 types::test_is_single_arg [function] [call site] 00974
54 types::test_is_single_arg [function] [call site] 00975
54 types::test_is_single_arg [function] [call site] 00976
54 process::Stdio::piped [function] [call site] 00978
54 process::Stdio::piped [function] [call site] 00980
54 ClusterClientBuilder::max_retry_wait [function] [call site] 00983
53 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::e::x::t::make_key [function] [call site] 00985
53 process::Command::new [function] [call site] 00986
53 types::test_is_single_arg [function] [call site] 00987
53 types::test_is_single_arg [function] [call site] 00988
53 types::test_is_single_arg [function] [call site] 00989
53 types::test_is_single_arg [function] [call site] 00990
53 types::test_is_single_arg [function] [call site] 00991
53 types::test_is_single_arg [function] [call site] 00992
53 types::test_is_single_arg [function] [call site] 00993
53 types::test_is_single_arg [function] [call site] 00994
53 types::test_is_single_arg [function] [call site] 00995
53 types::test_is_single_arg [function] [call site] 00996
53 types::test_is_single_arg [function] [call site] 00997
53 types::test_is_single_arg [function] [call site] 00998
53 types::test_is_single_arg [function] [call site] 00999
53 process::Stdio::piped [function] [call site] 01001
53 process::Stdio::piped [function] [call site] 01003
53 ClusterClientBuilder::max_retry_wait [function] [call site] 01006
53 Tokio::poll_write [function] [call site] 01008
54 RedisServer::new [function] [call site] 01009
55 RedisServer::with_modules [function] [call site] 01010
54 Tokio::poll_write [function] [call site] 01011
55 RedisServer::new [function] [call site] 01012
55 Tokio::poll_write [function] [call site] 01013
55 RedisServer::new [function] [call site] 01014
55 Tokio::poll_write [function] [call site] 01015
55 RedisServer::new [function] [call site] 01016
55 Tokio::poll_write [function] [call site] 01017
54 RedisServer::new [function] [call site] 01018
54 Tokio::poll_write [function] [call site] 01019
54 RedisServer::new [function] [call site] 01020
54 Tokio::poll_write [function] [call site] 01021
53 Poll::expect [function] [call site] 01022
53 process::Command::new [function] [call site] 01023
53 types::test_is_single_arg [function] [call site] 01024
53 types::test_is_single_arg [function] [call site] 01025
53 types::test_is_single_arg [function] [call site] 01026
53 types::test_is_single_arg [function] [call site] 01027
53 types::test_is_single_arg [function] [call site] 01028
53 types::test_is_single_arg [function] [call site] 01029
53 types::test_is_single_arg [function] [call site] 01030
53 process::Stdio::piped [function] [call site] 01032
53 process::Stdio::piped [function] [call site] 01034
53 process::Command::new [function] [call site] 01037
53 types::test_is_single_arg [function] [call site] 01038
53 types::test_is_single_arg [function] [call site] 01039
53 types::test_is_single_arg [function] [call site] 01040
53 types::test_is_single_arg [function] [call site] 01041
53 types::test_is_single_arg [function] [call site] 01042
53 types::test_is_single_arg [function] [call site] 01043
53 types::test_is_single_arg [function] [call site] 01044
53 types::test_is_single_arg [function] [call site] 01045
53 types::test_is_single_arg [function] [call site] 01046
53 types::test_is_single_arg [function] [call site] 01047
53 types::test_is_single_arg [function] [call site] 01048
53 types::test_is_single_arg [function] [call site] 01049
53 types::test_is_single_arg [function] [call site] 01050
53 types::test_is_single_arg [function] [call site] 01051
53 types::test_is_single_arg [function] [call site] 01052
53 types::test_is_single_arg [function] [call site] 01053
53 types::test_is_single_arg [function] [call site] 01054
53 types::test_is_single_arg [function] [call site] 01055
53 Cmd::take [function] [call site] 01057
54 std::mem::take [function] [call site] 01058
55 std::mem::take [function] [call site] 01059
53 ClusterClientBuilder::max_retry_wait [function] [call site] 01063
53 ClusterClientBuilder::max_retry_wait [function] [call site] 01065
51 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 01067
51 std::collections::HashSet::new [function] [call site] 01068
51 basic::test_pipeline_len [function] [call site] 01069
52 redis::pipe [function] [call site] 01070
52 types::test_is_single_arg [function] [call site] 01073
51 RedisServer::insert [function] [call site] 01074
52 TestContext::with_modules [function] [call site] 01075
52 TestContext::connection [function] [call site] 01076
52 redis::Connection::json_set [function] [call site] 01077
53 TestContext::with_modules [function] [call site] 01078
53 TestContext::connection [function] [call site] 01079
53 redis::Connection::json_set [function] [call site] 01080
52 redis::Connection::json_arr_insert [function] [call site] 01081
53 TestContext::with_modules [function] [call site] 01082
53 TestContext::connection [function] [call site] 01083
53 redis::Connection::json_set [function] [call site] 01084
53 redis::Connection::json_arr_insert [function] [call site] 01085
53 redis::Connection::json_set [function] [call site] 01086
53 redis::Connection::json_arr_insert [function] [call site] 01087
52 redis::Connection::json_set [function] [call site] 01088
52 redis::Connection::json_arr_insert [function] [call site] 01089
51 get_random_available_port [function] [call site] 01090
52 get_listener_on_free_port [function] [call site] 01091
52 TcpListener::local_addr [function] [call site] 01092
52 get_listener_on_free_port [function] [call site] 01094
51 &'a [call site] 01095
52 std::iter::once [function] [call site] 01096
52 basic::test_tuple_decoding_from_iter [function] [call site] 01098
51 std::iter::Chain::collect [function] [call site] 01099
51 RedisServer::pop [function] [call site] 01100
52 TestContext::with_modules [function] [call site] 01101
52 TestContext::connection [function] [call site] 01102
52 redis::Connection::json_set [function] [call site] 01103
52 redis::Connection::json_arr_pop [function] [call site] 01104
53 TestContext::with_modules [function] [call site] 01105
53 TestContext::connection [function] [call site] 01106
53 redis::Connection::json_set [function] [call site] 01107
53 redis::Connection::json_arr_pop [function] [call site] 01108
53 redis::Connection::json_set [function] [call site] 01109
53 redis::Connection::json_arr_pop [function] [call site] 01110
52 redis::Connection::json_set [function] [call site] 01111
52 redis::Connection::json_arr_pop [function] [call site] 01112
51 unwrap [function] [call site] 01113
51 tempfile::Builder::new [function] [call site] 01114
51 RedisResult::prefix [function] [call site] 01115
51 tempdir [function] [call site] 01116
51 expect [function] [call site] 01117
51 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 01118
52 TestContext::new [function] [call site] 01119
52 ProtocolVersion::supports_resp3 [function] [call site] 01120
52 tokio::sync::mpsc::unbounded_channel [function] [call site] 01121
52 redis::aio::ConnectionManagerConfig::new [function] [call site] 01122
52 AsyncConnectionConfig::set_push_sender [function] [call site] 01123
52 Client::get_connection_manager_lazy [function] [call site] 01124
52 tests::into_redis_value_hashset [function] [call site] 01126
52 MockConnection::send_packed_command [function] [call site] 01128
52 Cmd::arg [function] [call site] 01130
52 types::test_is_single_arg [function] [call site] 01131
52 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01133
52 tests::into_redis_value_hashset [function] [call site] 01135
52 Pipeline::send_recv [function] [call site] 01137
51 spawn_master_server [function] [call site] 01139
52 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 01140
52 get_addr [function] [call site] 01141
53 RedisServer::get_addr [function] [call site] 01142
53 ConnectionAddr::Tcp [function] [call site] 01143
53 String::from [function] [call site] 01144
54 ValueComparison::arg_to_string [function] [call site] 01145
54 ValueComparison::arg_to_string [function] [call site] 01146
54 ValueComparison::arg_to_string [function] [call site] 01147
54 ValueComparison::arg_to_string [function] [call site] 01148
54 ValueComparison::arg_to_string [function] [call site] 01149
54 ValueComparison::arg_to_string [function] [call site] 01150
54 ValueComparison::arg_to_string [function] [call site] 01151
54 ValueComparison::arg_to_string [function] [call site] 01152
54 ValueComparison::arg_to_string [function] [call site] 01153
54 ValueComparison::arg_to_string [function] [call site] 01154
54 ValueComparison::arg_to_string [function] [call site] 01155
54 ValueComparison::arg_to_string [function] [call site] 01156
54 ValueComparison::arg_to_string [function] [call site] 01157
54 ValueComparison::arg_to_string [function] [call site] 01158
54 ValueComparison::arg_to_string [function] [call site] 01159
54 ValueComparison::arg_to_string [function] [call site] 01160
54 ValueComparison::arg_to_string [function] [call site] 01161
52 ClientTlsParams::clone [function] [call site] 01163
53 ClientTlsParams::clone [function] [call site] 01164
53 secret_pkcs1_der [function] [call site] 01166
53 write_command_to_vec [function] [call site] 01167
53 secret_pkcs8_der [function] [call site] 01170
53 write_command_to_vec [function] [call site] 01171
53 secret_sec1_der [function] [call site] 01174
53 write_command_to_vec [function] [call site] 01175
52 Cmd::arg [function] [call site] 01177
52 types::test_is_single_arg [function] [call site] 01178
52 get_addr [function] [call site] 01179
52 Cmd::arg [function] [call site] 01180
52 types::test_is_single_arg [function] [call site] 01181
52 Cmd::current_dir [function] [call site] 01182
52 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01183
52 Cmd::spawn [function] [call site] 01184
53 tokio::runtime::Handle::try_current [function] [call site] 01185
53 smol::spawn [function] [call site] 01187
53 TaskHandle::detach [function] [call site] 01188
51 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 01190
51 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 01191
51 RedisServer::pop [function] [call site] 01192
51 unwrap [function] [call site] 01193
51 tempfile::Builder::new [function] [call site] 01194
51 RedisResult::prefix [function] [call site] 01195
51 tempdir [function] [call site] 01196
51 expect [function] [call site] 01197
51 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 01198
51 spawn_replica_server [function] [call site] 01199
52 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01200
52 File::create [function] [call site] 01202
53 TestContext::new [function] [call site] 01203
53 TestContext::connection [function] [call site] 01204
53 xadd [function] [call site] 01205
54 &mut [call site] 01206
55 &mut [call site] 01207
55 &mut [call site] 01209
55 &mut [call site] 01211
55 &mut [call site] 01213
54 &mut [call site] 01216
54 &mut [call site] 01218
54 &mut [call site] 01220
53 redis::Connection::xinfo_stream [function] [call site] 01222
53 TestContext::connection [function] [call site] 01223
53 redis::Connection::xinfo_stream [function] [call site] 01224
53 redis::Connection::xgroup_create [function] [call site] 01226
54 TestContext::new [function] [call site] 01227
54 TestContext::connection [function] [call site] 01228
54 redis::Connection::xinfo_stream [function] [call site] 01230
54 TestContext::connection [function] [call site] 01231
54 redis::Connection::xinfo_stream [function] [call site] 01232
54 redis::Connection::xgroup_create [function] [call site] 01234
54 redis::Connection::xinfo_groups [function] [call site] 01235
53 redis::Connection::xinfo_groups [function] [call site] 01237
52 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 01240
52 get_addr [function] [call site] 01241
52 ClientTlsParams::clone [function] [call site] 01244
52 Cmd::arg [function] [call site] 01245
52 types::test_is_single_arg [function] [call site] 01246
52 types::test_is_single_arg [function] [call site] 01247
52 ValueComparison::arg_to_string [function] [call site] 01248
53 impl [call site] 01249
53 String::from_utf8_lossy [function] [call site] 01250
53 into_owned [function] [call site] 01251
52 get_addr [function] [call site] 01252
52 Cmd::arg [function] [call site] 01253
52 types::test_is_single_arg [function] [call site] 01254
52 Cmd::current_dir [function] [call site] 01255
52 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01256
52 Cmd::spawn [function] [call site] 01257
51 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 01259
51 RedisServer::pop [function] [call site] 01260
51 unwrap [function] [call site] 01261
51 tempfile::Builder::new [function] [call site] 01262
51 RedisResult::prefix [function] [call site] 01263
51 tempdir [function] [call site] 01264
51 expect [function] [call site] 01265
51 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 01266
51 spawn_sentinel_server [function] [call site] 01267
52 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01268
52 File::create [function] [call site] 01270
52 basic::test_tuple_decoding_from_iter [function] [call site] 01272
53 TestContext::new [function] [call site] 01273
53 TestContext::connection [function] [call site] 01274
53 ValueType::from [function] [call site] 01275
53 basic::test_tuple_decoding_from_iter [function] [call site] 01276
53 hscan::<_, [call site] 01277
52 enumerate [function] [call site] 01280
52 PathBuf::write_all [function] [call site] 01281
52 as_bytes [function] [call site] 01282
52 PipelineSink::poll_flush [function] [call site] 01284
53 PipelineSink::poll_read [function] [call site] 01285
54 PipelineSink::as_mut [function] [call site] 01286
54 ResultExpectation::is_closed [function] [call site] 01288
55 ResultExpectation::is_closed [function] [call site] 01289
56 ResultExpectation::is_closed [function] [call site] 01290
54 Poll::Ready [function] [call site] 01291
54 Poll::Ready [function] [call site] 01293
54 PipelineSink::as_mut [function] [call site] 01295
54 PipelineSink::handle_message [function] [call site] 01296
55 PipelineSink::project [function] [call site] 01297
55 impl [call site] 01298
55 pop_front [function] [call site] 01299
55 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01300
55 Value::Array [function] [call site] 01302
55 Msg::from_owned_value [function] [call site] 01304
56 Msg::from_push_info [function] [call site] 01305
57 &'a [call site] 01306
57 MapIter::next [function] [call site] 01307
57 MapIter::next [function] [call site] 01308
57 MapIter::next [function] [call site] 01310
57 MapIter::next [function] [call site] 01311
57 MapIter::next [function] [call site] 01312
56 from_redis_value [function] [call site] 01314
56 tests::redis_ok [function] [call site] 01315
56 &'a [call site] 01316
56 from_redis_value [function] [call site] 01317
56 MapIter::next [function] [call site] 01318
56 tests::redis_ok [function] [call site] 01319
56 MapIter::next [function] [call site] 01320
56 MapIter::next [function] [call site] 01321
56 MapIter::next [function] [call site] 01323
56 MapIter::next [function] [call site] 01324
56 MapIter::next [function] [call site] 01325
55 Value::Array [function] [call site] 01327
55 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01328
55 PushKind::has_reply [function] [call site] 01331
55 pop_front [function] [call site] 01332
55 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01333
55 Msg::from_push_info [function] [call site] 01336
56 &'a [call site] 01337
56 MapIter::next [function] [call site] 01338
56 MapIter::next [function] [call site] 01339
56 MapIter::next [function] [call site] 01341
56 MapIter::next [function] [call site] 01342
56 MapIter::next [function] [call site] 01343
55 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01345
55 RedisError::is_unrecoverable_error [function] [call site] 01348
56 RedisError::retry_method [function] [call site] 01349
57 RedisError::kind [function] [call site] 01350
58 get_push_kind [function] [call site] 01351
59 PushKind::as_str [function] [call site] 01352
59 PushKind::Other [function] [call site] 01353
58 ErrorKind::Server [function] [call site] 01354
58 Replicas::first [function] [call site] 01355
58 and_then [function] [call site] 01356
58 get_push_kind [function] [call site] 01357
58 tests::into_redis_value_hashmap [function] [call site] 01358
58 PushKind::into [function] [call site] 01359
58 unwrap_or [function] [call site] 01360
58 ErrorKind::Server [function] [call site] 01361
57 RedisError::retry_method [function] [call site] 01362
58 RedisError::kind [function] [call site] 01363
58 RedisError::retry_method [function] [call site] 01364
58 RedisError::is_connection_dropped [function] [call site] 01365
59 RedisError::as_io_error [function] [call site] 01366
60 downcast_ref [function] [call site] 01367
59 Option::is_some_and [function] [call site] 01368
58 RedisError::as_io_error [function] [call site] 01369
58 tests::into_redis_value_hashmap [function] [call site] 01370
59 ValueType::from [function] [call site] 01371
59 String::into_redis_value [function] [call site] 01372
59 Value::into_map_iter [function] [call site] 01373
59 Result::expect [function] [call site] 01374
59 into_map_iter() [call site] 01375
6 .expect("extracting [call site] 01376
6 .collect::<Vec<(Value, [call site] 01377
58 get_push_kind [function] [call site] 01380
58 unwrap_or [function] [call site] 01381
57 RedisError::is_connection_dropped [function] [call site] 01382
57 RedisError::as_io_error [function] [call site] 01383
57 tests::into_redis_value_hashmap [function] [call site] 01384
57 get_push_kind [function] [call site] 01385
57 unwrap_or [function] [call site] 01386
55 Err [function] [call site] 01387
55 pop_front [function] [call site] 01388
55 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01389
55 Ok [function] [call site] 01390
55 Err [function] [call site] 01391
52 Poll::unwrap [function] [call site] 01392
52 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 01393
52 get_addr [function] [call site] 01394
52 Some [function] [call site] 01395
52 Some [function] [call site] 01396
52 ClientTlsParams::clone [function] [call site] 01397
52 Cmd::arg [function] [call site] 01398
52 get_addr [function] [call site] 01399
52 Cmd::arg [function] [call site] 01400
52 types::test_is_single_arg [function] [call site] 01401
52 Cmd::current_dir [function] [call site] 01402
52 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01403
52 Cmd::spawn [function] [call site] 01404
52 unwrap [function] [call site] 01405
51 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 01406
51 wait_for_replicas_to_sync [function] [call site] 01407
52 basic::test_pipeline_len [function] [call site] 01408
53 redis::pipe [function] [call site] 01409
53 types::test_is_single_arg [function] [call site] 01412
52 basic::test_pipeline_len [function] [call site] 01413
52 RedisServer::connection_info [function] [call site] 01414
53 RedisServer::client_addr [function] [call site] 01415
53 &redis::ConnectionAddr::clone [function] [call site] 01416
53 ConnectionInfo::into_connection_info [function] [call site] 01417
53 RedisResult::unwrap [function] [call site] 01418
53 ConnectionInfo::set_redis_settings [function] [call site] 01419
53 redis_settings [function] [call site] 01420
52 wait_for_master_server [function] [call site] 01421
53 redis::cmd [function] [call site] 01422
53 Client::get_connection [function] [call site] 01423
53 redis::Cmd::query [function] [call site] 01424
54 ConnectionLike::req_command [function] [call site] 01425
55 Cmd::get_packed_command [function] [call site] 01426
55 MockRedisConnection::req_packed_command [function] [call site] 01427
56 Cmd::get_packed_command [function] [call site] 01428
56 MockRedisConnection::req_packed_command [function] [call site] 01429
56 as_slice [function] [call site] 01430
56 PipelineSink::poll_ready [function] [call site] 01431
56 types::test_parse_boxed [function] [call site] 01432
54 RedisResult::from_redis_value [function] [call site] 01434
54 Value::extract_error [function] [call site] 01435
53 RedisResult::unwrap [function] [call site] 01437
53 String::from_redis_value_ref [function] [call site] 01438
54 get_inner_value [function] [call site] 01439
54 std::str::from_utf8 [function] [call site] 01442
54 ValueComparison::arg_to_string [function] [call site] 01443
55 impl [call site] 01444
55 String::from_utf8_lossy [function] [call site] 01445
55 into_owned [function] [call site] 01446
54 ValueComparison::arg_to_string [function] [call site] 01448
54 ValueComparison::arg_to_string [function] [call site] 01450
54 ValueComparison::arg_to_string [function] [call site] 01452
54 ValueComparison::arg_to_string [function] [call site] 01454
54 ValueComparison::arg_to_string [function] [call site] 01456
53 Replicas::first [function] [call site] 01457
53 &'a [call site] 01458
53 Result::unwrap [function] [call site] 01459
53 starts_with [function] [call site] 01460
53 get_connection_info [function] [call site] 01462
54 get_connection_addr [function] [call site] 01463
55 ConnectionAddr::Tcp [function] [call site] 01464
54 get_default_host [function] [call site] 01465
55 ValueComparison::arg_to_string [function] [call site] 01466
54 ValueComparison::arg_to_string [function] [call site] 01467
55 impl [call site] 01468
55 String::from_utf8_lossy [function] [call site] 01469
55 into_owned [function] [call site] 01470
54 get_listener_on_free_port [function] [call site] 01471
54 ClientTlsParams::clone [function] [call site] 01472
54 ClientTlsParams::clone [function] [call site] 01473
54 ClientTlsParams::clone [function] [call site] 01474
54 unwrap_or_default [function] [call site] 01475
54 RedisServer::default [function] [call site] 01476
54 ClientTlsParams::clone [function] [call site] 01477
53 ConnectionInfo::addr [function] [call site] 01478
53 RedisSentinelCluster::log_redis_state_via_cli [function] [call site] 01479
54 RedisServer::new [function] [call site] 01480
55 RedisServer::with_modules [function] [call site] 01481
54 types::test_std_types_to_redis_args [function] [call site] 01482
54 ValueComparison::arg_to_string [function] [call site] 01483
55 impl [call site] 01484
55 String::from_utf8_lossy [function] [call site] 01485
55 into_owned [function] [call site] 01486
54 MockRedisConnection::is_empty [function] [call site] 01488
53 std::thread::sleep [function] [call site] 01489
53 Duration::from_millis [function] [call site] 01490
52 redis::Client::open [function] [call site] 01492
52 ClientTlsParams::clone [function] [call site] 01493
52 ConnectionAddr::is_err [function] [call site] 01495
53 is_unexpected_end_of_input [function] [call site] 01497
53 RedisError::from [function] [call site] 01498
53 io::Error::from [function] [call site] 01499
53 map_range [function] [call site] 01500
53 map_position [function] [call site] 01501
53 translate_position [function] [call site] 01502
53 to_string [function] [call site] 01504
53 RedisError::from [function] [call site] 01505
53 ParsingError::from [function] [call site] 01506
52 RedisSentinelCluster::log_sentinel_state_via_cli [function] [call site] 01507
53 Replicas::first [function] [call site] 01508
53 &redis::sentinel::Sentinel::host_and_port [function] [call site] 01509
53 RedisServer::new [function] [call site] 01512
53 types::test_std_types_to_redis_args [function] [call site] 01513
53 ValueComparison::arg_to_string [function] [call site] 01514
53 MockRedisConnection::is_empty [function] [call site] 01516
53 RedisServer::new [function] [call site] 01517
53 types::test_std_types_to_redis_args [function] [call site] 01518
53 ValueComparison::arg_to_string [function] [call site] 01519
53 MockRedisConnection::is_empty [function] [call site] 01521
53 RedisServer::new [function] [call site] 01522
53 types::test_std_types_to_redis_args [function] [call site] 01523
53 ValueComparison::arg_to_string [function] [call site] 01524
53 MockRedisConnection::is_empty [function] [call site] 01526
52 RedisServer::connection_info [function] [call site] 01527
52 wait_for_replica [function] [call site] 01528
53 redis::cmd [function] [call site] 01529
53 Client::get_connection [function] [call site] 01530
53 redis::Cmd::query [function] [call site] 01531
53 RedisResult::unwrap [function] [call site] 01532
53 String::from_redis_value_ref [function] [call site] 01533
53 Replicas::first [function] [call site] 01534
53 &'a [call site] 01535
53 Result::unwrap [function] [call site] 01536
53 String::from_redis_value_ref [function] [call site] 01537
53 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01538
54 TestClusterContext::new [function] [call site] 01539
54 TestClusterContext::wait_for_cluster_up [function] [call site] 01540
54 RedisCluster::iter_servers [function] [call site] 01541
54 MapIter::next [function] [call site] 01542
54 RedisServer::connection_info [function] [call site] 01544
54 hotkeys_cluster::port_of [function] [call site] 01545
54 redis::ConnectionInfo::addr [function] [call site] 01546
54 hotkeys_cluster::direct_connection [function] [call site] 01547
54 redis::ConnectionInfo::clone [function] [call site] 01548
54 redis::Cmd::new [function] [call site] 01549
54 types::test_is_single_arg [function] [call site] 01550
54 basic::test_pipeline_reuse_query [function] [call site] 01551
54 parse_version [function] [call site] 01553
54 hotkeys_cluster::first_owned_slot_range [function] [call site] 01554
54 hotkeys_cluster::find_key_in_range [function] [call site] 01555
53 Option::unwrap [function] [call site] 01557
53 Result::unwrap [function] [call site] 01558
53 starts_with [function] [call site] 01559
53 get_connection_info [function] [call site] 01561
53 ConnectionInfo::addr [function] [call site] 01562
53 RedisSentinelCluster::log_redis_state_via_cli [function] [call site] 01563
53 std::thread::sleep [function] [call site] 01564
53 Duration::from_millis [function] [call site] 01565
52 redis::Client::open [function] [call site] 01567
52 ClientTlsParams::clone [function] [call site] 01568
52 ConnectionAddr::is_err [function] [call site] 01570
52 RedisSentinelCluster::log_sentinel_state_via_cli [function] [call site] 01571
49 RedisSentinelCluster::iter_sentinel_servers [function] [call site] 01572
50 basic::test_tuple_decoding_from_iter [function] [call site] 01573
49 tests::into_redis_value_hashmap [function] [call site] 01574
50 ValueType::from [function] [call site] 01575
50 String::into_redis_value [function] [call site] 01576
50 Value::into_map_iter [function] [call site] 01577
50 Result::expect [function] [call site] 01578
50 into_map_iter() [call site] 01579
6 .expect("extracting [call site] 01580
6 .collect::<Vec<(Value, [call site] 01581
49 collect [function] [call site] 01584
49 redis::sentinel::Sentinel::build [function] [call site] 01585
50 Sentinel::build_inner [function] [call site] 01586
51 MockRedisConnection::is_empty [function] [call site] 01587
52 StreamReadOptions::block [function] [call site] 01588
52 MockRedisConnection::is_empty [function] [call site] 01590
51 &'a [call site] 01592
52 std::iter::once [function] [call site] 01593
52 basic::test_tuple_decoding_from_iter [function] [call site] 01595
51 std::iter::Chain::map [function] [call site] 01596
51 ConnectionInfo::into_connection_info [function] [call site] 01597
51 into_iter() [call site] 01599
6 .map(|p| [call site] 01600
6 .collect::<RedisResult<Vec<ConnectionInfo>>> [function] [call site] 01601
51 basic::test_tuple_decoding_from_iter [function] [call site] 01602
52 TestContext::new [function] [call site] 01603
52 TestContext::connection [function] [call site] 01604
52 ValueType::from [function] [call site] 01605
52 basic::test_tuple_decoding_from_iter [function] [call site] 01606
52 hscan::<_, [call site] 01607
51 cluster::test_cluster_reconnect_after_complete_server_disconnect_route_to_many [function] [call site] 01610
52 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 01611
52 cluster::test_cluster_retries [function] [call site] 01612
53 atomic::AtomicUsize::new [function] [call site] 01613
54 RedisServer::with_modules [function] [call site] 01614
53 MockEnv::with_client_builder [function] [call site] 01615
54 tokio::runtime::Builder::new_current_thread [function] [call site] 01616
54 enable_io [function] [call site] 01617
54 enable_time [function] [call site] 01618
54 Sentinel::build [function] [call site] 01619
55 Sentinel::build_inner [function] [call site] 01620
54 ValueComparison::arg_to_string [function] [call site] 01622
54 Tokio::poll_write [function] [call site] 01623
55 RedisServer::new [function] [call site] 01624
55 Tokio::poll_write [function] [call site] 01625
55 RedisServer::new [function] [call site] 01626
55 Tokio::poll_write [function] [call site] 01627
55 RedisServer::new [function] [call site] 01628
55 Tokio::poll_write [function] [call site] 01629
54 test_module_json_arr_insert [function] [call site] 01631
55 TestContext::with_modules [function] [call site] 01632
55 TestContext::connection [function] [call site] 01633
55 redis::Connection::json_set [function] [call site] 01634
55 redis::Connection::json_arr_insert [function] [call site] 01635
55 redis::Connection::json_set [function] [call site] 01636
55 redis::Connection::json_arr_insert [function] [call site] 01637
54 ClientTlsParams::clone [function] [call site] 01638
54 RedisServer::new [function] [call site] 01639
54 Sentinel::build [function] [call site] 01640
54 RedisResult::unwrap [function] [call site] 01641
54 ClusterClient::get_generic_connection [function] [call site] 01642
55 cluster::ClusterConnection::new [function] [call site] 01643
56 ClusterConnection::new_inner [function] [call site] 01644
57 unwrap_or_default [function] [call site] 01645
57 ClientTlsParams::clone [function] [call site] 01646
57 Runtime::locate [function] [call site] 01647
57 ClusterConnInner::new [function] [call site] 01648
58 RedisServer::new [function] [call site] 01651
59 RedisServer::with_modules [function] [call site] 01652
58 RedisServer::default [function] [call site] 01653
59 RedisServer::new [function] [call site] 01654
58 tests::into_redis_value_hashmap [function] [call site] 01656
58 T::create_strategy [function] [call site] 01657
59 RedisServer::new [function] [call site] 01658
59 RedisServer::default [function] [call site] 01659
60 RedisServer::new [function] [call site] 01660
58 mpsc::unbounded_channel [function] [call site] 01661
58 RedisServer::new [function] [call site] 01662
58 RedisServer::new [function] [call site] 01663
59 RedisServer::with_modules [function] [call site] 01664
58 RedisServer::default [function] [call site] 01665
58 SlotMap::new [function] [call site] 01666
59 RedisServer::default [function] [call site] 01667
58 write_command_to_vec [function] [call site] 01668
58 ClientTlsParams::clone [function] [call site] 01670
59 ClientTlsParams::clone [function] [call site] 01671
59 secret_pkcs1_der [function] [call site] 01673
59 write_command_to_vec [function] [call site] 01674
59 secret_pkcs8_der [function] [call site] 01677
59 write_command_to_vec [function] [call site] 01678
59 secret_sec1_der [function] [call site] 01681
59 write_command_to_vec [function] [call site] 01682
58 RedisServer::default [function] [call site] 01684
58 ConnectionState::Recover [function] [call site] 01685
58 RecoverFuture::Reconnect [function] [call site] 01686
58 Box::pin [function] [call site] 01687
58 ClusterConnInner::reconnect_to_initial_nodes [function] [call site] 01688
59 ClientTlsParams::clone [function] [call site] 01689
59 ClusterConnection::create_initial_connections [function] [call site] 01690
60 Cmd::with_capacity [function] [call site] 01691
61 Cmd::with_capacity [function] [call site] 01692
61 Cmd::with_capacity [function] [call site] 01693
60 basic::test_pipeline_len [function] [call site] 01694
60 RedisServer::new [function] [call site] 01695
60 basic::test_tuple_decoding_from_iter [function] [call site] 01696
60 NodeAddress::try_from [function] [call site] 01697
61 NodeAddress::new [function] [call site] 01699
62 NodeAddress::from_parts [function] [call site] 01700
62 String::into [function] [call site] 01701
61 String::as_str [function] [call site] 01702
61 RedisError::from [function] [call site] 01704
62 io::Error::from [function] [call site] 01705
63 io::Error::from [function] [call site] 01706
63 Self::into [function] [call site] 01707
62 Self::into [function] [call site] 01708
60 ClusterConnection::connect [function] [call site] 01709
61 Client::get_connection_info [function] [call site] 01710
61 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 01711
62 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 01712
62 cluster::test_cluster_retries [function] [call site] 01713
62 TestClusterContext::get_ports [function] [call site] 01714
63 basic::test_tuple_decoding_from_iter [function] [call site] 01715
63 tests::into_redis_value_hashmap [function] [call site] 01716
63 redis::ConnectionInfo::addr [function] [call site] 01717
62 MockRedisConnection::check_connection [function] [call site] 01719
62 RedisServer::drop [function] [call site] 01720
62 ClusterConnection::route_command [function] [call site] 01722
63 Msg::get_channel [function] [call site] 01723
63 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01724
63 RedisServer::new [function] [call site] 01725
63 RedisError::from [function] [call site] 01728
63 io::Error::new [function] [call site] 01729
64 RedisServer::with_modules [function] [call site] 01730
63 unwrap_or_else [function] [call site] 01731
63 RedisError::from [function] [call site] 01733
63 io::Error::new [function] [call site] 01734
63 tests::into_redis_value_hashmap [function] [call site] 01735
63 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 01736
64 TestSentinelContext::new [function] [call site] 01737
64 SentinelClient::build [function] [call site] 01738
65 Sentinel::build_inner [function] [call site] 01739
64 TestSentinelContext::sentinels_connection_info [function] [call site] 01740
64 ClientTlsParams::clone [function] [call site] 01741
65 ClientTlsParams::clone [function] [call site] 01742
65 secret_pkcs1_der [function] [call site] 01744
65 write_command_to_vec [function] [call site] 01745
65 secret_pkcs8_der [function] [call site] 01748
65 write_command_to_vec [function] [call site] 01749
65 secret_sec1_der [function] [call site] 01752
65 write_command_to_vec [function] [call site] 01753
64 String::from [function] [call site] 01755
64 TestSentinelContext::sentinel_node_connection_info [function] [call site] 01757
65 TestSentinelContext::tls_mode [function] [call site] 01758
66 RedisServer::client_addr [function] [call site] 01759
65 &SentinelNodeConnectionInfo::default [function] [call site] 01762
65 SentinelNodeConnectionInfo::set_tls_mode [function] [call site] 01763
65 &SentinelNodeConnectionInfo::default [function] [call site] 01765
64 RedisResult::unwrap [function] [call site] 01766
64 SentinelClient::build [function] [call site] 01767
64 TestSentinelContext::sentinels_connection_info [function] [call site] 01768
64 ClientTlsParams::clone [function] [call site] 01769
64 String::from [function] [call site] 01770
64 TestSentinelContext::sentinel_node_connection_info [function] [call site] 01772
64 RedisResult::unwrap [function] [call site] 01773
64 AsyncConnectionConfig::new [function] [call site] 01774
64 AsyncConnectionConfig::set_connection_timeout [function] [call site] 01775
64 Duration::from_secs [function] [call site] 01777
64 SentinelClient::get_async_connection_with_config [function] [call site] 01778
65 SentinelClient::async_get_client [function] [call site] 01779
66 Sentinel::async_master_for [function] [call site] 01780
67 Sentinel::async_find_master_address [function] [call site] 01781
68 Sentinel::async_get_sentinel_masters [function] [call site] 01782
69 Sentinel::async_try_all_sentinels [function] [call site] 01783
70 basic::test_tuple_decoding_from_iter [function] [call site] 01784
70 iter_mut [function] [call site] 01786
70 async_try_single_sentinel [function] [call site] 01787
71 &mut [call site] 01788
71 async_reconnect [function] [call site] 01789
72 Client::open [function] [call site] 01790
73 ConnectionInfo::into_connection_info [function] [call site] 01792
72 redis::ConnectionInfo::clone [function] [call site] 01793
72 Client::get_multiplexed_async_connection [function] [call site] 01794
72 CopyOptions::replace [function] [call site] 01795
71 Cmd::query_async [function] [call site] 01797
72 &mut [call site] 01798
72 RedisResult::from_redis_value [function] [call site] 01800
72 Value::extract_error [function] [call site] 01801
71 &mut [call site] 01802
71 RedisError::is_unrecoverable_error [function] [call site] 01804
71 types::test_is_io_error [function] [call site] 01805
72 RedisError::from [function] [call site] 01806
71 async_reconnect [function] [call site] 01807
71 Cmd::query_async [function] [call site] 01808
71 &mut [call site] 01809
70 ClientTlsParams::clone [function] [call site] 01812
71 ClientTlsParams::clone [function] [call site] 01813
71 secret_pkcs1_der [function] [call site] 01815
71 write_command_to_vec [function] [call site] 01816
71 secret_pkcs8_der [function] [call site] 01819
71 write_command_to_vec [function] [call site] 01820
71 secret_sec1_der [function] [call site] 01823
71 write_command_to_vec [function] [call site] 01824
70 None::expect [function] [call site] 01829
69 sentinel_masters_cmd [function] [call site] 01830
70 crate::cmd [function] [call site] 01831
71 redis::cmd [function] [call site] 01832
71 Cmd::set_cache_config [function] [call site] 01833
71 CommandCacheConfig::new [function] [call site] 01834
71 CommandCacheConfig::set_enable_cache [function] [call site] 01835
70 Cmd::arg [function] [call site] 01836
68 async_find_valid_master [function] [call site] 01837
69 valid_addrs [function] [call site] 01838
70 &'a [call site] 01839
71 std::iter::once [function] [call site] 01840
71 basic::test_tuple_decoding_from_iter [function] [call site] 01842
70 std::iter::Chain::filter [function] [call site] 01843
70 tests::into_redis_value_hashmap [function] [call site] 01844
70 redis::ConnectionInfo::remove [function] [call site] 01845
70 parse::<u16> [function] [call site] 01847
69 is_master_valid [function] [call site] 01849
70 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01850
71 TestClusterContext::new [function] [call site] 01851
71 TestClusterContext::wait_for_cluster_up [function] [call site] 01852
71 RedisCluster::iter_servers [function] [call site] 01853
71 MapIter::next [function] [call site] 01854
71 RedisServer::connection_info [function] [call site] 01856
71 hotkeys_cluster::port_of [function] [call site] 01857
71 redis::ConnectionInfo::addr [function] [call site] 01858
71 hotkeys_cluster::direct_connection [function] [call site] 01859
71 redis::ConnectionInfo::clone [function] [call site] 01860
71 redis::Cmd::new [function] [call site] 01861
71 types::test_is_single_arg [function] [call site] 01862
71 basic::test_pipeline_reuse_query [function] [call site] 01863
71 parse_version [function] [call site] 01865
71 hotkeys_cluster::first_owned_slot_range [function] [call site] 01866
71 hotkeys_cluster::find_key_in_range [function] [call site] 01867
70 tests::into_redis_value_hashmap [function] [call site] 01869
70 TlsFilePaths::as_str [function] [call site] 01870
70 InfoDict::contains_key [function] [call site] 01872
71 InfoDict::find [function] [call site] 01873
72 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01874
71 Option::is_some [function] [call site] 01875
70 InfoDict::contains_key [function] [call site] 01876
70 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01877
70 Option::is_some_and [function] [call site] 01878
70 contains [function] [call site] 01879
70 contains [function] [call site] 01880
70 contains [function] [call site] 01881
70 parse::<u16> [function] [call site] 01882
70 tests::redis_ok [function] [call site] 01883
69 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01884
70 crate::ConnectionAddr::Tcp [function] [call site] 01885
70 ClusterClientBuilder::as_ref [function] [call site] 01886
70 tests::into_redis_value_hashmap [function] [call site] 01887
70 transpose [function] [call site] 01888
70 ClientTlsParams::clone [function] [call site] 01890
70 unwrap_or_default [function] [call site] 01891
70 ClientTlsParams::clone [function] [call site] 01892
70 unwrap_or_default [function] [call site] 01893
69 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01894
69 async_determine_master_from_role_or_info_replication [function] [call site] 01895
70 Client::open [function] [call site] 01896
70 redis::ConnectionInfo::clone [function] [call site] 01897
70 Client::get_multiplexed_async_connection [function] [call site] 01898
70 async_check_role [function] [call site] 01899
71 crate::cmd [function] [call site] 01900
71 redis::Cmd::query_async [function] [call site] 01901
72 &mut [call site] 01902
72 RedisResult::from_redis_value [function] [call site] 01904
72 Value::extract_error [function] [call site] 01905
70 async_check_info_replication [function] [call site] 01907
71 crate::cmd [function] [call site] 01908
71 redis::Cmd::arg [function] [call site] 01909
71 Cmd::query_async [function] [call site] 01910
72 &mut [call site] 01911
72 RedisResult::from_redis_value [function] [call site] 01913
72 Value::extract_error [function] [call site] 01914
71 parse_replication_info [function] [call site] 01915
72 impl [call site] 01916
73 TestContext::new [function] [call site] 01917
73 TestContext::async_pubsub [function] [call site] 01918
73 basic_async::automatic_unsubscription_on_split [function] [call site] 01920
73 basic::test_pubsub_unsubscribe [function] [call site] 01921
73 TestContext::async_connection [function] [call site] 01923
73 Runtime::sleep [function] [call site] 01925
73 Duration::from_millis [function] [call site] 01926
73 redis::cmd [function] [call site] 01928
73 redis::Cmd::arg [function] [call site] 01929
73 types::test_is_single_arg [function] [call site] 01930
73 Cmd::query_async [function] [call site] 01931
73 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01933
73 RedisServer::drop [function] [call site] 01935
73 redis::cmd [function] [call site] 01936
73 redis::Cmd::arg [function] [call site] 01937
73 types::test_is_single_arg [function] [call site] 01938
73 Cmd::query_async [function] [call site] 01939
73 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01941
73 Runtime::sleep [function] [call site] 01943
73 Duration::from_millis [function] [call site] 01944
73 basic::test_pubsub_unsubscribe [function] [call site] 01946
73 unwrap_err [function] [call site] 01947
72 trim_start [function] [call site] 01949
72 starts_with [function] [call site] 01950
72 filter_map [function] [call site] 01951
72 split_once [function] [call site] 01952
72 tests::into_redis_value_hashmap [function] [call site] 01953
72 ValueComparison::arg_to_string [function] [call site] 01954
72 ValueComparison::arg_to_string [function] [call site] 01955
71 hotkeys_cluster::setup_cluster_and_target [function] [call site] 01957
72 TestClusterContext::new [function] [call site] 01958
72 TestClusterContext::wait_for_cluster_up [function] [call site] 01959
72 RedisCluster::iter_servers [function] [call site] 01960
72 MapIter::next [function] [call site] 01961
72 RedisServer::connection_info [function] [call site] 01963
72 hotkeys_cluster::port_of [function] [call site] 01964
72 redis::ConnectionInfo::addr [function] [call site] 01965
72 hotkeys_cluster::direct_connection [function] [call site] 01966
72 redis::ConnectionInfo::clone [function] [call site] 01967
72 redis::Cmd::new [function] [call site] 01968
72 types::test_is_single_arg [function] [call site] 01969
72 basic::test_pipeline_reuse_query [function] [call site] 01970
72 parse_version [function] [call site] 01972
72 hotkeys_cluster::first_owned_slot_range [function] [call site] 01973
72 hotkeys_cluster::find_key_in_range [function] [call site] 01974
71 ClientTlsParams::clone [function] [call site] 01977
71 RedisError::from [function] [call site] 01979
70 evaluate_role_check_errors [function] [call site] 01981
70 unwrap_err [function] [call site] 01986
70 unwrap_err [function] [call site] 01987
67 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 01989
67 Client::open [function] [call site] 01990
66 Sentinel::async_replica_for [function] [call site] 01993
67 Sentinel::async_find_valid_replica_addresses [function] [call site] 01994
68 Sentinel::async_get_sentinel_replicas [function] [call site] 01995
69 Sentinel::async_try_all_sentinels [function] [call site] 01996
69 sentinel_replicas_cmd [function] [call site] 01997
70 crate::cmd [function] [call site] 01998
70 Cmd::arg [function] [call site] 01999
70 Cmd::arg [function] [call site] 02000
68 async_get_valid_replicas_addresses [function] [call site] 02001
69 valid_addrs [function] [call site] 02002
69 tests::into_redis_value_hashmap [function] [call site] 02003
69 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02004
69 map(|(ip, [call site] 02005
4 .collect::<RedisResult<Vec<_>>> [function] [call site] 02006
69 futures_util::stream::iter [function] [call site] 02008
70 TestContext::new [function] [call site] 02009
70 TestContext::connection [function] [call site] 02010
70 ValueType::from [function] [call site] 02011
70 basic::test_tuple_decoding_from_iter [function] [call site] 02012
70 hscan::<_, [call site] 02013
69 filter_map [function] [call site] 02016
67 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02018
67 RedisServer::new [function] [call site] 02019
67 basic::test_pipeline_len [function] [call site] 02020
68 redis::pipe [function] [call site] 02021
68 types::test_is_single_arg [function] [call site] 02024
67 tests::into_redis_value_hashmap [function] [call site] 02025
68 ValueType::from [function] [call site] 02026
68 String::into_redis_value [function] [call site] 02027
68 Value::into_map_iter [function] [call site] 02028
68 Result::expect [function] [call site] 02029
68 into_map_iter() [call site] 02030
6 .expect("extracting [call site] 02031
6 .collect::<Vec<(Value, [call site] 02032
67 try_connect_to_first_replica [function] [call site] 02035
68 MockRedisConnection::is_empty [function] [call site] 02036
69 StreamReadOptions::block [function] [call site] 02037
69 MockRedisConnection::is_empty [function] [call site] 02039
68 Option<usize>::unwrap_or [function] [call site] 02041
68 basic::test_pipeline_len [function] [call site] 02042
68 basic::test_pipeline_len [function] [call site] 02043
68 Client::open [function] [call site] 02044
68 ClientTlsParams::clone [function] [call site] 02045
68 None::expect [function] [call site] 02049
66 as_str [function] [call site] 02050
66 Some [function] [call site] 02051
65 Client::get_multiplexed_async_connection_with_config [function] [call site] 02052
66 Runtime::locate [function] [call site] 02053
66 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::tokio::Tokio> [function] [call site] 02054
66 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::smol::Smol> [function] [call site] 02055
64 unwrap [function] [call site] 02056
64 async_tests::async_assert_is_connection_to_master [function] [call site] 02057
65 redis::cmd [function] [call site] 02058
65 redis::Cmd::arg [function] [call site] 02059
65 Cmd::query_async [function] [call site] 02060
65 assert_is_master_role [function] [call site] 02062
66 parse_replication_info [function] [call site] 02063
64 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02064
64 TestSentinelContext::sentinel_mut [function] [call site] 02065
64 &redis::sentinel::Sentinel::async_master_for [function] [call site] 02066
65 Sentinel::async_find_master_address [function] [call site] 02067
65 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02068
65 Client::open [function] [call site] 02069
64 Some [function] [call site] 02070
64 unwrap [function] [call site] 02071
64 SentinelClient::get_async_connection_with_config [function] [call site] 02072
64 unwrap [function] [call site] 02073
64 async_tests::async_assert_connection_is_replica_of_correct_master [function] [call site] 02074
65 redis::cmd [function] [call site] 02075
65 redis::Cmd::arg [function] [call site] 02076
65 Cmd::query_async [function] [call site] 02077
65 assert_replica_role_and_master_addr [function] [call site] 02079
66 parse_replication_info [function] [call site] 02080
66 RedisServer::get_addr [function] [call site] 02081
67 ServerType::get_intended [function] [call site] 02082
67 get_default_host [function] [call site] 02083
68 ValueComparison::arg_to_string [function] [call site] 02084
67 redis::ConnectionAddr::Tcp [function] [call site] 02085
67 get_default_host [function] [call site] 02086
67 rand::random::<(u64, [call site] 02087
67 redis::ConnectionAddr::Unix [function] [call site] 02088
67 ValueType::from [function] [call site] 02089
68 TlsFilePaths::as_ref [function] [call site] 02090
68 ValueType::Unknown [function] [call site] 02091
68 ValueComparison::arg_to_string [function] [call site] 02092
65 Client::get_connection_info [function] [call site] 02093
62 RoutingInfo::SingleNode [function] [call site] 02094
62 MockRedisConnection::req_packed_command [function] [call site] 02095
63 Cmd::get_packed_command [function] [call site] 02096
63 MockRedisConnection::req_packed_command [function] [call site] 02097
63 as_slice [function] [call site] 02098
63 PipelineSink::poll_ready [function] [call site] 02099
63 types::test_parse_boxed [function] [call site] 02100
62 Cmd::get_packed_command [function] [call site] 02101
62 RedisCluster::new [function] [call site] 02102
62 RedisServer::default [function] [call site] 02103
62 ClusterConnection::route_command [function] [call site] 02104
62 RoutingInfo::SingleNode [function] [call site] 02105
62 RedisResult::unwrap [function] [call site] 02106
61 Some [function] [call site] 02107
61 cmd::cmd [function] [call site] 02108
62 redis::cmd [function] [call site] 02109
62 Cmd::set_cache_config [function] [call site] 02110
62 CommandCacheConfig::new [function] [call site] 02111
62 CommandCacheConfig::set_enable_cache [function] [call site] 02112
61 Cmd::exec [function] [call site] 02113
62 query::<()> [function] [call site] 02114
61 MockConnection::set_read_timeout [function] [call site] 02115
61 borrow [function] [call site] 02117
61 MockConnection::set_write_timeout [function] [call site] 02118
61 borrow [function] [call site] 02120
61 Ok [function] [call site] 02121
60 MockRedisConnection::check_connection [function] [call site] 02122
60 RedisResult::insert [function] [call site] 02123
61 TestContext::with_modules [function] [call site] 02124
61 TestContext::connection [function] [call site] 02125
61 redis::Connection::json_set [function] [call site] 02126
61 redis::Connection::json_arr_insert [function] [call site] 02127
61 redis::Connection::json_set [function] [call site] 02128
61 redis::Connection::json_arr_insert [function] [call site] 02129
60 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02130
61 TestContext::new [function] [call site] 02131
61 ProtocolVersion::supports_resp3 [function] [call site] 02132
61 tokio::sync::mpsc::unbounded_channel [function] [call site] 02133
61 redis::aio::ConnectionManagerConfig::new [function] [call site] 02134
61 AsyncConnectionConfig::set_push_sender [function] [call site] 02135
61 Client::get_connection_manager_lazy [function] [call site] 02136
61 tests::into_redis_value_hashset [function] [call site] 02138
61 MockConnection::send_packed_command [function] [call site] 02140
61 Cmd::arg [function] [call site] 02142
61 types::test_is_single_arg [function] [call site] 02143
61 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02145
61 tests::into_redis_value_hashset [function] [call site] 02147
61 Pipeline::send_recv [function] [call site] 02149
60 RedisError::from [function] [call site] 02151
60 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02152
60 MockRedisConnection::is_empty [function] [call site] 02153
60 MockRedisConnection::is_empty [function] [call site] 02154
61 StreamReadOptions::block [function] [call site] 02155
61 MockRedisConnection::is_empty [function] [call site] 02157
60 ValueComparison::arg_to_string [function] [call site] 02158
60 ValueComparison::arg_to_string [function] [call site] 02159
60 &'a [call site] 02160
60 std::iter::Chain::enumerate [function] [call site] 02161
60 Err [function] [call site] 02162
60 RedisError::from [function] [call site] 02163
60 borrow_mut [function] [call site] 02164
60 ClusterConnection::refresh_slots [function] [call site] 02165
61 borrow_mut [function] [call site] 02166
61 ClusterConnection::create_new_slots [function] [call site] 02167
62 borrow_mut [function] [call site] 02168
62 RedisResult::iter_mut [function] [call site] 02169
62 ConnectionLike::req_command [function] [call site] 02170
63 Cmd::get_packed_command [function] [call site] 02171
63 MockRedisConnection::req_packed_command [function] [call site] 02172
62 cluster_handling::slot_cmd [function] [call site] 02173
63 Cmd::new [function] [call site] 02174
63 Cmd::arg [function] [call site] 02175
63 types::test_is_single_arg [function] [call site] 02176
62 super::topology::parse_slots [function] [call site] 02177
63 Cmd::with_capacity [function] [call site] 02178
63 HashSet::<ArcStr>::new [function] [call site] 02179
64 RedisServer::with_modules [function] [call site] 02180
63 &'a [call site] 02181
63 MapIter::next [function] [call site] 02182
63 basic::test_pipeline_len [function] [call site] 02183
64 redis::pipe [function] [call site] 02184
64 types::test_is_single_arg [function] [call site] 02187
63 basic::test_pipeline_len [function] [call site] 02188
63 String::from_utf8_lossy [function] [call site] 02189
63 MockRedisConnection::is_empty [function] [call site] 02190
63 is_wildcard_address [function] [call site] 02191
63 &str::into [function] [call site] 02192
63 &str::into [function] [call site] 02193
63 MockRedisConnection::is_empty [function] [call site] 02194
63 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02195
64 TestClusterContext::new [function] [call site] 02196
64 TestClusterContext::wait_for_cluster_up [function] [call site] 02197
64 RedisCluster::iter_servers [function] [call site] 02198
64 MapIter::next [function] [call site] 02199
64 RedisServer::connection_info [function] [call site] 02201
64 hotkeys_cluster::port_of [function] [call site] 02202
64 redis::ConnectionInfo::addr [function] [call site] 02203
64 hotkeys_cluster::direct_connection [function] [call site] 02204
64 redis::ConnectionInfo::clone [function] [call site] 02205
64 redis::Cmd::new [function] [call site] 02206
64 types::test_is_single_arg [function] [call site] 02207
64 basic::test_pipeline_reuse_query [function] [call site] 02208
64 parse_version [function] [call site] 02210
64 hotkeys_cluster::first_owned_slot_range [function] [call site] 02211
64 hotkeys_cluster::find_key_in_range [function] [call site] 02212
63 ClientTlsParams::clone [function] [call site] 02215
63 RedisServer::insert [function] [call site] 02217
63 ClientTlsParams::clone [function] [call site] 02218
63 NodeAddress::new [function] [call site] 02220
63 &'a [call site] 02221
64 std::iter::once [function] [call site] 02222
64 basic::test_tuple_decoding_from_iter [function] [call site] 02224
63 std::iter::Chain::skip [function] [call site] 02225
63 MapIter::next [function] [call site] 02227
63 try_to_address [function] [call site] 02228
63 filter_map [function] [call site] 02229
63 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02231
64 TestContext::new [function] [call site] 02232
64 ProtocolVersion::supports_resp3 [function] [call site] 02233
64 tokio::sync::mpsc::unbounded_channel [function] [call site] 02234
64 redis::aio::ConnectionManagerConfig::new [function] [call site] 02235
64 AsyncConnectionConfig::set_push_sender [function] [call site] 02236
64 Client::get_connection_manager_lazy [function] [call site] 02237
64 tests::into_redis_value_hashset [function] [call site] 02239
64 MockConnection::send_packed_command [function] [call site] 02241
64 Cmd::arg [function] [call site] 02243
64 types::test_is_single_arg [function] [call site] 02244
64 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02246
64 tests::into_redis_value_hashset [function] [call site] 02248
64 Pipeline::send_recv [function] [call site] 02250
63 SlotRange::new [function] [call site] 02252
62 ConnectionAddr::host [function] [call site] 02254
63 ValueComparison::arg_to_string [function] [call site] 02255
62 SlotMap::from_slots [function] [call site] 02257
63 SlotRangeMap::new [function] [call site] 02258
64 RedisServer::new [function] [call site] 02259
65 RedisServer::with_modules [function] [call site] 02260
63 test_module_json_arr_insert [function] [call site] 02261
63 SlotAddrs::from_slot [function] [call site] 02262
64 SlotAddrs::new [function] [call site] 02263
62 RedisError::from [function] [call site] 02266
61 RoundRobinReplicaStrategy::on_topology_changed [function] [call site] 02267
62 SlotRangeMap::new [function] [call site] 02268
62 ClusterTopology::shards [function] [call site] 02269
63 std::collections::HashSet::new [function] [call site] 02270
63 MockCmd::with_values [function] [call site] 02271
64 Cmd::into_redis_cmd_bytes [function] [call site] 02272
64 tests::into_redis_value_hashmap [function] [call site] 02273
65 ValueType::from [function] [call site] 02274
65 String::into_redis_value [function] [call site] 02275
65 Value::into_map_iter [function] [call site] 02276
65 Result::expect [function] [call site] 02277
65 into_map_iter() [call site] 02278
6 .expect("extracting [call site] 02279
6 .collect::<Vec<(Value, [call site] 02280
64 &'a [call site] 02283
64 tests::into_redis_value_hashmap [function] [call site] 02284
64 String::into_redis_value [function] [call site] 02285
65 Value::BulkString [function] [call site] 02286
65 String::as_bytes [function] [call site] 02287
65 write_command_to_vec [function] [call site] 02288
64 collect [function] [call site] 02289
63 filter_map [function] [call site] 02290
63 RedisServer::insert [function] [call site] 02291
63 Arc::as_ptr [function] [call site] 02292
63 Some [function] [call site] 02293
63 std::sync::MutexGuard::as_ref [function] [call site] 02294
62 RedisServer::new [function] [call site] 02295
62 RedisServer::new [function] [call site] 02296
63 RedisServer::with_modules [function] [call site] 02297
62 std::sync::MutexGuard::slot_ranges [function] [call site] 02298
63 cluster::test_cluster_fan_out [function] [call site] 02299
64 RedisServer::new [function] [call site] 02300
64 std::sync::Mutex::new [function] [call site] 02301
65 RedisServer::with_modules [function] [call site] 02302
64 RedisServer::new [function] [call site] 02303
64 ClientTlsParams::clone [function] [call site] 02304
65 ClientTlsParams::clone [function] [call site] 02305
65 secret_pkcs1_der [function] [call site] 02307
65 write_command_to_vec [function] [call site] 02308
65 secret_pkcs8_der [function] [call site] 02311
65 write_command_to_vec [function] [call site] 02312
65 secret_sec1_der [function] [call site] 02315
65 write_command_to_vec [function] [call site] 02316
64 redis::Cmd::new [function] [call site] 02318
64 RedisFuture::split_whitespace [function] [call site] 02319
64 Cmd::arg [function] [call site] 02320
64 Cmd::get_packed_command [function] [call site] 02321
64 MockEnv::with_client_builder [function] [call site] 02322
64 ClusterClient::builder [function] [call site] 02323
65 ClusterClientBuilder::new [function] [call site] 02324
66 &'a [call site] 02325
66 std::iter::Chain::map [function] [call site] 02326
66 ConnectionInfo::into_connection_info [function] [call site] 02327
66 RedisServer::default [function] [call site] 02329
64 ClusterClientBuilder::retries [function] [call site] 02330
64 ClusterClientBuilder::read_routing_strategy [function] [call site] 02331
65 RedisServer::new [function] [call site] 02333
64 respond_startup_with_replica_using_config [function] [call site] 02334
65 Option<Vec<MockSlotRange>>::unwrap_or [function] [call site] 02335
65 is_connection_check [function] [call site] 02336
66 contains_slice [function] [call site] 02337
67 basic::test_pipeline_len [function] [call site] 02338
68 redis::pipe [function] [call site] 02339
68 types::test_is_single_arg [function] [call site] 02342
67 starts_with [function] [call site] 02343
66 contains_slice [function] [call site] 02344
65 Value::SimpleString [function] [call site] 02347
65 &str::into [function] [call site] 02348
65 contains_slice [function] [call site] 02349
65 contains_slice [function] [call site] 02350
65 &'a [call site] 02351
66 std::iter::once [function] [call site] 02352
66 basic::test_tuple_decoding_from_iter [function] [call site] 02354
65 std::iter::Chain::map [function] [call site] 02355
65 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02356
65 Value::Array [function] [call site] 02357
65 Value::Array [function] [call site] 02358
65 Value::Array [function] [call site] 02362
64 ClientTlsParams::clone [function] [call site] 02364
65 ClientTlsParams::clone [function] [call site] 02365
65 secret_pkcs1_der [function] [call site] 02367
65 write_command_to_vec [function] [call site] 02368
65 secret_pkcs8_der [function] [call site] 02371
65 write_command_to_vec [function] [call site] 02372
65 secret_sec1_der [function] [call site] 02375
65 write_command_to_vec [function] [call site] 02376
64 StreamReadOptions::block [function] [call site] 02378
64 Self::unwrap [function] [call site] 02380
64 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02381
64 redis_value [function] [call site] 02384
65 $crate::IntoRedisValue::into_redis_value [function] [call site] 02385
64 query::<Option<()>> [function] [call site] 02387
64 StreamReadOptions::block [function] [call site] 02388
64 Self::unwrap [function] [call site] 02390
62 RedisResult::insert [function] [call site] 02393
62 ClientTlsParams::clone [function] [call site] 02394
63 ClientTlsParams::clone [function] [call site] 02395
63 secret_pkcs1_der [function] [call site] 02397
63 write_command_to_vec [function] [call site] 02398
63 secret_pkcs8_der [function] [call site] 02401
63 write_command_to_vec [function] [call site] 02402
63 secret_sec1_der [function] [call site] 02405
63 write_command_to_vec [function] [call site] 02406
62 Tokio::poll_write [function] [call site] 02408
62 expect [function] [call site] 02409
61 SlotMap::topology [function] [call site] 02410
62 RedisServer::new [function] [call site] 02411
62 basic::test_tuple_decoding_from_iter [function] [call site] 02412
62 RedisServer::iter_mut [function] [call site] 02413
62 InfoDict::find [function] [call site] 02414
63 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02415
62 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02416
62 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02417
62 ClientTlsParams::clone [function] [call site] 02418
62 ClientTlsParams::clone [function] [call site] 02419
62 ClusterTopology::from_shards [function] [call site] 02420
63 SlotRangeMap::new [function] [call site] 02421
63 RedisServer::new [function] [call site] 02422
63 std::sync::MutexGuard::slot_ranges [function] [call site] 02423
63 RedisResult::insert [function] [call site] 02424
63 ClientTlsParams::clone [function] [call site] 02425
62 &'a [call site] 02426
62 std::iter::Chain::map [function] [call site] 02427
61 MockCmd::with_values [function] [call site] 02432
62 Cmd::into_redis_cmd_bytes [function] [call site] 02433
62 tests::into_redis_value_hashmap [function] [call site] 02434
62 &'a [call site] 02435
62 tests::into_redis_value_hashmap [function] [call site] 02436
62 String::into_redis_value [function] [call site] 02437
61 Self::flatten [function] [call site] 02439
61 values().flatten().collect::<Vec<_>> [function] [call site] 02440
61 sort_unstable [function] [call site] 02441
61 dedup [function] [call site] 02442
61 borrow_mut [function] [call site] 02443
61 &'a [call site] 02444
61 std::iter::Chain::filter_map [function] [call site] 02445
61 RedisResult::remove [function] [call site] 02446
61 MockRedisConnection::check_connection [function] [call site] 02447
61 Some [function] [call site] 02448
61 ClientTlsParams::clone [function] [call site] 02449
62 ClientTlsParams::clone [function] [call site] 02450
62 secret_pkcs1_der [function] [call site] 02452
62 write_command_to_vec [function] [call site] 02453
62 secret_pkcs8_der [function] [call site] 02456
62 write_command_to_vec [function] [call site] 02457
62 secret_sec1_der [function] [call site] 02460
62 write_command_to_vec [function] [call site] 02461
61 ClusterConnection::connect [function] [call site] 02463
61 MockRedisConnection::check_connection [function] [call site] 02464
61 Some [function] [call site] 02465
61 ClientTlsParams::clone [function] [call site] 02466
61 collect [function] [call site] 02467
61 Ok [function] [call site] 02468
60 Ok [function] [call site] 02469
59 Tokio::poll_write [function] [call site] 02470
59 SlotMap::new [function] [call site] 02471
59 ClusterConnection::refresh_slots [function] [call site] 02472
60 borrow_mut [function] [call site] 02473
60 ClusterConnection::create_new_slots [function] [call site] 02474
60 RoundRobinReplicaStrategy::on_topology_changed [function] [call site] 02475
60 SlotMap::topology [function] [call site] 02476
60 MockCmd::with_values [function] [call site] 02477
60 Self::flatten [function] [call site] 02478
60 values().flatten().collect::<Vec<_>> [function] [call site] 02479
60 sort_unstable [function] [call site] 02480
60 borrow_mut [function] [call site] 02482
60 &'a [call site] 02483
60 std::iter::Chain::filter_map [function] [call site] 02484
60 RedisResult::remove [function] [call site] 02485
60 MockRedisConnection::check_connection [function] [call site] 02486
60 ClientTlsParams::clone [function] [call site] 02488
60 ClusterConnection::connect [function] [call site] 02489
60 MockRedisConnection::check_connection [function] [call site] 02490
60 ClientTlsParams::clone [function] [call site] 02492
59 Ok [function] [call site] 02495
57 oneshot::channel::<RedisResult<()>> [function] [call site] 02496
57 mpsc::channel::<Message<_>> [function] [call site] 02497
57 ClusterConnInner::wait_for_initial_connection [function] [call site] 02498
58 std::mem::replace [function] [call site] 02499
57 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 02501
57 stream::poll_fn [function] [call site] 02502
57 ( [call site] 02503
4 PendingRequest::poll_recv [function] [call site] 02504
57 tests::into_redis_value_hashmap [function] [call site] 02505
57 HandleContainer::new [function] [call site] 02507
57 tokio::runtime::Runtime::spawn [function] [call site] 02508
58 crate_tokio::Tokio::spawn [function] [call site] 02509
59 TaskHandle::Tokio [function] [call site] 02510
59 tokio::spawn [function] [call site] 02511
60 tokio::runtime::Handle::try_current [function] [call site] 02512
60 smol::spawn [function] [call site] 02514
60 TaskHandle::detach [function] [call site] 02515
58 crate_smol::Smol::spawn [function] [call site] 02516
59 TaskHandle::Smol [function] [call site] 02517
59 smol::spawn [function] [call site] 02518
57 RedisServer::new [function] [call site] 02519
56 map_err [function] [call site] 02520
56 RedisError::from [function] [call site] 02521
56 Ok [function] [call site] 02522
55 ClientTlsParams::clone [function] [call site] 02523
55 ClientTlsParams::clone [function] [call site] 02524
54 RedisResult::unwrap [function] [call site] 02525
54 tokio::runtime::Runtime::block_on [function] [call site] 02526
54 ClusterClient::get_async_generic_connection [function] [call site] 02527
55 cluster_async::ClusterConnection::new [function] [call site] 02528
56 ClusterConnection::new_inner [function] [call site] 02529
56 RedisError::from [function] [call site] 02531
55 ClientTlsParams::clone [function] [call site] 02533
54 unwrap [function] [call site] 02534
54 RemoveHandler [function] [call site] 02535
53 ClusterClient::builder [function] [call site] 02536
53 ClusterClientBuilder::retries [function] [call site] 02537
53 respond_startup [function] [call site] 02538
54 is_connection_check [function] [call site] 02539
54 Value::SimpleString [function] [call site] 02542
54 &str::into [function] [call site] 02543
54 contains_slice [function] [call site] 02544
54 contains_slice [function] [call site] 02545
54 Value::Array [function] [call site] 02548
53 fetch_add [function] [call site] 02550
53 Err [function] [call site] 02551
53 parse_redis_value [function] [call site] 02552
53 Err [function] [call site] 02553
53 Ok [function] [call site] 02554
53 redis_value [function] [call site] 02555
53 cmd [function] [call site] 02556
53 Cmd::arg [function] [call site] 02557
53 arg("test").query::<Option<i32>> [function] [call site] 02558
52 TestClusterContext::get_ports [function] [call site] 02559
52 MockRedisConnection::check_connection [function] [call site] 02560
52 RedisServer::drop [function] [call site] 02561
52 RedisCluster::new [function] [call site] 02562
52 RedisServer::default [function] [call site] 02563
52 cmd [function] [call site] 02564
52 ClusterConnection::route_command [function] [call site] 02565
52 RoutingInfo::MultiNode [function] [call site] 02566
52 Some [function] [call site] 02567
52 RedisResult::unwrap [function] [call site] 02568
51 redis::ConnectionInfo::redis_settings [function] [call site] 02569
51 resize_with [function] [call site] 02570
51 basic::test_pipeline_len [function] [call site] 02571
52 redis::pipe [function] [call site] 02572
52 types::test_is_single_arg [function] [call site] 02575
51 resize_with [function] [call site] 02576
51 basic::test_pipeline_len [function] [call site] 02577
51 Ok [function] [call site] 02578
51 random_replica_index [function] [call site] 02579
52 rand::rng [function] [call site] 02580
52 random_range [function] [call site] 02581
52 NonZeroUsize::into [function] [call site] 02582
51 RedisServer::new [function] [call site] 02583
51 RedisServer::unwrap [function] [call site] 02584
51 resize_with [function] [call site] 02585
51 basic::test_pipeline_len [function] [call site] 02586
51 Ok [function] [call site] 02587
51 random_replica_index [function] [call site] 02588
51 RedisServer::new [function] [call site] 02589
51 RedisServer::unwrap [function] [call site] 02590
51 Ok [function] [call site] 02591
51 random_replica_index [function] [call site] 02592
51 RedisServer::new [function] [call site] 02593
51 RedisServer::unwrap [function] [call site] 02594
51 Ok [function] [call site] 02595
51 random_replica_index [function] [call site] 02596
51 RedisServer::new [function] [call site] 02597
51 RedisServer::unwrap [function] [call site] 02598
49 ClientTlsParams::clone [function] [call site] 02599
49 &redis::sentinel::Sentinel::unwrap [function] [call site] 02600
49 TestSentinelContext::wait_for_cluster_up [function] [call site] 02601
50 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02602
50 TestSentinelContext::sentinel_mut [function] [call site] 02603
50 redis_test::sentinel::wait_for_master_server [function] [call site] 02604
51 redis::cmd [function] [call site] 02605
51 Client::get_connection [function] [call site] 02606
51 redis::Cmd::query [function] [call site] 02607
51 RedisResult::unwrap [function] [call site] 02608
51 String::from_redis_value_ref [function] [call site] 02609
51 Replicas::first [function] [call site] 02610
51 &'a [call site] 02611
51 Result::unwrap [function] [call site] 02612
51 starts_with [function] [call site] 02613
51 get_connection_info [function] [call site] 02615
51 ConnectionInfo::addr [function] [call site] 02616
51 RedisSentinelCluster::log_redis_state_via_cli [function] [call site] 02617
51 std::thread::sleep [function] [call site] 02618
51 Duration::from_millis [function] [call site] 02619
50 &mut [call site] 02621
51 Sentinel::find_master_address [function] [call site] 02622
52 Sentinel::get_sentinel_masters [function] [call site] 02623
53 Sentinel::try_all_sentinels [function] [call site] 02624
54 basic::test_tuple_decoding_from_iter [function] [call site] 02625
54 iter_mut [function] [call site] 02627
54 try_single_sentinel [function] [call site] 02628
55 &mut [call site] 02629
55 reconnect [function] [call site] 02630
56 Client::open [function] [call site] 02631
56 redis::ConnectionInfo::clone [function] [call site] 02632
56 Client::get_connection [function] [call site] 02633
56 CopyOptions::replace [function] [call site] 02634
55 Cmd::query [function] [call site] 02636
56 ConnectionLike::req_command [function] [call site] 02637
56 RedisResult::from_redis_value [function] [call site] 02639
56 Value::extract_error [function] [call site] 02640
55 &mut [call site] 02642
55 RedisError::is_unrecoverable_error [function] [call site] 02644
55 types::test_is_io_error [function] [call site] 02645
55 reconnect [function] [call site] 02646
55 Cmd::query [function] [call site] 02647
55 &mut [call site] 02648
54 ClientTlsParams::clone [function] [call site] 02651
54 None::expect [function] [call site] 02655
53 sentinel_masters_cmd [function] [call site] 02656
52 find_valid_master [function] [call site] 02657
53 valid_addrs [function] [call site] 02658
53 is_master_valid [function] [call site] 02659
53 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02660
53 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02661
53 determine_master_from_role_or_info_replication [function] [call site] 02662
54 Client::open [function] [call site] 02663
54 redis::ConnectionInfo::clone [function] [call site] 02664
54 Client::get_connection [function] [call site] 02665
54 check_role [function] [call site] 02666
55 crate::cmd [function] [call site] 02667
55 redis::Cmd::query [function] [call site] 02668
54 check_info_replication [function] [call site] 02670
55 crate::cmd [function] [call site] 02671
55 redis::Cmd::arg [function] [call site] 02672
55 basic::test_pipeline_reuse_query [function] [call site] 02673
55 parse_replication_info [function] [call site] 02674
55 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02675
55 ClientTlsParams::clone [function] [call site] 02677
55 RedisError::from [function] [call site] 02679
54 evaluate_role_check_errors [function] [call site] 02681
54 RedisResult::unwrap_err [function] [call site] 02682
54 RedisResult::unwrap_err [function] [call site] 02683
51 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02685
51 Client::open [function] [call site] 02686
50 ConnectionAddr::is_err [function] [call site] 02688
50 redis_test::sentinel::wait_for_replica [function] [call site] 02689
51 redis::cmd [function] [call site] 02690
51 Client::get_connection [function] [call site] 02691
51 redis::Cmd::query [function] [call site] 02692
51 RedisResult::unwrap [function] [call site] 02693
51 String::from_redis_value_ref [function] [call site] 02694
51 Replicas::first [function] [call site] 02695
51 &'a [call site] 02696
51 Result::unwrap [function] [call site] 02697
51 String::from_redis_value_ref [function] [call site] 02698
51 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02699
51 Option::unwrap [function] [call site] 02700
51 Result::unwrap [function] [call site] 02701
51 starts_with [function] [call site] 02702
51 get_connection_info [function] [call site] 02704
51 ConnectionInfo::addr [function] [call site] 02705
51 RedisSentinelCluster::log_redis_state_via_cli [function] [call site] 02706
51 std::thread::sleep [function] [call site] 02707
51 Duration::from_millis [function] [call site] 02708
50 &mut [call site] 02710
51 Sentinel::find_valid_replica_addresses [function] [call site] 02711
52 Sentinel::get_sentinel_replicas [function] [call site] 02712
53 Sentinel::try_all_sentinels [function] [call site] 02713
53 sentinel_replicas_cmd [function] [call site] 02714
52 get_valid_replicas_addresses [function] [call site] 02715
53 valid_addrs [function] [call site] 02716
53 tests::into_redis_value_hashmap [function] [call site] 02717
53 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02718
53 map(|(ip, [call site] 02719
4 .collect::<RedisResult<Vec<ConnectionInfo>>> [function] [call site] 02720
53 &'a [call site] 02722
53 std::iter::Chain::filter [function] [call site] 02723
53 get_node_role [function] [call site] 02724
54 Client::open [function] [call site] 02725
54 redis::ConnectionInfo::clone [function] [call site] 02726
54 Client::get_connection [function] [call site] 02727
54 crate::cmd [function] [call site] 02728
54 redis::Cmd::query [function] [call site] 02729
53 RedisResult::is_ok_and [function] [call site] 02730
51 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02732
51 RedisServer::new [function] [call site] 02733
51 basic::test_pipeline_len [function] [call site] 02734
51 tests::into_redis_value_hashmap [function] [call site] 02735
51 try_connect_to_first_replica [function] [call site] 02736
50 Some [function] [call site] 02737
50 ConnectionAddr::is_err [function] [call site] 02738
47 SentinelClient::build [function] [call site] 02739
47 TestSentinelContext::sentinels_connection_info [function] [call site] 02740
47 ClientTlsParams::clone [function] [call site] 02741
47 String::from [function] [call site] 02742
47 Some [function] [call site] 02743
47 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02744
47 RedisResult::unwrap [function] [call site] 02745
47 SentinelClient::build [function] [call site] 02746
47 TestSentinelContext::sentinels_connection_info [function] [call site] 02747
47 ClientTlsParams::clone [function] [call site] 02748
47 String::from [function] [call site] 02749
47 Some [function] [call site] 02750
47 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02751
47 RedisResult::unwrap [function] [call site] 02752
47 AsyncConnectionConfig::new [function] [call site] 02753
47 AsyncConnectionConfig::set_connection_timeout [function] [call site] 02754
47 Some [function] [call site] 02755
47 Duration::from_secs [function] [call site] 02756
47 SentinelClient::get_async_connection_with_config [function] [call site] 02757
47 unwrap [function] [call site] 02758
47 async_tests::async_assert_is_connection_to_master [function] [call site] 02759
47 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02760
47 TestSentinelContext::sentinel_mut [function] [call site] 02761
47 &redis::sentinel::Sentinel::async_master_for [function] [call site] 02762
47 Some [function] [call site] 02763
47 unwrap [function] [call site] 02764
47 SentinelClient::get_async_connection_with_config [function] [call site] 02765
47 unwrap [function] [call site] 02766
47 async_tests::async_assert_connection_is_replica_of_correct_master [function] [call site] 02767
46 Err [function] [call site] 02768
46 Some [function] [call site] 02769
46 into [function] [call site] 02770
46 map_err [function] [call site] 02771
46 unwrap_or_else [function] [call site] 02772
45 unwrap [function] [call site] 02773
44 std::sync::Mutex::new [function] [call site] 02774
44 RedisServer::new [function] [call site] 02775
44 RedisServer::default [function] [call site] 02776
45 RedisServer::new [function] [call site] 02777
44 RedisServer::new [function] [call site] 02778
43 CacheManager::clone_and_increase_epoch [function] [call site] 02779
44 ClientTlsParams::clone [function] [call site] 02780
44 CacheManager::clone_and_increase_epoch [function] [call site] 02781
45 ClientTlsParams::clone [function] [call site] 02782
45 CacheManager::clone_and_increase_epoch [function] [call site] 02783
42 Self::as_ref [function] [call site] 02784
42 AsyncConnectionConfig::set_cache_manager [function] [call site] 02785
43 Cache::Manager [function] [call site] 02787
42 ClientTlsParams::clone [function] [call site] 02788
42 Some [function] [call site] 02789
42 Msg::get_channel [function] [call site] 02790
42 HandleContainer::new [function] [call site] 02791
42 tokio::runtime::Runtime::spawn [function] [call site] 02792
42 ConnectionManager::check_for_disconnect_pushes [function] [call site] 02793
43 Pipeline::send_recv [function] [call site] 02794
43 Self::reconnect [function] [call site] 02796
44 Client::open [function] [call site] 02797
44 redis::ConnectionInfo::clone [function] [call site] 02798
44 Client::get_multiplexed_async_connection [function] [call site] 02799
44 CopyOptions::replace [function] [call site] 02800
43 Arc::downgrade [function] [call site] 02802
43 script::test_script_load [function] [call site] 02803
44 TestContext::new [function] [call site] 02804
44 TestContext::connection [function] [call site] 02805
44 redis::Script::new [function] [call site] 02806
45 RedisServer::new [function] [call site] 02807
46 RedisServer::with_modules [function] [call site] 02808
45 SortedSetAddOptions::add_or_update [function] [call site] 02809
46 RedisServer::default [function] [call site] 02810
45 Option::as_bytes [function] [call site] 02811
45 ValueComparison::arg_to_string [function] [call site] 02812
46 impl [call site] 02813
46 String::from_utf8_lossy [function] [call site] 02814
46 into_owned [function] [call site] 02815
45 calculate_value_digest [function] [call site] 02816
46 impl [call site] 02817
46 RedisServer::new [function] [call site] 02818
46 RedisServer::extend_from_slice [function] [call site] 02819
45 ValueComparison::arg_to_string [function] [call site] 02821
44 script::test_script_load [function] [call site] 02822
43 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 02824
42 ClientTlsParams::clone [function] [call site] 02825
42 check_resp3 [function] [call site] 02826
43 supports_resp3 [function] [call site] 02827
43 RedisError::from [function] [call site] 02829
42 tokio::sync::mpsc::unbounded_channel [function] [call site] 02830
42 Some [function] [call site] 02831
42 Some [function] [call site] 02832
42 AsyncConnectionConfig::set_push_sender_internal [function] [call site] 02833
42 RedisServer::new [function] [call site] 02835
42 ProtocolVersion::supports_resp3 [function] [call site] 02836
42 tokio::sync::mpsc::unbounded_channel [function] [call site] 02837
42 Some [function] [call site] 02838
42 AsyncConnectionConfig::set_push_sender_internal [function] [call site] 02839
42 RedisServer::new [function] [call site] 02840
42 Some [function] [call site] 02841
42 RedisServer::new [function] [call site] 02842
42 RedisServer::default [function] [call site] 02843
42 ClientTlsParams::clone [function] [call site] 02844
42 ClientTlsParams::clone [function] [call site] 02845
42 cluster_async::test_async_cluster_ask_save_new_connection [function] [call site] 02846
43 RedisServer::new [function] [call site] 02847
43 RedisServer::new [function] [call site] 02848
44 RedisServer::with_modules [function] [call site] 02849
43 ClientTlsParams::clone [function] [call site] 02850
43 MockEnv::with_client_builder [function] [call site] 02851
43 ClusterClient::builder [function] [call site] 02852
43 respond_startup_two_nodes [function] [call site] 02853
44 respond_startup_with_replica_using_config [function] [call site] 02854
43 parse_redis_value [function] [call site] 02857
43 is_connection_check [function] [call site] 02858
43 Self::fetch_add [function] [call site] 02859
43 respond_startup_two_nodes [function] [call site] 02860
43 tokio::runtime::Runtime::block_on [function] [call site] 02863
43 Cmd::arg [function] [call site] 02865
43 arg("test").query_async::<Value> [function] [call site] 02866
42 types::test_parse_boxed [function] [call site] 02868
43 ValueComparison::arg_to_string [function] [call site] 02869
43 parse_redis_value [function] [call site] 02870
43 Value::SimpleString [function] [call site] 02871
43 ClientTlsParams::clone [function] [call site] 02872
42 shared [function] [call site] 02873
42 Self [function] [call site] 02874
42 RedisServer::new [function] [call site] 02875
42 ArcSwap::from_pointee [function] [call site] 02876
42 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 02877
42 Arc::downgrade [function] [call site] 02878
42 map_err [function] [call site] 02879
42 crate::RedisError::from [function] [call site] 02880
43 io::Error::from [function] [call site] 02881
43 Self::into [function] [call site] 02882
42 Ok [function] [call site] 02883
41 ClientTlsParams::clone [function] [call site] 02884
42 ClientTlsParams::clone [function] [call site] 02885
42 secret_pkcs1_der [function] [call site] 02887
42 write_command_to_vec [function] [call site] 02888
42 secret_pkcs8_der [function] [call site] 02891
42 write_command_to_vec [function] [call site] 02892
42 secret_sec1_der [function] [call site] 02895
42 write_command_to_vec [function] [call site] 02896
40 unwrap [function] [call site] 02898
40 tests::into_redis_value_hashset [function] [call site] 02899
40 unwrap [function] [call site] 02900
40 MockConnection::send_packed_command [function] [call site] 02901
40 cmd [function] [call site] 02902
40 Cmd::arg [function] [call site] 02903
40 types::test_is_single_arg [function] [call site] 02904
40 unwrap [function] [call site] 02905
40 hotkeys_cluster::setup_cluster_and_target [function] [call site] 02906
40 unwrap [function] [call site] 02907
40 tests::into_redis_value_hashset [function] [call site] 02908
40 unwrap [function] [call site] 02909
40 Pipeline::send_recv [function] [call site] 02910
40 unwrap [function] [call site] 02911
39 Some [function] [call site] 02912
39 Cmd::arg_idx [function] [call site] 02913
39 get_route [function] [call site] 02914
40 Route::with_key [function] [call site] 02915
41 Route::with_slot [function] [call site] 02916
41 Slot::for_key [function] [call site] 02918
42 S::l::o::t::::::::f::o::r::_::k::e::y::impl_ [function] [call site] 02919
43 crc16::State::<crc16::XMODEM>::calculate [function] [call site] 02921
43 get_hashtag [function] [call site] 02922
44 basic::test_tuple_decoding_from_iter [function] [call site] 02923
44 Cmd::position [function] [call site] 02924
45 Cmd::args_iter [function] [call site] 02925
45 Cmd::position [function] [call site] 02926
46 Cmd::args_iter [function] [call site] 02927
46 Cmd::position [function] [call site] 02928
46 ServerType::eq_ignore_ascii_case [function] [call site] 02929
45 ServerType::eq_ignore_ascii_case [function] [call site] 02930
44 basic::test_tuple_decoding_from_iter [function] [call site] 02931
44 Cmd::position [function] [call site] 02932
44 MockRedisConnection::is_empty [function] [call site] 02933
44 then_some [function] [call site] 02934
43 Option::unwrap_or [function] [call site] 02935
40 Route::with_key [function] [call site] 02937
39 tests::redis_array_single_entry [function] [call site] 02938
40 redis_value [function] [call site] 02939
40 Value::Array [function] [call site] 02940
39 or_insert [function] [call site] 02941
39 RedisServer::new [function] [call site] 02942
39 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02943
39 incr_add_next_arg [function] [call site] 02944
39 Cmd::arg_idx [function] [call site] 02945
39 Option::is_none [function] [call site] 02946
39 RedisServer::values_mut [function] [call site] 02947
39 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02948
39 incr_add_next_arg [function] [call site] 02949
39 incr_add_next_arg [function] [call site] 02950
39 &'a [call site] 02951
39 std::iter::Chain::collect [function] [call site] 02952
39 MockRedisConnection::is_empty [function] [call site] 02953
39 Some [function] [call site] 02954
39 basic::test_pipeline_len [function] [call site] 02955
39 RoutingInfo::SingleNode [function] [call site] 02956
39 SingleNodeRoutingInfo::SpecificNode [function] [call site] 02957
39 RedisServer::pop [function] [call site] 02958
39 unwrap [function] [call site] 02959
39 RoutingInfo::MultiNode [function] [call site] 02960
39 MultipleNodeRoutingInfo::MultiSlot [function] [call site] 02961
39 ResponsePolicy::for_command [function] [call site] 02962
38 Some [function] [call site] 02963
38 RoutingInfo::SingleNode [function] [call site] 02964
38 Cmd::arg_idx [function] [call site] 02965
39 Cmd::arg_idx [function] [call site] 02966
38 Option::and_then [function] [call site] 02967
38 std::str::from_utf8 [function] [call site] 02968
38 tests::redis_ok [function] [call site] 02969
38 and_then [function] [call site] 02970
38 parse::<u64> [function] [call site] 02971
38 tests::redis_ok [function] [call site] 02972
38 Some [function] [call site] 02973
38 RoutingInfo::SingleNode [function] [call site] 02974
38 Cmd::arg_idx [function] [call site] 02975
38 tests::into_redis_value_hashmap [function] [call site] 02976
38 RoutingInfo::for_key [function] [call site] 02977
39 RoutingInfo::SingleNode [function] [call site] 02978
39 SingleNodeRoutingInfo::SpecificNode [function] [call site] 02979
39 get_route [function] [call site] 02980
39 commands::is_readonly_cmd [function] [call site] 02981
38 Cmd::arg_idx [function] [call site] 02982
38 tests::into_redis_value_hashmap [function] [call site] 02983
38 RoutingInfo::for_key [function] [call site] 02984
38 Cmd::arg_idx [function] [call site] 02985
38 Option::and_then [function] [call site] 02986
38 std::str::from_utf8 [function] [call site] 02987
38 tests::redis_ok [function] [call site] 02988
38 and_then [function] [call site] 02989
38 parse::<u64> [function] [call site] 02990
38 tests::redis_ok [function] [call site] 02991
38 Some [function] [call site] 02992
38 RoutingInfo::SingleNode [function] [call site] 02993
38 Cmd::arg_idx [function] [call site] 02994
38 tests::into_redis_value_hashmap [function] [call site] 02995
38 RoutingInfo::for_key [function] [call site] 02996
38 Cmd::position [function] [call site] 02997
39 Cmd::args_iter [function] [call site] 02998
39 Cmd::position [function] [call site] 02999
39 ServerType::eq_ignore_ascii_case [function] [call site] 03000
38 Cmd::arg_idx [function] [call site] 03001
38 tests::into_redis_value_hashmap [function] [call site] 03002
38 RoutingInfo::for_key [function] [call site] 03003
38 Cmd::arg_idx [function] [call site] 03004
38 Option::and_then [function] [call site] 03005
38 std::str::from_utf8 [function] [call site] 03006
38 tests::redis_ok [function] [call site] 03007
38 and_then [function] [call site] 03008
38 parse::<u16> [function] [call site] 03009
38 tests::redis_ok [function] [call site] 03010
38 and_then [function] [call site] 03011
38 tests::into_redis_value_hashmap [function] [call site] 03012
38 RoutingInfo::SingleNode [function] [call site] 03013
38 SingleNodeRoutingInfo::SpecificNode [function] [call site] 03014
38 Route::with_slot [function] [call site] 03015
38 Cmd::arg_idx [function] [call site] 03017
38 Some [function] [call site] 03018
38 RoutingInfo::for_key [function] [call site] 03019
38 Some [function] [call site] 03020
38 RoutingInfo::SingleNode [function] [call site] 03021
37 std::collections::HashMap::new [function] [call site] 03022
38 RedisServer::with_modules [function] [call site] 03023
37 RedisServer::insert [function] [call site] 03024
37 Route [function] [call site] 03025
37 RedisServer::insert [function] [call site] 03026
37 Route [function] [call site] 03027
37 RedisServer::insert [function] [call site] 03028
37 Route [function] [call site] 03029
36 join [function] [call site] 03030
36 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03031
36 join [function] [call site] 03032
36 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03033
36 join [function] [call site] 03034
36 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03035
36 join [function] [call site] 03036
36 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03037
36 join [function] [call site] 03038
36 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03039
36 join [function] [call site] 03040
36 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::e::x::t::make_key [function] [call site] 03041
36 b::u::i::l::d::_::k::e::y::s::_::a::n::d::_::c::e::r::t::s::_::f::o::r::_::t::l::s::_::e::x::t::make_key [function] [call site] 03042
36 process::Command::new [function] [call site] 03043
36 types::test_is_single_arg [function] [call site] 03044
36 types::test_is_single_arg [function] [call site] 03045
36 types::test_is_single_arg [function] [call site] 03046
36 types::test_is_single_arg [function] [call site] 03047
36 types::test_is_single_arg [function] [call site] 03048
36 types::test_is_single_arg [function] [call site] 03049
36 types::test_is_single_arg [function] [call site] 03050
36 types::test_is_single_arg [function] [call site] 03051
36 types::test_is_single_arg [function] [call site] 03052
36 types::test_is_single_arg [function] [call site] 03053
36 types::test_is_single_arg [function] [call site] 03054
36 types::test_is_single_arg [function] [call site] 03055
36 types::test_is_single_arg [function] [call site] 03056
36 stdout [function] [call site] 03057
36 process::Stdio::piped [function] [call site] 03058
36 stderr [function] [call site] 03059
36 process::Stdio::piped [function] [call site] 03060
36 spawn [function] [call site] 03061
36 expect [function] [call site] 03062
36 ClusterClientBuilder::max_retry_wait [function] [call site] 03063
36 expect [function] [call site] 03064
36 Tokio::poll_write [function] [call site] 03065
36 Poll::expect [function] [call site] 03066
36 process::Command::new [function] [call site] 03067
36 types::test_is_single_arg [function] [call site] 03068
36 types::test_is_single_arg [function] [call site] 03069
36 types::test_is_single_arg [function] [call site] 03070
36 types::test_is_single_arg [function] [call site] 03071
36 types::test_is_single_arg [function] [call site] 03072
36 types::test_is_single_arg [function] [call site] 03073
36 types::test_is_single_arg [function] [call site] 03074
36 stdout [function] [call site] 03075
36 process::Stdio::piped [function] [call site] 03076
36 stderr [function] [call site] 03077
36 process::Stdio::piped [function] [call site] 03078
36 spawn [function] [call site] 03079
36 expect [function] [call site] 03080
36 process::Command::new [function] [call site] 03081
36 types::test_is_single_arg [function] [call site] 03082
36 types::test_is_single_arg [function] [call site] 03083
36 types::test_is_single_arg [function] [call site] 03084
36 types::test_is_single_arg [function] [call site] 03085
36 types::test_is_single_arg [function] [call site] 03086
36 types::test_is_single_arg [function] [call site] 03087
36 types::test_is_single_arg [function] [call site] 03088
36 types::test_is_single_arg [function] [call site] 03089
36 types::test_is_single_arg [function] [call site] 03090
36 types::test_is_single_arg [function] [call site] 03091
36 types::test_is_single_arg [function] [call site] 03092
36 types::test_is_single_arg [function] [call site] 03093
36 types::test_is_single_arg [function] [call site] 03094
36 types::test_is_single_arg [function] [call site] 03095
36 types::test_is_single_arg [function] [call site] 03096
36 types::test_is_single_arg [function] [call site] 03097
36 types::test_is_single_arg [function] [call site] 03098
36 types::test_is_single_arg [function] [call site] 03099
36 stdin [function] [call site] 03100
36 Cmd::take [function] [call site] 03101
36 expect [function] [call site] 03102
36 spawn [function] [call site] 03103
36 expect [function] [call site] 03104
36 ClusterClientBuilder::max_retry_wait [function] [call site] 03105
36 expect [function] [call site] 03106
36 ClusterClientBuilder::max_retry_wait [function] [call site] 03107
36 expect [function] [call site] 03108
35 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 03109
35 Some [function] [call site] 03110
35 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 03111
35 ClusterType::build_addr [function] [call site] 03112
36 ClusterType::get_intended [function] [call site] 03113
36 redis::ConnectionAddr::Tcp [function] [call site] 03114
36 &str::into [function] [call site] 03115
36 &str::into [function] [call site] 03116
35 ClientTlsParams::clone [function] [call site] 03117
36 ClientTlsParams::clone [function] [call site] 03118
36 secret_pkcs1_der [function] [call site] 03120
36 write_command_to_vec [function] [call site] 03121
36 secret_pkcs8_der [function] [call site] 03124
36 write_command_to_vec [function] [call site] 03125
36 secret_sec1_der [function] [call site] 03128
36 write_command_to_vec [function] [call site] 03129
35 tempfile::Builder::new [function] [call site] 03131
35 RedisResult::prefix [function] [call site] 03132
35 tempdir [function] [call site] 03133
35 expect [function] [call site] 03134
35 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03135
36 Cmd::arg [function] [call site] 03137
36 types::test_is_single_arg [function] [call site] 03138
36 types::test_is_single_arg [function] [call site] 03139
36 types::test_is_single_arg [function] [call site] 03140
36 types::test_is_single_arg [function] [call site] 03141
36 RoutingInfo::for_routable [function] [call site] 03142
36 std::collections::HashMap::new [function] [call site] 03143
36 RedisServer::insert [function] [call site] 03144
36 RedisServer::insert [function] [call site] 03146
36 RedisServer::insert [function] [call site] 03148
35 join [function] [call site] 03150
35 std::fs::write [function] [call site] 03151
36 RedisServer::new [function] [call site] 03152
36 Tokio::poll_write [function] [call site] 03153
36 RedisServer::new [function] [call site] 03154
36 Tokio::poll_write [function] [call site] 03155
36 RedisServer::new [function] [call site] 03156
36 Tokio::poll_write [function] [call site] 03157
35 Poll::expect [function] [call site] 03158
35 Cmd::arg [function] [call site] 03159
35 types::test_is_single_arg [function] [call site] 03160
35 types::test_is_single_arg [function] [call site] 03161
35 types::test_is_single_arg [function] [call site] 03162
35 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03163
35 join [function] [call site] 03164
35 types::test_is_single_arg [function] [call site] 03165
35 types::test_is_single_arg [function] [call site] 03166
35 types::test_is_single_arg [function] [call site] 03167
35 types::test_is_single_arg [function] [call site] 03168
35 Cmd::arg [function] [call site] 03169
35 types::test_is_single_arg [function] [call site] 03170
35 Cmd::arg [function] [call site] 03171
35 types::test_is_single_arg [function] [call site] 03172
35 Cmd::current_dir [function] [call site] 03173
35 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03174
35 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 03175
35 Cmd::spawn [function] [call site] 03176
35 unwrap [function] [call site] 03177
35 ClusterClientBuilder::max_retry_wait [function] [call site] 03178
35 RedisServer::log_file_contents [function] [call site] 03179
36 std::fs::read_to_string [function] [call site] 03180
36 ClientTlsParams::clone [function] [call site] 03181
36 tests::redis_ok [function] [call site] 03182
35 Err [function] [call site] 03183
35 RedisServer::log_file_contents [function] [call site] 03184
35 Err [function] [call site] 03185
35 port_in_use [function] [call site] 03186
36 ConnectionAddr::parse [function] [call site] 03187
36 socket2::Socket::new [function] [call site] 03189
37 RedisServer::with_modules [function] [call site] 03190
36 socket2::Domain::for_address [function] [call site] 03191
36 RedisServer::expect [function] [call site] 03192
36 tests::redis_ok [function] [call site] 03195
35 ValueComparison::arg_to_string [function] [call site] 03196
35 Ok [function] [call site] 03197
35 std::thread::sleep [function] [call site] 03198
35 Duration::from_millis [function] [call site] 03199
35 &'a [call site] 03200
35 tests::into_redis_value_hashmap [function] [call site] 03201
35 get_random_available_port [function] [call site] 03202
35 RedisServer::contains [function] [call site] 03203
35 RedisServer::insert [function] [call site] 03204
35 make_server [function] [call site] 03205
35 std::thread::sleep [function] [call site] 03206
35 Duration::from_millis [function] [call site] 03207
35 verify_server [function] [call site] 03208
35 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 03209
35 ClientTlsParams::clone [function] [call site] 03210
35 collect [function] [call site] 03211
35 process::Command::new [function] [call site] 03212
35 Cmd::stdout [function] [call site] 03213
35 process::Stdio::piped [function] [call site] 03214
35 types::test_is_single_arg [function] [call site] 03215
35 types::test_is_single_arg [function] [call site] 03216
35 types::test_std_types_to_redis_args [function] [call site] 03217
35 Cmd::arg [function] [call site] 03218
35 types::test_is_single_arg [function] [call site] 03219
35 ValueComparison::arg_to_string [function] [call site] 03220
35 Cmd::arg [function] [call site] 03221
35 Cmd::arg [function] [call site] 03222
35 Cmd::arg [function] [call site] 03223
35 Cmd::arg [function] [call site] 03224
35 Cmd::arg [function] [call site] 03225
35 Cmd::arg [function] [call site] 03226
35 Cmd::arg [function] [call site] 03227
35 Cmd::arg [function] [call site] 03228
35 None::is_some [function] [call site] 03229
35 None::as_ref [function] [call site] 03230
35 unwrap [function] [call site] 03231
35 Cmd::arg [function] [call site] 03232
35 types::test_is_single_arg [function] [call site] 03233
35 types::test_is_single_arg [function] [call site] 03234
35 Cmd::arg [function] [call site] 03235
35 types::test_is_single_arg [function] [call site] 03236
35 Cmd::output [function] [call site] 03237
35 unwrap [function] [call site] 03238
35 test_get_replica_clients_success [function] [call site] 03239
36 TestSentinelContext::new [function] [call site] 03240
36 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03241
36 TestSentinelContext::sentinel_mut [function] [call site] 03242
36 &redis::sentinel::Sentinel::get_replica_clients [function] [call site] 03243
37 Sentinel::find_valid_replica_addresses [function] [call site] 03244
37 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 03245
37 build_replica_clients [function] [call site] 03246
38 MockRedisConnection::is_empty [function] [call site] 03247
38 basic::test_tuple_decoding_from_iter [function] [call site] 03249
39 TestContext::new [function] [call site] 03250
39 TestContext::connection [function] [call site] 03251
39 ValueType::from [function] [call site] 03252
39 basic::test_tuple_decoding_from_iter [function] [call site] 03253
39 hscan::<_, [call site] 03254
38 tests::into_redis_value_hashmap [function] [call site] 03257
38 Client::open [function] [call site] 03258
38 ClientTlsParams::clone [function] [call site] 03259
36 RedisResult::unwrap [function] [call site] 03262
35 std::thread::sleep [function] [call site] 03263
35 Duration::from_millis [function] [call site] 03264
35 RedisCluster::wait_for_replicas [function] [call site] 03265
36 RedisServer::connection_info [function] [call site] 03266
36 redis::Client::open [function] [call site] 03267
36 RedisServer::connection_info [function] [call site] 03268
36 RedisResult::unwrap [function] [call site] 03269
36 Client::get_connection [function] [call site] 03270
36 RedisResult::unwrap [function] [call site] 03271
36 redis::cmd [function] [call site] 03272
36 redis::Cmd::arg [function] [call site] 03273
36 basic::test_pipeline_reuse_query [function] [call site] 03274
36 RedisResult::from_redis_value [function] [call site] 03276
37 from_redis_value [function] [call site] 03280
37 tests::into_redis_value_hashmap [function] [call site] 03281
36 Result::unwrap [function] [call site] 03283
36 basic::test_tuple_decoding_from_iter [function] [call site] 03284
36 block_on_all [function] [call site] 03285
37 panic::set_hook [function] [call site] 03286
37 RedisServer::new [function] [call site] 03287
37 RadiusOptions::store [function] [call site] 03288
38 ToRedisArgs::to_redis_args [function] [call site] 03290
39 RedisServer::new [function] [call site] 03291
39 SetExpiry::write_redis_args [function] [call site] 03292
40 Vec::write_arg [function] [call site] 03293
40 Vec::write_arg [function] [call site] 03294
40 as_bytes [function] [call site] 03295
40 Vec::write_arg [function] [call site] 03296
40 Vec::write_arg [function] [call site] 03297
40 as_bytes [function] [call site] 03298
40 Vec::write_arg [function] [call site] 03299
40 Vec::write_arg [function] [call site] 03300
40 as_bytes [function] [call site] 03301
40 Vec::write_arg [function] [call site] 03302
40 Vec::write_arg [function] [call site] 03303
40 as_bytes [function] [call site] 03304
40 Vec::write_arg [function] [call site] 03305
37 futures_util::FutureExt::fuse [function] [call site] 03306
37 script::test_script_load [function] [call site] 03307
37 futures_time::task::sleep [function] [call site] 03308
38 tokio::time::sleep [function] [call site] 03309
38 smol::Timer::after [function] [call site] 03310
37 futures_time::time::Duration::from_millis [function] [call site] 03311
37 futures_util::FutureExt::fuse [function] [call site] 03312
37 block_on_all_using_tokio [function] [call site] 03313
38 redis::aio::prefer_tokio [function] [call site] 03314
39 set_runtime [function] [call site] 03315
40 tests::into_redis_value_hashset [function] [call site] 03316
40 RedisError::from [function] [call site] 03318
38 Result::unwrap [function] [call site] 03319
38 current_thread_runtime [function] [call site] 03320
39 tokio::runtime::Builder::new_current_thread [function] [call site] 03321
39 enable_io [function] [call site] 03322
39 enable_time [function] [call site] 03323
39 Sentinel::build [function] [call site] 03324
39 RedisResult::unwrap [function] [call site] 03325
38 tokio::runtime::Runtime::block_on [function] [call site] 03326
37 block_on_all_using_smol [function] [call site] 03327
38 redis::aio::prefer_smol [function] [call site] 03328
39 set_runtime [function] [call site] 03329
38 Result::unwrap [function] [call site] 03330
38 smol::block_on [function] [call site] 03331
37 panic::take_hook [function] [call site] 03332
36 basic::test_pipeline_len [function] [call site] 03335
37 redis::pipe [function] [call site] 03336
37 types::test_is_single_arg [function] [call site] 03339
36 std::thread::sleep [function] [call site] 03340
36 Duration::from_millis [function] [call site] 03341
35 wait_for_status_ok [function] [call site] 03342
36 RedisServer::log_file [function] [call site] 03343
37 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03344
36 std::fs::read_to_string [function] [call site] 03346
36 Option::contains [function] [call site] 03348
36 std::thread::sleep [function] [call site] 03349
36 Duration::from_millis [function] [call site] 03350
34 RedisCluster::iter_servers [function] [call site] 03351
34 tests::into_redis_value_hashmap [function] [call site] 03352
34 collect [function] [call site] 03353
34 redis::cluster::ClusterClientBuilder::new [function] [call site] 03354
35 &'a [call site] 03355
35 std::iter::Chain::map [function] [call site] 03356
35 ConnectionInfo::into_connection_info [function] [call site] 03357
35 RedisServer::default [function] [call site] 03359
34 ClientTlsParams::clone [function] [call site] 03360
34 ClusterClientBuilder::use_protocol [function] [call site] 03361
34 redis_test::server::use_protocol [function] [call site] 03363
35 entra_id_tests::get_env_var [function] [call site] 03364
35 String::unwrap_or_default [function] [call site] 03365
34 ClusterType::get_intended [function] [call site] 03366
34 ClusterClientBuilder::certs [function] [call site] 03367
34 super::load_certs_from_file [function] [call site] 03371
35 MockRedisConnection::is_open [function] [call site] 03372
35 bool::expect [function] [call site] 03373
35 RedisServer::new [function] [call site] 03374
35 RedisServer::new [function] [call site] 03375
36 RedisServer::with_modules [function] [call site] 03376
35 RedisServer::read_to_end [function] [call site] 03377
35 MockRedisConnection::is_open [function] [call site] 03379
35 bool::expect [function] [call site] 03380
35 RedisServer::new [function] [call site] 03381
35 RedisServer::new [function] [call site] 03382
35 RedisServer::read_to_end [function] [call site] 03383
35 MockRedisConnection::is_open [function] [call site] 03385
35 bool::expect [function] [call site] 03386
35 RedisServer::new [function] [call site] 03387
35 RedisServer::new [function] [call site] 03388
35 RedisServer::read_to_end [function] [call site] 03389
34 initializer [function] [call site] 03393
34 Sentinel::build [function] [call site] 03394
34 RedisResult::unwrap [function] [call site] 03395
34 redis_test::server::use_protocol [function] [call site] 03396
33 RedisClusterConfiguration::default [function] [call site] 03397
32 cluster::test_cluster_retries [function] [call site] 03398
32 TestClusterContext::get_ports [function] [call site] 03399
32 MockRedisConnection::check_connection [function] [call site] 03400
32 RedisServer::drop [function] [call site] 03401
32 cmd [function] [call site] 03402
32 ClusterConnection::route_command [function] [call site] 03403
32 RoutingInfo::SingleNode [function] [call site] 03404
32 MockRedisConnection::req_packed_command [function] [call site] 03405
32 Cmd::get_packed_command [function] [call site] 03406
32 RedisCluster::new [function] [call site] 03407
32 RedisServer::default [function] [call site] 03408
32 ClusterConnection::route_command [function] [call site] 03409
32 RoutingInfo::SingleNode [function] [call site] 03410
32 RedisResult::unwrap [function] [call site] 03411
31 into [function] [call site] 03412
31 Arc::into_inner [function] [call site] 03413
31 unwrap [function] [call site] 03414
31 into_inner [function] [call site] 03415
31 crate::io::tcp::stream_with_settings [function] [call site] 03416
32 TcpSettings::set_nodelay [function] [call site] 03417
32 TcpStream::into [function] [call site] 03418
32 set_tcp_keepalive [function] [call site] 03419
32 set_linger [function] [call site] 03420
32 set_tcp_user_timeout [function] [call site] 03422
31 try_into [function] [call site] 03426
30 ConnectionAddr::to_socket_addrs [function] [call site] 03427
30 connect_tcp_timeout [function] [call site] 03428
31 TcpStream::connect_timeout [function] [call site] 03429
31 io::tcp::stream_with_settings [function] [call site] 03430
32 TcpSettings::set_nodelay [function] [call site] 03431
32 TcpStream::into [function] [call site] 03432
32 set_tcp_keepalive [function] [call site] 03433
32 set_linger [function] [call site] 03434
32 set_tcp_user_timeout [function] [call site] 03436
30 Some [function] [call site] 03440
30 Some [function] [call site] 03441
30 fail [function] [call site] 03442
30 fail [function] [call site] 03443
30 ActualConnection::Tcp [function] [call site] 03444
30 TlsConnector::builder [function] [call site] 03445
31 TestSentinelContext::new [function] [call site] 03446
31 TestSentinelContext::sentinels_connection_info [function] [call site] 03447
31 Client::open [function] [call site] 03448
31 &redis::sentinel::Sentinel::clone [function] [call site] 03449
32 ClientTlsParams::clone [function] [call site] 03450
32 secret_pkcs1_der [function] [call site] 03452
32 write_command_to_vec [function] [call site] 03453
32 secret_pkcs8_der [function] [call site] 03456
32 write_command_to_vec [function] [call site] 03457
32 secret_sec1_der [function] [call site] 03460
32 write_command_to_vec [function] [call site] 03461
31 RedisResult::inspect_err [function] [call site] 03463
31 log_connection_error [function] [call site] 03464
32 &redis::sentinel::Sentinel::addr [function] [call site] 03465
33 ServerType::get_intended [function] [call site] 03466
33 get_default_host [function] [call site] 03467
33 redis::ConnectionAddr::Tcp [function] [call site] 03468
33 get_default_host [function] [call site] 03469
33 rand::random::<(u64, [call site] 03470
33 redis::ConnectionAddr::Unix [function] [call site] 03471
33 ValueType::from [function] [call site] 03472
32 RedisSentinelCluster::log_redis_state_via_cli [function] [call site] 03473
31 Client::get_connection [function] [call site] 03475
31 inspect_err [function] [call site] 03476
31 log_connection_error [function] [call site] 03477
31 redis::cmd [function] [call site] 03479
31 redis::Cmd::query [function] [call site] 03480
31 RedisResult::unwrap [function] [call site] 03481
31 SentinelClientBuilder::new [function] [call site] 03482
32 &'a [call site] 03484
32 into_iter().collect::<Vec<_>> [function] [call site] 03485
32 impl [call site] 03486
32 TcpSettings::default [function] [call site] 03488
32 TcpSettings::default [function] [call site] 03489
31 basic::test_tuple_decoding_from_iter [function] [call site] 03490
31 tests::into_redis_value_hashmap [function] [call site] 03491
31 &redis::sentinel::Sentinel::addr [function] [call site] 03492
31 ClientTlsParams::clone [function] [call site] 03493
31 String::from [function] [call site] 03494
31 RedisResult::unwrap [function] [call site] 03495
31 SentinelClientBuilder::new [function] [call site] 03496
31 basic::test_tuple_decoding_from_iter [function] [call site] 03497
31 tests::into_redis_value_hashmap [function] [call site] 03498
31 &redis::sentinel::Sentinel::addr [function] [call site] 03499
31 ClientTlsParams::clone [function] [call site] 03500
31 String::from [function] [call site] 03501
31 RedisResult::unwrap [function] [call site] 03502
31 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 03503
31 redis_test::server::use_protocol [function] [call site] 03505
31 TestSentinelContext::tls_mode [function] [call site] 03506
31 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03507
31 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03509
31 Sentinel::build [function] [call site] 03510
31 Sentinel::build [function] [call site] 03512
31 Client::get_connection [function] [call site] 03514
31 redis::cmd [function] [call site] 03516
31 redis::Cmd::query [function] [call site] 03517
31 RedisResult::unwrap [function] [call site] 03518
31 assert_is_connection_to_master [function] [call site] 03519
32 redis::cmd [function] [call site] 03520
32 redis::Cmd::arg [function] [call site] 03521
32 basic::test_pipeline_reuse_query [function] [call site] 03522
32 assert_is_master_role [function] [call site] 03524
31 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03525
31 TestSentinelContext::sentinel_mut [function] [call site] 03526
31 &redis::sentinel::Sentinel::master_for [function] [call site] 03527
32 Sentinel::find_master_address [function] [call site] 03528
32 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 03529
32 Client::open [function] [call site] 03530
31 RedisResult::unwrap [function] [call site] 03532
31 Client::get_connection [function] [call site] 03533
31 redis::cmd [function] [call site] 03535
31 redis::Cmd::query [function] [call site] 03536
31 RedisResult::unwrap [function] [call site] 03537
31 assert_connection_is_replica_of_correct_master [function] [call site] 03538
32 redis::cmd [function] [call site] 03539
32 redis::Cmd::arg [function] [call site] 03540
32 basic::test_pipeline_reuse_query [function] [call site] 03541
32 assert_replica_role_and_master_addr [function] [call site] 03543
32 Client::get_connection_info [function] [call site] 03544
30 danger_accept_invalid_certs [function] [call site] 03545
30 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03546
31 ClusterType::get_intended [function] [call site] 03547
31 TestClusterContext::new_with_config_and_builder [function] [call site] 03548
32 support::start_tls_crypto_provider [function] [call site] 03549
32 RedisCluster::new [function] [call site] 03550
32 RedisCluster::iter_servers [function] [call site] 03551
32 tests::into_redis_value_hashmap [function] [call site] 03552
32 redis::cluster::ClusterClientBuilder::new [function] [call site] 03554
32 ClientTlsParams::clone [function] [call site] 03555
32 ClusterClientBuilder::use_protocol [function] [call site] 03556
32 redis_test::server::use_protocol [function] [call site] 03557
32 ClusterType::get_intended [function] [call site] 03558
32 ClusterClientBuilder::certs [function] [call site] 03559
32 super::load_certs_from_file [function] [call site] 03560
32 initializer [function] [call site] 03561
32 Sentinel::build [function] [call site] 03562
32 RedisResult::unwrap [function] [call site] 03563
32 redis_test::server::use_protocol [function] [call site] 03564
31 RedisServer::default [function] [call site] 03565
31 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03566
31 cluster::smoke_test_connection [function] [call site] 03567
32 redis::cmd [function] [call site] 03568
32 redis::Cmd::arg [function] [call site] 03569
32 types::test_is_single_arg [function] [call site] 03570
32 Cmd::exec [function] [call site] 03571
33 query::<()> [function] [call site] 03572
32 RedisResult::unwrap [function] [call site] 03573
32 redis::cmd [function] [call site] 03574
32 redis::Cmd::arg [function] [call site] 03575
32 Cmd::exec [function] [call site] 03576
32 RedisResult::unwrap [function] [call site] 03577
31 MockRedisConnection::check_connection [function] [call site] 03578
30 use_sni [function] [call site] 03579
30 Sentinel::build [function] [call site] 03580
30 TlsConnector::builder [function] [call site] 03581
30 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03582
30 Sentinel::build [function] [call site] 03583
30 RedisServer::new [function] [call site] 03584
31 RedisServer::with_modules [function] [call site] 03585
30 String::as_str [function] [call site] 03586
30 connect_tcp [function] [call site] 03587
30 connect [function] [call site] 03588
30 fail [function] [call site] 03589
30 String::as_str [function] [call site] 03590
30 to_socket_addrs [function] [call site] 03591
30 connect_tcp_timeout [function] [call site] 03592
30 Some [function] [call site] 03593
30 Some [function] [call site] 03594
30 connect [function] [call site] 03595
30 unwrap [function] [call site] 03596
30 fail [function] [call site] 03597
30 fail [function] [call site] 03598
30 ActualConnection::TcpNativeTls [function] [call site] 03599
30 RedisServer::new [function] [call site] 03600
30 create_rustls_config [function] [call site] 03601
31 MockRedisConnection::is_empty [function] [call site] 03602
32 StreamReadOptions::block [function] [call site] 03603
32 MockRedisConnection::is_empty [function] [call site] 03605
31 bool::extend [function] [call site] 03606
31 basic::test_tuple_decoding_from_iter [function] [call site] 03607
31 rustls_native_certs::load_native_certs [function] [call site] 03609
31 test_module_json_arr_pop [function] [call site] 03610
32 TestContext::with_modules [function] [call site] 03611
32 TestContext::connection [function] [call site] 03612
32 redis::Connection::json_set [function] [call site] 03613
32 redis::Connection::json_arr_pop [function] [call site] 03614
32 redis::Connection::json_set [function] [call site] 03615
32 redis::Connection::json_arr_pop [function] [call site] 03616
31 bool::add [function] [call site] 03619
32 &mut [call site] 03620
32 &mut [call site] 03622
32 &mut [call site] 03624
32 &mut [call site] 03626
31 rustls::ClientConfig::builder [function] [call site] 03628
32 TestSentinelContext::new [function] [call site] 03629
32 TestSentinelContext::sentinels_connection_info [function] [call site] 03630
32 Client::open [function] [call site] 03631
32 &redis::sentinel::Sentinel::clone [function] [call site] 03632
32 RedisResult::inspect_err [function] [call site] 03633
32 log_connection_error [function] [call site] 03634
32 Client::get_connection [function] [call site] 03636
32 inspect_err [function] [call site] 03637
32 log_connection_error [function] [call site] 03638
32 redis::cmd [function] [call site] 03640
32 redis::Cmd::query [function] [call site] 03641
32 RedisResult::unwrap [function] [call site] 03642
32 SentinelClientBuilder::new [function] [call site] 03643
32 basic::test_tuple_decoding_from_iter [function] [call site] 03644
32 tests::into_redis_value_hashmap [function] [call site] 03645
32 &redis::sentinel::Sentinel::addr [function] [call site] 03646
32 ClientTlsParams::clone [function] [call site] 03647
32 String::from [function] [call site] 03648
32 RedisResult::unwrap [function] [call site] 03649
32 SentinelClientBuilder::new [function] [call site] 03650
32 basic::test_tuple_decoding_from_iter [function] [call site] 03651
32 tests::into_redis_value_hashmap [function] [call site] 03652
32 &redis::sentinel::Sentinel::addr [function] [call site] 03653
32 ClientTlsParams::clone [function] [call site] 03654
32 String::from [function] [call site] 03655
32 RedisResult::unwrap [function] [call site] 03656
32 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 03657
32 redis_test::server::use_protocol [function] [call site] 03658
32 TestSentinelContext::tls_mode [function] [call site] 03659
32 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03660
32 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03661
32 Sentinel::build [function] [call site] 03662
32 Sentinel::build [function] [call site] 03664
32 Client::get_connection [function] [call site] 03666
32 redis::cmd [function] [call site] 03668
32 redis::Cmd::query [function] [call site] 03669
32 RedisResult::unwrap [function] [call site] 03670
32 assert_is_connection_to_master [function] [call site] 03671
32 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03672
32 TestSentinelContext::sentinel_mut [function] [call site] 03673
32 &redis::sentinel::Sentinel::master_for [function] [call site] 03674
32 RedisResult::unwrap [function] [call site] 03676
32 Client::get_connection [function] [call site] 03677
32 redis::cmd [function] [call site] 03679
32 redis::Cmd::query [function] [call site] 03680
32 RedisResult::unwrap [function] [call site] 03681
32 assert_connection_is_replica_of_correct_master [function] [call site] 03682
31 unwrap_or [function] [call site] 03683
31 Self::with_root_certificates [function] [call site] 03684
31 ClientTlsParams::clone [function] [call site] 03685
31 with_client_auth_cert [function] [call site] 03686
31 RedisError::from [function] [call site] 03688
31 ValueComparison::arg_to_string [function] [call site] 03689
31 with_no_client_auth [function] [call site] 03690
31 Self::dangerous [function] [call site] 03692
31 set_certificate_verifier [function] [call site] 03693
31 RedisServer::new [function] [call site] 03694
31 rustls::client::WebPkiServerVerifier::builder [function] [call site] 03695
32 TestSentinelContext::new [function] [call site] 03696
32 TestSentinelContext::sentinels_connection_info [function] [call site] 03697
32 Client::open [function] [call site] 03698
32 &redis::sentinel::Sentinel::clone [function] [call site] 03699
32 RedisResult::inspect_err [function] [call site] 03700
32 log_connection_error [function] [call site] 03701
32 Client::get_connection [function] [call site] 03703
32 inspect_err [function] [call site] 03704
32 log_connection_error [function] [call site] 03705
32 redis::cmd [function] [call site] 03707
32 redis::Cmd::query [function] [call site] 03708
32 RedisResult::unwrap [function] [call site] 03709
32 SentinelClientBuilder::new [function] [call site] 03710
32 basic::test_tuple_decoding_from_iter [function] [call site] 03711
32 tests::into_redis_value_hashmap [function] [call site] 03712
32 &redis::sentinel::Sentinel::addr [function] [call site] 03713
32 ClientTlsParams::clone [function] [call site] 03714
32 String::from [function] [call site] 03715
32 RedisResult::unwrap [function] [call site] 03716
32 SentinelClientBuilder::new [function] [call site] 03717
32 basic::test_tuple_decoding_from_iter [function] [call site] 03718
32 tests::into_redis_value_hashmap [function] [call site] 03719
32 &redis::sentinel::Sentinel::addr [function] [call site] 03720
32 ClientTlsParams::clone [function] [call site] 03721
32 String::from [function] [call site] 03722
32 RedisResult::unwrap [function] [call site] 03723
32 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 03724
32 redis_test::server::use_protocol [function] [call site] 03725
32 TestSentinelContext::tls_mode [function] [call site] 03726
32 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03727
32 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03728
32 Sentinel::build [function] [call site] 03729
32 Sentinel::build [function] [call site] 03731
32 Client::get_connection [function] [call site] 03733
32 redis::cmd [function] [call site] 03735
32 redis::Cmd::query [function] [call site] 03736
32 RedisResult::unwrap [function] [call site] 03737
32 assert_is_connection_to_master [function] [call site] 03738
32 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03739
32 TestSentinelContext::sentinel_mut [function] [call site] 03740
32 &redis::sentinel::Sentinel::master_for [function] [call site] 03741
32 RedisResult::unwrap [function] [call site] 03743
32 Client::get_connection [function] [call site] 03744
32 redis::cmd [function] [call site] 03746
32 redis::Cmd::query [function] [call site] 03747
32 RedisResult::unwrap [function] [call site] 03748
32 assert_connection_is_replica_of_correct_master [function] [call site] 03749
31 RedisServer::new [function] [call site] 03750
31 Sentinel::build [function] [call site] 03751
31 RedisResult::map_err [function] [call site] 03752
31 rustls::Error::from [function] [call site] 03753
32 io::Error::from [function] [call site] 03754
32 Self::into [function] [call site] 03755
31 rustls::OtherError [function] [call site] 03756
31 RedisServer::new [function] [call site] 03757
31 Self::with_root_certificates [function] [call site] 03758
31 with_no_client_auth [function] [call site] 03759
31 rustls::crypto::CryptoProvider::get_default [function] [call site] 03760
31 RedisError::from [function] [call site] 03762
31 Self::dangerous [function] [call site] 03763
31 set_certificate_verifier [function] [call site] 03764
31 RedisServer::new [function] [call site] 03765
30 ClientTlsParams::clone [function] [call site] 03769
30 rustls::ClientConnection::new [function] [call site] 03770
31 RedisServer::with_modules [function] [call site] 03771
30 RedisServer::new [function] [call site] 03772
30 rustls::pki_types::ServerName::try_from [function] [call site] 03773
30 to_owned [function] [call site] 03776
30 connect_tcp [function] [call site] 03777
30 RedisServer::new [function] [call site] 03778
31 RedisServer::with_modules [function] [call site] 03779
30 to_socket_addrs [function] [call site] 03780
30 connect_tcp_timeout [function] [call site] 03781
30 Some [function] [call site] 03782
30 Some [function] [call site] 03783
30 RedisServer::new [function] [call site] 03784
30 fail [function] [call site] 03785
30 fail [function] [call site] 03786
30 ActualConnection::TcpRustls [function] [call site] 03787
30 RedisServer::new [function] [call site] 03788
30 fail [function] [call site] 03789
30 ActualConnection::Unix [function] [call site] 03790
30 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 03791
31 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 03792
31 cluster::test_cluster_retries [function] [call site] 03793
31 TestClusterContext::get_ports [function] [call site] 03794
31 MockRedisConnection::check_connection [function] [call site] 03795
31 RedisServer::drop [function] [call site] 03796
31 ClusterConnection::route_command [function] [call site] 03798
31 RoutingInfo::SingleNode [function] [call site] 03799
31 MockRedisConnection::req_packed_command [function] [call site] 03800
31 Cmd::get_packed_command [function] [call site] 03801
31 RedisCluster::new [function] [call site] 03802
31 RedisServer::default [function] [call site] 03803
31 ClusterConnection::route_command [function] [call site] 03804
31 RoutingInfo::SingleNode [function] [call site] 03805
31 RedisResult::unwrap [function] [call site] 03806
30 fail [function] [call site] 03807
29 and_then [function] [call site] 03808
29 checked_sub [function] [call site] 03809
29 elapsed [function] [call site] 03810
29 is_some [function] [call site] 03811
29 is_none [function] [call site] 03812
29 Err [function] [call site] 03813
29 RedisError::from [function] [call site] 03814
29 std::io::Error::new [function] [call site] 03815
30 RedisServer::with_modules [function] [call site] 03816
29 MockConnection::set_read_timeout [function] [call site] 03817
29 MockConnection::set_write_timeout [function] [call site] 03819
29 setup_connection [function] [call site] 03821
30 execute_connection_pipeline [function] [call site] 03822
31 basic::test_pipeline_len [function] [call site] 03823
31 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 03825
31 Pipeline::get_packed_pipeline [function] [call site] 03826
32 encode_pipeline [function] [call site] 03827
33 write_pipeline [function] [call site] 03828
34 basic::test_tuple_decoding_from_iter [function] [call site] 03829
34 tests::into_redis_value_hashmap [function] [call site] 03830
34 cmd::cmd [function] [call site] 03832
34 cmd::cmd [function] [call site] 03833
34 &mut [call site] 03834
34 cmd::cmd_len [function] [call site] 03835
35 args_len [function] [call site] 03836
35 Cmd::args_iter [function] [call site] 03837
35 unwrap_or [function] [call site] 03838
34 cmd::cmd_len [function] [call site] 03839
34 Cmd::write_packed_command_preallocated [function] [call site] 03840
35 write_command [function] [call site] 03841
35 Cmd::args_iter [function] [call site] 03842
35 unwrap_or [function] [call site] 03843
35 io::Result::unwrap [function] [call site] 03844
34 Cmd::write_packed_command_preallocated [function] [call site] 03845
35 write_command [function] [call site] 03846
35 Cmd::args_iter [function] [call site] 03847
35 unwrap_or [function] [call site] 03848
35 io::Result::unwrap [function] [call site] 03849
34 Cmd::write_packed_command_preallocated [function] [call site] 03850
34 &mut [call site] 03851
34 Cmd::write_packed_command_preallocated [function] [call site] 03852
31 Cmd::with_capacity [function] [call site] 03853
31 MapIter::next [function] [call site] 03854
32 MapIter::next [function] [call site] 03856
32 MapIter::next [function] [call site] 03857
32 MapIter::next [function] [call site] 03858
31 ok_or_else [function] [call site] 03860
31 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 03861
31 connection::check_connection_setup [function] [call site] 03862
32 hotkeys_cluster::setup_cluster_and_target [function] [call site] 03863
33 TestClusterContext::new [function] [call site] 03864
33 TestClusterContext::wait_for_cluster_up [function] [call site] 03865
33 RedisCluster::iter_servers [function] [call site] 03866
33 MapIter::next [function] [call site] 03867
33 RedisServer::connection_info [function] [call site] 03869
33 hotkeys_cluster::port_of [function] [call site] 03870
33 redis::ConnectionInfo::addr [function] [call site] 03871
33 hotkeys_cluster::direct_connection [function] [call site] 03872
33 redis::ConnectionInfo::clone [function] [call site] 03873
33 redis::Cmd::new [function] [call site] 03874
33 types::test_is_single_arg [function] [call site] 03875
33 basic::test_pipeline_reuse_query [function] [call site] 03876
33 parse_version [function] [call site] 03878
33 hotkeys_cluster::first_owned_slot_range [function] [call site] 03879
33 hotkeys_cluster::find_key_in_range [function] [call site] 03880
32 check_resp3_auth [function] [call site] 03884
33 get_resp3_hello_command_error [function] [call site] 03886
34 RedisError::detail [function] [call site] 03887
35 Option::as_ref [function] [call site] 03888
35 tests::into_redis_value_hashmap [function] [call site] 03889
35 Option::as_str [function] [call site] 03890
35 ServerError::details [function] [call site] 03892
36 Option::as_ref [function] [call site] 03893
36 tests::into_redis_value_hashmap [function] [call site] 03894
36 Option::as_ref [function] [call site] 03896
36 tests::into_redis_value_hashmap [function] [call site] 03897
34 Option::starts_with [function] [call site] 03899
33 ClientTlsParams::clone [function] [call site] 03901
33 Self::into [function] [call site] 03902
32 hotkeys_cluster::setup_cluster_and_target [function] [call site] 03904
32 hotkeys_cluster::setup_cluster_and_target [function] [call site] 03919
32 check_db_select [function] [call site] 03922
32 hotkeys_cluster::setup_cluster_and_target [function] [call site] 03932
30 connection_setup_pipeline [function] [call site] 03941
31 cmd::pipe [function] [call site] 03942
32 redis::pipe [function] [call site] 03943
32 Pipeline::atomic [function] [call site] 03944
32 redis::pipe [function] [call site] 03945
31 ProtocolVersion::supports_resp3 [function] [call site] 03946
31 add_command [function] [call site] 03947
31 commands::resp3_hello [function] [call site] 03948
32 cmd::cmd [function] [call site] 03949
32 Cmd::arg [function] [call site] 03950
32 Cmd::arg [function] [call site] 03952
32 types::test_is_single_arg [function] [call site] 03953
32 types::test_is_single_arg [function] [call site] 03954
32 &'static [call site] 03955
31 add_command [function] [call site] 03958
31 authenticate_cmd [function] [call site] 03959
32 cmd::cmd [function] [call site] 03960
32 types::test_is_single_arg [function] [call site] 03961
32 types::test_is_single_arg [function] [call site] 03962
31 bool::then [function] [call site] 03963
31 redis::ConnectionInfo::username [function] [call site] 03964
32 as_deref [function] [call site] 03965
31 basic::test_pipeline_len [function] [call site] 03969
31 cmd::cmd [function] [call site] 03971
31 Cmd::arg [function] [call site] 03972
31 tests::into_redis_value_hashmap [function] [call site] 03973
32 ValueType::from [function] [call site] 03974
32 String::into_redis_value [function] [call site] 03975
32 Value::into_map_iter [function] [call site] 03976
32 Result::expect [function] [call site] 03977
32 into_map_iter() [call site] 03978
6 .expect("extracting [call site] 03979
6 .collect::<Vec<(Value, [call site] 03980
31 cmd::cmd [function] [call site] 03983
31 Cmd::arg [function] [call site] 03984
31 types::test_is_single_arg [function] [call site] 03985
31 types::test_is_single_arg [function] [call site] 03986
31 basic::test_pipeline_len [function] [call site] 03987
31 cmd::cmd [function] [call site] 03988
31 Cmd::arg [function] [call site] 03989
31 types::test_is_single_arg [function] [call site] 03990
31 types::test_is_single_arg [function] [call site] 03991
31 as_ref [function] [call site] 03992
31 map_or [function] [call site] 03993
31 ignore [function] [call site] 03994
31 cmd::cmd [function] [call site] 03995
31 Cmd::arg [function] [call site] 03996
31 types::test_is_single_arg [function] [call site] 03997
31 types::test_is_single_arg [function] [call site] 03998
31 as_ref [function] [call site] 03999
31 map_or [function] [call site] 04000
31 ignore [function] [call site] 04001
30 execute_connection_pipeline [function] [call site] 04002
30 connection_setup_pipeline [function] [call site] 04003
30 Ok [function] [call site] 04004
29 MockConnection::set_read_timeout [function] [call site] 04005
29 MockConnection::set_write_timeout [function] [call site] 04006
29 Ok [function] [call site] 04007
27 unwrap [function] [call site] 04008
26 ValueType::from [function] [call site] 04009
26 basic::test_tuple_decoding_from_iter [function] [call site] 04010
26 hscan::<_, [call site] 04011
26 unwrap [function] [call site] 04012
26 unwrap [function] [call site] 04013
24 into_iter().collect::<Vec<_>> [function] [call site] 04014
24 impl [call site] 04015
24 into [function] [call site] 04016
24 TcpSettings::default [function] [call site] 04017
24 TcpSettings::default [function] [call site] 04018
23 RedisResult::prefix [function] [call site] 04019
23 tempdir [function] [call site] 04020
23 expect [function] [call site] 04021
23 RedisServer::log_file [function] [call site] 04022
24 tests_routing::test_multi_shard_keys_and_path [function] [call site] 04023
23 types::test_is_single_arg [function] [call site] 04025
23 types::test_is_single_arg [function] [call site] 04026
23 ClientTlsParams::clone [function] [call site] 04027
24 ClientTlsParams::clone [function] [call site] 04028
24 secret_pkcs1_der [function] [call site] 04030
24 write_command_to_vec [function] [call site] 04031
24 secret_pkcs8_der [function] [call site] 04034
24 write_command_to_vec [function] [call site] 04035
24 secret_sec1_der [function] [call site] 04038
24 write_command_to_vec [function] [call site] 04039
23 get_major_version [function] [call site] 04041
24 String::from_utf8 [function] [call site] 04042
24 process::Command::new [function] [call site] 04043
24 types::test_is_single_arg [function] [call site] 04044
24 split_once [function] [call site] 04048
24 split_once [function] [call site] 04050
23 types::test_is_single_arg [function] [call site] 04054
23 types::test_is_single_arg [function] [call site] 04055
23 types::test_is_single_arg [function] [call site] 04056
23 types::test_is_single_arg [function] [call site] 04057
23 ValueComparison::arg_to_string [function] [call site] 04058
23 types::test_is_single_arg [function] [call site] 04059
23 types::test_is_single_arg [function] [call site] 04060
23 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04061
24 entra_id_tests::get_env_var [function] [call site] 04062
24 String::unwrap_or_else [function] [call site] 04063
24 ValueComparison::arg_to_string [function] [call site] 04064
24 process::Command::new [function] [call site] 04065
24 types::test_is_single_arg [function] [call site] 04066
24 types::test_is_single_arg [function] [call site] 04067
24 types::test_is_single_arg [function] [call site] 04068
24 entra_id_tests::get_env_var [function] [call site] 04069
24 entra_id_tests::get_env_var [function] [call site] 04070
24 types::test_is_single_arg [function] [call site] 04071
24 types::test_is_single_arg [function] [call site] 04072
24 RedisServer::stdout [function] [call site] 04073
24 process::Stdio::piped [function] [call site] 04074
24 process::Stdio::piped [function] [call site] 04076
24 tempfile::Builder::new [function] [call site] 04077
24 RedisResult::prefix [function] [call site] 04078
24 RedisServer::log_file [function] [call site] 04081
24 types::test_is_single_arg [function] [call site] 04082
24 types::test_is_single_arg [function] [call site] 04083
24 ClientTlsParams::clone [function] [call site] 04084
24 get_major_version [function] [call site] 04085
24 types::test_is_single_arg [function] [call site] 04086
24 types::test_is_single_arg [function] [call site] 04087
24 types::test_is_single_arg [function] [call site] 04088
24 types::test_is_single_arg [function] [call site] 04089
24 ValueComparison::arg_to_string [function] [call site] 04090
24 types::test_is_single_arg [function] [call site] 04091
24 types::test_is_single_arg [function] [call site] 04092
24 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04093
24 Option<TlsFilePaths>::unwrap_or_else [function] [call site] 04094
24 utils::build_keys_and_certs_for_tls [function] [call site] 04095
25 build_keys_and_certs_for_tls_ext [function] [call site] 04096
24 types::test_is_single_arg [function] [call site] 04097
24 types::test_is_single_arg [function] [call site] 04098
24 ValueComparison::arg_to_string [function] [call site] 04099
24 types::test_is_single_arg [function] [call site] 04100
24 types::test_is_single_arg [function] [call site] 04101
24 types::test_is_single_arg [function] [call site] 04102
24 types::test_is_single_arg [function] [call site] 04103
24 types::test_is_single_arg [function] [call site] 04104
24 types::test_is_single_arg [function] [call site] 04105
24 types::test_is_single_arg [function] [call site] 04106
24 types::test_is_single_arg [function] [call site] 04107
24 types::test_is_single_arg [function] [call site] 04108
24 types::test_is_single_arg [function] [call site] 04109
24 types::test_is_single_arg [function] [call site] 04110
24 types::test_is_single_arg [function] [call site] 04111
24 types::test_is_single_arg [function] [call site] 04112
24 types::test_is_single_arg [function] [call site] 04113
24 ClientTlsParams::clone [function] [call site] 04114
24 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04115
24 types::test_is_single_arg [function] [call site] 04117
24 types::test_is_single_arg [function] [call site] 04118
24 types::test_is_single_arg [function] [call site] 04119
24 types::test_is_single_arg [function] [call site] 04120
24 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04121
23 Option<TlsFilePaths>::unwrap_or_else [function] [call site] 04122
23 utils::build_keys_and_certs_for_tls [function] [call site] 04123
23 types::test_is_single_arg [function] [call site] 04124
23 types::test_is_single_arg [function] [call site] 04125
23 ValueComparison::arg_to_string [function] [call site] 04126
23 types::test_is_single_arg [function] [call site] 04127
23 types::test_is_single_arg [function] [call site] 04128
23 types::test_is_single_arg [function] [call site] 04129
23 types::test_is_single_arg [function] [call site] 04130
23 types::test_is_single_arg [function] [call site] 04131
23 types::test_is_single_arg [function] [call site] 04132
23 types::test_is_single_arg [function] [call site] 04133
23 types::test_is_single_arg [function] [call site] 04134
23 types::test_is_single_arg [function] [call site] 04135
23 types::test_is_single_arg [function] [call site] 04136
23 types::test_is_single_arg [function] [call site] 04137
23 types::test_is_single_arg [function] [call site] 04138
23 types::test_is_single_arg [function] [call site] 04139
23 types::test_is_single_arg [function] [call site] 04140
23 ClientTlsParams::clone [function] [call site] 04141
23 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04142
23 Some [function] [call site] 04143
23 types::test_is_single_arg [function] [call site] 04144
23 types::test_is_single_arg [function] [call site] 04145
23 types::test_is_single_arg [function] [call site] 04146
23 types::test_is_single_arg [function] [call site] 04147
23 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04148
22 Cmd::spawn [function] [call site] 04149
22 unwrap_or_else [function] [call site] 04150
22 build_single_client [function] [call site] 04151
23 redis::Client::open [function] [call site] 04152
22 RedisServer::connection_info [function] [call site] 04153
22 RedisResult::unwrap [function] [call site] 04154
22 Duration::from_millis [function] [call site] 04155
22 Client::get_connection [function] [call site] 04156
22 RedisError::is_connection_refusal [function] [call site] 04157
23 RedisError::as_io_error [function] [call site] 04158
23 Option::is_some_and [function] [call site] 04159
23 get_push_kind [function] [call site] 04160
22 std::thread::sleep [function] [call site] 04161
22 flushdb::<()> [function] [call site] 04162
22 std::thread::sleep [function] [call site] 04163
22 redis_test::server::use_protocol [function] [call site] 04164
17 ProtocolVersion::supports_resp3 [function] [call site] 04165
17 tokio::sync::mpsc::unbounded_channel [function] [call site] 04166
17 redis::aio::ConnectionManagerConfig::new [function] [call site] 04167
17 AsyncConnectionConfig::set_push_sender [function] [call site] 04168
17 Client::get_connection_manager_lazy [function] [call site] 04169
17 unwrap [function] [call site] 04170
17 tests::into_redis_value_hashset [function] [call site] 04171
17 unwrap [function] [call site] 04172
17 MockConnection::send_packed_command [function] [call site] 04173
17 cmd [function] [call site] 04174
17 Cmd::arg [function] [call site] 04175
17 types::test_is_single_arg [function] [call site] 04176
17 unwrap [function] [call site] 04177
17 hotkeys_cluster::setup_cluster_and_target [function] [call site] 04178
17 unwrap [function] [call site] 04179
17 tests::into_redis_value_hashset [function] [call site] 04180
17 unwrap [function] [call site] 04181
17 Pipeline::send_recv [function] [call site] 04182
17 unwrap [function] [call site] 04183
16 to_owned [function] [call site] 04184
15 Vec::write_arg [function] [call site] 04185
15 as_bytes [function] [call site] 04186
15 Vec::write_arg [function] [call site] 04187
15 Vec::write_arg [function] [call site] 04188
15 as_bytes [function] [call site] 04189
15 Vec::write_arg [function] [call site] 04190
15 Vec::write_arg [function] [call site] 04191
15 as_bytes [function] [call site] 04192
15 Vec::write_arg [function] [call site] 04193
15 Vec::write_arg [function] [call site] 04194
15 as_bytes [function] [call site] 04195
15 Vec::write_arg [function] [call site] 04196
12 cmd [function] [call site] 04197
12 types::test_is_single_arg [function] [call site] 04198
11 bulklen [function] [call site] 04199
12 countdigits [function] [call site] 04200
11 countdigits [function] [call site] 04201
11 basic::test_pipeline_len [function] [call site] 04202
10 ClientTlsParams::clone [function] [call site] 04203
10 Cmd::reserve [function] [call site] 04204
10 write_command [function] [call site] 04205
10 io::Result::unwrap [function] [call site] 04206
8 Value::into_map_iter [function] [call site] 04207
8 Result::expect [function] [call site] 04208
8 into_map_iter() [call site] 04209
6 .expect("extracting [call site] 04210
6 .collect::<Vec<(Value, [call site] 04211
6 get_default_host [function] [call site] 04214
6 redis::ConnectionAddr::Tcp [function] [call site] 04215
6 get_default_host [function] [call site] 04216
6 rand::random::<(u64, [call site] 04217
6 redis::ConnectionAddr::Unix [function] [call site] 04218
6 ValueType::from [function] [call site] 04219
5 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04220
5 Cmd::spawn [function] [call site] 04221
5 unwrap_or_else [function] [call site] 04222
2 Parser::parse_value [function] [call site] 04223