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