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
2089 1216 get_push_kind call site: 01216 cluster::test_cluster_reconnect_after_complete_server_disconnect
949 265 parse_redis_value call site: 00265 Client::get_connection
915 3306 RedisCluster::new call site: 03306 cluster::test_cluster_reconnect_after_complete_server_disconnect
260 3 Parser::new call site: 00003 cluster::test_cluster_reconnect_after_complete_server_disconnect
1 0 EP call site: 00000

Fuzzer calltree

0 fuzz_target [function] [call site] 00000
1 redis::parse_redis_value [function] [call site] 00001
2 Parser::new [function] [call site] 00002
3 RedisServer::new [function] [call site] 00003
4 RedisServer::with_modules [function] [call site] 00004
5 utils::get_random_available_port [function] [call site] 00005
6 get_listener_on_free_port [function] [call site] 00006
7 0.0.1:0".parse::<SocketAddr> [function] [call site] 00007
7 RedisServer::new [function] [call site] 00010
8 RedisServer::with_modules [function] [call site] 00011
7 RedisServer::unwrap [function] [call site] 00012
7 set_reuse_address [function] [call site] 00013
7 ValueType::from [function] [call site] 00019
8 TlsFilePaths::as_ref [function] [call site] 00020
8 ValueType::Unknown [function] [call site] 00021
8 ValueComparison::arg_to_string [function] [call site] 00022
9 impl [call site] 00023
9 String::from_utf8_lossy [function] [call site] 00024
9 into_owned [function] [call site] 00025
6 TcpListener::local_addr [function] [call site] 00026
6 get_listener_on_free_port [function] [call site] 00028
7 0.0.1:0".parse::<SocketAddr> [function] [call site] 00029
7 RedisServer::new [function] [call site] 00032
7 RedisServer::unwrap [function] [call site] 00033
7 set_reuse_address [function] [call site] 00034
7 ValueType::from [function] [call site] 00040
5 RedisServer::get_addr [function] [call site] 00041
6 ServerType::get_intended [function] [call site] 00042
7 entra_id_tests::get_env_var [function] [call site] 00043
8 std::env::var [function] [call site] 00044
9 std::env::var [function] [call site] 00045
9 String::unwrap_or_else [function] [call site] 00046
8 String::unwrap_or_else [function] [call site] 00047
7 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 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00087
22 entra_id_tests::get_env_var [function] [call site] 00088
22 String::unwrap_or_else [function] [call site] 00089
22 ValueComparison::arg_to_string [function] [call site] 00090
23 impl [call site] 00091
23 String::from_utf8_lossy [function] [call site] 00092
23 into_owned [function] [call site] 00093
22 process::Command::new [function] [call site] 00094
23 RedisServer::with_modules [function] [call site] 00095
22 types::test_is_single_arg [function] [call site] 00096
22 types::test_is_single_arg [function] [call site] 00097
22 types::test_is_single_arg [function] [call site] 00098
22 entra_id_tests::get_env_var [function] [call site] 00099
22 entra_id_tests::get_env_var [function] [call site] 00100
22 types::test_is_single_arg [function] [call site] 00101
22 types::test_is_single_arg [function] [call site] 00102
22 RedisServer::stdout [function] [call site] 00103
22 process::Stdio::piped [function] [call site] 00104
22 process::Stdio::piped [function] [call site] 00106
22 tempfile::Builder::new [function] [call site] 00107
23 &'a [call site] 00109
24 std::iter::once [function] [call site] 00110
24 basic::test_tuple_decoding_from_iter [function] [call site] 00112
25 TestContext::new [function] [call site] 00113
25 TestContext::connection [function] [call site] 00114
26 Client::get_connection [function] [call site] 00115
27 connect [function] [call site] 00116
28 Instant::now [function] [call site] 00117
28 ActualConnection::new [function] [call site] 00118
29 is_wildcard_address [function] [call site] 00120
29 fail [function] [call site] 00121
30 ::std::convert::From::from [function] [call site] 00123
29 &str::as_str [function] [call site] 00124
29 connect_tcp [function] [call site] 00125
30 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 00126
31 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 00127
32 TestClusterContext::new_with_config_and_builder [function] [call site] 00128
33 support::start_tls_crypto_provider [function] [call site] 00129
34 rustls::crypto::CryptoProvider::get_default [function] [call site] 00130
34 rustls::crypto::ring::default_provider [function] [call site] 00132
34 install_default [function] [call site] 00133
33 RedisCluster::new [function] [call site] 00134
34 MockRedisConnection::is_empty [function] [call site] 00135
35 StreamReadOptions::block [function] [call site] 00136
35 MockRedisConnection::is_empty [function] [call site] 00139
36 StreamReadOptions::block [function] [call site] 00140
36 MockRedisConnection::is_empty [function] [call site] 00142
34 &'a [call site] 00143
35 std::iter::once [function] [call site] 00144
35 basic::test_tuple_decoding_from_iter [function] [call site] 00146
34 std::iter::Chain::map [function] [call site] 00147
35 ValueType::from [function] [call site] 00148
35 String::into_redis_value [function] [call site] 00149
35 Value::into_map_iter [function] [call site] 00150
36 basic::test_pipeline_len [function] [call site] 00151
36 OwnedMapIter::Array [function] [call site] 00153
36 &'a [call site] 00154
37 std::iter::once [function] [call site] 00155
37 basic::test_tuple_decoding_from_iter [function] [call site] 00157
36 Value::Array [function] [call site] 00159
36 OwnedMapIter::Map [function] [call site] 00161
36 &'a [call site] 00162
35 Result::expect [function] [call site] 00164
35 into_map_iter() [call site] 00165
6 .expect("extracting [call site] 00166
6 .collect::<Vec<(Value, [call site] 00167
34 std::collections::HashSet::new [function] [call site] 00171
35 RedisServer::with_modules [function] [call site] 00172
34 ClusterType::get_intended [function] [call site] 00173
35 entra_id_tests::get_env_var [function] [call site] 00174
35 tests::redis_ok [function] [call site] 00175
35 tests::into_redis_value_hashmap [function] [call site] 00177
34 tempfile::Builder::new [function] [call site] 00178
34 RedisResult::prefix [function] [call site] 00179
34 { [call site] 00182
0 server::build_keys_and_certs_for_tls_ext [function] [call site] 00183
35 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00184
36 Cmd::arg [function] [call site] 00186
36 types::test_is_single_arg [function] [call site] 00187
36 types::test_is_single_arg [function] [call site] 00188
36 types::test_is_single_arg [function] [call site] 00189
36 types::test_is_single_arg [function] [call site] 00190
36 RoutingInfo::for_routable [function] [call site] 00191
37 MockRedisConnection::req_packed_command [function] [call site] 00192
38 Cmd::get_packed_command [function] [call site] 00193
39 RedisServer::new [function] [call site] 00194
40 RedisServer::with_modules [function] [call site] 00195
39 Cmd::is_empty [function] [call site] 00196
40 MockRedisConnection::is_empty [function] [call site] 00197
39 Cmd::write_packed_command [function] [call site] 00198
40 write_command_to_vec [function] [call site] 00199
41 args_len [function] [call site] 00200
41 ClientTlsParams::clone [function] [call site] 00201
42 ClientTlsParams::clone [function] [call site] 00202
42 secret_pkcs1_der [function] [call site] 00204
42 write_command_to_vec [function] [call site] 00205
42 secret_pkcs8_der [function] [call site] 00208
42 write_command_to_vec [function] [call site] 00209
42 secret_sec1_der [function] [call site] 00212
42 write_command_to_vec [function] [call site] 00213
41 Cmd::reserve [function] [call site] 00215
41 write_command [function] [call site] 00216
42 ::itoa::Buffer::new [function] [call site] 00217
43 RedisServer::with_modules [function] [call site] 00218
42 Cmd::write_all [function] [call site] 00219
42 RedisServer::format [function] [call site] 00220
42 basic::test_pipeline_len [function] [call site] 00221
42 Cmd::write_all [function] [call site] 00222
42 TlsFilePaths::as_bytes [function] [call site] 00223
42 Cmd::write_all [function] [call site] 00224
42 itoa::Buffer::new [function] [call site] 00225
43 RedisServer::with_modules [function] [call site] 00226
42 RedisServer::format [function] [call site] 00227
42 as_bytes [function] [call site] 00228
42 Cmd::write_all [function] [call site] 00229
42 RedisServer::format [function] [call site] 00230
42 basic::test_pipeline_len [function] [call site] 00231
43 redis::pipe [function] [call site] 00232
43 types::test_is_single_arg [function] [call site] 00235
42 Cmd::write_all [function] [call site] 00236
42 TlsFilePaths::as_bytes [function] [call site] 00237
42 Cmd::write_all [function] [call site] 00238
42 Cmd::write_all [function] [call site] 00239
42 Cmd::write_all [function] [call site] 00240
41 io::Result::unwrap [function] [call site] 00242
40 Cmd::args_iter [function] [call site] 00243
41 basic::test_tuple_decoding_from_iter [function] [call site] 00244
41 tests::into_redis_value_hashmap [function] [call site] 00245
41 Arg::Simple [function] [call site] 00246
40 unwrap_or [function] [call site] 00247
38 MockRedisConnection::req_packed_command [function] [call site] 00248
39 Cmd::get_packed_command [function] [call site] 00249
39 MockRedisConnection::req_packed_command [function] [call site] 00250
39 as_slice [function] [call site] 00251
39 PipelineSink::poll_ready [function] [call site] 00252
40 PipelineSink::as_mut [function] [call site] 00253
40 PipelineSink::poll_ready [function] [call site] 00255
41 PipelineSink::as_mut [function] [call site] 00256
41 PipelineSink::poll_ready [function] [call site] 00258
39 types::test_parse_boxed [function] [call site] 00261
40 ValueComparison::arg_to_string [function] [call site] 00262
40 parse_redis_value [function] [call site] 00263
41 Parser::new [function] [call site] 00264
41 Parser::parse_value [function] [call site] 00265
42 to_redis_err [function] [call site] 00267
43 is_unexpected_end_of_input [function] [call site] 00269
43 RedisError::from [function] [call site] 00270
43 io::Error::from [function] [call site] 00271
43 map_range [function] [call site] 00272
43 map_position [function] [call site] 00273
43 translate_position [function] [call site] 00274
43 to_string [function] [call site] 00276
43 RedisError::from [function] [call site] 00277
43 ParsingError::from [function] [call site] 00278
40 Value::SimpleString [function] [call site] 00280
40 ClientTlsParams::clone [function] [call site] 00281
41 ClientTlsParams::clone [function] [call site] 00282
41 secret_pkcs1_der [function] [call site] 00284
41 write_command_to_vec [function] [call site] 00285
41 secret_pkcs8_der [function] [call site] 00288
41 write_command_to_vec [function] [call site] 00289
41 secret_sec1_der [function] [call site] 00292
41 write_command_to_vec [function] [call site] 00293
38 as_slice [function] [call site] 00295
38 PipelineSink::poll_ready [function] [call site] 00296
38 types::test_parse_boxed [function] [call site] 00297
37 base_routing [function] [call site] 00298
38 RouteBy::MultiShard [function] [call site] 00299
38 RouteBy::MultiShard [function] [call site] 00300
38 RouteBy::MultiShard [function] [call site] 00301
38 RouteBy::MultiShard [function] [call site] 00302
37 RoutingInfo::MultiNode [function] [call site] 00304
37 ResponsePolicy::for_command [function] [call site] 00305
38 ResponsePolicy::AggregateLogical [function] [call site] 00307
38 ResponsePolicy::Aggregate [function] [call site] 00309
38 ResponsePolicy::Aggregate [function] [call site] 00311
37 RoutingInfo::MultiNode [function] [call site] 00322
37 ResponsePolicy::for_command [function] [call site] 00323
37 multi_shard [function] [call site] 00324
38 commands::is_readonly_cmd [function] [call site] 00325
38 RedisServer::new [function] [call site] 00326
39 RedisServer::with_modules [function] [call site] 00327
38 Cmd::arg_idx [function] [call site] 00328
39 Cmd::arg_idx [function] [call site] 00329
40 Cmd::arg_idx [function] [call site] 00330
38 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00331
39 TestContext::new [function] [call site] 00332
39 ProtocolVersion::supports_resp3 [function] [call site] 00333
39 tokio::sync::mpsc::unbounded_channel [function] [call site] 00334
39 redis::aio::ConnectionManagerConfig::new [function] [call site] 00335
40 RedisServer::default [function] [call site] 00336
41 RedisServer::new [function] [call site] 00337
42 RedisServer::with_modules [function] [call site] 00338
39 AsyncConnectionConfig::set_push_sender [function] [call site] 00339
40 AsyncConnectionConfig::set_push_sender_internal [function] [call site] 00340
40 std::sync::Arc::new [function] [call site] 00342
41 RedisServer::with_modules [function] [call site] 00343
39 Client::get_connection_manager_lazy [function] [call site] 00344
40 crate::aio::ConnectionManager::new_lazy_with_config [function] [call site] 00345
41 Runtime::locate [function] [call site] 00346
42 cache_mget [function] [call site] 00347
43 TestContext::new [function] [call site] 00348
43 ProtocolVersion::supports_resp3 [function] [call site] 00349
43 TestContext::async_connection_with_cache [function] [call site] 00350
44 TestContext::async_connection_with_cache_config [function] [call site] 00351
45 ClientTlsParams::clone [function] [call site] 00352
45 Client::get_multiplexed_async_connection_with_config [function] [call site] 00353
46 Runtime::locate [function] [call site] 00354
46 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::tokio::Tokio> [function] [call site] 00355
46 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::smol::Smol> [function] [call site] 00356
45 AsyncConnectionConfig::new [function] [call site] 00357
46 RedisServer::default [function] [call site] 00358
45 Cmd::set_cache_config [function] [call site] 00359
44 CacheConfig::default [function] [call site] 00361
45 CacheConfig::new [function] [call site] 00362
46 RedisServer::new [function] [call site] 00363
47 RedisServer::with_modules [function] [call site] 00364
46 RedisServer::unwrap [function] [call site] 00365
46 Duration::from_secs [function] [call site] 00366
43 get_pipe [function] [call site] 00368
44 redis::pipe [function] [call site] 00369
44 Pipeline::atomic [function] [call site] 00370
44 redis::pipe [function] [call site] 00371
43 redis::Pipeline::cmd [function] [call site] 00372
44 redis::cmd [function] [call site] 00373
45 redis::cmd [function] [call site] 00374
45 Cmd::set_cache_config [function] [call site] 00375
45 CommandCacheConfig::new [function] [call site] 00377
45 CommandCacheConfig::set_enable_cache [function] [call site] 00378
44 Cmd::set_cache_config [function] [call site] 00379
44 CommandCacheConfig::new [function] [call site] 00380
44 CommandCacheConfig::set_enable_cache [function] [call site] 00381
43 redis::Cmd::arg [function] [call site] 00382
44 SetExpiry::write_redis_args [function] [call site] 00383
43 types::test_is_single_arg [function] [call site] 00384
43 types::test_is_single_arg [function] [call site] 00387
43 types::test_is_single_arg [function] [call site] 00388
43 Cmd::query_async [function] [call site] 00390
44 &mut [call site] 00391
45 Cmd::get_packed_command [function] [call site] 00392
45 MockRedisConnection::req_packed_command [function] [call site] 00393
45 as_slice [function] [call site] 00394
45 PipelineSink::poll_ready [function] [call site] 00395
45 types::test_parse_boxed [function] [call site] 00396
44 RedisResult::from_redis_value [function] [call site] 00398
45 from_redis_value [function] [call site] 00402
46 RedisResult::from_redis_value [function] [call site] 00403
47 from_redis_value [function] [call site] 00407
47 tests::into_redis_value_hashmap [function] [call site] 00408
48 ValueType::from [function] [call site] 00409
48 String::into_redis_value [function] [call site] 00410
48 Value::into_map_iter [function] [call site] 00411
48 Result::expect [function] [call site] 00412
48 into_map_iter() [call site] 00413
6 .expect("extracting [call site] 00414
6 .collect::<Vec<(Value, [call site] 00415
47 Ok [function] [call site] 00418
45 tests::into_redis_value_hashmap [function] [call site] 00419
45 Ok [function] [call site] 00420
44 Value::extract_error [function] [call site] 00421
45 Self::Array [function] [call site] 00423
45 Value::extract_error_vec [function] [call site] 00424
46 &'a [call site] 00425
46 std::iter::Chain::map [function] [call site] 00426
46 into_iter() [call site] 00427
6 .map(Self::extract_error) [call site] 00428
6 .collect::<RedisResult<Vec<_>>> [function] [call site] 00429
45 Self::Map [function] [call site] 00431
45 Value::extract_error_map [function] [call site] 00432
46 Cmd::with_capacity [function] [call site] 00433
47 Cmd::with_capacity [function] [call site] 00434
47 Cmd::with_capacity [function] [call site] 00435
46 basic::test_pipeline_len [function] [call site] 00436
46 &'a [call site] 00437
46 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00438
46 Value::extract_error [function] [call site] 00439
46 impl [call site] 00440
47 Self::Array [function] [call site] 00442
47 Value::extract_error_vec [function] [call site] 00443
47 Self::Map [function] [call site] 00445
47 Value::extract_error_map [function] [call site] 00446
47 RedisServer::new [function] [call site] 00447
48 RedisServer::with_modules [function] [call site] 00448
47 Value::extract_error [function] [call site] 00449
47 Value::extract_error_map [function] [call site] 00450
47 Self::Set [function] [call site] 00453
47 Value::extract_error_vec [function] [call site] 00454
47 Value::extract_error_vec [function] [call site] 00456
45 RedisServer::new [function] [call site] 00461
45 Value::extract_error [function] [call site] 00462
45 Value::extract_error_map [function] [call site] 00463
45 Self::Set [function] [call site] 00466
45 Value::extract_error_vec [function] [call site] 00467
45 Value::extract_error_vec [function] [call site] 00469
43 unwrap [function] [call site] 00473
43 redis::cmd [function] [call site] 00474
43 redis::Cmd::arg [function] [call site] 00475
43 types::test_is_single_arg [function] [call site] 00476
43 Cmd::query_async [function] [call site] 00477
43 unwrap [function] [call site] 00478
43 assert_hit [function] [call site] 00479
43 assert_miss [function] [call site] 00480
43 redis::cmd [function] [call site] 00481
43 redis::Cmd::arg [function] [call site] 00482
43 types::test_is_single_arg [function] [call site] 00483
43 types::test_is_single_arg [function] [call site] 00484
43 Cmd::query_async [function] [call site] 00485
43 unwrap [function] [call site] 00486
43 assert_hit [function] [call site] 00487
43 assert_miss [function] [call site] 00488
43 redis::cmd [function] [call site] 00489
43 redis::Cmd::arg [function] [call site] 00490
43 Cmd::query_async [function] [call site] 00491
44 &mut [call site] 00492
44 RedisResult::from_redis_value [function] [call site] 00494
44 Value::extract_error [function] [call site] 00495
43 unwrap [function] [call site] 00496
43 assert_hit [function] [call site] 00497
43 assert_miss [function] [call site] 00498
41 is_none [function] [call site] 00499
41 Err [function] [call site] 00500
41 into [function] [call site] 00501
41 RedisServer::default [function] [call site] 00502
42 RedisServer::new [function] [call site] 00503
41 Self::with_factor [function] [call site] 00504
41 with_min_delay [function] [call site] 00505
41 with_max_times [function] [call site] 00506
41 with_jitter [function] [call site] 00507
41 with_max_delay [function] [call site] 00508
41 AsyncConnectionConfig::new [function] [call site] 00509
41 AsyncConnectionConfig::set_connection_timeout [function] [call site] 00510
41 AsyncConnectionConfig::set_response_timeout [function] [call site] 00511
41 as_ref [function] [call site] 00512
41 tests::into_redis_value_hashmap [function] [call site] 00513
41 CacheManager::new [function] [call site] 00514
42 RedisServer::new [function] [call site] 00515
43 RedisServer::with_modules [function] [call site] 00516
42 ShardedLRU::new [function] [call site] 00517
43 NonZeroUsize::get [function] [call site] 00518
44 TestContext::new [function] [call site] 00519
44 ProtocolVersion::supports_resp3 [function] [call site] 00520
44 TestContext::async_connection_with_cache [function] [call site] 00521
44 get_pipe [function] [call site] 00523
44 redis::Pipeline::cmd [function] [call site] 00524
44 redis::Cmd::arg [function] [call site] 00525
44 types::test_is_single_arg [function] [call site] 00526
44 types::test_is_single_arg [function] [call site] 00529
44 types::test_is_single_arg [function] [call site] 00530
44 Cmd::query_async [function] [call site] 00532
44 redis::cmd [function] [call site] 00534
44 redis::Cmd::arg [function] [call site] 00535
44 types::test_is_single_arg [function] [call site] 00536
44 Cmd::query_async [function] [call site] 00537
44 assert_hit [function] [call site] 00539
44 assert_miss [function] [call site] 00540
44 redis::cmd [function] [call site] 00541
44 redis::Cmd::arg [function] [call site] 00542
44 types::test_is_single_arg [function] [call site] 00543
44 types::test_is_single_arg [function] [call site] 00544
44 Cmd::query_async [function] [call site] 00545
44 assert_hit [function] [call site] 00547
44 assert_miss [function] [call site] 00548
44 redis::cmd [function] [call site] 00549
44 redis::Cmd::arg [function] [call site] 00550
44 Cmd::query_async [function] [call site] 00551
44 assert_hit [function] [call site] 00553
44 assert_miss [function] [call site] 00554
43 NonZeroUsize::get [function] [call site] 00555
43 NonZeroUsize::get [function] [call site] 00556
43 Cmd::with_capacity [function] [call site] 00557
43 RedisServer::new [function] [call site] 00558
44 RedisServer::with_modules [function] [call site] 00559
43 RedisServer::new [function] [call site] 00560
43 RedisServer::unwrap [function] [call site] 00561
43 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00562
44 TestContext::new [function] [call site] 00563
44 ProtocolVersion::supports_resp3 [function] [call site] 00564
44 tokio::sync::mpsc::unbounded_channel [function] [call site] 00565
44 redis::aio::ConnectionManagerConfig::new [function] [call site] 00566
44 AsyncConnectionConfig::set_push_sender [function] [call site] 00567
44 Client::get_connection_manager_lazy [function] [call site] 00568
44 tests::into_redis_value_hashset [function] [call site] 00570
45 ValueType::from [function] [call site] 00571
46 TlsFilePaths::as_ref [function] [call site] 00572
46 ValueType::Unknown [function] [call site] 00573
46 ValueComparison::arg_to_string [function] [call site] 00574
45 String::into_redis_value [function] [call site] 00575
45 Result::expect [function] [call site] 00581
44 MockConnection::send_packed_command [function] [call site] 00585
44 Cmd::arg [function] [call site] 00588
44 types::test_is_single_arg [function] [call site] 00589
44 cache_mget [function] [call site] 00591
44 tests::into_redis_value_hashset [function] [call site] 00593
44 Pipeline::send_recv [function] [call site] 00595
45 MockRedisConnection::is_empty [function] [call site] 00596
46 StreamReadOptions::block [function] [call site] 00597
46 MockRedisConnection::is_empty [function] [call site] 00599
45 RedisError::make_empty_command [function] [call site] 00601
46 ErrorRepr::General [function] [call site] 00602
45 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 00603
45 Msg::get_channel [function] [call site] 00606
46 from_redis_value_ref [function] [call site] 00608
47 FromRedisValue::from_redis_value_ref [function] [call site] 00609
48 RedisResult::from_redis_value [function] [call site] 00610
49 from_redis_value [function] [call site] 00614
49 tests::into_redis_value_hashmap [function] [call site] 00615
48 ClientTlsParams::clone [function] [call site] 00617
49 ClientTlsParams::clone [function] [call site] 00618
49 secret_pkcs1_der [function] [call site] 00620
49 write_command_to_vec [function] [call site] 00621
49 secret_pkcs8_der [function] [call site] 00624
49 write_command_to_vec [function] [call site] 00625
49 secret_sec1_der [function] [call site] 00628
49 write_command_to_vec [function] [call site] 00629
45 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 00631
45 and_then [function] [call site] 00635
45 Runtime::locate [function] [call site] 00637
45 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 00638
46 TestSentinelContext::new [function] [call site] 00639
47 TestSentinelContext::new_with_cluster_client_builder [function] [call site] 00640
48 support::start_tls_crypto_provider [function] [call site] 00641
48 RedisSentinelCluster::new [function] [call site] 00642
49 RedisSentinelCluster::with_modules [function] [call site] 00643
50 tempfile::Builder::new [function] [call site] 00644
50 RedisResult::prefix [function] [call site] 00645
50 { [call site] 00648
0 server::build_keys_and_certs_for_tls [function] [call site] 00649
51 build_keys_and_certs_for_tls_ext [function] [call site] 00650
52 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00651
52 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00653
52 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00655
52 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00657
52 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00659
52 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00661
52 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] 00663
53 process::Command::new [function] [call site] 00664
53 types::test_is_single_arg [function] [call site] 00665
53 types::test_is_single_arg [function] [call site] 00666
53 types::test_is_single_arg [function] [call site] 00667
53 types::test_is_single_arg [function] [call site] 00668
53 process::Stdio::piped [function] [call site] 00670
53 process::Stdio::piped [function] [call site] 00672
53 spawn [function] [call site] 00673
54 tokio::runtime::Handle::try_current [function] [call site] 00674
54 smol::spawn [function] [call site] 00676
55 tokio::runtime::Handle::try_current [function] [call site] 00677
55 smol::spawn [function] [call site] 00679
55 TaskHandle::detach [function] [call site] 00680
56 TaskHandle::detach [function] [call site] 00681
54 TaskHandle::detach [function] [call site] 00682
53 ClusterClientBuilder::max_retry_wait [function] [call site] 00684
52 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] 00686
52 process::Command::new [function] [call site] 00687
52 types::test_is_single_arg [function] [call site] 00688
52 types::test_is_single_arg [function] [call site] 00689
52 types::test_is_single_arg [function] [call site] 00690
52 types::test_is_single_arg [function] [call site] 00691
52 types::test_is_single_arg [function] [call site] 00692
52 types::test_is_single_arg [function] [call site] 00693
52 types::test_is_single_arg [function] [call site] 00694
52 types::test_is_single_arg [function] [call site] 00695
52 types::test_is_single_arg [function] [call site] 00696
52 types::test_is_single_arg [function] [call site] 00697
52 types::test_is_single_arg [function] [call site] 00698
52 types::test_is_single_arg [function] [call site] 00699
52 types::test_is_single_arg [function] [call site] 00700
52 process::Stdio::piped [function] [call site] 00702
52 process::Stdio::piped [function] [call site] 00704
52 ClusterClientBuilder::max_retry_wait [function] [call site] 00707
52 Tokio::poll_write [function] [call site] 00709
53 RedisServer::new [function] [call site] 00710
54 RedisServer::with_modules [function] [call site] 00711
53 Tokio::poll_write [function] [call site] 00712
54 RedisServer::new [function] [call site] 00713
54 Tokio::poll_write [function] [call site] 00714
54 RedisServer::new [function] [call site] 00715
54 Tokio::poll_write [function] [call site] 00716
54 RedisServer::new [function] [call site] 00717
54 Tokio::poll_write [function] [call site] 00718
53 RedisServer::new [function] [call site] 00719
53 Tokio::poll_write [function] [call site] 00720
53 RedisServer::new [function] [call site] 00721
53 Tokio::poll_write [function] [call site] 00722
52 Poll::expect [function] [call site] 00723
52 process::Command::new [function] [call site] 00724
52 types::test_is_single_arg [function] [call site] 00725
52 types::test_is_single_arg [function] [call site] 00726
52 types::test_is_single_arg [function] [call site] 00727
52 types::test_is_single_arg [function] [call site] 00728
52 types::test_is_single_arg [function] [call site] 00729
52 types::test_is_single_arg [function] [call site] 00730
52 types::test_is_single_arg [function] [call site] 00731
52 process::Stdio::piped [function] [call site] 00733
52 process::Stdio::piped [function] [call site] 00735
52 process::Command::new [function] [call site] 00738
52 types::test_is_single_arg [function] [call site] 00739
52 types::test_is_single_arg [function] [call site] 00740
52 types::test_is_single_arg [function] [call site] 00741
52 types::test_is_single_arg [function] [call site] 00742
52 types::test_is_single_arg [function] [call site] 00743
52 types::test_is_single_arg [function] [call site] 00744
52 types::test_is_single_arg [function] [call site] 00745
52 types::test_is_single_arg [function] [call site] 00746
52 types::test_is_single_arg [function] [call site] 00747
52 types::test_is_single_arg [function] [call site] 00748
52 types::test_is_single_arg [function] [call site] 00749
52 types::test_is_single_arg [function] [call site] 00750
52 types::test_is_single_arg [function] [call site] 00751
52 types::test_is_single_arg [function] [call site] 00752
52 types::test_is_single_arg [function] [call site] 00753
52 types::test_is_single_arg [function] [call site] 00754
52 types::test_is_single_arg [function] [call site] 00755
52 types::test_is_single_arg [function] [call site] 00756
52 Cmd::take [function] [call site] 00758
53 std::mem::take [function] [call site] 00759
54 std::mem::take [function] [call site] 00760
52 ClusterClientBuilder::max_retry_wait [function] [call site] 00764
52 ClusterClientBuilder::max_retry_wait [function] [call site] 00766
50 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00768
50 std::collections::HashSet::new [function] [call site] 00769
50 basic::test_pipeline_len [function] [call site] 00770
51 redis::pipe [function] [call site] 00771
51 types::test_is_single_arg [function] [call site] 00774
50 RedisServer::insert [function] [call site] 00775
51 TestContext::with_modules [function] [call site] 00776
51 TestContext::connection [function] [call site] 00777
51 redis::Connection::json_set [function] [call site] 00778
52 TestContext::with_modules [function] [call site] 00779
52 TestContext::connection [function] [call site] 00780
52 redis::Connection::json_set [function] [call site] 00781
51 redis::Connection::json_arr_insert [function] [call site] 00782
52 TestContext::with_modules [function] [call site] 00783
52 TestContext::connection [function] [call site] 00784
52 redis::Connection::json_set [function] [call site] 00785
52 redis::Connection::json_arr_insert [function] [call site] 00786
52 redis::Connection::json_set [function] [call site] 00787
52 redis::Connection::json_arr_insert [function] [call site] 00788
51 redis::Connection::json_set [function] [call site] 00789
51 redis::Connection::json_arr_insert [function] [call site] 00790
50 get_random_available_port [function] [call site] 00791
51 get_listener_on_free_port [function] [call site] 00792
51 TcpListener::local_addr [function] [call site] 00793
51 get_listener_on_free_port [function] [call site] 00795
50 &'a [call site] 00796
51 std::iter::once [function] [call site] 00797
51 basic::test_tuple_decoding_from_iter [function] [call site] 00799
50 std::iter::Chain::collect [function] [call site] 00800
50 RedisServer::pop [function] [call site] 00801
51 TestContext::with_modules [function] [call site] 00802
51 TestContext::connection [function] [call site] 00803
51 redis::Connection::json_set [function] [call site] 00804
51 redis::Connection::json_arr_pop [function] [call site] 00805
52 TestContext::with_modules [function] [call site] 00806
52 TestContext::connection [function] [call site] 00807
52 redis::Connection::json_set [function] [call site] 00808
52 redis::Connection::json_arr_pop [function] [call site] 00809
52 redis::Connection::json_set [function] [call site] 00810
52 redis::Connection::json_arr_pop [function] [call site] 00811
51 redis::Connection::json_set [function] [call site] 00812
51 redis::Connection::json_arr_pop [function] [call site] 00813
50 unwrap [function] [call site] 00814
50 tempfile::Builder::new [function] [call site] 00815
50 RedisResult::prefix [function] [call site] 00816
50 tempdir [function] [call site] 00817
50 expect [function] [call site] 00818
50 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00819
51 TestContext::new [function] [call site] 00820
51 ProtocolVersion::supports_resp3 [function] [call site] 00821
51 tokio::sync::mpsc::unbounded_channel [function] [call site] 00822
51 redis::aio::ConnectionManagerConfig::new [function] [call site] 00823
51 AsyncConnectionConfig::set_push_sender [function] [call site] 00824
51 Client::get_connection_manager_lazy [function] [call site] 00825
51 tests::into_redis_value_hashset [function] [call site] 00827
51 MockConnection::send_packed_command [function] [call site] 00829
51 Cmd::arg [function] [call site] 00831
51 types::test_is_single_arg [function] [call site] 00832
51 cache_mget [function] [call site] 00834
51 tests::into_redis_value_hashset [function] [call site] 00836
51 Pipeline::send_recv [function] [call site] 00838
50 spawn_master_server [function] [call site] 00840
51 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00841
51 get_addr [function] [call site] 00842
52 RedisServer::get_addr [function] [call site] 00843
52 ConnectionAddr::Tcp [function] [call site] 00844
52 String::from [function] [call site] 00845
53 ValueComparison::arg_to_string [function] [call site] 00846
53 ValueComparison::arg_to_string [function] [call site] 00847
53 ValueComparison::arg_to_string [function] [call site] 00848
53 ValueComparison::arg_to_string [function] [call site] 00849
53 ValueComparison::arg_to_string [function] [call site] 00850
53 ValueComparison::arg_to_string [function] [call site] 00851
53 ValueComparison::arg_to_string [function] [call site] 00852
53 ValueComparison::arg_to_string [function] [call site] 00853
53 ValueComparison::arg_to_string [function] [call site] 00854
53 ValueComparison::arg_to_string [function] [call site] 00855
53 ValueComparison::arg_to_string [function] [call site] 00856
53 ValueComparison::arg_to_string [function] [call site] 00857
53 ValueComparison::arg_to_string [function] [call site] 00858
53 ValueComparison::arg_to_string [function] [call site] 00859
53 ValueComparison::arg_to_string [function] [call site] 00860
53 ValueComparison::arg_to_string [function] [call site] 00861
53 ValueComparison::arg_to_string [function] [call site] 00862
51 ClientTlsParams::clone [function] [call site] 00864
52 ClientTlsParams::clone [function] [call site] 00865
52 secret_pkcs1_der [function] [call site] 00867
52 write_command_to_vec [function] [call site] 00868
52 secret_pkcs8_der [function] [call site] 00871
52 write_command_to_vec [function] [call site] 00872
52 secret_sec1_der [function] [call site] 00875
52 write_command_to_vec [function] [call site] 00876
51 Cmd::arg [function] [call site] 00878
51 types::test_is_single_arg [function] [call site] 00879
51 get_addr [function] [call site] 00880
51 Cmd::arg [function] [call site] 00881
51 types::test_is_single_arg [function] [call site] 00882
51 Cmd::current_dir [function] [call site] 00883
51 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00884
51 Cmd::spawn [function] [call site] 00885
52 tokio::runtime::Handle::try_current [function] [call site] 00886
52 smol::spawn [function] [call site] 00888
52 TaskHandle::detach [function] [call site] 00889
50 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00891
50 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00892
50 RedisServer::pop [function] [call site] 00893
50 unwrap [function] [call site] 00894
50 tempfile::Builder::new [function] [call site] 00895
50 RedisResult::prefix [function] [call site] 00896
50 tempdir [function] [call site] 00897
50 expect [function] [call site] 00898
50 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00899
50 spawn_replica_server [function] [call site] 00900
51 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00901
51 File::create [function] [call site] 00903
52 TestContext::new [function] [call site] 00904
52 TestContext::connection [function] [call site] 00905
52 xadd [function] [call site] 00906
53 &mut [call site] 00907
54 &mut [call site] 00908
54 &mut [call site] 00910
54 &mut [call site] 00912
54 &mut [call site] 00914
53 &mut [call site] 00917
53 &mut [call site] 00919
53 &mut [call site] 00921
52 redis::Connection::xinfo_stream [function] [call site] 00923
52 TestContext::connection [function] [call site] 00924
52 redis::Connection::xinfo_stream [function] [call site] 00925
52 redis::Connection::xgroup_create [function] [call site] 00927
53 TestContext::new [function] [call site] 00928
53 TestContext::connection [function] [call site] 00929
53 redis::Connection::xinfo_stream [function] [call site] 00931
53 TestContext::connection [function] [call site] 00932
53 redis::Connection::xinfo_stream [function] [call site] 00933
53 redis::Connection::xgroup_create [function] [call site] 00935
53 redis::Connection::xinfo_groups [function] [call site] 00936
52 redis::Connection::xinfo_groups [function] [call site] 00938
51 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 00941
51 get_addr [function] [call site] 00942
51 ClientTlsParams::clone [function] [call site] 00945
51 Cmd::arg [function] [call site] 00946
51 types::test_is_single_arg [function] [call site] 00947
51 types::test_is_single_arg [function] [call site] 00948
51 ValueComparison::arg_to_string [function] [call site] 00949
52 impl [call site] 00950
52 String::from_utf8_lossy [function] [call site] 00951
52 into_owned [function] [call site] 00952
51 get_addr [function] [call site] 00953
51 Cmd::arg [function] [call site] 00954
51 types::test_is_single_arg [function] [call site] 00955
51 Cmd::current_dir [function] [call site] 00956
51 tests_routing::test_multi_shard_keys_and_path [function] [call site] 00957
51 Cmd::spawn [function] [call site] 00958
50 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 00960
50 wait_for_replicas_to_sync [function] [call site] 00961
51 basic::test_pipeline_len [function] [call site] 00962
52 redis::pipe [function] [call site] 00963
52 types::test_is_single_arg [function] [call site] 00966
51 basic::test_pipeline_len [function] [call site] 00967
51 RedisServer::connection_info [function] [call site] 00968
52 RedisServer::client_addr [function] [call site] 00969
52 &redis::ConnectionAddr::clone [function] [call site] 00970
53 ClientTlsParams::clone [function] [call site] 00971
53 secret_pkcs1_der [function] [call site] 00973
53 write_command_to_vec [function] [call site] 00974
53 secret_pkcs8_der [function] [call site] 00977
53 write_command_to_vec [function] [call site] 00978
53 secret_sec1_der [function] [call site] 00981
53 write_command_to_vec [function] [call site] 00982
52 ConnectionInfo::into_connection_info [function] [call site] 00984
52 RedisResult::unwrap [function] [call site] 00986
52 ConnectionInfo::set_redis_settings [function] [call site] 00987
52 redis_settings [function] [call site] 00988
53 RedisServer::default [function] [call site] 00989
54 RedisServer::new [function] [call site] 00990
53 RedisConnectionInfo::set_protocol [function] [call site] 00991
53 use_protocol [function] [call site] 00992
54 entra_id_tests::get_env_var [function] [call site] 00993
54 String::unwrap_or_default [function] [call site] 00994
51 wait_for_master_server [function] [call site] 00995
52 redis::cmd [function] [call site] 00996
52 Client::get_connection [function] [call site] 00997
52 redis::Cmd::query [function] [call site] 00998
53 ConnectionLike::req_command [function] [call site] 00999
54 Cmd::get_packed_command [function] [call site] 01000
54 MockRedisConnection::req_packed_command [function] [call site] 01001
55 Cmd::get_packed_command [function] [call site] 01002
55 MockRedisConnection::req_packed_command [function] [call site] 01003
55 as_slice [function] [call site] 01004
55 PipelineSink::poll_ready [function] [call site] 01005
55 types::test_parse_boxed [function] [call site] 01006
53 RedisResult::from_redis_value [function] [call site] 01008
53 Value::extract_error [function] [call site] 01009
52 RedisResult::unwrap [function] [call site] 01011
52 String::from_redis_value_ref [function] [call site] 01012
53 get_inner_value [function] [call site] 01013
53 std::str::from_utf8 [function] [call site] 01016
53 ValueComparison::arg_to_string [function] [call site] 01017
54 impl [call site] 01018
54 String::from_utf8_lossy [function] [call site] 01019
54 into_owned [function] [call site] 01020
53 ValueComparison::arg_to_string [function] [call site] 01022
53 ValueComparison::arg_to_string [function] [call site] 01024
53 ValueComparison::arg_to_string [function] [call site] 01026
53 ValueComparison::arg_to_string [function] [call site] 01028
53 ValueComparison::arg_to_string [function] [call site] 01030
52 Replicas::first [function] [call site] 01031
52 &'a [call site] 01032
52 Result::unwrap [function] [call site] 01033
52 starts_with [function] [call site] 01034
52 std::thread::sleep [function] [call site] 01036
53 tokio::time::sleep [function] [call site] 01037
54 tokio::time::sleep [function] [call site] 01038
54 smol::Timer::after [function] [call site] 01039
53 smol::Timer::after [function] [call site] 01040
52 Duration::from_millis [function] [call site] 01041
51 redis::Client::open [function] [call site] 01043
52 ConnectionInfo::into_connection_info [function] [call site] 01045
51 ClientTlsParams::clone [function] [call site] 01047
51 ConnectionAddr::is_err [function] [call site] 01048
52 is_unexpected_end_of_input [function] [call site] 01050
52 RedisError::from [function] [call site] 01051
52 io::Error::from [function] [call site] 01052
52 map_range [function] [call site] 01053
52 map_position [function] [call site] 01054
52 translate_position [function] [call site] 01055
52 to_string [function] [call site] 01057
52 RedisError::from [function] [call site] 01058
52 ParsingError::from [function] [call site] 01059
51 RedisServer::connection_info [function] [call site] 01060
51 wait_for_replica [function] [call site] 01061
52 redis::cmd [function] [call site] 01062
52 Client::get_connection [function] [call site] 01063
52 redis::Cmd::query [function] [call site] 01064
52 RedisResult::unwrap [function] [call site] 01065
52 String::from_redis_value_ref [function] [call site] 01066
52 Replicas::first [function] [call site] 01067
52 &'a [call site] 01068
52 Result::unwrap [function] [call site] 01069
52 String::from_redis_value_ref [function] [call site] 01070
52 ConnectionAddr::get [function] [call site] 01071
53 TestContext::new [function] [call site] 01072
53 ProtocolVersion::supports_resp3 [function] [call site] 01073
53 TestContext::async_connection_with_cache [function] [call site] 01074
53 get_pipe [function] [call site] 01076
53 redis::Pipeline::cmd [function] [call site] 01077
53 redis::Cmd::arg [function] [call site] 01078
53 types::test_is_single_arg [function] [call site] 01079
53 types::test_is_single_arg [function] [call site] 01082
53 types::test_is_single_arg [function] [call site] 01083
53 Cmd::query_async [function] [call site] 01085
53 redis::cmd [function] [call site] 01087
53 redis::Cmd::arg [function] [call site] 01088
53 types::test_is_single_arg [function] [call site] 01089
53 Cmd::query_async [function] [call site] 01090
53 assert_hit [function] [call site] 01092
53 assert_miss [function] [call site] 01093
53 redis::cmd [function] [call site] 01094
53 redis::Cmd::arg [function] [call site] 01095
53 types::test_is_single_arg [function] [call site] 01096
53 types::test_is_single_arg [function] [call site] 01097
53 Cmd::query_async [function] [call site] 01098
53 assert_hit [function] [call site] 01100
53 assert_miss [function] [call site] 01101
53 redis::cmd [function] [call site] 01102
53 redis::Cmd::arg [function] [call site] 01103
53 Cmd::query_async [function] [call site] 01104
53 assert_hit [function] [call site] 01106
53 assert_miss [function] [call site] 01107
52 Result::unwrap [function] [call site] 01109
52 starts_with [function] [call site] 01110
52 std::thread::sleep [function] [call site] 01112
52 Duration::from_millis [function] [call site] 01113
51 redis::Client::open [function] [call site] 01115
51 ClientTlsParams::clone [function] [call site] 01116
51 ConnectionAddr::is_err [function] [call site] 01117
50 RedisServer::pop [function] [call site] 01118
50 unwrap [function] [call site] 01119
50 tempfile::Builder::new [function] [call site] 01120
50 RedisResult::prefix [function] [call site] 01121
50 tempdir [function] [call site] 01122
50 expect [function] [call site] 01123
50 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 01124
50 spawn_sentinel_server [function] [call site] 01125
51 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01126
51 File::create [function] [call site] 01128
51 basic::test_tuple_decoding_from_iter [function] [call site] 01130
52 TestContext::new [function] [call site] 01131
52 TestContext::connection [function] [call site] 01132
52 ValueType::from [function] [call site] 01133
52 basic::test_tuple_decoding_from_iter [function] [call site] 01134
52 hscan::<_, [call site] 01135
51 enumerate [function] [call site] 01138
51 PathBuf::write_all [function] [call site] 01139
51 as_bytes [function] [call site] 01140
51 PipelineSink::poll_flush [function] [call site] 01142
52 PipelineSink::poll_read [function] [call site] 01143
53 PipelineSink::as_mut [function] [call site] 01144
53 ResultExpectation::is_closed [function] [call site] 01146
54 ResultExpectation::is_closed [function] [call site] 01147
55 ResultExpectation::is_closed [function] [call site] 01148
53 Poll::Ready [function] [call site] 01149
53 Poll::Ready [function] [call site] 01151
53 PipelineSink::as_mut [function] [call site] 01153
53 PipelineSink::handle_message [function] [call site] 01154
54 PipelineSink::project [function] [call site] 01155
54 impl [call site] 01156
54 pop_front [function] [call site] 01157
54 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01158
54 Value::Array [function] [call site] 01160
54 Msg::from_owned_value [function] [call site] 01162
55 Msg::from_push_info [function] [call site] 01163
56 &'a [call site] 01164
56 MapIter::next [function] [call site] 01165
57 MapIter::next [function] [call site] 01167
57 MapIter::next [function] [call site] 01168
57 MapIter::next [function] [call site] 01169
56 MapIter::next [function] [call site] 01171
56 MapIter::next [function] [call site] 01173
56 MapIter::next [function] [call site] 01174
56 MapIter::next [function] [call site] 01175
55 from_redis_value [function] [call site] 01177
55 tests::redis_ok [function] [call site] 01178
55 &'a [call site] 01179
55 from_redis_value [function] [call site] 01180
55 MapIter::next [function] [call site] 01181
55 tests::redis_ok [function] [call site] 01182
55 MapIter::next [function] [call site] 01183
55 MapIter::next [function] [call site] 01184
55 MapIter::next [function] [call site] 01186
55 MapIter::next [function] [call site] 01187
55 MapIter::next [function] [call site] 01188
54 Value::Array [function] [call site] 01190
54 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01191
54 PushKind::has_reply [function] [call site] 01194
54 pop_front [function] [call site] 01195
54 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01196
54 Msg::from_push_info [function] [call site] 01199
55 &'a [call site] 01200
55 MapIter::next [function] [call site] 01201
55 MapIter::next [function] [call site] 01202
55 MapIter::next [function] [call site] 01204
55 MapIter::next [function] [call site] 01205
55 MapIter::next [function] [call site] 01206
54 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01208
54 RedisError::is_unrecoverable_error [function] [call site] 01211
55 RedisError::retry_method [function] [call site] 01212
56 RedisError::kind [function] [call site] 01213
57 get_push_kind [function] [call site] 01214
58 PushKind::as_str [function] [call site] 01215
58 PushKind::Other [function] [call site] 01216
57 ErrorKind::Server [function] [call site] 01217
57 Replicas::first [function] [call site] 01218
57 and_then [function] [call site] 01219
57 get_push_kind [function] [call site] 01220
57 tests::into_redis_value_hashmap [function] [call site] 01221
57 PushKind::into [function] [call site] 01222
57 unwrap_or [function] [call site] 01223
57 ErrorKind::Server [function] [call site] 01224
56 RedisError::retry_method [function] [call site] 01225
57 RedisError::kind [function] [call site] 01226
57 RedisError::retry_method [function] [call site] 01227
57 RedisError::is_connection_dropped [function] [call site] 01228
58 RedisError::as_io_error [function] [call site] 01229
59 downcast_ref [function] [call site] 01230
58 Option::is_some_and [function] [call site] 01231
57 RedisError::as_io_error [function] [call site] 01232
57 tests::into_redis_value_hashmap [function] [call site] 01233
58 ValueType::from [function] [call site] 01234
58 String::into_redis_value [function] [call site] 01235
58 Value::into_map_iter [function] [call site] 01236
58 Result::expect [function] [call site] 01237
58 into_map_iter() [call site] 01238
6 .expect("extracting [call site] 01239
6 .collect::<Vec<(Value, [call site] 01240
57 get_push_kind [function] [call site] 01243
57 unwrap_or [function] [call site] 01244
56 RedisError::is_connection_dropped [function] [call site] 01245
56 RedisError::as_io_error [function] [call site] 01246
56 tests::into_redis_value_hashmap [function] [call site] 01247
56 get_push_kind [function] [call site] 01248
56 unwrap_or [function] [call site] 01249
54 Err [function] [call site] 01250
54 pop_front [function] [call site] 01251
54 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01252
54 Ok [function] [call site] 01253
54 Err [function] [call site] 01254
51 Poll::unwrap [function] [call site] 01255
51 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 01256
51 get_addr [function] [call site] 01257
51 Some [function] [call site] 01258
51 Some [function] [call site] 01259
51 ClientTlsParams::clone [function] [call site] 01260
51 Cmd::arg [function] [call site] 01261
51 get_addr [function] [call site] 01262
51 Cmd::arg [function] [call site] 01263
51 types::test_is_single_arg [function] [call site] 01264
51 Cmd::current_dir [function] [call site] 01265
51 tests_routing::test_multi_shard_keys_and_path [function] [call site] 01266
51 Cmd::spawn [function] [call site] 01267
51 unwrap [function] [call site] 01268
50 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 01269
48 RedisSentinelCluster::iter_sentinel_servers [function] [call site] 01270
49 basic::test_tuple_decoding_from_iter [function] [call site] 01271
48 tests::into_redis_value_hashmap [function] [call site] 01272
49 ValueType::from [function] [call site] 01273
49 String::into_redis_value [function] [call site] 01274
49 Value::into_map_iter [function] [call site] 01275
49 Result::expect [function] [call site] 01276
49 into_map_iter() [call site] 01277
6 .expect("extracting [call site] 01278
6 .collect::<Vec<(Value, [call site] 01279
48 collect [function] [call site] 01282
48 redis::sentinel::Sentinel::build [function] [call site] 01283
49 Sentinel::build_inner [function] [call site] 01284
50 MockRedisConnection::is_empty [function] [call site] 01285
51 StreamReadOptions::block [function] [call site] 01286
51 MockRedisConnection::is_empty [function] [call site] 01288
50 &'a [call site] 01290
51 std::iter::once [function] [call site] 01291
51 basic::test_tuple_decoding_from_iter [function] [call site] 01293
50 std::iter::Chain::map [function] [call site] 01294
50 ConnectionInfo::into_connection_info [function] [call site] 01295
50 into_iter() [call site] 01297
6 .map(|p| [call site] 01298
6 .collect::<RedisResult<Vec<ConnectionInfo>>> [function] [call site] 01299
50 basic::test_tuple_decoding_from_iter [function] [call site] 01300
51 TestContext::new [function] [call site] 01301
51 TestContext::connection [function] [call site] 01302
51 ValueType::from [function] [call site] 01303
51 basic::test_tuple_decoding_from_iter [function] [call site] 01304
51 hscan::<_, [call site] 01305
50 cluster::test_cluster_reconnect_after_complete_server_disconnect_route_to_many [function] [call site] 01308
51 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 01309
51 cluster::test_cluster_retries [function] [call site] 01310
52 atomic::AtomicUsize::new [function] [call site] 01311
53 RedisServer::with_modules [function] [call site] 01312
52 MockEnv::with_client_builder [function] [call site] 01313
53 tokio::runtime::Builder::new_current_thread [function] [call site] 01314
53 enable_io [function] [call site] 01315
53 enable_time [function] [call site] 01316
53 Sentinel::build [function] [call site] 01317
54 Sentinel::build_inner [function] [call site] 01318
53 ValueComparison::arg_to_string [function] [call site] 01320
53 Tokio::poll_write [function] [call site] 01321
54 RedisServer::new [function] [call site] 01322
54 Tokio::poll_write [function] [call site] 01323
54 RedisServer::new [function] [call site] 01324
54 Tokio::poll_write [function] [call site] 01325
54 RedisServer::new [function] [call site] 01326
54 Tokio::poll_write [function] [call site] 01327
53 test_module_json_arr_insert [function] [call site] 01329
54 TestContext::with_modules [function] [call site] 01330
54 TestContext::connection [function] [call site] 01331
54 redis::Connection::json_set [function] [call site] 01332
54 redis::Connection::json_arr_insert [function] [call site] 01333
54 redis::Connection::json_set [function] [call site] 01334
54 redis::Connection::json_arr_insert [function] [call site] 01335
53 ClientTlsParams::clone [function] [call site] 01336
53 RedisServer::new [function] [call site] 01337
53 Sentinel::build [function] [call site] 01338
53 RedisResult::unwrap [function] [call site] 01339
53 ClusterClient::get_generic_connection [function] [call site] 01340
54 cluster::ClusterConnection::new [function] [call site] 01341
55 ClusterConnection::new_inner [function] [call site] 01342
56 unwrap_or_default [function] [call site] 01343
56 ClientTlsParams::clone [function] [call site] 01344
56 Runtime::locate [function] [call site] 01345
56 ClusterConnInner::new [function] [call site] 01346
57 RedisServer::new [function] [call site] 01349
58 RedisServer::with_modules [function] [call site] 01350
57 RedisServer::default [function] [call site] 01351
58 RedisServer::new [function] [call site] 01352
57 tests::into_redis_value_hashmap [function] [call site] 01354
57 T::create_strategy [function] [call site] 01355
58 RedisServer::new [function] [call site] 01356
58 RedisServer::default [function] [call site] 01357
59 RedisServer::new [function] [call site] 01358
57 mpsc::unbounded_channel [function] [call site] 01359
57 RedisServer::new [function] [call site] 01360
57 RedisServer::new [function] [call site] 01361
58 RedisServer::with_modules [function] [call site] 01362
57 RedisServer::default [function] [call site] 01363
58 RedisServer::new [function] [call site] 01364
57 SlotMap::new [function] [call site] 01365
58 RedisServer::default [function] [call site] 01366
57 write_command_to_vec [function] [call site] 01367
57 ClientTlsParams::clone [function] [call site] 01369
58 ClientTlsParams::clone [function] [call site] 01370
58 secret_pkcs1_der [function] [call site] 01372
58 write_command_to_vec [function] [call site] 01373
58 secret_pkcs8_der [function] [call site] 01376
58 write_command_to_vec [function] [call site] 01377
58 secret_sec1_der [function] [call site] 01380
58 write_command_to_vec [function] [call site] 01381
57 RedisServer::default [function] [call site] 01383
57 ConnectionState::Recover [function] [call site] 01384
57 RecoverFuture::Reconnect [function] [call site] 01385
57 Box::pin [function] [call site] 01386
57 ClusterConnInner::reconnect_to_initial_nodes [function] [call site] 01387
58 ClientTlsParams::clone [function] [call site] 01388
58 ClusterConnection::create_initial_connections [function] [call site] 01389
59 Cmd::with_capacity [function] [call site] 01390
60 Cmd::with_capacity [function] [call site] 01391
60 Cmd::with_capacity [function] [call site] 01392
59 basic::test_pipeline_len [function] [call site] 01393
59 RedisServer::new [function] [call site] 01394
59 basic::test_tuple_decoding_from_iter [function] [call site] 01395
59 NodeAddress::try_from [function] [call site] 01396
60 NodeAddress::new [function] [call site] 01398
61 NodeAddress::from_parts [function] [call site] 01399
61 &str::into [function] [call site] 01400
60 &str::as_str [function] [call site] 01401
60 RedisError::from [function] [call site] 01403
61 io::Error::from [function] [call site] 01404
62 io::Error::from [function] [call site] 01405
62 Self::into [function] [call site] 01406
61 Self::into [function] [call site] 01407
59 ClusterConnection::connect [function] [call site] 01408
60 Client::get_connection_info [function] [call site] 01409
60 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 01410
61 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 01411
61 cluster::test_cluster_retries [function] [call site] 01412
61 TestClusterContext::get_ports [function] [call site] 01413
62 basic::test_tuple_decoding_from_iter [function] [call site] 01414
62 tests::into_redis_value_hashmap [function] [call site] 01415
62 redis::ConnectionInfo::addr [function] [call site] 01416
61 MockRedisConnection::check_connection [function] [call site] 01418
61 RedisServer::drop [function] [call site] 01419
62 RedisServer::stop [function] [call site] 01420
63 ClusterClientBuilder::max_retry_wait [function] [call site] 01422
63 RedisServer::client_addr [function] [call site] 01423
63 fs::remove_file [function] [call site] 01424
63 tests::redis_ok [function] [call site] 01425
61 ClusterConnection::route_command [function] [call site] 01427
62 Msg::get_channel [function] [call site] 01428
62 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01429
62 RedisServer::new [function] [call site] 01430
62 RouteBy::into [function] [call site] 01431
62 RedisError::from [function] [call site] 01433
62 io::Error::new [function] [call site] 01434
63 RedisServer::with_modules [function] [call site] 01435
62 unwrap_or_else [function] [call site] 01436
62 RedisError::from [function] [call site] 01438
62 io::Error::new [function] [call site] 01439
62 tests::into_redis_value_hashmap [function] [call site] 01440
62 async_tests::sentinel_client_async_with_connection_timeout [function] [call site] 01441
63 TestSentinelContext::new [function] [call site] 01442
63 SentinelClient::build [function] [call site] 01443
64 Sentinel::build_inner [function] [call site] 01444
63 TestSentinelContext::sentinels_connection_info [function] [call site] 01445
63 ClientTlsParams::clone [function] [call site] 01446
64 ClientTlsParams::clone [function] [call site] 01447
64 secret_pkcs1_der [function] [call site] 01449
64 write_command_to_vec [function] [call site] 01450
64 secret_pkcs8_der [function] [call site] 01453
64 write_command_to_vec [function] [call site] 01454
64 secret_sec1_der [function] [call site] 01457
64 write_command_to_vec [function] [call site] 01458
63 String::from [function] [call site] 01460
63 TestSentinelContext::sentinel_node_connection_info [function] [call site] 01462
64 TestSentinelContext::tls_mode [function] [call site] 01463
65 RedisServer::client_addr [function] [call site] 01464
64 &SentinelNodeConnectionInfo::default [function] [call site] 01467
64 SentinelNodeConnectionInfo::set_tls_mode [function] [call site] 01468
64 &SentinelNodeConnectionInfo::default [function] [call site] 01470
63 RedisResult::unwrap [function] [call site] 01471
63 SentinelClient::build [function] [call site] 01472
63 TestSentinelContext::sentinels_connection_info [function] [call site] 01473
63 ClientTlsParams::clone [function] [call site] 01474
63 String::from [function] [call site] 01475
63 TestSentinelContext::sentinel_node_connection_info [function] [call site] 01477
63 RedisResult::unwrap [function] [call site] 01478
63 AsyncConnectionConfig::new [function] [call site] 01479
63 AsyncConnectionConfig::set_connection_timeout [function] [call site] 01480
63 Duration::from_secs [function] [call site] 01482
63 SentinelClient::get_async_connection_with_config [function] [call site] 01483
64 SentinelClient::async_get_client [function] [call site] 01484
65 Sentinel::async_master_for [function] [call site] 01485
66 Sentinel::async_find_master_address [function] [call site] 01486
67 Sentinel::async_get_sentinel_masters [function] [call site] 01487
68 Sentinel::async_try_all_sentinels [function] [call site] 01488
69 basic::test_tuple_decoding_from_iter [function] [call site] 01489
69 iter_mut [function] [call site] 01491
69 async_try_single_sentinel [function] [call site] 01492
70 &mut [call site] 01493
70 async_reconnect [function] [call site] 01494
71 Client::open [function] [call site] 01495
72 ConnectionInfo::into_connection_info [function] [call site] 01497
71 redis::ConnectionInfo::clone [function] [call site] 01498
72 ClientTlsParams::clone [function] [call site] 01499
72 secret_pkcs1_der [function] [call site] 01501
72 write_command_to_vec [function] [call site] 01502
72 secret_pkcs8_der [function] [call site] 01505
72 write_command_to_vec [function] [call site] 01506
72 secret_sec1_der [function] [call site] 01509
72 write_command_to_vec [function] [call site] 01510
71 Client::get_multiplexed_async_connection [function] [call site] 01512
72 Client::get_multiplexed_async_connection_with_config [function] [call site] 01513
73 Runtime::locate [function] [call site] 01514
73 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::tokio::Tokio> [function] [call site] 01515
73 get_multiplexed_async_connection_inner_with_timeout::<crate::aio::smol::Smol> [function] [call site] 01516
72 AsyncConnectionConfig::new [function] [call site] 01517
71 CopyOptions::replace [function] [call site] 01518
70 Cmd::query_async [function] [call site] 01520
71 &mut [call site] 01521
71 RedisResult::from_redis_value [function] [call site] 01523
71 Value::extract_error [function] [call site] 01524
70 &mut [call site] 01525
70 RedisError::is_unrecoverable_error [function] [call site] 01527
70 types::test_is_io_error [function] [call site] 01528
71 RedisError::from [function] [call site] 01529
70 async_reconnect [function] [call site] 01530
70 Cmd::query_async [function] [call site] 01531
70 &mut [call site] 01532
69 ClientTlsParams::clone [function] [call site] 01535
70 ClientTlsParams::clone [function] [call site] 01536
70 secret_pkcs1_der [function] [call site] 01538
70 write_command_to_vec [function] [call site] 01539
70 secret_pkcs8_der [function] [call site] 01542
70 write_command_to_vec [function] [call site] 01543
70 secret_sec1_der [function] [call site] 01546
70 write_command_to_vec [function] [call site] 01547
69 None::expect [function] [call site] 01552
68 sentinel_masters_cmd [function] [call site] 01553
69 crate::cmd [function] [call site] 01554
70 redis::cmd [function] [call site] 01555
70 Cmd::set_cache_config [function] [call site] 01556
70 CommandCacheConfig::new [function] [call site] 01557
70 CommandCacheConfig::set_enable_cache [function] [call site] 01558
69 Cmd::arg [function] [call site] 01559
67 async_find_valid_master [function] [call site] 01560
68 valid_addrs [function] [call site] 01561
69 &'a [call site] 01562
70 std::iter::once [function] [call site] 01563
70 basic::test_tuple_decoding_from_iter [function] [call site] 01565
69 std::iter::Chain::filter [function] [call site] 01566
69 tests::into_redis_value_hashmap [function] [call site] 01567
69 redis::ConnectionInfo::remove [function] [call site] 01568
69 parse::<u16> [function] [call site] 01570
68 is_master_valid [function] [call site] 01572
69 &HashMap<String, [call site] 01573
70 TestContext::new [function] [call site] 01574
70 ProtocolVersion::supports_resp3 [function] [call site] 01575
70 TestContext::async_connection_with_cache [function] [call site] 01576
70 get_pipe [function] [call site] 01578
70 redis::Pipeline::cmd [function] [call site] 01579
70 redis::Cmd::arg [function] [call site] 01580
70 types::test_is_single_arg [function] [call site] 01581
70 types::test_is_single_arg [function] [call site] 01584
70 types::test_is_single_arg [function] [call site] 01585
70 Cmd::query_async [function] [call site] 01587
70 redis::cmd [function] [call site] 01589
70 redis::Cmd::arg [function] [call site] 01590
70 types::test_is_single_arg [function] [call site] 01591
70 Cmd::query_async [function] [call site] 01592
70 assert_hit [function] [call site] 01594
70 assert_miss [function] [call site] 01595
70 redis::cmd [function] [call site] 01596
70 redis::Cmd::arg [function] [call site] 01597
70 types::test_is_single_arg [function] [call site] 01598
70 types::test_is_single_arg [function] [call site] 01599
70 Cmd::query_async [function] [call site] 01600
70 assert_hit [function] [call site] 01602
70 assert_miss [function] [call site] 01603
70 redis::cmd [function] [call site] 01604
70 redis::Cmd::arg [function] [call site] 01605
70 Cmd::query_async [function] [call site] 01606
70 assert_hit [function] [call site] 01608
70 assert_miss [function] [call site] 01609
69 tests::into_redis_value_hashmap [function] [call site] 01610
69 TlsFilePaths::as_str [function] [call site] 01611
69 InfoDict::contains_key [function] [call site] 01613
70 InfoDict::find [function] [call site] 01614
71 cache_mget [function] [call site] 01615
70 Option::is_some [function] [call site] 01616
69 InfoDict::contains_key [function] [call site] 01617
69 &HashMap<String, [call site] 01618
69 is_some_and [function] [call site] 01619
69 contains [function] [call site] 01620
69 contains [function] [call site] 01621
69 contains [function] [call site] 01622
69 parse::<u16> [function] [call site] 01623
69 tests::redis_ok [function] [call site] 01624
68 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01625
69 crate::ConnectionAddr::Tcp [function] [call site] 01626
69 ClusterClientBuilder::as_ref [function] [call site] 01627
69 tests::into_redis_value_hashmap [function] [call site] 01628
69 transpose [function] [call site] 01629
69 ClientTlsParams::clone [function] [call site] 01631
69 unwrap_or_default [function] [call site] 01632
69 ClientTlsParams::clone [function] [call site] 01633
69 unwrap_or_default [function] [call site] 01634
68 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 01635
68 async_determine_master_from_role_or_info_replication [function] [call site] 01636
69 Client::open [function] [call site] 01637
69 redis::ConnectionInfo::clone [function] [call site] 01638
69 Client::get_multiplexed_async_connection [function] [call site] 01639
69 async_check_role [function] [call site] 01640
70 crate::cmd [function] [call site] 01641
70 redis::Cmd::query_async [function] [call site] 01642
71 &mut [call site] 01643
71 RedisResult::from_redis_value [function] [call site] 01645
71 Value::extract_error [function] [call site] 01646
69 async_check_info_replication [function] [call site] 01648
70 crate::cmd [function] [call site] 01649
70 redis::Cmd::arg [function] [call site] 01650
70 Cmd::query_async [function] [call site] 01651
70 parse_replication_info [function] [call site] 01652
71 impl [call site] 01653
72 TestContext::new [function] [call site] 01654
72 TestContext::async_pubsub [function] [call site] 01655
73 Client::get_async_pubsub [function] [call site] 01656
74 Client::get_simple_async_connection_dynamically [function] [call site] 01657
75 Runtime::locate [function] [call site] 01658
75 get_simple_async_connection::<crate::aio::tokio::Tokio> [function] [call site] 01659
75 get_simple_async_connection::<crate::aio::smol::Smol> [function] [call site] 01660
74 crate::aio::PubSub::new [function] [call site] 01661
75 RedisServer::default [function] [call site] 01662
76 RedisServer::new [function] [call site] 01663
75 Self::framed [function] [call site] 01664
75 super::setup_connection [function] [call site] 01665
76 execute_connection_pipeline [function] [call site] 01666
77 basic::test_pipeline_len [function] [call site] 01667
77 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 01669
77 Pipeline::get_packed_pipeline [function] [call site] 01670
78 encode_pipeline [function] [call site] 01671
79 write_pipeline [function] [call site] 01672
80 basic::test_tuple_decoding_from_iter [function] [call site] 01673
81 TestContext::new [function] [call site] 01674
81 TestContext::connection [function] [call site] 01675
81 ValueType::from [function] [call site] 01676
81 basic::test_tuple_decoding_from_iter [function] [call site] 01677
81 hscan::<_, [call site] 01678
80 tests::into_redis_value_hashmap [function] [call site] 01681
80 cmd::cmd [function] [call site] 01683
81 redis::cmd [function] [call site] 01684
81 Cmd::set_cache_config [function] [call site] 01685
81 CommandCacheConfig::new [function] [call site] 01686
81 CommandCacheConfig::set_enable_cache [function] [call site] 01687
80 cmd::cmd [function] [call site] 01688
80 &mut [call site] 01689
80 cmd::cmd_len [function] [call site] 01690
81 args_len [function] [call site] 01691
81 Cmd::args_iter [function] [call site] 01692
81 unwrap_or [function] [call site] 01693
80 cmd::cmd_len [function] [call site] 01694
80 Cmd::write_packed_command_preallocated [function] [call site] 01695
81 write_command [function] [call site] 01696
81 Cmd::args_iter [function] [call site] 01697
81 unwrap_or [function] [call site] 01698
81 io::Result::unwrap [function] [call site] 01699
80 Cmd::write_packed_command_preallocated [function] [call site] 01700
81 write_command [function] [call site] 01701
81 Cmd::args_iter [function] [call site] 01702
81 unwrap_or [function] [call site] 01703
81 io::Result::unwrap [function] [call site] 01704
80 Cmd::write_packed_command_preallocated [function] [call site] 01705
80 &mut [call site] 01706
80 Cmd::write_packed_command_preallocated [function] [call site] 01707
77 Cmd::with_capacity [function] [call site] 01708
77 MapIter::next [function] [call site] 01709
78 MapIter::next [function] [call site] 01711
78 MapIter::next [function] [call site] 01712
78 MapIter::next [function] [call site] 01713
77 ok_or_else [function] [call site] 01715
77 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 01716
78 TestContext::new [function] [call site] 01717
78 ProtocolVersion::supports_resp3 [function] [call site] 01718
78 tokio::sync::mpsc::unbounded_channel [function] [call site] 01719
78 redis::aio::ConnectionManagerConfig::new [function] [call site] 01720
78 AsyncConnectionConfig::set_push_sender [function] [call site] 01721
78 Client::get_connection_manager_lazy [function] [call site] 01722
78 tests::into_redis_value_hashset [function] [call site] 01724
78 MockConnection::send_packed_command [function] [call site] 01726
78 Cmd::arg [function] [call site] 01728
78 types::test_is_single_arg [function] [call site] 01729
78 cache_mget [function] [call site] 01731
78 tests::into_redis_value_hashset [function] [call site] 01733
78 Pipeline::send_recv [function] [call site] 01735
77 connection::check_connection_setup [function] [call site] 01737
78 RedisResult::get [function] [call site] 01738
79 TestContext::new [function] [call site] 01739
79 ProtocolVersion::supports_resp3 [function] [call site] 01740
79 TestContext::async_connection_with_cache [function] [call site] 01741
79 get_pipe [function] [call site] 01743
79 redis::Pipeline::cmd [function] [call site] 01744
79 redis::Cmd::arg [function] [call site] 01745
79 types::test_is_single_arg [function] [call site] 01746
79 types::test_is_single_arg [function] [call site] 01749
79 types::test_is_single_arg [function] [call site] 01750
79 Cmd::query_async [function] [call site] 01752
79 redis::cmd [function] [call site] 01754
79 redis::Cmd::arg [function] [call site] 01755
79 types::test_is_single_arg [function] [call site] 01756
79 Cmd::query_async [function] [call site] 01757
79 assert_hit [function] [call site] 01759
79 assert_miss [function] [call site] 01760
79 redis::cmd [function] [call site] 01761
79 redis::Cmd::arg [function] [call site] 01762
79 types::test_is_single_arg [function] [call site] 01763
79 types::test_is_single_arg [function] [call site] 01764
79 Cmd::query_async [function] [call site] 01765
79 assert_hit [function] [call site] 01767
79 assert_miss [function] [call site] 01768
79 redis::cmd [function] [call site] 01769
79 redis::Cmd::arg [function] [call site] 01770
79 Cmd::query_async [function] [call site] 01771
79 assert_hit [function] [call site] 01773
79 assert_miss [function] [call site] 01774
78 check_resp3_auth [function] [call site] 01777
79 get_resp3_hello_command_error [function] [call site] 01779
80 RedisError::detail [function] [call site] 01780
81 Option::as_ref [function] [call site] 01781
81 tests::into_redis_value_hashmap [function] [call site] 01782
81 Option::as_str [function] [call site] 01783
81 ServerError::details [function] [call site] 01785
82 Option::as_ref [function] [call site] 01786
82 tests::into_redis_value_hashmap [function] [call site] 01787
82 Option::as_ref [function] [call site] 01789
82 tests::into_redis_value_hashmap [function] [call site] 01790
80 Option::starts_with [function] [call site] 01792
79 ClientTlsParams::clone [function] [call site] 01794
79 Self::into [function] [call site] 01795
78 RedisResult::get [function] [call site] 01797
78 RedisResult::get [function] [call site] 01812
78 check_db_select [function] [call site] 01815
78 RedisResult::get [function] [call site] 01825
76 connection_setup_pipeline [function] [call site] 01834
77 cmd::pipe [function] [call site] 01835
78 redis::pipe [function] [call site] 01836
78 Pipeline::atomic [function] [call site] 01837
78 redis::pipe [function] [call site] 01838
77 ProtocolVersion::supports_resp3 [function] [call site] 01839
77 add_command [function] [call site] 01840
77 commands::resp3_hello [function] [call site] 01841
78 cmd::cmd [function] [call site] 01842
78 Cmd::arg [function] [call site] 01843
78 Cmd::arg [function] [call site] 01845
78 types::test_is_single_arg [function] [call site] 01846
78 types::test_is_single_arg [function] [call site] 01847
78 &'static [call site] 01848
77 add_command [function] [call site] 01851
77 authenticate_cmd [function] [call site] 01852
78 cmd::cmd [function] [call site] 01853
78 types::test_is_single_arg [function] [call site] 01854
78 types::test_is_single_arg [function] [call site] 01855
77 bool::then [function] [call site] 01856
77 redis::ConnectionInfo::username [function] [call site] 01857
78 as_deref [function] [call site] 01858
77 basic::test_pipeline_len [function] [call site] 01862
77 cmd::cmd [function] [call site] 01864
77 Cmd::arg [function] [call site] 01865
77 tests::into_redis_value_hashmap [function] [call site] 01866
78 ValueType::from [function] [call site] 01867
78 String::into_redis_value [function] [call site] 01868
78 Value::into_map_iter [function] [call site] 01869
78 Result::expect [function] [call site] 01870
78 into_map_iter() [call site] 01871
6 .expect("extracting [call site] 01872
6 .collect::<Vec<(Value, [call site] 01873
77 cmd::cmd [function] [call site] 01876
77 Cmd::arg [function] [call site] 01877
77 types::test_is_single_arg [function] [call site] 01878
77 types::test_is_single_arg [function] [call site] 01879
77 basic::test_pipeline_len [function] [call site] 01880
77 cmd::cmd [function] [call site] 01881
77 Cmd::arg [function] [call site] 01882
77 types::test_is_single_arg [function] [call site] 01883
77 types::test_is_single_arg [function] [call site] 01884
77 as_ref [function] [call site] 01885
77 map_or [function] [call site] 01886
77 ignore [function] [call site] 01887
77 cmd::cmd [function] [call site] 01888
77 Cmd::arg [function] [call site] 01889
77 types::test_is_single_arg [function] [call site] 01890
77 types::test_is_single_arg [function] [call site] 01891
77 as_ref [function] [call site] 01892
77 map_or [function] [call site] 01893
77 ignore [function] [call site] 01894
76 execute_connection_pipeline [function] [call site] 01895
76 connection_setup_pipeline [function] [call site] 01896
76 Ok [function] [call site] 01897
75 tokio::sync::mpsc::unbounded_channel [function] [call site] 01898
75 PubSubSink::new [function] [call site] 01899
76 tokio::sync::mpsc::unbounded_channel [function] [call site] 01900
76 PipelineSink::new [function] [call site] 01901
77 RedisServer::new [function] [call site] 01902
78 RedisServer::with_modules [function] [call site] 01903
76 stream::poll_fn [function] [call site] 01904
76 ( [call site] 01905
4 PendingRequest::poll_recv [function] [call site] 01906
76 tests::into_redis_value_hashmap [function] [call site] 01907
76 tests::into_redis_value_hashmap [function] [call site] 01909
75 Runtime::locate [function] [call site] 01910
75 Self::spawn [function] [call site] 01911
76 tokio::runtime::Handle::try_current [function] [call site] 01912
76 smol::spawn [function] [call site] 01914
76 TaskHandle::detach [function] [call site] 01915
75 Some [function] [call site] 01916
75 SharedHandleContainer::new [function] [call site] 01917
76 RedisServer::new [function] [call site] 01919
76 HandleContainer::new [function] [call site] 01920
75 Ok [function] [call site] 01923
72 unwrap [function] [call site] 01924
72 basic_async::automatic_unsubscription_on_split [function] [call site] 01925
73 TestContext::new [function] [call site] 01926
73 TestContext::async_pubsub [function] [call site] 01927
73 basic_async::automatic_unsubscription_on_split [function] [call site] 01929
73 basic::test_pubsub_unsubscribe [function] [call site] 01930
74 TestContext::new [function] [call site] 01931
74 TestContext::connection [function] [call site] 01932
74 std::sync::mpsc::channel [function] [call site] 01933
75 from_redis_value_ref [function] [call site] 01935
74 redis::Connection::set_push_sender [function] [call site] 01936
74 redis::Connection::as_pubsub [function] [call site] 01938
75 PubSub::new [function] [call site] 01939
76 RedisServer::default [function] [call site] 01940
76 Self::framed [function] [call site] 01941
76 super::setup_connection [function] [call site] 01942
76 tokio::sync::mpsc::unbounded_channel [function] [call site] 01943
76 PubSubSink::new [function] [call site] 01944
76 Runtime::locate [function] [call site] 01945
76 Self::spawn [function] [call site] 01946
76 SharedHandleContainer::new [function] [call site] 01948
74 basic::test_pubsub_unsubscribe [function] [call site] 01950
74 basic::test_pubsub_unsubscribe [function] [call site] 01952
74 basic::test_pubsub_unsubscribe [function] [call site] 01954
74 PubSub::psubscribe [function] [call site] 01956
75 PubSub::psubscribe [function] [call site] 01957
74 RedisResult::unwrap [function] [call site] 01958
74 PubSub::psubscribe [function] [call site] 01959
74 RedisResult::unwrap [function] [call site] 01960
74 PubSub::psubscribe [function] [call site] 01961
74 RedisResult::unwrap [function] [call site] 01962
74 redis::Connection::set [function] [call site] 01963
75 ValueType::from [function] [call site] 01964
75 String::into_redis_value [function] [call site] 01965
75 Value::into_sequence [function] [call site] 01966
75 Result::expect [function] [call site] 01967
74 redis::Connection::get [function] [call site] 01971
75 TestContext::new [function] [call site] 01972
75 ProtocolVersion::supports_resp3 [function] [call site] 01973
75 TestContext::async_connection_with_cache [function] [call site] 01974
75 get_pipe [function] [call site] 01976
75 redis::Pipeline::cmd [function] [call site] 01977
75 redis::Cmd::arg [function] [call site] 01978
75 types::test_is_single_arg [function] [call site] 01979
75 types::test_is_single_arg [function] [call site] 01982
75 types::test_is_single_arg [function] [call site] 01983
75 Cmd::query_async [function] [call site] 01985
75 redis::cmd [function] [call site] 01987
75 redis::Cmd::arg [function] [call site] 01988
75 types::test_is_single_arg [function] [call site] 01989
75 Cmd::query_async [function] [call site] 01990
75 assert_hit [function] [call site] 01992
75 assert_miss [function] [call site] 01993
75 redis::cmd [function] [call site] 01994
75 redis::Cmd::arg [function] [call site] 01995
75 types::test_is_single_arg [function] [call site] 01996
75 types::test_is_single_arg [function] [call site] 01997
75 Cmd::query_async [function] [call site] 01998
75 assert_hit [function] [call site] 02000
75 assert_miss [function] [call site] 02001
75 redis::cmd [function] [call site] 02002
75 redis::Cmd::arg [function] [call site] 02003
75 Cmd::query_async [function] [call site] 02004
75 assert_hit [function] [call site] 02006
75 assert_miss [function] [call site] 02007
74 ProtocolVersion::supports_resp3 [function] [call site] 02010
74 try_recv [function] [call site] 02011
74 RedisResult::from_redis_value_ref [function] [call site] 02013
75 ClientTlsParams::clone [function] [call site] 02016
75 Self::into [function] [call site] 02017
75 from_redis_value_ref [function] [call site] 02018
75 tests::into_redis_value_hashmap [function] [call site] 02019
74 Replicas::first [function] [call site] 02021
74 &'a [call site] 02022
74 Result::unwrap [function] [call site] 02023
74 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02024
73 TestContext::async_connection [function] [call site] 02026
74 Client::get_multiplexed_async_connection [function] [call site] 02027
73 Runtime::sleep [function] [call site] 02029
74 tokio::time::sleep [function] [call site] 02030
74 smol::Timer::after [function] [call site] 02031
73 Duration::from_millis [function] [call site] 02032
73 redis::cmd [function] [call site] 02034
73 redis::Cmd::arg [function] [call site] 02035
73 types::test_is_single_arg [function] [call site] 02036
73 Cmd::query_async [function] [call site] 02037
73 cache_mget [function] [call site] 02039
73 RedisServer::drop [function] [call site] 02041
73 redis::cmd [function] [call site] 02042
73 redis::Cmd::arg [function] [call site] 02043
73 types::test_is_single_arg [function] [call site] 02044
73 Cmd::query_async [function] [call site] 02045
73 cache_mget [function] [call site] 02047
73 Runtime::sleep [function] [call site] 02049
73 Duration::from_millis [function] [call site] 02050
73 basic::test_pubsub_unsubscribe [function] [call site] 02052
73 unwrap_err [function] [call site] 02053
72 basic::test_pubsub_unsubscribe [function] [call site] 02054
72 unwrap [function] [call site] 02055
72 TestContext::async_connection [function] [call site] 02056
72 unwrap [function] [call site] 02057
72 Runtime::sleep [function] [call site] 02058
72 Duration::from_millis [function] [call site] 02059
72 into [function] [call site] 02060
72 redis::cmd [function] [call site] 02061
72 redis::Cmd::arg [function] [call site] 02062
72 types::test_is_single_arg [function] [call site] 02063
72 Cmd::query_async [function] [call site] 02064
72 unwrap [function] [call site] 02065
72 cache_mget [function] [call site] 02066
72 unwrap [function] [call site] 02067
72 RedisServer::drop [function] [call site] 02068
72 redis::cmd [function] [call site] 02069
72 redis::Cmd::arg [function] [call site] 02070
72 types::test_is_single_arg [function] [call site] 02071
72 Cmd::query_async [function] [call site] 02072
72 unwrap [function] [call site] 02073
72 cache_mget [function] [call site] 02074
72 unwrap [function] [call site] 02075
72 Runtime::sleep [function] [call site] 02076
72 Duration::from_millis [function] [call site] 02077
72 into [function] [call site] 02078
72 basic::test_pubsub_unsubscribe [function] [call site] 02079
72 unwrap_err [function] [call site] 02080
71 filter [function] [call site] 02081
71 trim_start [function] [call site] 02082
71 starts_with [function] [call site] 02083
71 filter_map [function] [call site] 02084
71 split_once [function] [call site] 02085
71 tests::into_redis_value_hashmap [function] [call site] 02086
71 ValueComparison::arg_to_string [function] [call site] 02087
71 ValueComparison::arg_to_string [function] [call site] 02088
71 collect [function] [call site] 02089
70 HashMap::get [function] [call site] 02090
71 TestContext::new [function] [call site] 02091
71 ProtocolVersion::supports_resp3 [function] [call site] 02092
71 TestContext::async_connection_with_cache [function] [call site] 02093
71 get_pipe [function] [call site] 02095
71 redis::Pipeline::cmd [function] [call site] 02096
71 redis::Cmd::arg [function] [call site] 02097
71 types::test_is_single_arg [function] [call site] 02098
71 types::test_is_single_arg [function] [call site] 02101
71 types::test_is_single_arg [function] [call site] 02102
71 Cmd::query_async [function] [call site] 02104
71 redis::cmd [function] [call site] 02106
71 redis::Cmd::arg [function] [call site] 02107
71 types::test_is_single_arg [function] [call site] 02108
71 Cmd::query_async [function] [call site] 02109
71 assert_hit [function] [call site] 02111
71 assert_miss [function] [call site] 02112
71 redis::cmd [function] [call site] 02113
71 redis::Cmd::arg [function] [call site] 02114
71 types::test_is_single_arg [function] [call site] 02115
71 types::test_is_single_arg [function] [call site] 02116
71 Cmd::query_async [function] [call site] 02117
71 assert_hit [function] [call site] 02119
71 assert_miss [function] [call site] 02120
71 redis::cmd [function] [call site] 02121
71 redis::Cmd::arg [function] [call site] 02122
71 Cmd::query_async [function] [call site] 02123
71 assert_hit [function] [call site] 02125
71 assert_miss [function] [call site] 02126
70 Ok [function] [call site] 02127
70 ClientTlsParams::clone [function] [call site] 02128
70 Err [function] [call site] 02129
70 RedisError::from [function] [call site] 02130
69 Ok [function] [call site] 02131
69 evaluate_role_check_errors [function] [call site] 02132
70 RedisError::kind [function] [call site] 02133
69 unwrap_err [function] [call site] 02137
69 unwrap_err [function] [call site] 02138
68 Ok [function] [call site] 02139
66 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02140
66 Client::open [function] [call site] 02141
65 as_str [function] [call site] 02142
65 Some [function] [call site] 02143
65 Sentinel::async_replica_for [function] [call site] 02144
66 Sentinel::async_find_valid_replica_addresses [function] [call site] 02145
67 Sentinel::async_get_sentinel_replicas [function] [call site] 02146
68 Sentinel::async_try_all_sentinels [function] [call site] 02147
68 sentinel_replicas_cmd [function] [call site] 02148
69 crate::cmd [function] [call site] 02149
69 Cmd::arg [function] [call site] 02150
69 Cmd::arg [function] [call site] 02151
67 async_get_valid_replicas_addresses [function] [call site] 02152
68 valid_addrs [function] [call site] 02153
68 tests::into_redis_value_hashmap [function] [call site] 02154
68 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02155
68 map(|(ip, [call site] 02156
4 .collect::<RedisResult<Vec<_>>> [function] [call site] 02157
68 futures_util::stream::iter [function] [call site] 02159
69 TestContext::new [function] [call site] 02160
69 TestContext::connection [function] [call site] 02161
69 ValueType::from [function] [call site] 02162
69 basic::test_tuple_decoding_from_iter [function] [call site] 02163
69 hscan::<_, [call site] 02164
68 filter_map [function] [call site] 02167
66 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02169
66 RedisServer::new [function] [call site] 02170
66 basic::test_pipeline_len [function] [call site] 02171
67 redis::pipe [function] [call site] 02172
67 types::test_is_single_arg [function] [call site] 02175
66 tests::into_redis_value_hashmap [function] [call site] 02176
67 ValueType::from [function] [call site] 02177
67 String::into_redis_value [function] [call site] 02178
67 Value::into_map_iter [function] [call site] 02179
67 Result::expect [function] [call site] 02180
67 into_map_iter() [call site] 02181
6 .expect("extracting [call site] 02182
6 .collect::<Vec<(Value, [call site] 02183
66 try_connect_to_first_replica [function] [call site] 02186
67 MockRedisConnection::is_empty [function] [call site] 02187
68 StreamReadOptions::block [function] [call site] 02188
68 MockRedisConnection::is_empty [function] [call site] 02190
67 Option<usize>::unwrap_or [function] [call site] 02192
67 basic::test_pipeline_len [function] [call site] 02193
67 basic::test_pipeline_len [function] [call site] 02194
67 Client::open [function] [call site] 02195
67 ClientTlsParams::clone [function] [call site] 02196
67 None::expect [function] [call site] 02200
65 as_str [function] [call site] 02201
65 Some [function] [call site] 02202
64 Client::get_multiplexed_async_connection_with_config [function] [call site] 02203
63 unwrap [function] [call site] 02204
63 async_tests::async_assert_is_connection_to_master [function] [call site] 02205
64 redis::cmd [function] [call site] 02206
64 redis::Cmd::arg [function] [call site] 02207
64 Cmd::query_async [function] [call site] 02208
64 assert_is_master_role [function] [call site] 02210
65 parse_replication_info [function] [call site] 02211
63 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02212
63 TestSentinelContext::sentinel_mut [function] [call site] 02213
63 &redis::sentinel::Sentinel::async_master_for [function] [call site] 02214
64 Sentinel::async_find_master_address [function] [call site] 02215
64 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02216
64 Client::open [function] [call site] 02217
63 Some [function] [call site] 02218
63 unwrap [function] [call site] 02219
63 SentinelClient::get_async_connection_with_config [function] [call site] 02220
63 unwrap [function] [call site] 02221
63 async_tests::async_assert_connection_is_replica_of_correct_master [function] [call site] 02222
64 redis::cmd [function] [call site] 02223
64 redis::Cmd::arg [function] [call site] 02224
64 Cmd::query_async [function] [call site] 02225
64 assert_replica_role_and_master_addr [function] [call site] 02227
65 parse_replication_info [function] [call site] 02228
65 RedisServer::get_addr [function] [call site] 02229
66 ServerType::get_intended [function] [call site] 02230
66 ValueComparison::arg_to_string [function] [call site] 02231
66 redis::ConnectionAddr::Tcp [function] [call site] 02232
66 ValueComparison::arg_to_string [function] [call site] 02233
66 rand::random::<(u64, [call site] 02234
66 redis::ConnectionAddr::Unix [function] [call site] 02235
66 ValueType::from [function] [call site] 02236
67 TlsFilePaths::as_ref [function] [call site] 02237
67 ValueType::Unknown [function] [call site] 02238
67 ValueComparison::arg_to_string [function] [call site] 02239
64 Client::get_connection_info [function] [call site] 02240
61 RoutingInfo::SingleNode [function] [call site] 02241
61 MockRedisConnection::req_packed_command [function] [call site] 02242
62 Cmd::get_packed_command [function] [call site] 02243
62 MockRedisConnection::req_packed_command [function] [call site] 02244
62 as_slice [function] [call site] 02245
62 PipelineSink::poll_ready [function] [call site] 02246
62 types::test_parse_boxed [function] [call site] 02247
61 Cmd::get_packed_command [function] [call site] 02248
61 RedisCluster::new [function] [call site] 02249
61 RedisServer::default [function] [call site] 02250
61 ClusterConnection::route_command [function] [call site] 02251
61 RoutingInfo::SingleNode [function] [call site] 02252
61 RedisResult::unwrap [function] [call site] 02253
60 Some [function] [call site] 02254
60 cmd::cmd [function] [call site] 02255
60 Cmd::exec [function] [call site] 02256
61 query::<()> [function] [call site] 02257
60 MockConnection::set_read_timeout [function] [call site] 02258
60 borrow [function] [call site] 02260
60 MockConnection::set_write_timeout [function] [call site] 02261
60 borrow [function] [call site] 02263
60 Ok [function] [call site] 02264
59 MockRedisConnection::check_connection [function] [call site] 02265
59 RedisResult::insert [function] [call site] 02266
60 TestContext::with_modules [function] [call site] 02267
60 TestContext::connection [function] [call site] 02268
60 redis::Connection::json_set [function] [call site] 02269
60 redis::Connection::json_arr_insert [function] [call site] 02270
60 redis::Connection::json_set [function] [call site] 02271
60 redis::Connection::json_arr_insert [function] [call site] 02272
59 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02273
60 TestContext::new [function] [call site] 02274
60 ProtocolVersion::supports_resp3 [function] [call site] 02275
60 tokio::sync::mpsc::unbounded_channel [function] [call site] 02276
60 redis::aio::ConnectionManagerConfig::new [function] [call site] 02277
60 AsyncConnectionConfig::set_push_sender [function] [call site] 02278
60 Client::get_connection_manager_lazy [function] [call site] 02279
60 tests::into_redis_value_hashset [function] [call site] 02281
60 MockConnection::send_packed_command [function] [call site] 02283
60 Cmd::arg [function] [call site] 02285
60 types::test_is_single_arg [function] [call site] 02286
60 cache_mget [function] [call site] 02288
60 tests::into_redis_value_hashset [function] [call site] 02290
60 Pipeline::send_recv [function] [call site] 02292
59 RedisError::from [function] [call site] 02294
59 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02295
59 MockRedisConnection::is_empty [function] [call site] 02296
59 MockRedisConnection::is_empty [function] [call site] 02297
60 StreamReadOptions::block [function] [call site] 02298
60 MockRedisConnection::is_empty [function] [call site] 02300
59 ValueComparison::arg_to_string [function] [call site] 02301
59 ValueComparison::arg_to_string [function] [call site] 02302
59 &'a [call site] 02303
59 std::iter::Chain::enumerate [function] [call site] 02304
59 Err [function] [call site] 02305
59 RedisError::from [function] [call site] 02306
59 borrow_mut [function] [call site] 02307
59 ClusterConnection::refresh_slots [function] [call site] 02308
60 borrow_mut [function] [call site] 02309
60 ClusterConnection::create_new_slots [function] [call site] 02310
61 borrow_mut [function] [call site] 02311
61 RedisResult::iter_mut [function] [call site] 02312
61 ConnectionLike::req_command [function] [call site] 02313
62 Cmd::get_packed_command [function] [call site] 02314
62 MockRedisConnection::req_packed_command [function] [call site] 02315
61 cluster_handling::slot_cmd [function] [call site] 02316
62 Cmd::new [function] [call site] 02317
62 Cmd::arg [function] [call site] 02318
62 types::test_is_single_arg [function] [call site] 02319
61 super::topology::parse_slots [function] [call site] 02320
62 Cmd::with_capacity [function] [call site] 02321
62 HashSet::<ArcStr>::new [function] [call site] 02322
63 RedisServer::with_modules [function] [call site] 02323
62 &'a [call site] 02324
62 MapIter::next [function] [call site] 02325
62 basic::test_pipeline_len [function] [call site] 02326
63 redis::pipe [function] [call site] 02327
63 types::test_is_single_arg [function] [call site] 02330
62 basic::test_pipeline_len [function] [call site] 02331
62 String::from_utf8_lossy [function] [call site] 02332
62 MockRedisConnection::is_empty [function] [call site] 02333
62 is_wildcard_address [function] [call site] 02334
62 &str::into [function] [call site] 02335
62 &str::into [function] [call site] 02336
62 MockRedisConnection::is_empty [function] [call site] 02337
62 RedisServer::get [function] [call site] 02338
63 TestContext::new [function] [call site] 02339
63 ProtocolVersion::supports_resp3 [function] [call site] 02340
63 TestContext::async_connection_with_cache [function] [call site] 02341
63 get_pipe [function] [call site] 02343
63 redis::Pipeline::cmd [function] [call site] 02344
63 redis::Cmd::arg [function] [call site] 02345
63 types::test_is_single_arg [function] [call site] 02346
63 types::test_is_single_arg [function] [call site] 02349
63 types::test_is_single_arg [function] [call site] 02350
63 Cmd::query_async [function] [call site] 02352
63 redis::cmd [function] [call site] 02354
63 redis::Cmd::arg [function] [call site] 02355
63 types::test_is_single_arg [function] [call site] 02356
63 Cmd::query_async [function] [call site] 02357
63 assert_hit [function] [call site] 02359
63 assert_miss [function] [call site] 02360
63 redis::cmd [function] [call site] 02361
63 redis::Cmd::arg [function] [call site] 02362
63 types::test_is_single_arg [function] [call site] 02363
63 types::test_is_single_arg [function] [call site] 02364
63 Cmd::query_async [function] [call site] 02365
63 assert_hit [function] [call site] 02367
63 assert_miss [function] [call site] 02368
63 redis::cmd [function] [call site] 02369
63 redis::Cmd::arg [function] [call site] 02370
63 Cmd::query_async [function] [call site] 02371
63 assert_hit [function] [call site] 02373
63 assert_miss [function] [call site] 02374
62 ClientTlsParams::clone [function] [call site] 02376
63 ClientTlsParams::clone [function] [call site] 02377
63 secret_pkcs1_der [function] [call site] 02379
63 write_command_to_vec [function] [call site] 02380
63 secret_pkcs8_der [function] [call site] 02383
63 write_command_to_vec [function] [call site] 02384
63 secret_sec1_der [function] [call site] 02387
63 write_command_to_vec [function] [call site] 02388
62 RedisServer::insert [function] [call site] 02391
62 ClientTlsParams::clone [function] [call site] 02392
62 NodeAddress::new [function] [call site] 02394
62 &'a [call site] 02395
63 std::iter::once [function] [call site] 02396
63 basic::test_tuple_decoding_from_iter [function] [call site] 02398
62 std::iter::Chain::skip [function] [call site] 02399
62 MapIter::next [function] [call site] 02401
62 try_to_address [function] [call site] 02402
62 filter_map [function] [call site] 02403
62 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02405
62 Slot::new [function] [call site] 02406
61 NodeAddress::host [function] [call site] 02408
61 SlotMap::from_slots [function] [call site] 02410
62 SlotRangeMap::new [function] [call site] 02411
63 RedisServer::new [function] [call site] 02412
64 RedisServer::with_modules [function] [call site] 02413
62 test_module_json_arr_insert [function] [call site] 02414
62 SlotAddrs::from_slot [function] [call site] 02415
63 SlotAddrs::new [function] [call site] 02416
61 RedisError::from [function] [call site] 02419
60 RoundRobinReplicaStrategy::on_topology_changed [function] [call site] 02420
61 SlotRangeMap::new [function] [call site] 02421
61 ClusterTopology::shards [function] [call site] 02422
62 std::collections::HashSet::new [function] [call site] 02423
62 MockCmd::with_values [function] [call site] 02424
63 Cmd::into_redis_cmd_bytes [function] [call site] 02425
64 Cmd::get_packed_command [function] [call site] 02426
63 tests::into_redis_value_hashmap [function] [call site] 02427
64 ValueType::from [function] [call site] 02428
64 String::into_redis_value [function] [call site] 02429
64 Value::into_map_iter [function] [call site] 02430
64 Result::expect [function] [call site] 02431
64 into_map_iter() [call site] 02432
6 .expect("extracting [call site] 02433
6 .collect::<Vec<(Value, [call site] 02434
63 &'a [call site] 02437
63 tests::into_redis_value_hashmap [function] [call site] 02438
63 String::into_redis_value [function] [call site] 02439
64 Value::BulkString [function] [call site] 02440
64 String::as_bytes [function] [call site] 02441
64 write_command_to_vec [function] [call site] 02442
63 collect [function] [call site] 02443
62 filter_map [function] [call site] 02444
62 RedisServer::insert [function] [call site] 02445
62 Arc::as_ptr [function] [call site] 02446
62 Some [function] [call site] 02447
62 std::sync::MutexGuard::as_ref [function] [call site] 02448
61 RedisServer::new [function] [call site] 02449
61 RedisServer::new [function] [call site] 02450
62 RedisServer::with_modules [function] [call site] 02451
61 std::sync::MutexGuard::slot_ranges [function] [call site] 02452
62 cluster::test_cluster_fan_out [function] [call site] 02453
63 RedisServer::new [function] [call site] 02454
63 std::sync::Mutex::new [function] [call site] 02455
64 RedisServer::with_modules [function] [call site] 02456
63 RedisServer::new [function] [call site] 02457
63 ClientTlsParams::clone [function] [call site] 02458
64 ClientTlsParams::clone [function] [call site] 02459
64 secret_pkcs1_der [function] [call site] 02461
64 write_command_to_vec [function] [call site] 02462
64 secret_pkcs8_der [function] [call site] 02465
64 write_command_to_vec [function] [call site] 02466
64 secret_sec1_der [function] [call site] 02469
64 write_command_to_vec [function] [call site] 02470
63 redis::Cmd::new [function] [call site] 02472
64 Cmd::into_redis_cmd_bytes [function] [call site] 02473
64 tests::into_redis_value_hashmap [function] [call site] 02474
63 RedisFuture::split_whitespace [function] [call site] 02475
63 Cmd::arg [function] [call site] 02476
63 Cmd::get_packed_command [function] [call site] 02477
63 MockEnv::with_client_builder [function] [call site] 02478
63 ClusterClient::builder [function] [call site] 02479
64 ClusterClientBuilder::new [function] [call site] 02480
65 &'a [call site] 02481
65 std::iter::Chain::map [function] [call site] 02482
65 ConnectionInfo::into_connection_info [function] [call site] 02483
65 RedisServer::default [function] [call site] 02485
63 ClusterClientBuilder::retries [function] [call site] 02486
63 ClusterClientBuilder::read_routing_strategy [function] [call site] 02487
64 RedisServer::new [function] [call site] 02489
63 respond_startup_with_replica_using_config [function] [call site] 02490
64 Option<Vec<MockSlotRange>>::unwrap_or [function] [call site] 02491
64 is_connection_check [function] [call site] 02492
65 contains_slice [function] [call site] 02493
66 basic::test_pipeline_len [function] [call site] 02494
67 redis::pipe [function] [call site] 02495
67 types::test_is_single_arg [function] [call site] 02498
66 starts_with [function] [call site] 02499
65 contains_slice [function] [call site] 02500
64 Value::SimpleString [function] [call site] 02503
64 &str::into [function] [call site] 02504
64 contains_slice [function] [call site] 02505
64 contains_slice [function] [call site] 02506
64 &'a [call site] 02507
65 std::iter::once [function] [call site] 02508
65 basic::test_tuple_decoding_from_iter [function] [call site] 02510
64 std::iter::Chain::map [function] [call site] 02511
64 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02512
64 Value::Array [function] [call site] 02513
64 Value::Array [function] [call site] 02514
64 Value::Array [function] [call site] 02518
63 ClientTlsParams::clone [function] [call site] 02520
64 ClientTlsParams::clone [function] [call site] 02521
64 secret_pkcs1_der [function] [call site] 02523
64 write_command_to_vec [function] [call site] 02524
64 secret_pkcs8_der [function] [call site] 02527
64 write_command_to_vec [function] [call site] 02528
64 secret_sec1_der [function] [call site] 02531
64 write_command_to_vec [function] [call site] 02532
63 StreamReadOptions::block [function] [call site] 02534
63 Self::unwrap [function] [call site] 02536
63 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02537
63 redis_value [function] [call site] 02540
64 $crate::IntoRedisValue::into_redis_value [function] [call site] 02541
63 query::<Option<()>> [function] [call site] 02543
63 StreamReadOptions::block [function] [call site] 02544
63 Self::unwrap [function] [call site] 02546
61 RedisResult::insert [function] [call site] 02549
61 ClientTlsParams::clone [function] [call site] 02550
62 ClientTlsParams::clone [function] [call site] 02551
62 secret_pkcs1_der [function] [call site] 02553
62 write_command_to_vec [function] [call site] 02554
62 secret_pkcs8_der [function] [call site] 02557
62 write_command_to_vec [function] [call site] 02558
62 secret_sec1_der [function] [call site] 02561
62 write_command_to_vec [function] [call site] 02562
61 Tokio::poll_write [function] [call site] 02564
61 expect [function] [call site] 02565
60 SlotMap::topology [function] [call site] 02566
61 RedisServer::new [function] [call site] 02567
61 basic::test_tuple_decoding_from_iter [function] [call site] 02568
61 RedisServer::iter_mut [function] [call site] 02569
61 InfoDict::find [function] [call site] 02570
62 cache_mget [function] [call site] 02571
61 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02572
61 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 02573
61 ClientTlsParams::clone [function] [call site] 02574
61 ClientTlsParams::clone [function] [call site] 02575
61 ClusterTopology::from_shards [function] [call site] 02576
62 SlotRangeMap::new [function] [call site] 02577
62 RedisServer::new [function] [call site] 02578
62 std::sync::MutexGuard::slot_ranges [function] [call site] 02579
62 RedisResult::insert [function] [call site] 02580
62 ClientTlsParams::clone [function] [call site] 02581
61 &'a [call site] 02582
61 std::iter::Chain::map [function] [call site] 02583
60 MockCmd::with_values [function] [call site] 02588
61 Cmd::into_redis_cmd_bytes [function] [call site] 02589
61 tests::into_redis_value_hashmap [function] [call site] 02590
61 &'a [call site] 02591
61 tests::into_redis_value_hashmap [function] [call site] 02592
61 String::into_redis_value [function] [call site] 02593
60 Self::flatten [function] [call site] 02595
60 values().flatten().collect::<Vec<_>> [function] [call site] 02596
60 sort_unstable [function] [call site] 02597
60 dedup [function] [call site] 02598
60 borrow_mut [function] [call site] 02599
60 &'a [call site] 02600
60 std::iter::Chain::filter_map [function] [call site] 02601
60 RedisResult::remove [function] [call site] 02602
60 MockRedisConnection::check_connection [function] [call site] 02603
60 Some [function] [call site] 02604
60 ClientTlsParams::clone [function] [call site] 02605
61 ClientTlsParams::clone [function] [call site] 02606
61 secret_pkcs1_der [function] [call site] 02608
61 write_command_to_vec [function] [call site] 02609
61 secret_pkcs8_der [function] [call site] 02612
61 write_command_to_vec [function] [call site] 02613
61 secret_sec1_der [function] [call site] 02616
61 write_command_to_vec [function] [call site] 02617
60 ClusterConnection::connect [function] [call site] 02619
60 MockRedisConnection::check_connection [function] [call site] 02620
60 Some [function] [call site] 02621
60 ClientTlsParams::clone [function] [call site] 02622
60 collect [function] [call site] 02623
60 Ok [function] [call site] 02624
59 Ok [function] [call site] 02625
58 Tokio::poll_write [function] [call site] 02626
58 SlotMap::new [function] [call site] 02627
58 ClusterConnection::refresh_slots [function] [call site] 02628
59 borrow_mut [function] [call site] 02629
59 ClusterConnection::create_new_slots [function] [call site] 02630
59 RoundRobinReplicaStrategy::on_topology_changed [function] [call site] 02631
59 SlotMap::topology [function] [call site] 02632
59 MockCmd::with_values [function] [call site] 02633
59 Self::flatten [function] [call site] 02634
59 values().flatten().collect::<Vec<_>> [function] [call site] 02635
59 sort_unstable [function] [call site] 02636
59 borrow_mut [function] [call site] 02638
59 &'a [call site] 02639
59 std::iter::Chain::filter_map [function] [call site] 02640
59 RedisResult::remove [function] [call site] 02641
59 MockRedisConnection::check_connection [function] [call site] 02642
59 ClientTlsParams::clone [function] [call site] 02644
59 ClusterConnection::connect [function] [call site] 02645
59 MockRedisConnection::check_connection [function] [call site] 02646
59 ClientTlsParams::clone [function] [call site] 02648
58 Ok [function] [call site] 02651
56 oneshot::channel::<RedisResult<()>> [function] [call site] 02652
56 mpsc::channel::<Message<_>> [function] [call site] 02653
56 ClusterConnInner::wait_for_initial_connection [function] [call site] 02654
57 std::mem::replace [function] [call site] 02655
56 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 02657
56 stream::poll_fn [function] [call site] 02658
56 ( [call site] 02659
4 PendingRequest::poll_recv [function] [call site] 02660
56 tests::into_redis_value_hashmap [function] [call site] 02661
56 HandleContainer::new [function] [call site] 02663
56 tokio::runtime::Runtime::spawn [function] [call site] 02664
57 crate_tokio::Tokio::spawn [function] [call site] 02665
58 TaskHandle::Tokio [function] [call site] 02666
58 tokio::spawn [function] [call site] 02667
59 tokio::runtime::Handle::try_current [function] [call site] 02668
59 smol::spawn [function] [call site] 02670
59 TaskHandle::detach [function] [call site] 02671
57 crate_smol::Smol::spawn [function] [call site] 02672
58 TaskHandle::Smol [function] [call site] 02673
58 smol::spawn [function] [call site] 02674
56 RedisServer::new [function] [call site] 02675
55 map_err [function] [call site] 02676
55 RedisError::from [function] [call site] 02677
55 Ok [function] [call site] 02678
54 ClientTlsParams::clone [function] [call site] 02679
54 ClientTlsParams::clone [function] [call site] 02680
53 RedisResult::unwrap [function] [call site] 02681
53 tokio::runtime::Runtime::block_on [function] [call site] 02682
53 ClusterClient::get_async_generic_connection [function] [call site] 02683
54 cluster_async::ClusterConnection::new [function] [call site] 02684
55 ClusterConnection::new_inner [function] [call site] 02685
55 RedisError::from [function] [call site] 02687
54 ClientTlsParams::clone [function] [call site] 02689
53 unwrap [function] [call site] 02690
53 RemoveHandler [function] [call site] 02691
52 ClusterClient::builder [function] [call site] 02692
52 ClusterClientBuilder::retries [function] [call site] 02693
52 respond_startup [function] [call site] 02694
53 is_connection_check [function] [call site] 02695
53 Value::SimpleString [function] [call site] 02698
53 &str::into [function] [call site] 02699
53 contains_slice [function] [call site] 02700
53 contains_slice [function] [call site] 02701
53 Value::Array [function] [call site] 02704
52 fetch_add [function] [call site] 02706
52 Err [function] [call site] 02707
52 parse_redis_value [function] [call site] 02708
52 Err [function] [call site] 02709
52 Ok [function] [call site] 02710
52 redis_value [function] [call site] 02711
52 cmd [function] [call site] 02712
52 Cmd::arg [function] [call site] 02713
52 arg("test").query::<Option<i32>> [function] [call site] 02714
51 TestClusterContext::get_ports [function] [call site] 02715
51 MockRedisConnection::check_connection [function] [call site] 02716
51 RedisServer::drop [function] [call site] 02717
51 RedisCluster::new [function] [call site] 02718
51 RedisServer::default [function] [call site] 02719
51 cmd [function] [call site] 02720
51 ClusterConnection::route_command [function] [call site] 02721
51 RoutingInfo::MultiNode [function] [call site] 02722
51 Some [function] [call site] 02723
51 RedisResult::unwrap [function] [call site] 02724
50 redis::ConnectionInfo::redis_settings [function] [call site] 02725
50 resize_with [function] [call site] 02726
50 basic::test_pipeline_len [function] [call site] 02727
51 redis::pipe [function] [call site] 02728
51 types::test_is_single_arg [function] [call site] 02731
50 resize_with [function] [call site] 02732
50 basic::test_pipeline_len [function] [call site] 02733
50 Ok [function] [call site] 02734
50 random_replica_index [function] [call site] 02735
51 rand::rng [function] [call site] 02736
51 random_range [function] [call site] 02737
51 NonZeroUsize::into [function] [call site] 02738
50 RedisServer::new [function] [call site] 02739
50 RedisServer::unwrap [function] [call site] 02740
50 resize_with [function] [call site] 02741
50 basic::test_pipeline_len [function] [call site] 02742
50 Ok [function] [call site] 02743
50 random_replica_index [function] [call site] 02744
50 RedisServer::new [function] [call site] 02745
50 RedisServer::unwrap [function] [call site] 02746
50 Ok [function] [call site] 02747
50 random_replica_index [function] [call site] 02748
50 RedisServer::new [function] [call site] 02749
50 RedisServer::unwrap [function] [call site] 02750
50 Ok [function] [call site] 02751
50 random_replica_index [function] [call site] 02752
50 RedisServer::new [function] [call site] 02753
50 RedisServer::unwrap [function] [call site] 02754
48 ClientTlsParams::clone [function] [call site] 02755
48 &redis::sentinel::Sentinel::unwrap [function] [call site] 02756
48 TestSentinelContext::wait_for_cluster_up [function] [call site] 02757
49 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02758
49 TestSentinelContext::sentinel_mut [function] [call site] 02759
49 redis_test::sentinel::wait_for_master_server [function] [call site] 02760
50 redis::cmd [function] [call site] 02761
50 Client::get_connection [function] [call site] 02762
50 redis::Cmd::query [function] [call site] 02763
50 RedisResult::unwrap [function] [call site] 02764
50 String::from_redis_value_ref [function] [call site] 02765
50 Replicas::first [function] [call site] 02766
50 &'a [call site] 02767
50 Result::unwrap [function] [call site] 02768
50 starts_with [function] [call site] 02769
50 std::thread::sleep [function] [call site] 02771
50 Duration::from_millis [function] [call site] 02772
49 &mut [call site] 02774
50 Sentinel::find_master_address [function] [call site] 02775
51 Sentinel::get_sentinel_masters [function] [call site] 02776
52 Sentinel::try_all_sentinels [function] [call site] 02777
53 basic::test_tuple_decoding_from_iter [function] [call site] 02778
53 iter_mut [function] [call site] 02780
53 try_single_sentinel [function] [call site] 02781
54 &mut [call site] 02782
54 reconnect [function] [call site] 02783
55 Client::open [function] [call site] 02784
55 redis::ConnectionInfo::clone [function] [call site] 02785
55 Client::get_connection [function] [call site] 02786
55 CopyOptions::replace [function] [call site] 02787
54 Cmd::query [function] [call site] 02789
55 ConnectionLike::req_command [function] [call site] 02790
55 RedisResult::from_redis_value [function] [call site] 02792
55 Value::extract_error [function] [call site] 02793
54 &mut [call site] 02795
54 RedisError::is_unrecoverable_error [function] [call site] 02797
54 types::test_is_io_error [function] [call site] 02798
54 reconnect [function] [call site] 02799
54 Cmd::query [function] [call site] 02800
54 &mut [call site] 02801
53 ClientTlsParams::clone [function] [call site] 02804
53 None::expect [function] [call site] 02808
52 sentinel_masters_cmd [function] [call site] 02809
51 find_valid_master [function] [call site] 02810
52 valid_addrs [function] [call site] 02811
52 is_master_valid [function] [call site] 02812
52 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02813
52 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02814
52 determine_master_from_role_or_info_replication [function] [call site] 02815
53 Client::open [function] [call site] 02816
53 redis::ConnectionInfo::clone [function] [call site] 02817
53 Client::get_connection [function] [call site] 02818
53 check_role [function] [call site] 02819
54 crate::cmd [function] [call site] 02820
54 redis::Cmd::query [function] [call site] 02821
53 check_info_replication [function] [call site] 02823
54 crate::cmd [function] [call site] 02824
54 redis::Cmd::arg [function] [call site] 02825
54 basic::test_pipeline_reuse_query [function] [call site] 02826
55 TestContext::new [function] [call site] 02827
55 TestContext::connection [function] [call site] 02828
55 redis::pipe [function] [call site] 02829
55 types::test_is_single_arg [function] [call site] 02831
55 types::test_is_single_arg [function] [call site] 02832
55 types::test_is_single_arg [function] [call site] 02835
55 basic::test_pipeline_reuse_query [function] [call site] 02836
56 TestContext::new [function] [call site] 02837
56 TestContext::connection [function] [call site] 02838
56 redis::pipe [function] [call site] 02839
56 types::test_is_single_arg [function] [call site] 02841
56 types::test_is_single_arg [function] [call site] 02842
56 types::test_is_single_arg [function] [call site] 02845
56 basic::test_pipeline_reuse_query [function] [call site] 02846
56 redis::cmd [function] [call site] 02848
56 redis::Cmd::arg [function] [call site] 02849
56 Cmd::exec [function] [call site] 02850
57 query::<()> [function] [call site] 02851
56 RedisResult::unwrap [function] [call site] 02852
56 types::test_is_single_arg [function] [call site] 02854
56 types::test_is_single_arg [function] [call site] 02855
56 types::test_is_single_arg [function] [call site] 02858
56 types::test_is_single_arg [function] [call site] 02859
56 basic::test_pipeline_reuse_query [function] [call site] 02860
55 redis::cmd [function] [call site] 02863
55 redis::Cmd::arg [function] [call site] 02864
55 Cmd::exec [function] [call site] 02865
55 RedisResult::unwrap [function] [call site] 02866
55 types::test_is_single_arg [function] [call site] 02868
55 types::test_is_single_arg [function] [call site] 02869
55 types::test_is_single_arg [function] [call site] 02872
55 types::test_is_single_arg [function] [call site] 02873
55 basic::test_pipeline_reuse_query [function] [call site] 02874
54 parse_replication_info [function] [call site] 02876
54 HashMap::get [function] [call site] 02877
54 ClientTlsParams::clone [function] [call site] 02879
54 RedisError::from [function] [call site] 02881
53 evaluate_role_check_errors [function] [call site] 02883
53 RedisResult::unwrap_err [function] [call site] 02884
53 RedisResult::unwrap_err [function] [call site] 02885
50 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02887
50 Client::open [function] [call site] 02888
49 ConnectionAddr::is_err [function] [call site] 02890
49 redis_test::sentinel::wait_for_replica [function] [call site] 02891
50 redis::cmd [function] [call site] 02892
50 Client::get_connection [function] [call site] 02893
50 redis::Cmd::query [function] [call site] 02894
50 RedisResult::unwrap [function] [call site] 02895
50 String::from_redis_value_ref [function] [call site] 02896
50 Replicas::first [function] [call site] 02897
50 &'a [call site] 02898
50 Result::unwrap [function] [call site] 02899
50 String::from_redis_value_ref [function] [call site] 02900
50 ConnectionAddr::get [function] [call site] 02901
50 Result::unwrap [function] [call site] 02903
50 starts_with [function] [call site] 02904
50 std::thread::sleep [function] [call site] 02906
50 Duration::from_millis [function] [call site] 02907
49 &mut [call site] 02909
50 Sentinel::find_valid_replica_addresses [function] [call site] 02910
51 Sentinel::get_sentinel_replicas [function] [call site] 02911
52 Sentinel::try_all_sentinels [function] [call site] 02912
52 sentinel_replicas_cmd [function] [call site] 02913
51 get_valid_replicas_addresses [function] [call site] 02914
52 valid_addrs [function] [call site] 02915
52 tests::into_redis_value_hashmap [function] [call site] 02916
52 SentinelNodeConnectionInfo::create_connection_info [function] [call site] 02917
52 map(|(ip, [call site] 02918
4 .collect::<RedisResult<Vec<ConnectionInfo>>> [function] [call site] 02919
52 &'a [call site] 02921
52 std::iter::Chain::filter [function] [call site] 02922
52 get_node_role [function] [call site] 02923
53 Client::open [function] [call site] 02924
53 redis::ConnectionInfo::clone [function] [call site] 02925
53 Client::get_connection [function] [call site] 02926
53 crate::cmd [function] [call site] 02927
53 redis::Cmd::query [function] [call site] 02928
52 RedisResult::is_ok_and [function] [call site] 02929
50 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 02931
50 RedisServer::new [function] [call site] 02932
50 basic::test_pipeline_len [function] [call site] 02933
50 tests::into_redis_value_hashmap [function] [call site] 02934
50 try_connect_to_first_replica [function] [call site] 02935
49 Some [function] [call site] 02936
49 ConnectionAddr::is_err [function] [call site] 02937
46 SentinelClient::build [function] [call site] 02938
46 TestSentinelContext::sentinels_connection_info [function] [call site] 02939
46 ClientTlsParams::clone [function] [call site] 02940
46 String::from [function] [call site] 02941
46 Some [function] [call site] 02942
46 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02943
46 RedisResult::unwrap [function] [call site] 02944
46 SentinelClient::build [function] [call site] 02945
46 TestSentinelContext::sentinels_connection_info [function] [call site] 02946
46 ClientTlsParams::clone [function] [call site] 02947
46 String::from [function] [call site] 02948
46 Some [function] [call site] 02949
46 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02950
46 RedisResult::unwrap [function] [call site] 02951
46 AsyncConnectionConfig::new [function] [call site] 02952
46 AsyncConnectionConfig::set_connection_timeout [function] [call site] 02953
46 Some [function] [call site] 02954
46 Duration::from_secs [function] [call site] 02955
46 SentinelClient::get_async_connection_with_config [function] [call site] 02956
46 unwrap [function] [call site] 02957
46 async_tests::async_assert_is_connection_to_master [function] [call site] 02958
46 TestSentinelContext::sentinel_node_connection_info [function] [call site] 02959
46 TestSentinelContext::sentinel_mut [function] [call site] 02960
46 &redis::sentinel::Sentinel::async_master_for [function] [call site] 02961
46 Some [function] [call site] 02962
46 unwrap [function] [call site] 02963
46 SentinelClient::get_async_connection_with_config [function] [call site] 02964
46 unwrap [function] [call site] 02965
46 async_tests::async_assert_connection_is_replica_of_correct_master [function] [call site] 02966
45 Err [function] [call site] 02967
45 Some [function] [call site] 02968
45 into [function] [call site] 02969
45 map_err [function] [call site] 02970
45 unwrap_or_else [function] [call site] 02971
44 unwrap [function] [call site] 02972
43 std::sync::Mutex::new [function] [call site] 02973
43 RedisServer::new [function] [call site] 02974
43 RedisServer::default [function] [call site] 02975
44 RedisServer::new [function] [call site] 02976
43 RedisServer::new [function] [call site] 02977
42 CacheManager::clone_and_increase_epoch [function] [call site] 02978
43 ClientTlsParams::clone [function] [call site] 02979
43 CacheManager::clone_and_increase_epoch [function] [call site] 02980
44 ClientTlsParams::clone [function] [call site] 02981
44 CacheManager::clone_and_increase_epoch [function] [call site] 02982
41 Self::as_ref [function] [call site] 02983
41 AsyncConnectionConfig::set_cache_manager [function] [call site] 02984
42 Cache::Manager [function] [call site] 02986
41 ClientTlsParams::clone [function] [call site] 02987
41 Some [function] [call site] 02988
41 Msg::get_channel [function] [call site] 02989
41 HandleContainer::new [function] [call site] 02990
41 tokio::runtime::Runtime::spawn [function] [call site] 02991
41 ConnectionManager::check_for_disconnect_pushes [function] [call site] 02992
42 Pipeline::send_recv [function] [call site] 02993
42 Self::reconnect [function] [call site] 02995
43 Client::open [function] [call site] 02996
43 redis::ConnectionInfo::clone [function] [call site] 02997
43 Client::get_multiplexed_async_connection [function] [call site] 02998
43 CopyOptions::replace [function] [call site] 02999
42 Arc::downgrade [function] [call site] 03001
42 script::test_script_load [function] [call site] 03002
43 TestContext::new [function] [call site] 03003
43 TestContext::connection [function] [call site] 03004
43 redis::Script::new [function] [call site] 03005
44 RedisServer::new [function] [call site] 03006
45 RedisServer::with_modules [function] [call site] 03007
44 SortedSetAddOptions::add_or_update [function] [call site] 03008
45 RedisServer::default [function] [call site] 03009
44 Option::as_bytes [function] [call site] 03010
44 ValueComparison::arg_to_string [function] [call site] 03011
45 impl [call site] 03012
45 String::from_utf8_lossy [function] [call site] 03013
45 into_owned [function] [call site] 03014
44 calculate_value_digest [function] [call site] 03015
45 impl [call site] 03016
45 RedisServer::new [function] [call site] 03017
45 RedisServer::extend_from_slice [function] [call site] 03018
44 ValueComparison::arg_to_string [function] [call site] 03020
45 impl [call site] 03021
45 String::from_utf8_lossy [function] [call site] 03022
45 into_owned [function] [call site] 03023
43 script::test_script_load [function] [call site] 03024
42 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 03026
41 ClientTlsParams::clone [function] [call site] 03027
41 check_resp3 [function] [call site] 03028
42 supports_resp3 [function] [call site] 03029
42 RedisError::from [function] [call site] 03031
41 tokio::sync::mpsc::unbounded_channel [function] [call site] 03032
41 Some [function] [call site] 03033
41 Some [function] [call site] 03034
41 AsyncConnectionConfig::set_push_sender_internal [function] [call site] 03035
41 RedisServer::new [function] [call site] 03037
41 ProtocolVersion::supports_resp3 [function] [call site] 03038
41 tokio::sync::mpsc::unbounded_channel [function] [call site] 03039
41 Some [function] [call site] 03040
41 AsyncConnectionConfig::set_push_sender_internal [function] [call site] 03041
41 RedisServer::new [function] [call site] 03042
41 Some [function] [call site] 03043
41 RedisServer::new [function] [call site] 03044
41 RedisServer::default [function] [call site] 03045
41 ClientTlsParams::clone [function] [call site] 03046
41 ClientTlsParams::clone [function] [call site] 03047
41 cluster_async::test_async_cluster_ask_save_new_connection [function] [call site] 03048
42 RedisServer::new [function] [call site] 03049
42 RedisServer::new [function] [call site] 03050
43 RedisServer::with_modules [function] [call site] 03051
42 ClientTlsParams::clone [function] [call site] 03052
42 MockEnv::with_client_builder [function] [call site] 03053
42 ClusterClient::builder [function] [call site] 03054
42 respond_startup_two_nodes [function] [call site] 03055
43 respond_startup_with_replica_using_config [function] [call site] 03056
42 parse_redis_value [function] [call site] 03059
42 is_connection_check [function] [call site] 03060
42 Self::fetch_add [function] [call site] 03061
42 respond_startup_two_nodes [function] [call site] 03062
42 tokio::runtime::Runtime::block_on [function] [call site] 03065
42 Cmd::arg [function] [call site] 03067
42 arg("test").query_async::<Value> [function] [call site] 03068
41 types::test_parse_boxed [function] [call site] 03070
42 ValueComparison::arg_to_string [function] [call site] 03071
42 parse_redis_value [function] [call site] 03072
42 Value::SimpleString [function] [call site] 03073
42 ClientTlsParams::clone [function] [call site] 03074
41 shared [function] [call site] 03075
41 Self [function] [call site] 03076
41 RedisServer::new [function] [call site] 03077
41 ArcSwap::from_pointee [function] [call site] 03078
41 t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send [function] [call site] 03079
41 Arc::downgrade [function] [call site] 03080
41 map_err [function] [call site] 03081
41 crate::RedisError::from [function] [call site] 03082
42 io::Error::from [function] [call site] 03083
42 Self::into [function] [call site] 03084
41 Ok [function] [call site] 03085
40 ClientTlsParams::clone [function] [call site] 03086
41 ClientTlsParams::clone [function] [call site] 03087
41 secret_pkcs1_der [function] [call site] 03089
41 write_command_to_vec [function] [call site] 03090
41 secret_pkcs8_der [function] [call site] 03093
41 write_command_to_vec [function] [call site] 03094
41 secret_sec1_der [function] [call site] 03097
41 write_command_to_vec [function] [call site] 03098
39 unwrap [function] [call site] 03100
39 tests::into_redis_value_hashset [function] [call site] 03101
39 unwrap [function] [call site] 03102
39 MockConnection::send_packed_command [function] [call site] 03103
39 cmd [function] [call site] 03104
39 Cmd::arg [function] [call site] 03105
39 types::test_is_single_arg [function] [call site] 03106
39 unwrap [function] [call site] 03107
39 cache_mget [function] [call site] 03108
39 unwrap [function] [call site] 03109
39 tests::into_redis_value_hashset [function] [call site] 03110
39 unwrap [function] [call site] 03111
39 Pipeline::send_recv [function] [call site] 03112
39 unwrap [function] [call site] 03113
38 Some [function] [call site] 03114
38 Cmd::arg_idx [function] [call site] 03115
38 get_route [function] [call site] 03116
39 get_slot [function] [call site] 03117
40 get_hashtag [function] [call site] 03118
41 basic::test_tuple_decoding_from_iter [function] [call site] 03119
41 Cmd::position [function] [call site] 03120
42 Cmd::args_iter [function] [call site] 03121
42 Cmd::position [function] [call site] 03122
43 Cmd::args_iter [function] [call site] 03123
43 Cmd::position [function] [call site] 03124
43 ServerType::eq_ignore_ascii_case [function] [call site] 03125
42 ServerType::eq_ignore_ascii_case [function] [call site] 03126
41 basic::test_tuple_decoding_from_iter [function] [call site] 03127
41 Cmd::position [function] [call site] 03128
41 MockRedisConnection::is_empty [function] [call site] 03129
41 then_some [function] [call site] 03130
40 slot [function] [call site] 03131
41 crc16::State::<crc16::XMODEM>::calculate [function] [call site] 03132
39 Route::new [function] [call site] 03135
38 tests::redis_array_single_entry [function] [call site] 03136
39 redis_value [function] [call site] 03137
39 Value::Array [function] [call site] 03138
38 or_insert [function] [call site] 03139
38 RedisServer::new [function] [call site] 03140
38 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 03141
38 incr_add_next_arg [function] [call site] 03142
38 Cmd::arg_idx [function] [call site] 03143
38 Option::is_none [function] [call site] 03144
38 RedisServer::iter_mut [function] [call site] 03145
38 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 03146
38 incr_add_next_arg [function] [call site] 03147
38 incr_add_next_arg [function] [call site] 03148
38 &'a [call site] 03149
38 std::iter::Chain::collect [function] [call site] 03150
38 MockRedisConnection::is_empty [function] [call site] 03151
38 Some [function] [call site] 03152
38 basic::test_pipeline_len [function] [call site] 03153
38 RoutingInfo::SingleNode [function] [call site] 03154
38 SingleNodeRoutingInfo::SpecificNode [function] [call site] 03155
38 RedisServer::pop [function] [call site] 03156
38 unwrap [function] [call site] 03157
38 RoutingInfo::MultiNode [function] [call site] 03158
38 MultipleNodeRoutingInfo::MultiSlot [function] [call site] 03159
38 ResponsePolicy::for_command [function] [call site] 03160
37 Some [function] [call site] 03161
37 RoutingInfo::SingleNode [function] [call site] 03162
37 Cmd::arg_idx [function] [call site] 03163
38 Cmd::arg_idx [function] [call site] 03164
37 Option::and_then [function] [call site] 03165
37 std::str::from_utf8 [function] [call site] 03166
37 tests::redis_ok [function] [call site] 03167
37 and_then [function] [call site] 03168
37 parse::<u64> [function] [call site] 03169
37 tests::redis_ok [function] [call site] 03170
37 Some [function] [call site] 03171
37 RoutingInfo::SingleNode [function] [call site] 03172
37 Cmd::arg_idx [function] [call site] 03173
37 tests::into_redis_value_hashmap [function] [call site] 03174
37 RoutingInfo::for_key [function] [call site] 03175
38 RoutingInfo::SingleNode [function] [call site] 03176
38 SingleNodeRoutingInfo::SpecificNode [function] [call site] 03177
38 get_route [function] [call site] 03178
38 commands::is_readonly_cmd [function] [call site] 03179
37 Cmd::arg_idx [function] [call site] 03180
37 tests::into_redis_value_hashmap [function] [call site] 03181
37 RoutingInfo::for_key [function] [call site] 03182
37 Cmd::arg_idx [function] [call site] 03183
37 Option::and_then [function] [call site] 03184
37 std::str::from_utf8 [function] [call site] 03185
37 tests::redis_ok [function] [call site] 03186
37 and_then [function] [call site] 03187
37 parse::<u64> [function] [call site] 03188
37 tests::redis_ok [function] [call site] 03189
37 Some [function] [call site] 03190
37 RoutingInfo::SingleNode [function] [call site] 03191
37 Cmd::arg_idx [function] [call site] 03192
37 tests::into_redis_value_hashmap [function] [call site] 03193
37 RoutingInfo::for_key [function] [call site] 03194
37 Cmd::position [function] [call site] 03195
38 Cmd::args_iter [function] [call site] 03196
38 Cmd::position [function] [call site] 03197
38 ServerType::eq_ignore_ascii_case [function] [call site] 03198
37 Cmd::arg_idx [function] [call site] 03199
37 tests::into_redis_value_hashmap [function] [call site] 03200
37 RoutingInfo::for_key [function] [call site] 03201
37 Cmd::arg_idx [function] [call site] 03202
37 Option::and_then [function] [call site] 03203
37 std::str::from_utf8 [function] [call site] 03204
37 tests::redis_ok [function] [call site] 03205
37 and_then [function] [call site] 03206
37 parse::<u16> [function] [call site] 03207
37 tests::redis_ok [function] [call site] 03208
37 tests::into_redis_value_hashmap [function] [call site] 03209
37 RoutingInfo::SingleNode [function] [call site] 03210
37 SingleNodeRoutingInfo::SpecificNode [function] [call site] 03211
37 Route::new [function] [call site] 03212
37 Cmd::arg_idx [function] [call site] 03213
37 Some [function] [call site] 03214
37 RoutingInfo::for_key [function] [call site] 03215
37 Some [function] [call site] 03216
37 RoutingInfo::SingleNode [function] [call site] 03217
36 std::collections::HashMap::new [function] [call site] 03218
37 RedisServer::with_modules [function] [call site] 03219
36 RedisServer::insert [function] [call site] 03220
36 Route [function] [call site] 03221
36 RedisServer::insert [function] [call site] 03222
36 Route [function] [call site] 03223
36 RedisServer::insert [function] [call site] 03224
36 Route [function] [call site] 03225
35 join [function] [call site] 03226
35 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03227
35 join [function] [call site] 03228
35 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03229
35 join [function] [call site] 03230
35 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03231
35 join [function] [call site] 03232
35 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03233
35 join [function] [call site] 03234
35 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03235
35 join [function] [call site] 03236
35 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] 03237
35 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] 03238
35 process::Command::new [function] [call site] 03239
35 types::test_is_single_arg [function] [call site] 03240
35 types::test_is_single_arg [function] [call site] 03241
35 types::test_is_single_arg [function] [call site] 03242
35 types::test_is_single_arg [function] [call site] 03243
35 types::test_is_single_arg [function] [call site] 03244
35 types::test_is_single_arg [function] [call site] 03245
35 types::test_is_single_arg [function] [call site] 03246
35 types::test_is_single_arg [function] [call site] 03247
35 types::test_is_single_arg [function] [call site] 03248
35 types::test_is_single_arg [function] [call site] 03249
35 types::test_is_single_arg [function] [call site] 03250
35 types::test_is_single_arg [function] [call site] 03251
35 types::test_is_single_arg [function] [call site] 03252
35 stdout [function] [call site] 03253
35 process::Stdio::piped [function] [call site] 03254
35 stderr [function] [call site] 03255
35 process::Stdio::piped [function] [call site] 03256
35 spawn [function] [call site] 03257
35 expect [function] [call site] 03258
35 ClusterClientBuilder::max_retry_wait [function] [call site] 03259
35 expect [function] [call site] 03260
35 Tokio::poll_write [function] [call site] 03261
35 Poll::expect [function] [call site] 03262
35 process::Command::new [function] [call site] 03263
35 types::test_is_single_arg [function] [call site] 03264
35 types::test_is_single_arg [function] [call site] 03265
35 types::test_is_single_arg [function] [call site] 03266
35 types::test_is_single_arg [function] [call site] 03267
35 types::test_is_single_arg [function] [call site] 03268
35 types::test_is_single_arg [function] [call site] 03269
35 types::test_is_single_arg [function] [call site] 03270
35 stdout [function] [call site] 03271
35 process::Stdio::piped [function] [call site] 03272
35 stderr [function] [call site] 03273
35 process::Stdio::piped [function] [call site] 03274
35 spawn [function] [call site] 03275
35 expect [function] [call site] 03276
35 process::Command::new [function] [call site] 03277
35 types::test_is_single_arg [function] [call site] 03278
35 types::test_is_single_arg [function] [call site] 03279
35 types::test_is_single_arg [function] [call site] 03280
35 types::test_is_single_arg [function] [call site] 03281
35 types::test_is_single_arg [function] [call site] 03282
35 types::test_is_single_arg [function] [call site] 03283
35 types::test_is_single_arg [function] [call site] 03284
35 types::test_is_single_arg [function] [call site] 03285
35 types::test_is_single_arg [function] [call site] 03286
35 types::test_is_single_arg [function] [call site] 03287
35 types::test_is_single_arg [function] [call site] 03288
35 types::test_is_single_arg [function] [call site] 03289
35 types::test_is_single_arg [function] [call site] 03290
35 types::test_is_single_arg [function] [call site] 03291
35 types::test_is_single_arg [function] [call site] 03292
35 types::test_is_single_arg [function] [call site] 03293
35 types::test_is_single_arg [function] [call site] 03294
35 types::test_is_single_arg [function] [call site] 03295
35 stdin [function] [call site] 03296
35 Cmd::take [function] [call site] 03297
35 expect [function] [call site] 03298
35 spawn [function] [call site] 03299
35 expect [function] [call site] 03300
35 ClusterClientBuilder::max_retry_wait [function] [call site] 03301
35 expect [function] [call site] 03302
35 ClusterClientBuilder::max_retry_wait [function] [call site] 03303
35 expect [function] [call site] 03304
34 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 03305
34 Some [function] [call site] 03306
34 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 03307
34 ClusterType::build_addr [function] [call site] 03308
35 ClusterType::get_intended [function] [call site] 03309
35 redis::ConnectionAddr::Tcp [function] [call site] 03310
35 &str::into [function] [call site] 03311
35 &str::into [function] [call site] 03312
34 ClientTlsParams::clone [function] [call site] 03313
35 ClientTlsParams::clone [function] [call site] 03314
35 secret_pkcs1_der [function] [call site] 03316
35 write_command_to_vec [function] [call site] 03317
35 secret_pkcs8_der [function] [call site] 03320
35 write_command_to_vec [function] [call site] 03321
35 secret_sec1_der [function] [call site] 03324
35 write_command_to_vec [function] [call site] 03325
34 tempfile::Builder::new [function] [call site] 03327
34 RedisResult::prefix [function] [call site] 03328
34 tempdir [function] [call site] 03329
34 expect [function] [call site] 03330
34 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03331
35 Cmd::arg [function] [call site] 03333
35 types::test_is_single_arg [function] [call site] 03334
35 types::test_is_single_arg [function] [call site] 03335
35 types::test_is_single_arg [function] [call site] 03336
35 types::test_is_single_arg [function] [call site] 03337
35 RoutingInfo::for_routable [function] [call site] 03338
35 std::collections::HashMap::new [function] [call site] 03339
35 RedisServer::insert [function] [call site] 03340
35 RedisServer::insert [function] [call site] 03342
35 RedisServer::insert [function] [call site] 03344
34 join [function] [call site] 03346
34 std::fs::write [function] [call site] 03347
35 RedisServer::new [function] [call site] 03348
35 Tokio::poll_write [function] [call site] 03349
35 RedisServer::new [function] [call site] 03350
35 Tokio::poll_write [function] [call site] 03351
35 RedisServer::new [function] [call site] 03352
35 Tokio::poll_write [function] [call site] 03353
34 Poll::expect [function] [call site] 03354
34 Cmd::arg [function] [call site] 03355
34 types::test_is_single_arg [function] [call site] 03356
34 types::test_is_single_arg [function] [call site] 03357
34 types::test_is_single_arg [function] [call site] 03358
34 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03359
34 join [function] [call site] 03360
34 types::test_is_single_arg [function] [call site] 03361
34 types::test_is_single_arg [function] [call site] 03362
34 types::test_is_single_arg [function] [call site] 03363
34 types::test_is_single_arg [function] [call site] 03364
34 Cmd::arg [function] [call site] 03365
34 types::test_is_single_arg [function] [call site] 03366
34 Cmd::arg [function] [call site] 03367
34 types::test_is_single_arg [function] [call site] 03368
34 Cmd::current_dir [function] [call site] 03369
34 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03370
34 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 03371
34 Cmd::spawn [function] [call site] 03372
34 unwrap [function] [call site] 03373
34 ClusterClientBuilder::max_retry_wait [function] [call site] 03374
34 RedisServer::log_file_contents [function] [call site] 03375
35 std::fs::read_to_string [function] [call site] 03376
35 ClientTlsParams::clone [function] [call site] 03377
35 tests::redis_ok [function] [call site] 03378
34 Err [function] [call site] 03379
34 RedisServer::log_file_contents [function] [call site] 03380
34 Err [function] [call site] 03381
34 port_in_use [function] [call site] 03382
35 ConnectionAddr::parse [function] [call site] 03383
35 socket2::Socket::new [function] [call site] 03385
36 RedisServer::with_modules [function] [call site] 03386
35 socket2::Domain::for_address [function] [call site] 03387
35 RedisServer::expect [function] [call site] 03388
35 tests::redis_ok [function] [call site] 03391
34 ValueComparison::arg_to_string [function] [call site] 03392
34 Ok [function] [call site] 03393
34 std::thread::sleep [function] [call site] 03394
34 Duration::from_millis [function] [call site] 03395
34 &'a [call site] 03396
34 tests::into_redis_value_hashmap [function] [call site] 03397
34 get_random_available_port [function] [call site] 03398
34 RedisServer::contains [function] [call site] 03399
34 RedisServer::insert [function] [call site] 03400
34 make_server [function] [call site] 03401
34 std::thread::sleep [function] [call site] 03402
34 Duration::from_millis [function] [call site] 03403
34 verify_server [function] [call site] 03404
34 basic_async::lazy_connection_manager_with_resp3_push [function] [call site] 03405
34 ClientTlsParams::clone [function] [call site] 03406
34 collect [function] [call site] 03407
34 process::Command::new [function] [call site] 03408
34 Cmd::stdout [function] [call site] 03409
34 process::Stdio::piped [function] [call site] 03410
34 types::test_is_single_arg [function] [call site] 03411
34 types::test_is_single_arg [function] [call site] 03412
34 types::test_std_types_to_redis_args [function] [call site] 03413
34 Cmd::arg [function] [call site] 03414
34 types::test_is_single_arg [function] [call site] 03415
34 ValueComparison::arg_to_string [function] [call site] 03416
34 Cmd::arg [function] [call site] 03417
34 Cmd::arg [function] [call site] 03418
34 Cmd::arg [function] [call site] 03419
34 Cmd::arg [function] [call site] 03420
34 Cmd::arg [function] [call site] 03421
34 Cmd::arg [function] [call site] 03422
34 Cmd::arg [function] [call site] 03423
34 Cmd::arg [function] [call site] 03424
34 None::is_some [function] [call site] 03425
34 None::as_ref [function] [call site] 03426
34 unwrap [function] [call site] 03427
34 Cmd::arg [function] [call site] 03428
34 types::test_is_single_arg [function] [call site] 03429
34 types::test_is_single_arg [function] [call site] 03430
34 Cmd::arg [function] [call site] 03431
34 types::test_is_single_arg [function] [call site] 03432
34 Cmd::output [function] [call site] 03433
34 unwrap [function] [call site] 03434
34 test_get_replica_clients_success [function] [call site] 03435
35 TestSentinelContext::new [function] [call site] 03436
35 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03437
35 TestSentinelContext::sentinel_mut [function] [call site] 03438
35 &redis::sentinel::Sentinel::get_replica_clients [function] [call site] 03439
36 Sentinel::find_valid_replica_addresses [function] [call site] 03440
36 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 03441
36 build_replica_clients [function] [call site] 03442
37 MockRedisConnection::is_empty [function] [call site] 03443
37 basic::test_tuple_decoding_from_iter [function] [call site] 03445
37 tests::into_redis_value_hashmap [function] [call site] 03446
37 Client::open [function] [call site] 03447
37 ClientTlsParams::clone [function] [call site] 03448
35 RedisResult::unwrap [function] [call site] 03451
34 std::thread::sleep [function] [call site] 03452
34 Duration::from_millis [function] [call site] 03453
34 RedisCluster::wait_for_replicas [function] [call site] 03454
35 RedisServer::connection_info [function] [call site] 03455
36 RedisServer::client_addr [function] [call site] 03456
36 &redis::ConnectionAddr::clone [function] [call site] 03457
36 ConnectionInfo::into_connection_info [function] [call site] 03458
36 RedisResult::unwrap [function] [call site] 03459
36 ConnectionInfo::set_redis_settings [function] [call site] 03460
36 redis_settings [function] [call site] 03461
35 redis::Client::open [function] [call site] 03462
35 RedisServer::connection_info [function] [call site] 03463
35 RedisResult::unwrap [function] [call site] 03464
35 Client::get_connection [function] [call site] 03465
35 RedisResult::unwrap [function] [call site] 03466
35 redis::cmd [function] [call site] 03467
35 redis::Cmd::arg [function] [call site] 03468
35 basic::test_pipeline_reuse_query [function] [call site] 03469
35 RedisResult::from_redis_value [function] [call site] 03471
36 from_redis_value [function] [call site] 03475
36 tests::into_redis_value_hashmap [function] [call site] 03476
35 Result::unwrap [function] [call site] 03478
35 basic::test_tuple_decoding_from_iter [function] [call site] 03479
35 block_on_all [function] [call site] 03480
36 panic::set_hook [function] [call site] 03481
36 RedisServer::new [function] [call site] 03482
36 RadiusOptions::store [function] [call site] 03483
37 ToRedisArgs::to_redis_args [function] [call site] 03485
38 RedisServer::new [function] [call site] 03486
38 SetExpiry::write_redis_args [function] [call site] 03487
39 Vec::write_arg [function] [call site] 03488
39 Vec::write_arg [function] [call site] 03489
39 as_bytes [function] [call site] 03490
39 Vec::write_arg [function] [call site] 03491
39 Vec::write_arg [function] [call site] 03492
39 as_bytes [function] [call site] 03493
39 Vec::write_arg [function] [call site] 03494
39 Vec::write_arg [function] [call site] 03495
39 as_bytes [function] [call site] 03496
39 Vec::write_arg [function] [call site] 03497
39 Vec::write_arg [function] [call site] 03498
39 as_bytes [function] [call site] 03499
39 Vec::write_arg [function] [call site] 03500
36 futures_util::FutureExt::fuse [function] [call site] 03501
36 script::test_script_load [function] [call site] 03502
36 futures_time::task::sleep [function] [call site] 03503
37 tokio::time::sleep [function] [call site] 03504
37 smol::Timer::after [function] [call site] 03505
36 futures_time::time::Duration::from_millis [function] [call site] 03506
36 futures_util::FutureExt::fuse [function] [call site] 03507
36 block_on_all_using_tokio [function] [call site] 03508
37 redis::aio::prefer_tokio [function] [call site] 03509
38 set_runtime [function] [call site] 03510
39 tests::into_redis_value_hashset [function] [call site] 03511
39 RedisError::from [function] [call site] 03513
37 Result::unwrap [function] [call site] 03514
37 current_thread_runtime [function] [call site] 03515
38 tokio::runtime::Builder::new_current_thread [function] [call site] 03516
38 enable_io [function] [call site] 03517
38 enable_time [function] [call site] 03518
38 Sentinel::build [function] [call site] 03519
38 RedisResult::unwrap [function] [call site] 03520
37 tokio::runtime::Runtime::block_on [function] [call site] 03521
36 block_on_all_using_smol [function] [call site] 03522
37 redis::aio::prefer_smol [function] [call site] 03523
38 set_runtime [function] [call site] 03524
37 Result::unwrap [function] [call site] 03525
37 smol::block_on [function] [call site] 03526
36 panic::take_hook [function] [call site] 03527
35 basic::test_pipeline_len [function] [call site] 03530
36 redis::pipe [function] [call site] 03531
36 types::test_is_single_arg [function] [call site] 03534
35 std::thread::sleep [function] [call site] 03535
35 Duration::from_millis [function] [call site] 03536
34 wait_for_status_ok [function] [call site] 03537
35 RedisServer::log_file [function] [call site] 03538
36 tests_routing::test_multi_shard_keys_and_path [function] [call site] 03539
35 std::fs::read_to_string [function] [call site] 03541
35 Option::contains [function] [call site] 03543
35 std::thread::sleep [function] [call site] 03544
35 Duration::from_millis [function] [call site] 03545
33 RedisCluster::iter_servers [function] [call site] 03546
34 basic::test_tuple_decoding_from_iter [function] [call site] 03547
33 tests::into_redis_value_hashmap [function] [call site] 03548
33 collect [function] [call site] 03549
33 redis::cluster::ClusterClientBuilder::new [function] [call site] 03550
34 &'a [call site] 03551
34 std::iter::Chain::map [function] [call site] 03552
34 ConnectionInfo::into_connection_info [function] [call site] 03553
34 RedisServer::default [function] [call site] 03555
33 ClientTlsParams::clone [function] [call site] 03556
33 ClusterClientBuilder::use_protocol [function] [call site] 03557
33 redis_test::server::use_protocol [function] [call site] 03559
34 entra_id_tests::get_env_var [function] [call site] 03560
34 String::unwrap_or_default [function] [call site] 03561
33 ClusterType::get_intended [function] [call site] 03562
33 ClusterClientBuilder::certs [function] [call site] 03563
33 super::load_certs_from_file [function] [call site] 03567
34 MockRedisConnection::is_open [function] [call site] 03568
34 bool::expect [function] [call site] 03569
34 RedisServer::new [function] [call site] 03570
34 RedisServer::new [function] [call site] 03571
35 RedisServer::with_modules [function] [call site] 03572
34 RedisServer::read_to_end [function] [call site] 03573
34 MockRedisConnection::is_open [function] [call site] 03575
34 bool::expect [function] [call site] 03576
34 RedisServer::new [function] [call site] 03577
34 RedisServer::new [function] [call site] 03578
34 RedisServer::read_to_end [function] [call site] 03579
34 MockRedisConnection::is_open [function] [call site] 03581
34 bool::expect [function] [call site] 03582
34 RedisServer::new [function] [call site] 03583
34 RedisServer::new [function] [call site] 03584
34 RedisServer::read_to_end [function] [call site] 03585
33 initializer [function] [call site] 03589
33 Sentinel::build [function] [call site] 03590
33 RedisResult::unwrap [function] [call site] 03591
33 redis_test::server::use_protocol [function] [call site] 03592
32 RedisClusterConfiguration::default [function] [call site] 03593
31 cluster::test_cluster_retries [function] [call site] 03594
31 TestClusterContext::get_ports [function] [call site] 03595
31 MockRedisConnection::check_connection [function] [call site] 03596
31 RedisServer::drop [function] [call site] 03597
31 cmd [function] [call site] 03598
31 ClusterConnection::route_command [function] [call site] 03599
31 RoutingInfo::SingleNode [function] [call site] 03600
31 MockRedisConnection::req_packed_command [function] [call site] 03601
31 Cmd::get_packed_command [function] [call site] 03602
31 RedisCluster::new [function] [call site] 03603
31 RedisServer::default [function] [call site] 03604
31 ClusterConnection::route_command [function] [call site] 03605
31 RoutingInfo::SingleNode [function] [call site] 03606
31 RedisResult::unwrap [function] [call site] 03607
30 into [function] [call site] 03608
30 Arc::into_inner [function] [call site] 03609
30 unwrap [function] [call site] 03610
30 into_inner [function] [call site] 03611
30 crate::io::tcp::stream_with_settings [function] [call site] 03612
31 TcpSettings::set_nodelay [function] [call site] 03613
31 TcpStream::into [function] [call site] 03614
31 set_tcp_keepalive [function] [call site] 03615
31 set_tcp_user_timeout [function] [call site] 03616
30 try_into [function] [call site] 03620
29 ConnectionAddr::to_socket_addrs [function] [call site] 03621
29 connect_tcp_timeout [function] [call site] 03622
30 TcpStream::connect_timeout [function] [call site] 03623
30 io::tcp::stream_with_settings [function] [call site] 03624
31 TcpSettings::set_nodelay [function] [call site] 03625
31 TcpStream::into [function] [call site] 03626
31 set_tcp_keepalive [function] [call site] 03627
31 set_tcp_user_timeout [function] [call site] 03628
29 Some [function] [call site] 03632
29 Some [function] [call site] 03633
29 fail [function] [call site] 03634
29 fail [function] [call site] 03635
29 ActualConnection::Tcp [function] [call site] 03636
29 TlsConnector::builder [function] [call site] 03637
30 TestSentinelContext::new [function] [call site] 03638
30 TestSentinelContext::sentinels_connection_info [function] [call site] 03639
30 Client::open [function] [call site] 03640
30 &redis::sentinel::Sentinel::clone [function] [call site] 03641
31 ClientTlsParams::clone [function] [call site] 03642
31 secret_pkcs1_der [function] [call site] 03644
31 write_command_to_vec [function] [call site] 03645
31 secret_pkcs8_der [function] [call site] 03648
31 write_command_to_vec [function] [call site] 03649
31 secret_sec1_der [function] [call site] 03652
31 write_command_to_vec [function] [call site] 03653
30 RedisResult::unwrap [function] [call site] 03655
30 Client::get_connection [function] [call site] 03656
30 redis::cmd [function] [call site] 03658
30 redis::Cmd::query [function] [call site] 03659
30 RedisResult::unwrap [function] [call site] 03660
30 SentinelClientBuilder::new [function] [call site] 03661
31 &'a [call site] 03663
31 into_iter().collect::<Vec<_>> [function] [call site] 03664
31 impl [call site] 03665
31 TcpSettings::default [function] [call site] 03667
31 TcpSettings::default [function] [call site] 03668
30 basic::test_tuple_decoding_from_iter [function] [call site] 03669
30 tests::into_redis_value_hashmap [function] [call site] 03670
30 &redis::sentinel::Sentinel::addr [function] [call site] 03671
31 ServerType::get_intended [function] [call site] 03672
31 ValueComparison::arg_to_string [function] [call site] 03673
31 redis::ConnectionAddr::Tcp [function] [call site] 03674
31 ValueComparison::arg_to_string [function] [call site] 03675
31 rand::random::<(u64, [call site] 03676
31 redis::ConnectionAddr::Unix [function] [call site] 03677
31 ValueType::from [function] [call site] 03678
30 ClientTlsParams::clone [function] [call site] 03679
30 String::from [function] [call site] 03680
30 RedisResult::unwrap [function] [call site] 03681
30 SentinelClientBuilder::new [function] [call site] 03682
30 basic::test_tuple_decoding_from_iter [function] [call site] 03683
30 tests::into_redis_value_hashmap [function] [call site] 03684
30 &redis::sentinel::Sentinel::addr [function] [call site] 03685
30 ClientTlsParams::clone [function] [call site] 03686
30 String::from [function] [call site] 03687
30 RedisResult::unwrap [function] [call site] 03688
30 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 03689
30 redis_test::server::use_protocol [function] [call site] 03691
30 TestSentinelContext::tls_mode [function] [call site] 03692
30 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03693
30 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03695
30 Sentinel::build [function] [call site] 03696
30 Sentinel::build [function] [call site] 03698
30 Client::get_connection [function] [call site] 03700
30 redis::cmd [function] [call site] 03702
30 redis::Cmd::query [function] [call site] 03703
30 RedisResult::unwrap [function] [call site] 03704
30 assert_is_connection_to_master [function] [call site] 03705
31 redis::cmd [function] [call site] 03706
31 redis::Cmd::arg [function] [call site] 03707
31 basic::test_pipeline_reuse_query [function] [call site] 03708
31 assert_is_master_role [function] [call site] 03710
30 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03711
30 TestSentinelContext::sentinel_mut [function] [call site] 03712
30 &redis::sentinel::Sentinel::master_for [function] [call site] 03713
31 Sentinel::find_master_address [function] [call site] 03714
31 SentinelNodeConnectionInfo::unwrap_or_default [function] [call site] 03715
31 Client::open [function] [call site] 03716
30 RedisResult::unwrap [function] [call site] 03718
30 Client::get_connection [function] [call site] 03719
30 redis::cmd [function] [call site] 03721
30 redis::Cmd::query [function] [call site] 03722
30 RedisResult::unwrap [function] [call site] 03723
30 assert_connection_is_replica_of_correct_master [function] [call site] 03724
31 redis::cmd [function] [call site] 03725
31 redis::Cmd::arg [function] [call site] 03726
31 basic::test_pipeline_reuse_query [function] [call site] 03727
31 assert_replica_role_and_master_addr [function] [call site] 03729
31 Client::get_connection_info [function] [call site] 03730
29 danger_accept_invalid_certs [function] [call site] 03731
29 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03732
30 ClusterType::get_intended [function] [call site] 03733
30 TestClusterContext::new_with_config_and_builder [function] [call site] 03734
31 support::start_tls_crypto_provider [function] [call site] 03735
31 RedisCluster::new [function] [call site] 03736
31 RedisCluster::iter_servers [function] [call site] 03737
31 tests::into_redis_value_hashmap [function] [call site] 03738
31 redis::cluster::ClusterClientBuilder::new [function] [call site] 03740
31 ClientTlsParams::clone [function] [call site] 03741
31 ClusterClientBuilder::use_protocol [function] [call site] 03742
31 redis_test::server::use_protocol [function] [call site] 03743
31 ClusterType::get_intended [function] [call site] 03744
31 ClusterClientBuilder::certs [function] [call site] 03745
31 super::load_certs_from_file [function] [call site] 03746
31 initializer [function] [call site] 03747
31 Sentinel::build [function] [call site] 03748
31 RedisResult::unwrap [function] [call site] 03749
31 redis_test::server::use_protocol [function] [call site] 03750
30 RedisServer::default [function] [call site] 03751
30 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03752
30 cluster::smoke_test_connection [function] [call site] 03753
31 redis::cmd [function] [call site] 03754
31 redis::Cmd::arg [function] [call site] 03755
31 types::test_is_single_arg [function] [call site] 03756
31 Cmd::exec [function] [call site] 03757
32 query::<()> [function] [call site] 03758
31 RedisResult::unwrap [function] [call site] 03759
31 redis::cmd [function] [call site] 03760
31 redis::Cmd::arg [function] [call site] 03761
31 Cmd::exec [function] [call site] 03762
31 RedisResult::unwrap [function] [call site] 03763
30 MockRedisConnection::check_connection [function] [call site] 03764
29 use_sni [function] [call site] 03765
29 Sentinel::build [function] [call site] 03766
29 TlsConnector::builder [function] [call site] 03767
29 cluster::test_danger_accept_invalid_hostnames [function] [call site] 03768
29 Sentinel::build [function] [call site] 03769
29 RedisServer::new [function] [call site] 03770
30 RedisServer::with_modules [function] [call site] 03771
29 &str::as_str [function] [call site] 03772
29 connect_tcp [function] [call site] 03773
29 connect [function] [call site] 03774
29 fail [function] [call site] 03775
29 &str::as_str [function] [call site] 03776
29 to_socket_addrs [function] [call site] 03777
29 connect_tcp_timeout [function] [call site] 03778
29 Some [function] [call site] 03779
29 Some [function] [call site] 03780
29 connect [function] [call site] 03781
29 unwrap [function] [call site] 03782
29 fail [function] [call site] 03783
29 fail [function] [call site] 03784
29 ActualConnection::TcpNativeTls [function] [call site] 03785
29 RedisServer::new [function] [call site] 03786
29 create_rustls_config [function] [call site] 03787
30 MockRedisConnection::is_empty [function] [call site] 03788
31 StreamReadOptions::block [function] [call site] 03789
31 MockRedisConnection::is_empty [function] [call site] 03791
30 bool::extend [function] [call site] 03792
30 basic::test_tuple_decoding_from_iter [function] [call site] 03793
30 rustls_native_certs::load_native_certs [function] [call site] 03795
30 test_module_json_arr_pop [function] [call site] 03796
31 TestContext::with_modules [function] [call site] 03797
31 TestContext::connection [function] [call site] 03798
31 redis::Connection::json_set [function] [call site] 03799
31 redis::Connection::json_arr_pop [function] [call site] 03800
31 redis::Connection::json_set [function] [call site] 03801
31 redis::Connection::json_arr_pop [function] [call site] 03802
30 bool::add [function] [call site] 03805
31 &mut [call site] 03806
31 &mut [call site] 03808
31 &mut [call site] 03810
31 &mut [call site] 03812
30 rustls::ClientConfig::builder [function] [call site] 03814
31 TestSentinelContext::new [function] [call site] 03815
31 TestSentinelContext::sentinels_connection_info [function] [call site] 03816
31 Client::open [function] [call site] 03817
31 &redis::sentinel::Sentinel::clone [function] [call site] 03818
31 RedisResult::unwrap [function] [call site] 03819
31 Client::get_connection [function] [call site] 03820
31 redis::cmd [function] [call site] 03822
31 redis::Cmd::query [function] [call site] 03823
31 RedisResult::unwrap [function] [call site] 03824
31 SentinelClientBuilder::new [function] [call site] 03825
31 basic::test_tuple_decoding_from_iter [function] [call site] 03826
31 tests::into_redis_value_hashmap [function] [call site] 03827
31 &redis::sentinel::Sentinel::addr [function] [call site] 03828
31 ClientTlsParams::clone [function] [call site] 03829
31 String::from [function] [call site] 03830
31 RedisResult::unwrap [function] [call site] 03831
31 SentinelClientBuilder::new [function] [call site] 03832
31 basic::test_tuple_decoding_from_iter [function] [call site] 03833
31 tests::into_redis_value_hashmap [function] [call site] 03834
31 &redis::sentinel::Sentinel::addr [function] [call site] 03835
31 ClientTlsParams::clone [function] [call site] 03836
31 String::from [function] [call site] 03837
31 RedisResult::unwrap [function] [call site] 03838
31 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 03839
31 redis_test::server::use_protocol [function] [call site] 03840
31 TestSentinelContext::tls_mode [function] [call site] 03841
31 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03842
31 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03843
31 Sentinel::build [function] [call site] 03844
31 Sentinel::build [function] [call site] 03846
31 Client::get_connection [function] [call site] 03848
31 redis::cmd [function] [call site] 03850
31 redis::Cmd::query [function] [call site] 03851
31 RedisResult::unwrap [function] [call site] 03852
31 assert_is_connection_to_master [function] [call site] 03853
31 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03854
31 TestSentinelContext::sentinel_mut [function] [call site] 03855
31 &redis::sentinel::Sentinel::master_for [function] [call site] 03856
31 RedisResult::unwrap [function] [call site] 03858
31 Client::get_connection [function] [call site] 03859
31 redis::cmd [function] [call site] 03861
31 redis::Cmd::query [function] [call site] 03862
31 RedisResult::unwrap [function] [call site] 03863
31 assert_connection_is_replica_of_correct_master [function] [call site] 03864
30 unwrap_or [function] [call site] 03865
30 Self::with_root_certificates [function] [call site] 03866
30 ClientTlsParams::clone [function] [call site] 03867
30 with_client_auth_cert [function] [call site] 03868
30 RedisError::from [function] [call site] 03870
30 ValueComparison::arg_to_string [function] [call site] 03871
30 with_no_client_auth [function] [call site] 03872
30 Self::dangerous [function] [call site] 03874
30 set_certificate_verifier [function] [call site] 03875
30 RedisServer::new [function] [call site] 03876
30 rustls::client::WebPkiServerVerifier::builder [function] [call site] 03877
31 TestSentinelContext::new [function] [call site] 03878
31 TestSentinelContext::sentinels_connection_info [function] [call site] 03879
31 Client::open [function] [call site] 03880
31 &redis::sentinel::Sentinel::clone [function] [call site] 03881
31 RedisResult::unwrap [function] [call site] 03882
31 Client::get_connection [function] [call site] 03883
31 redis::cmd [function] [call site] 03885
31 redis::Cmd::query [function] [call site] 03886
31 RedisResult::unwrap [function] [call site] 03887
31 SentinelClientBuilder::new [function] [call site] 03888
31 basic::test_tuple_decoding_from_iter [function] [call site] 03889
31 tests::into_redis_value_hashmap [function] [call site] 03890
31 &redis::sentinel::Sentinel::addr [function] [call site] 03891
31 ClientTlsParams::clone [function] [call site] 03892
31 String::from [function] [call site] 03893
31 RedisResult::unwrap [function] [call site] 03894
31 SentinelClientBuilder::new [function] [call site] 03895
31 basic::test_tuple_decoding_from_iter [function] [call site] 03896
31 tests::into_redis_value_hashmap [function] [call site] 03897
31 &redis::sentinel::Sentinel::addr [function] [call site] 03898
31 ClientTlsParams::clone [function] [call site] 03899
31 String::from [function] [call site] 03900
31 RedisResult::unwrap [function] [call site] 03901
31 SentinelClientBuilder::set_client_to_sentinel_protocol [function] [call site] 03902
31 redis_test::server::use_protocol [function] [call site] 03903
31 TestSentinelContext::tls_mode [function] [call site] 03904
31 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03905
31 SentinelClientBuilder::set_client_to_redis_tls_mode [function] [call site] 03906
31 Sentinel::build [function] [call site] 03907
31 Sentinel::build [function] [call site] 03909
31 Client::get_connection [function] [call site] 03911
31 redis::cmd [function] [call site] 03913
31 redis::Cmd::query [function] [call site] 03914
31 RedisResult::unwrap [function] [call site] 03915
31 assert_is_connection_to_master [function] [call site] 03916
31 TestSentinelContext::sentinel_node_connection_info [function] [call site] 03917
31 TestSentinelContext::sentinel_mut [function] [call site] 03918
31 &redis::sentinel::Sentinel::master_for [function] [call site] 03919
31 RedisResult::unwrap [function] [call site] 03921
31 Client::get_connection [function] [call site] 03922
31 redis::cmd [function] [call site] 03924
31 redis::Cmd::query [function] [call site] 03925
31 RedisResult::unwrap [function] [call site] 03926
31 assert_connection_is_replica_of_correct_master [function] [call site] 03927
30 RedisServer::new [function] [call site] 03928
30 Sentinel::build [function] [call site] 03929
30 RedisResult::map_err [function] [call site] 03930
30 rustls::Error::from [function] [call site] 03931
31 io::Error::from [function] [call site] 03932
31 Self::into [function] [call site] 03933
30 rustls::OtherError [function] [call site] 03934
30 RedisServer::new [function] [call site] 03935
30 Self::with_root_certificates [function] [call site] 03936
30 with_no_client_auth [function] [call site] 03937
30 rustls::crypto::CryptoProvider::get_default [function] [call site] 03938
30 RedisError::from [function] [call site] 03940
30 Self::dangerous [function] [call site] 03941
30 set_certificate_verifier [function] [call site] 03942
30 RedisServer::new [function] [call site] 03943
29 ClientTlsParams::clone [function] [call site] 03947
29 rustls::ClientConnection::new [function] [call site] 03948
30 RedisServer::with_modules [function] [call site] 03949
29 RedisServer::new [function] [call site] 03950
29 rustls::pki_types::ServerName::try_from [function] [call site] 03951
29 to_owned [function] [call site] 03954
29 connect_tcp [function] [call site] 03955
29 RedisServer::new [function] [call site] 03956
30 RedisServer::with_modules [function] [call site] 03957
29 to_socket_addrs [function] [call site] 03958
29 connect_tcp_timeout [function] [call site] 03959
29 Some [function] [call site] 03960
29 Some [function] [call site] 03961
29 RedisServer::new [function] [call site] 03962
29 fail [function] [call site] 03963
29 fail [function] [call site] 03964
29 ActualConnection::TcpRustls [function] [call site] 03965
29 RedisServer::new [function] [call site] 03966
29 fail [function] [call site] 03967
29 ActualConnection::Unix [function] [call site] 03968
29 cluster::test_cluster_reconnect_after_complete_server_disconnect [function] [call site] 03969
30 TestClusterContext::new_insecure_with_cluster_client_builder [function] [call site] 03970
30 cluster::test_cluster_retries [function] [call site] 03971
30 TestClusterContext::get_ports [function] [call site] 03972
30 MockRedisConnection::check_connection [function] [call site] 03973
30 RedisServer::drop [function] [call site] 03974
30 ClusterConnection::route_command [function] [call site] 03976
30 RoutingInfo::SingleNode [function] [call site] 03977
30 MockRedisConnection::req_packed_command [function] [call site] 03978
30 Cmd::get_packed_command [function] [call site] 03979
30 RedisCluster::new [function] [call site] 03980
30 RedisServer::default [function] [call site] 03981
30 ClusterConnection::route_command [function] [call site] 03982
30 RoutingInfo::SingleNode [function] [call site] 03983
30 RedisResult::unwrap [function] [call site] 03984
29 fail [function] [call site] 03985
28 and_then [function] [call site] 03986
28 checked_sub [function] [call site] 03987
28 elapsed [function] [call site] 03988
28 is_some [function] [call site] 03989
28 is_none [function] [call site] 03990
28 Err [function] [call site] 03991
28 RedisError::from [function] [call site] 03992
28 std::io::Error::new [function] [call site] 03993
29 RedisServer::with_modules [function] [call site] 03994
28 MockConnection::set_read_timeout [function] [call site] 03995
28 MockConnection::set_write_timeout [function] [call site] 03997
28 setup_connection [function] [call site] 03999
29 execute_connection_pipeline [function] [call site] 04000
29 connection_setup_pipeline [function] [call site] 04001
29 execute_connection_pipeline [function] [call site] 04002
29 connection_setup_pipeline [function] [call site] 04003
28 MockConnection::set_read_timeout [function] [call site] 04005
28 MockConnection::set_write_timeout [function] [call site] 04006
28 Ok [function] [call site] 04007
26 unwrap [function] [call site] 04008
25 ValueType::from [function] [call site] 04009
25 basic::test_tuple_decoding_from_iter [function] [call site] 04010
25 hscan::<_, [call site] 04011
25 unwrap [function] [call site] 04012
25 unwrap [function] [call site] 04013
23 into_iter().collect::<Vec<_>> [function] [call site] 04014
23 impl [call site] 04015
23 into [function] [call site] 04016
23 TcpSettings::default [function] [call site] 04017
23 TcpSettings::default [function] [call site] 04018
22 RedisResult::prefix [function] [call site] 04019
22 tempdir [function] [call site] 04020
22 expect [function] [call site] 04021
22 RedisServer::log_file [function] [call site] 04022
23 tests_routing::test_multi_shard_keys_and_path [function] [call site] 04023
22 types::test_is_single_arg [function] [call site] 04025
22 types::test_is_single_arg [function] [call site] 04026
22 ClientTlsParams::clone [function] [call site] 04027
23 ClientTlsParams::clone [function] [call site] 04028
23 secret_pkcs1_der [function] [call site] 04030
23 write_command_to_vec [function] [call site] 04031
23 secret_pkcs8_der [function] [call site] 04034
23 write_command_to_vec [function] [call site] 04035
23 secret_sec1_der [function] [call site] 04038
23 write_command_to_vec [function] [call site] 04039
22 get_major_version [function] [call site] 04041
23 String::from_utf8 [function] [call site] 04042
23 process::Command::new [function] [call site] 04043
23 types::test_is_single_arg [function] [call site] 04044
23 split_once [function] [call site] 04048
23 split_once [function] [call site] 04050
22 types::test_is_single_arg [function] [call site] 04054
22 types::test_is_single_arg [function] [call site] 04055
22 types::test_is_single_arg [function] [call site] 04056
22 types::test_is_single_arg [function] [call site] 04057
22 ValueComparison::arg_to_string [function] [call site] 04058
22 types::test_is_single_arg [function] [call site] 04059
22 types::test_is_single_arg [function] [call site] 04060
22 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04061
23 entra_id_tests::get_env_var [function] [call site] 04062
23 String::unwrap_or_else [function] [call site] 04063
23 ValueComparison::arg_to_string [function] [call site] 04064
23 process::Command::new [function] [call site] 04065
23 types::test_is_single_arg [function] [call site] 04066
23 types::test_is_single_arg [function] [call site] 04067
23 types::test_is_single_arg [function] [call site] 04068
23 entra_id_tests::get_env_var [function] [call site] 04069
23 entra_id_tests::get_env_var [function] [call site] 04070
23 types::test_is_single_arg [function] [call site] 04071
23 types::test_is_single_arg [function] [call site] 04072
23 RedisServer::stdout [function] [call site] 04073
23 process::Stdio::piped [function] [call site] 04074
23 process::Stdio::piped [function] [call site] 04076
23 tempfile::Builder::new [function] [call site] 04077
23 RedisResult::prefix [function] [call site] 04078
23 RedisServer::log_file [function] [call site] 04081
23 types::test_is_single_arg [function] [call site] 04082
23 types::test_is_single_arg [function] [call site] 04083
23 ClientTlsParams::clone [function] [call site] 04084
23 get_major_version [function] [call site] 04085
23 types::test_is_single_arg [function] [call site] 04086
23 types::test_is_single_arg [function] [call site] 04087
23 types::test_is_single_arg [function] [call site] 04088
23 types::test_is_single_arg [function] [call site] 04089
23 ValueComparison::arg_to_string [function] [call site] 04090
23 types::test_is_single_arg [function] [call site] 04091
23 types::test_is_single_arg [function] [call site] 04092
23 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04093
23 Option<TlsFilePaths>::unwrap_or_else [function] [call site] 04094
23 utils::build_keys_and_certs_for_tls [function] [call site] 04095
24 build_keys_and_certs_for_tls_ext [function] [call site] 04096
23 types::test_is_single_arg [function] [call site] 04097
23 types::test_is_single_arg [function] [call site] 04098
23 ValueComparison::arg_to_string [function] [call site] 04099
24 impl [call site] 04100
24 String::from_utf8_lossy [function] [call site] 04101
24 into_owned [function] [call site] 04102
23 types::test_is_single_arg [function] [call site] 04103
23 types::test_is_single_arg [function] [call site] 04104
23 types::test_is_single_arg [function] [call site] 04105
23 types::test_is_single_arg [function] [call site] 04106
23 types::test_is_single_arg [function] [call site] 04107
23 types::test_is_single_arg [function] [call site] 04108
23 types::test_is_single_arg [function] [call site] 04109
23 types::test_is_single_arg [function] [call site] 04110
23 types::test_is_single_arg [function] [call site] 04111
23 types::test_is_single_arg [function] [call site] 04112
23 types::test_is_single_arg [function] [call site] 04113
23 types::test_is_single_arg [function] [call site] 04114
23 ClientTlsParams::clone [function] [call site] 04115
23 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04116
23 types::test_is_single_arg [function] [call site] 04118
23 types::test_is_single_arg [function] [call site] 04119
23 types::test_is_single_arg [function] [call site] 04120
23 types::test_is_single_arg [function] [call site] 04121
23 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04122
22 Option<TlsFilePaths>::unwrap_or_else [function] [call site] 04123
22 utils::build_keys_and_certs_for_tls [function] [call site] 04124
22 types::test_is_single_arg [function] [call site] 04125
22 types::test_is_single_arg [function] [call site] 04126
22 ValueComparison::arg_to_string [function] [call site] 04127
22 types::test_is_single_arg [function] [call site] 04128
22 types::test_is_single_arg [function] [call site] 04129
22 types::test_is_single_arg [function] [call site] 04130
22 types::test_is_single_arg [function] [call site] 04131
22 types::test_is_single_arg [function] [call site] 04132
22 types::test_is_single_arg [function] [call site] 04133
22 types::test_is_single_arg [function] [call site] 04134
22 types::test_is_single_arg [function] [call site] 04135
22 types::test_is_single_arg [function] [call site] 04136
22 types::test_is_single_arg [function] [call site] 04137
22 types::test_is_single_arg [function] [call site] 04138
22 types::test_is_single_arg [function] [call site] 04139
22 ClientTlsParams::clone [function] [call site] 04140
22 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04141
22 Some [function] [call site] 04142
22 types::test_is_single_arg [function] [call site] 04143
22 types::test_is_single_arg [function] [call site] 04144
22 types::test_is_single_arg [function] [call site] 04145
22 types::test_is_single_arg [function] [call site] 04146
22 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04147
21 Cmd::spawn [function] [call site] 04148
21 unwrap_or_else [function] [call site] 04149
21 build_single_client [function] [call site] 04150
22 redis::Client::open [function] [call site] 04151
21 RedisServer::connection_info [function] [call site] 04152
21 RedisResult::unwrap [function] [call site] 04153
21 Duration::from_millis [function] [call site] 04154
21 Client::get_connection [function] [call site] 04155
21 RedisError::is_connection_refusal [function] [call site] 04156
22 RedisError::as_io_error [function] [call site] 04157
22 Option::is_some_and [function] [call site] 04158
22 get_push_kind [function] [call site] 04159
21 std::thread::sleep [function] [call site] 04160
21 flushdb::<()> [function] [call site] 04161
21 unwrap [function] [call site] 04162
21 redis_test::server::use_protocol [function] [call site] 04163
17 ProtocolVersion::supports_resp3 [function] [call site] 04164
17 tokio::sync::mpsc::unbounded_channel [function] [call site] 04165
17 redis::aio::ConnectionManagerConfig::new [function] [call site] 04166
17 AsyncConnectionConfig::set_push_sender [function] [call site] 04167
17 Client::get_connection_manager_lazy [function] [call site] 04168
17 unwrap [function] [call site] 04169
17 tests::into_redis_value_hashset [function] [call site] 04170
17 unwrap [function] [call site] 04171
17 MockConnection::send_packed_command [function] [call site] 04172
17 cmd [function] [call site] 04173
17 Cmd::arg [function] [call site] 04174
17 types::test_is_single_arg [function] [call site] 04175
17 unwrap [function] [call site] 04176
17 cache_mget [function] [call site] 04177
17 unwrap [function] [call site] 04178
17 tests::into_redis_value_hashset [function] [call site] 04179
17 unwrap [function] [call site] 04180
17 Pipeline::send_recv [function] [call site] 04181
17 unwrap [function] [call site] 04182
16 to_owned [function] [call site] 04183
15 Vec::write_arg [function] [call site] 04184
15 as_bytes [function] [call site] 04185
15 Vec::write_arg [function] [call site] 04186
15 Vec::write_arg [function] [call site] 04187
15 as_bytes [function] [call site] 04188
15 Vec::write_arg [function] [call site] 04189
15 Vec::write_arg [function] [call site] 04190
15 as_bytes [function] [call site] 04191
15 Vec::write_arg [function] [call site] 04192
15 Vec::write_arg [function] [call site] 04193
15 as_bytes [function] [call site] 04194
15 Vec::write_arg [function] [call site] 04195
12 cmd [function] [call site] 04196
12 types::test_is_single_arg [function] [call site] 04197
11 bulklen [function] [call site] 04198
12 countdigits [function] [call site] 04199
11 countdigits [function] [call site] 04200
11 basic::test_pipeline_len [function] [call site] 04201
10 ClientTlsParams::clone [function] [call site] 04202
10 Cmd::reserve [function] [call site] 04203
10 write_command [function] [call site] 04204
10 io::Result::unwrap [function] [call site] 04205
8 Value::into_map_iter [function] [call site] 04206
8 Result::expect [function] [call site] 04207
8 into_map_iter() [call site] 04208
6 .expect("extracting [call site] 04209
6 .collect::<Vec<(Value, [call site] 04210
6 ValueComparison::arg_to_string [function] [call site] 04213
6 redis::ConnectionAddr::Tcp [function] [call site] 04214
6 ValueComparison::arg_to_string [function] [call site] 04215
6 rand::random::<(u64, [call site] 04216
6 redis::ConnectionAddr::Unix [function] [call site] 04217
6 ValueType::from [function] [call site] 04218
5 RedisServer::new_with_addr_tls_modules_and_spawner [function] [call site] 04219
5 Cmd::spawn [function] [call site] 04220
5 unwrap_or_else [function] [call site] 04221
2 Parser::parse_value [function] [call site] 04222