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