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