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
3497 660 get_push_kind call site: 00660 cluster::test_cluster_reconnect_after_complete_server_disconnect
364 3 Parser::new call site: 00003 cluster::test_cluster_reconnect_after_complete_server_disconnect
289 369 parse_redis_value call site: 00369 Sentinel::async_master_for
1 0 EP call site: 00000

Fuzzer calltree

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