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
2582 1056 get_push_kind call site: 01056 cluster::test_cluster_reconnect_after_complete_server_disconnect
953 3 Parser::new call site: 00003 cluster::test_cluster_reconnect_after_complete_server_disconnect
618 3724 Cmd::position call site: 03724 port_in_use
96 958 parse_redis_value call site: 00958 RedisError::is_unrecoverable_error
77 3644 Cmd::position call site: 03644 basic_async::test_lazy_connection_manager_with_resp3_push
1 0 EP call site: 00000

Fuzzer calltree

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