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