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