The following nodes represent call sites where fuzz blockers occur.
| Amount of callsites blocked | Calltree index | Parent function | Callsite | Largest blocked function |
|---|---|---|---|---|
| 1601 | 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
ClusterConnection::new_inner
[function]
[call site]
02566
unwrap_or_default
[function]
[call site]
02567
ClientTlsParams::clone
[function]
[call site]
02568
Runtime::locate
[function]
[call site]
02569
ClusterConnInner::new
[function]
[call site]
02570
is_some
[function]
[call site]
02571
Some
[function]
[call site]
02572
RedisServer::new
[function]
[call site]
02573
RedisServer::with_modules
[function]
[call site]
02574
RedisServer::default
[function]
[call site]
02575
RedisServer::new
[function]
[call site]
02576
RedisServer::new
[function]
[call site]
02577
RedisServer::new
[function]
[call site]
02578
RedisServer::with_modules
[function]
[call site]
02579
RedisServer::default
[function]
[call site]
02580
SlotMap::new
[function]
[call site]
02581
RedisServer::default
[function]
[call site]
02582
RedisServer::new
[function]
[call site]
02583
RedisServer::new
[function]
[call site]
02584
write_command_to_vec
[function]
[call site]
02585
Core
[function]
[call site]
02586
ClientTlsParams::clone
[function]
[call site]
02587
ClientTlsParams::clone
[function]
[call site]
02588
Pkcs1
[function]
[call site]
02589
secret_pkcs1_der
[function]
[call site]
02590
write_command_to_vec
[function]
[call site]
02591
into
[function]
[call site]
02592
Pkcs8
[function]
[call site]
02593
secret_pkcs8_der
[function]
[call site]
02594
write_command_to_vec
[function]
[call site]
02595
into
[function]
[call site]
02596
Sec1
[function]
[call site]
02597
secret_sec1_der
[function]
[call site]
02598
write_command_to_vec
[function]
[call site]
02599
into
[function]
[call site]
02600
RedisServer::default
[function]
[call site]
02601
ConnectionState::Recover
[function]
[call site]
02602
RecoverFuture::Reconnect
[function]
[call site]
02603
Box::pin
[function]
[call site]
02604
ClusterConnInner::reconnect_to_initial_nodes
[function]
[call site]
02605
ClientTlsParams::clone
[function]
[call site]
02606
ClusterConnection::create_initial_connections
[function]
[call site]
02607
Cmd::with_capacity
[function]
[call site]
02608
Cmd::with_capacity
[function]
[call site]
02609
Cmd::with_capacity
[function]
[call site]
02610
basic::test_pipeline_len
[function]
[call site]
02611
RedisServer::new
[function]
[call site]
02612
basic::test_tuple_decoding_from_iter
[function]
[call site]
02613
to_string
[function]
[call site]
02614
into
[function]
[call site]
02615
ClusterConnection::connect
[function]
[call site]
02616
Client::get_connection_info
[function]
[call site]
02617
cluster::test_cluster_reconnect_after_complete_server_disconnect
[function]
[call site]
02618
TestClusterContext::new_insecure_with_cluster_client_builder
[function]
[call site]
02619
cluster::test_cluster_retries
[function]
[call site]
02620
TestClusterContext::get_ports
[function]
[call site]
02621
basic::test_tuple_decoding_from_iter
[function]
[call site]
02622
types::test_hashmap
[function]
[call site]
02623
redis::ConnectionInfo::addr
[function]
[call site]
02624
collect
[function]
[call site]
02625
MockRedisConnection::check_connection
[function]
[call site]
02626
RedisServer::drop
[function]
[call site]
02627
cmd
[function]
[call site]
02628
ClusterConnection::route_command
[function]
[call site]
02629
Msg::get_channel
[function]
[call site]
02630
t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send
[function]
[call site]
02631
RedisServer::new
[function]
[call site]
02632
RouteBy::into
[function]
[call site]
02633
map_err
[function]
[call site]
02634
RedisError::from
[function]
[call site]
02635
io::Error::new
[function]
[call site]
02636
RedisServer::with_modules
[function]
[call site]
02637
unwrap_or_else
[function]
[call site]
02638
Err
[function]
[call site]
02639
RedisError::from
[function]
[call site]
02640
io::Error::new
[function]
[call site]
02641
types::test_hashmap
[function]
[call site]
02642
async_tests::sentinel_client_async_with_connection_timeout
[function]
[call site]
02643
TestSentinelContext::new
[function]
[call site]
02644
SentinelClient::build
[function]
[call site]
02645
TestSentinelContext::sentinels_connection_info
[function]
[call site]
02646
ClientTlsParams::clone
[function]
[call site]
02647
String::from
[function]
[call site]
02648
Some
[function]
[call site]
02649
TestSentinelContext::sentinel_node_connection_info
[function]
[call site]
02650
RedisResult::unwrap
[function]
[call site]
02651
SentinelClient::build
[function]
[call site]
02652
TestSentinelContext::sentinels_connection_info
[function]
[call site]
02653
ClientTlsParams::clone
[function]
[call site]
02654
String::from
[function]
[call site]
02655
Some
[function]
[call site]
02656
TestSentinelContext::sentinel_node_connection_info
[function]
[call site]
02657
RedisResult::unwrap
[function]
[call site]
02658
AsyncConnectionConfig::new
[function]
[call site]
02659
AsyncConnectionConfig::set_connection_timeout
[function]
[call site]
02660
Some
[function]
[call site]
02661
Duration::from_secs
[function]
[call site]
02662
SentinelClient::get_async_connection_with_config
[function]
[call site]
02663
async_tests::async_assert_is_connection_to_master
[function]
[call site]
02664
TestSentinelContext::sentinel_node_connection_info
[function]
[call site]
02665
TestSentinelContext::sentinel_mut
[function]
[call site]
02666
&redis::sentinel::Sentinel::async_master_for
[function]
[call site]
02667
Some
[function]
[call site]
02668
SentinelClient::get_async_connection_with_config
[function]
[call site]
02669
async_tests::async_assert_connection_is_replica_of_correct_master
[function]
[call site]
02670
Ok::<(),
[call site]
02671
RoutingInfo::SingleNode
[function]
[call site]
02672
MockRedisConnection::req_packed_command
[function]
[call site]
02673
Cmd::get_packed_command
[function]
[call site]
02674
MockRedisConnection::req_packed_command
[function]
[call site]
02675
as_slice
[function]
[call site]
02676
PipelineSink::poll_ready
[function]
[call site]
02677
types::test_parse_boxed
[function]
[call site]
02678
Cmd::get_packed_command
[function]
[call site]
02679
RedisCluster::new
[function]
[call site]
02680
RedisServer::default
[function]
[call site]
02681
ClusterConnection::route_command
[function]
[call site]
02682
RoutingInfo::SingleNode
[function]
[call site]
02683
RedisResult::unwrap
[function]
[call site]
02684
Some
[function]
[call site]
02685
cmd::cmd
[function]
[call site]
02686
Cmd::exec
[function]
[call site]
02687
query::<()>
[function]
[call site]
02688
MockConnection::set_read_timeout
[function]
[call site]
02689
Ok
[function]
[call site]
02690
borrow
[function]
[call site]
02691
MockConnection::set_write_timeout
[function]
[call site]
02692
Ok
[function]
[call site]
02693
borrow
[function]
[call site]
02694
Ok
[function]
[call site]
02695
MockRedisConnection::check_connection
[function]
[call site]
02696
RedisResult::insert
[function]
[call site]
02697
TestContext::with_modules
[function]
[call site]
02698
TestContext::connection
[function]
[call site]
02699
redis::Connection::json_set
[function]
[call site]
02700
redis::Connection::json_arr_insert
[function]
[call site]
02701
redis::Connection::json_set
[function]
[call site]
02702
redis::Connection::json_arr_insert
[function]
[call site]
02703
cluster_async::get_push
[function]
[call site]
02704
Pipeline::send_recv
[function]
[call site]
02705
async_tests::sentinel_client_async_with_connection_timeout
[function]
[call site]
02706
futures_time::time::Duration::from_millis
[function]
[call site]
02707
unwrap
[function]
[call site]
02708
unwrap
[function]
[call site]
02709
RedisError::from
[function]
[call site]
02710
cluster_async::get_push
[function]
[call site]
02711
basic::test_pipeline_is_empty
[function]
[call site]
02712
basic::test_pipeline_is_empty
[function]
[call site]
02713
&str::to_string
[function]
[call site]
02714
&str::to_string
[function]
[call site]
02715
&'a
[call site]
02716
std::iter::Chain::enumerate
[function]
[call site]
02717
Err
[function]
[call site]
02718
RedisError::from
[function]
[call site]
02719
borrow_mut
[function]
[call site]
02720
ClusterConnection::refresh_slots
[function]
[call site]
02721
borrow_mut
[function]
[call site]
02722
ClusterConnection::create_new_slots
[function]
[call site]
02723
borrow_mut
[function]
[call site]
02724
RedisResult::iter_mut
[function]
[call site]
02725
ConnectionLike::req_command
[function]
[call site]
02726
Cmd::get_packed_command
[function]
[call site]
02727
MockRedisConnection::req_packed_command
[function]
[call site]
02728
cluster_handling::slot_cmd
[function]
[call site]
02729
Cmd::new
[function]
[call site]
02730
Cmd::arg
[function]
[call site]
02731
types::test_is_single_arg
[function]
[call site]
02732
super::topology::parse_slots
[function]
[call site]
02733
Cmd::with_capacity
[function]
[call site]
02734
&'a
[call site]
02735
MapIter::next
[function]
[call site]
02736
basic::test_pipeline_len
[function]
[call site]
02737
redis::pipe
[function]
[call site]
02738
cmd
[function]
[call site]
02739
cmd
[function]
[call site]
02740
types::test_is_single_arg
[function]
[call site]
02741
basic::test_pipeline_len
[function]
[call site]
02742
String::from_utf8_lossy
[function]
[call site]
02743
basic::test_pipeline_is_empty
[function]
[call site]
02744
is_wildcard_address
[function]
[call site]
02745
&str::into
[function]
[call site]
02746
&str::into
[function]
[call site]
02747
basic::test_pipeline_is_empty
[function]
[call site]
02748
Some
[function]
[call site]
02749
into
[function]
[call site]
02750
&'a
[call site]
02751
std::iter::once
[function]
[call site]
02752
chain
[function]
[call site]
02753
basic::test_tuple_decoding_from_iter
[function]
[call site]
02754
std::iter::Chain::skip
[function]
[call site]
02755
is_none
[function]
[call site]
02756
MapIter::next
[function]
[call site]
02757
try_to_address
[function]
[call site]
02758
filter_map
[function]
[call site]
02759
collect
[function]
[call site]
02760
cluster_async::get_push
[function]
[call site]
02761
Slot::new
[function]
[call site]
02762
Ok
[function]
[call site]
02763
ConnectionAddr::rsplit_once
[function]
[call site]
02764
unwrap
[function]
[call site]
02765
Some
[function]
[call site]
02766
SlotMap::from_slots
[function]
[call site]
02767
&'a
[call site]
02768
std::iter::Chain::map
[function]
[call site]
02769
SlotMapValue::from_slot
[function]
[call site]
02770
SlotAddrs::from_slot
[function]
[call site]
02771
SlotAddrs::new
[function]
[call site]
02772
collect
[function]
[call site]
02773
Ok
[function]
[call site]
02774
Err
[function]
[call site]
02775
RedisError::from
[function]
[call site]
02776
MockCmd::with_values
[function]
[call site]
02777
Cmd::into_redis_cmd_bytes
[function]
[call site]
02778
Cmd::get_packed_command
[function]
[call site]
02779
types::test_hashmap
[function]
[call site]
02780
parse_redis_value
[function]
[call site]
02781
Value::Array
[function]
[call site]
02782
RedisServer::new
[function]
[call site]
02783
PathBuf::insert
[function]
[call site]
02784
&str::into
[function]
[call site]
02785
PathBuf::insert
[function]
[call site]
02786
&str::into
[function]
[call site]
02787
PathBuf::insert
[function]
[call site]
02788
&str::into
[function]
[call site]
02789
parse_redis_value
[function]
[call site]
02790
Value::Array
[function]
[call site]
02791
RedisServer::default
[function]
[call site]
02792
HashMap::with_hasher
[function]
[call site]
02793
PathBuf::insert
[function]
[call site]
02794
&str::into
[function]
[call site]
02795
PathBuf::insert
[function]
[call site]
02796
&str::into
[function]
[call site]
02797
PathBuf::insert
[function]
[call site]
02798
&str::into
[function]
[call site]
02799
parse_redis_value
[function]
[call site]
02800
Value::Array
[function]
[call site]
02801
&'a
[call site]
02802
types::test_hashmap
[function]
[call site]
02803
String::into_redis_value
[function]
[call site]
02804
Value::BulkString
[function]
[call site]
02805
String::as_bytes
[function]
[call site]
02806
write_command_to_vec
[function]
[call site]
02807
collect
[function]
[call site]
02808
Self::flatten
[function]
[call site]
02809
values().flatten().collect::<Vec<_>>
[function]
[call site]
02810
RedisResult::sort_unstable
[function]
[call site]
02811
RedisResult::dedup
[function]
[call site]
02812
borrow_mut
[function]
[call site]
02813
&'a
[call site]
02814
std::iter::Chain::filter_map
[function]
[call site]
02815
RedisResult::remove
[function]
[call site]
02816
MockRedisConnection::check_connection
[function]
[call site]
02817
Some
[function]
[call site]
02818
ClientTlsParams::clone
[function]
[call site]
02819
ClientTlsParams::clone
[function]
[call site]
02820
Pkcs1
[function]
[call site]
02821
secret_pkcs1_der
[function]
[call site]
02822
write_command_to_vec
[function]
[call site]
02823
into
[function]
[call site]
02824
Pkcs8
[function]
[call site]
02825
secret_pkcs8_der
[function]
[call site]
02826
write_command_to_vec
[function]
[call site]
02827
into
[function]
[call site]
02828
Sec1
[function]
[call site]
02829
secret_sec1_der
[function]
[call site]
02830
write_command_to_vec
[function]
[call site]
02831
into
[function]
[call site]
02832
ClusterConnection::connect
[function]
[call site]
02833
MockRedisConnection::check_connection
[function]
[call site]
02834
Some
[function]
[call site]
02835
ClientTlsParams::clone
[function]
[call site]
02836
collect
[function]
[call site]
02837
Ok
[function]
[call site]
02838
Ok
[function]
[call site]
02839
Tokio::poll_write
[function]
[call site]
02840
SlotMap::new
[function]
[call site]
02841
ClusterConnection::refresh_slots
[function]
[call site]
02842
borrow_mut
[function]
[call site]
02843
ClusterConnection::create_new_slots
[function]
[call site]
02844
MockCmd::with_values
[function]
[call site]
02845
Self::flatten
[function]
[call site]
02846
values().flatten().collect::<Vec<_>>
[function]
[call site]
02847
RedisResult::sort_unstable
[function]
[call site]
02848
RedisResult::dedup
[function]
[call site]
02849
borrow_mut
[function]
[call site]
02850
&'a
[call site]
02851
std::iter::Chain::filter_map
[function]
[call site]
02852
RedisResult::remove
[function]
[call site]
02853
MockRedisConnection::check_connection
[function]
[call site]
02854
Some
[function]
[call site]
02855
ClientTlsParams::clone
[function]
[call site]
02856
ClusterConnection::connect
[function]
[call site]
02857
MockRedisConnection::check_connection
[function]
[call site]
02858
Some
[function]
[call site]
02859
ClientTlsParams::clone
[function]
[call site]
02860
collect
[function]
[call site]
02861
Ok
[function]
[call site]
02862
Ok
[function]
[call site]
02863
oneshot::channel::<RedisResult<()>>
[function]
[call site]
02864
mpsc::channel::<Message<_>>
[function]
[call site]
02865
ClusterConnInner::wait_for_initial_connection
[function]
[call site]
02866
std::mem::replace
[function]
[call site]
02867
Ok
[function]
[call site]
02868
t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send
[function]
[call site]
02869
stream::poll_fn
[function]
[call site]
02870
(
[call site]
02871
PendingRequest::poll_recv
[function]
[call site]
02872
types::test_hashmap
[function]
[call site]
02873
forward
[function]
[call site]
02874
HandleContainer::new
[function]
[call site]
02875
tokio::runtime::Runtime::spawn
[function]
[call site]
02876
crate_tokio::Tokio::spawn
[function]
[call site]
02877
TaskHandle::Tokio
[function]
[call site]
02878
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]
02879
tokio::runtime::Handle::try_current
[function]
[call site]
02880
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]
02881
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]
02882
TaskHandle::detach
[function]
[call site]
02883
crate_smol::Smol::spawn
[function]
[call site]
02884
TaskHandle::Smol
[function]
[call site]
02885
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]
02886
RedisServer::new
[function]
[call site]
02887
map_err
[function]
[call site]
02888
RedisError::from
[function]
[call site]
02889
Ok
[function]
[call site]
02890
ClientTlsParams::clone
[function]
[call site]
02891
ClientTlsParams::clone
[function]
[call site]
02892
RedisResult::unwrap
[function]
[call site]
02893
tokio::runtime::Runtime::block_on
[function]
[call site]
02894
ClusterClient::get_async_generic_connection
[function]
[call site]
02895
cluster_async::ClusterConnection::new
[function]
[call site]
02896
ClusterConnection::new_inner
[function]
[call site]
02897
map_err
[function]
[call site]
02898
RedisError::from
[function]
[call site]
02899
Ok
[function]
[call site]
02900
ClientTlsParams::clone
[function]
[call site]
02901
unwrap
[function]
[call site]
02902
RemoveHandler
[function]
[call site]
02903
ClusterClient::builder
[function]
[call site]
02904
ClusterClientBuilder::new
[function]
[call site]
02905
&'a
[call site]
02906
std::iter::Chain::map
[function]
[call site]
02907
ConnectionInfo::into_connection_info
[function]
[call site]
02908
collect
[function]
[call site]
02909
RedisServer::default
[function]
[call site]
02910
ClusterClientBuilder::retries
[function]
[call site]
02911
respond_startup
[function]
[call site]
02912
contains_slice
[function]
[call site]
02913
basic::test_pipeline_len
[function]
[call site]
02914
redis::pipe
[function]
[call site]
02915
cmd
[function]
[call site]
02916
cmd
[function]
[call site]
02917
types::test_is_single_arg
[function]
[call site]
02918
starts_with
[function]
[call site]
02919
Err
[function]
[call site]
02920
Ok
[function]
[call site]
02921
Value::SimpleString
[function]
[call site]
02922
&str::into
[function]
[call site]
02923
contains_slice
[function]
[call site]
02924
contains_slice
[function]
[call site]
02925
Err
[function]
[call site]
02926
Ok
[function]
[call site]
02927
Value::Array
[function]
[call site]
02928
contains_slice
[function]
[call site]
02929
Err
[function]
[call site]
02930
Ok
[function]
[call site]
02931
Value::SimpleString
[function]
[call site]
02932
&str::into
[function]
[call site]
02933
Ok
[function]
[call site]
02934
fetch_add
[function]
[call site]
02935
Err
[function]
[call site]
02936
parse_redis_value
[function]
[call site]
02937
Err
[function]
[call site]
02938
Ok
[function]
[call site]
02939
Value::BulkString
[function]
[call site]
02940
&str::to_vec
[function]
[call site]
02941
args_len
[function]
[call site]
02942
ClientTlsParams::clone
[function]
[call site]
02943
Cmd::reserve
[function]
[call site]
02944
write_command
[function]
[call site]
02945
io::Result::unwrap
[function]
[call site]
02946
cmd
[function]
[call site]
02947
Cmd::arg
[function]
[call site]
02948
arg("test").query::<Option<i32>>
[function]
[call site]
02949
TestClusterContext::get_ports
[function]
[call site]
02950
MockRedisConnection::check_connection
[function]
[call site]
02951
RedisServer::drop
[function]
[call site]
02952
cmd
[function]
[call site]
02953
ClusterConnection::route_command
[function]
[call site]
02954
RoutingInfo::SingleNode
[function]
[call site]
02955
MockRedisConnection::req_packed_command
[function]
[call site]
02956
Cmd::get_packed_command
[function]
[call site]
02957
RedisCluster::new
[function]
[call site]
02958
RedisServer::default
[function]
[call site]
02959
ClusterConnection::route_command
[function]
[call site]
02960
RoutingInfo::SingleNode
[function]
[call site]
02961
RedisResult::unwrap
[function]
[call site]
02962
into
[function]
[call site]
02963
Arc::into_inner
[function]
[call site]
02964
unwrap
[function]
[call site]
02965
into_inner
[function]
[call site]
02966
crate::io::tcp::stream_with_settings
[function]
[call site]
02967
TcpSettings::set_nodelay
[function]
[call site]
02968
TcpStream::into
[function]
[call site]
02969
set_tcp_keepalive
[function]
[call site]
02970
set_tcp_user_timeout
[function]
[call site]
02971
Ok
[function]
[call site]
02972
into
[function]
[call site]
02973
Ok
[function]
[call site]
02974
try_into
[function]
[call site]
02975
ConnectionAddr::to_socket_addrs
[function]
[call site]
02976
connect_tcp_timeout
[function]
[call site]
02977
TcpStream::connect_timeout
[function]
[call site]
02978
io::tcp::stream_with_settings
[function]
[call site]
02979
TcpSettings::set_nodelay
[function]
[call site]
02980
TcpStream::into
[function]
[call site]
02981
set_tcp_keepalive
[function]
[call site]
02982
set_tcp_user_timeout
[function]
[call site]
02983
Ok
[function]
[call site]
02984
into
[function]
[call site]
02985
Ok
[function]
[call site]
02986
Some
[function]
[call site]
02987
Some
[function]
[call site]
02988
fail
[function]
[call site]
02989
fail
[function]
[call site]
02990
ActualConnection::Tcp
[function]
[call site]
02991
TlsConnector::builder
[function]
[call site]
02992
TestSentinelContext::new
[function]
[call site]
02993
TestSentinelContext::sentinels_connection_info
[function]
[call site]
02994
Client::open
[function]
[call site]
02995
&redis::sentinel::Sentinel::clone
[function]
[call site]
02996
ClientTlsParams::clone
[function]
[call site]
02997
Pkcs1
[function]
[call site]
02998
secret_pkcs1_der
[function]
[call site]
02999
write_command_to_vec
[function]
[call site]
03000
into
[function]
[call site]
03001
Pkcs8
[function]
[call site]
03002
secret_pkcs8_der
[function]
[call site]
03003
write_command_to_vec
[function]
[call site]
03004
into
[function]
[call site]
03005
Sec1
[function]
[call site]
03006
secret_sec1_der
[function]
[call site]
03007
write_command_to_vec
[function]
[call site]
03008
into
[function]
[call site]
03009
RedisResult::unwrap
[function]
[call site]
03010
Client::get_connection
[function]
[call site]
03011
unwrap
[function]
[call site]
03012
redis::cmd
[function]
[call site]
03013
redis::Cmd::query
[function]
[call site]
03014
RedisResult::unwrap
[function]
[call site]
03015
SentinelClientBuilder::new
[function]
[call site]
03016
Ok
[function]
[call site]
03017
&'a
[call site]
03018
into_iter().collect::<Vec<_>>
[function]
[call site]
03019
impl
[call site]
03020
into
[function]
[call site]
03021
basic::test_tuple_decoding_from_iter
[function]
[call site]
03022
types::test_hashmap
[function]
[call site]
03023
&redis::sentinel::Sentinel::addr
[function]
[call site]
03024
ServerType::get_intended
[function]
[call site]
03025
&str::to_string
[function]
[call site]
03026
redis::ConnectionAddr::Tcp
[function]
[call site]
03027
&str::to_string
[function]
[call site]
03028
rand::random::<(u64,
[call site]
03029
redis::ConnectionAddr::Unix
[function]
[call site]
03030
ValueType::from
[function]
[call site]
03031
ClientTlsParams::clone
[function]
[call site]
03032
String::from
[function]
[call site]
03033
RedisResult::unwrap
[function]
[call site]
03034
SentinelClientBuilder::new
[function]
[call site]
03035
basic::test_tuple_decoding_from_iter
[function]
[call site]
03036
types::test_hashmap
[function]
[call site]
03037
&redis::sentinel::Sentinel::addr
[function]
[call site]
03038
ClientTlsParams::clone
[function]
[call site]
03039
String::from
[function]
[call site]
03040
RedisResult::unwrap
[function]
[call site]
03041
SentinelClientBuilder::set_client_to_sentinel_protocol
[function]
[call site]
03042
Some
[function]
[call site]
03043
redis_test::server::use_protocol
[function]
[call site]
03044
env::var
[function]
[call site]
03045
unwrap_or_default
[function]
[call site]
03046
TestSentinelContext::tls_mode
[function]
[call site]
03047
SentinelClientBuilder::set_client_to_redis_tls_mode
[function]
[call site]
03048
Some
[function]
[call site]
03049
SentinelClientBuilder::set_client_to_redis_tls_mode
[function]
[call site]
03050
Sentinel::build
[function]
[call site]
03051
unwrap
[function]
[call site]
03052
Sentinel::build
[function]
[call site]
03053
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_is_connection_to_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_is_master_role
[function]
[call site]
03065
TestSentinelContext::sentinel_node_connection_info
[function]
[call site]
03066
TestSentinelContext::sentinel_mut
[function]
[call site]
03067
&redis::sentinel::Sentinel::master_for
[function]
[call site]
03068
Sentinel::find_master_address
[function]
[call site]
03069
SentinelNodeConnectionInfo::unwrap_or_default
[function]
[call site]
03070
Client::open
[function]
[call site]
03071
Some
[function]
[call site]
03072
RedisResult::unwrap
[function]
[call site]
03073
Client::get_connection
[function]
[call site]
03074
unwrap
[function]
[call site]
03075
redis::cmd
[function]
[call site]
03076
redis::Cmd::query
[function]
[call site]
03077
RedisResult::unwrap
[function]
[call site]
03078
assert_connection_is_replica_of_correct_master
[function]
[call site]
03079
redis::cmd
[function]
[call site]
03080
redis::Cmd::arg
[function]
[call site]
03081
basic::test_pipeline_reuse_query
[function]
[call site]
03082
unwrap
[function]
[call site]
03083
assert_replica_role_and_master_addr
[function]
[call site]
03084
Client::get_connection_info
[function]
[call site]
03085
danger_accept_invalid_certs
[function]
[call site]
03086
cluster::test_danger_accept_invalid_hostnames
[function]
[call site]
03087
ClusterType::get_intended
[function]
[call site]
03088
TestClusterContext::new_with_config_and_builder
[function]
[call site]
03089
support::start_tls_crypto_provider
[function]
[call site]
03090
RedisCluster::new
[function]
[call site]
03091
RedisCluster::iter_servers
[function]
[call site]
03092
basic::test_tuple_decoding_from_iter
[function]
[call site]
03093
types::test_hashmap
[function]
[call site]
03094
collect
[function]
[call site]
03095
redis::cluster::ClusterClientBuilder::new
[function]
[call site]
03096
&'a
[call site]
03097
std::iter::Chain::map
[function]
[call site]
03098
ConnectionInfo::into_connection_info
[function]
[call site]
03099
collect
[function]
[call site]
03100
RedisServer::default
[function]
[call site]
03101
ClientTlsParams::clone
[function]
[call site]
03102
ClusterClientBuilder::use_protocol
[function]
[call site]
03103
Some
[function]
[call site]
03104
redis_test::server::use_protocol
[function]
[call site]
03105
ClusterType::get_intended
[function]
[call site]
03106
ClusterClientBuilder::certs
[function]
[call site]
03107
is_none
[function]
[call site]
03108
Some
[function]
[call site]
03109
Some
[function]
[call site]
03110
super::load_certs_from_file
[function]
[call site]
03111
MockRedisConnection::is_open
[function]
[call site]
03112
bool::expect
[function]
[call site]
03113
RedisServer::new
[function]
[call site]
03114
RedisServer::new
[function]
[call site]
03115
RedisServer::with_modules
[function]
[call site]
03116
RedisServer::read_to_end
[function]
[call site]
03117
expect
[function]
[call site]
03118
MockRedisConnection::is_open
[function]
[call site]
03119
bool::expect
[function]
[call site]
03120
RedisServer::new
[function]
[call site]
03121
RedisServer::new
[function]
[call site]
03122
RedisServer::read_to_end
[function]
[call site]
03123
expect
[function]
[call site]
03124
MockRedisConnection::is_open
[function]
[call site]
03125
bool::expect
[function]
[call site]
03126
RedisServer::new
[function]
[call site]
03127
RedisServer::new
[function]
[call site]
03128
RedisServer::read_to_end
[function]
[call site]
03129
expect
[function]
[call site]
03130
Some
[function]
[call site]
03131
Some
[function]
[call site]
03132
initializer
[function]
[call site]
03133
Sentinel::build
[function]
[call site]
03134
RedisResult::unwrap
[function]
[call site]
03135
redis_test::server::use_protocol
[function]
[call site]
03136
RedisServer::default
[function]
[call site]
03137
cluster::test_danger_accept_invalid_hostnames
[function]
[call site]
03138
cluster::smoke_test_connection
[function]
[call site]
03139
redis::cmd
[function]
[call site]
03140
redis::Cmd::arg
[function]
[call site]
03141
types::test_is_single_arg
[function]
[call site]
03142
Cmd::exec
[function]
[call site]
03143
query::<()>
[function]
[call site]
03144
RedisResult::unwrap
[function]
[call site]
03145
redis::cmd
[function]
[call site]
03146
redis::Cmd::arg
[function]
[call site]
03147
Cmd::exec
[function]
[call site]
03148
RedisResult::unwrap
[function]
[call site]
03149
MockRedisConnection::check_connection
[function]
[call site]
03150
use_sni
[function]
[call site]
03151
Sentinel::build
[function]
[call site]
03152
TlsConnector::builder
[function]
[call site]
03153
cluster::test_danger_accept_invalid_hostnames
[function]
[call site]
03154
Sentinel::build
[function]
[call site]
03155
RedisServer::new
[function]
[call site]
03156
RedisServer::with_modules
[function]
[call site]
03157
as_str
[function]
[call site]
03158
connect_tcp
[function]
[call site]
03159
connect
[function]
[call site]
03160
fail
[function]
[call site]
03161
as_str
[function]
[call site]
03162
to_socket_addrs
[function]
[call site]
03163
connect_tcp_timeout
[function]
[call site]
03164
Some
[function]
[call site]
03165
Some
[function]
[call site]
03166
connect
[function]
[call site]
03167
unwrap
[function]
[call site]
03168
fail
[function]
[call site]
03169
fail
[function]
[call site]
03170
ActualConnection::TcpNativeTls
[function]
[call site]
03171
RedisServer::new
[function]
[call site]
03172
create_rustls_config
[function]
[call site]
03173
basic::test_pipeline_is_empty
[function]
[call site]
03174
redis::pipe
[function]
[call site]
03175
cmd
[function]
[call site]
03176
cmd
[function]
[call site]
03177
types::test_is_single_arg
[function]
[call site]
03178
extend
[function]
[call site]
03179
basic::test_tuple_decoding_from_iter
[function]
[call site]
03180
cloned
[function]
[call site]
03181
rustls_native_certs::load_native_certs
[function]
[call site]
03182
test_module_json_arr_pop
[function]
[call site]
03183
TestContext::with_modules
[function]
[call site]
03184
TestContext::connection
[function]
[call site]
03185
redis::Connection::json_set
[function]
[call site]
03186
redis::Connection::json_arr_pop
[function]
[call site]
03187
redis::Connection::json_set
[function]
[call site]
03188
redis::Connection::json_arr_pop
[function]
[call site]
03189
Err
[function]
[call site]
03190
into
[function]
[call site]
03191
xadd
[function]
[call site]
03192
&mut
[call site]
03193
unwrap
[function]
[call site]
03194
&mut
[call site]
03195
unwrap
[function]
[call site]
03196
&mut
[call site]
03197
unwrap
[function]
[call site]
03198
&mut
[call site]
03199
unwrap
[function]
[call site]
03200
rustls::ClientConfig::builder
[function]
[call site]
03201
TestSentinelContext::new
[function]
[call site]
03202
TestSentinelContext::sentinels_connection_info
[function]
[call site]
03203
Client::open
[function]
[call site]
03204
&redis::sentinel::Sentinel::clone
[function]
[call site]
03205
RedisResult::unwrap
[function]
[call site]
03206
Client::get_connection
[function]
[call site]
03207
unwrap
[function]
[call site]
03208
redis::cmd
[function]
[call site]
03209
redis::Cmd::query
[function]
[call site]
03210
RedisResult::unwrap
[function]
[call site]
03211
SentinelClientBuilder::new
[function]
[call site]
03212
basic::test_tuple_decoding_from_iter
[function]
[call site]
03213
types::test_hashmap
[function]
[call site]
03214
&redis::sentinel::Sentinel::addr
[function]
[call site]
03215
ClientTlsParams::clone
[function]
[call site]
03216
String::from
[function]
[call site]
03217
RedisResult::unwrap
[function]
[call site]
03218
SentinelClientBuilder::new
[function]
[call site]
03219
basic::test_tuple_decoding_from_iter
[function]
[call site]
03220
types::test_hashmap
[function]
[call site]
03221
&redis::sentinel::Sentinel::addr
[function]
[call site]
03222
ClientTlsParams::clone
[function]
[call site]
03223
String::from
[function]
[call site]
03224
RedisResult::unwrap
[function]
[call site]
03225
SentinelClientBuilder::set_client_to_sentinel_protocol
[function]
[call site]
03226
redis_test::server::use_protocol
[function]
[call site]
03227
TestSentinelContext::tls_mode
[function]
[call site]
03228
SentinelClientBuilder::set_client_to_redis_tls_mode
[function]
[call site]
03229
SentinelClientBuilder::set_client_to_redis_tls_mode
[function]
[call site]
03230
Sentinel::build
[function]
[call site]
03231
unwrap
[function]
[call site]
03232
Sentinel::build
[function]
[call site]
03233
unwrap
[function]
[call site]
03234
Client::get_connection
[function]
[call site]
03235
unwrap
[function]
[call site]
03236
redis::cmd
[function]
[call site]
03237
redis::Cmd::query
[function]
[call site]
03238
RedisResult::unwrap
[function]
[call site]
03239
assert_is_connection_to_master
[function]
[call site]
03240
TestSentinelContext::sentinel_node_connection_info
[function]
[call site]
03241
TestSentinelContext::sentinel_mut
[function]
[call site]
03242
&redis::sentinel::Sentinel::master_for
[function]
[call site]
03243
Some
[function]
[call site]
03244
RedisResult::unwrap
[function]
[call site]
03245
Client::get_connection
[function]
[call site]
03246
unwrap
[function]
[call site]
03247
redis::cmd
[function]
[call site]
03248
redis::Cmd::query
[function]
[call site]
03249
RedisResult::unwrap
[function]
[call site]
03250
assert_connection_is_replica_of_correct_master
[function]
[call site]
03251
unwrap_or
[function]
[call site]
03252
Self::with_root_certificates
[function]
[call site]
03253
ClientTlsParams::clone
[function]
[call site]
03254
with_client_auth_cert
[function]
[call site]
03255
map_err
[function]
[call site]
03256
RedisError::from
[function]
[call site]
03257
to_string
[function]
[call site]
03258
with_no_client_auth
[function]
[call site]
03259
fail
[function]
[call site]
03260
Self::dangerous
[function]
[call site]
03261
set_certificate_verifier
[function]
[call site]
03262
RedisServer::new
[function]
[call site]
03263
rustls::client::WebPkiServerVerifier::builder
[function]
[call site]
03264
TestSentinelContext::new
[function]
[call site]
03265
TestSentinelContext::sentinels_connection_info
[function]
[call site]
03266
Client::open
[function]
[call site]
03267
&redis::sentinel::Sentinel::clone
[function]
[call site]
03268
RedisResult::unwrap
[function]
[call site]
03269
Client::get_connection
[function]
[call site]
03270
unwrap
[function]
[call site]
03271
redis::cmd
[function]
[call site]
03272
redis::Cmd::query
[function]
[call site]
03273
RedisResult::unwrap
[function]
[call site]
03274
SentinelClientBuilder::new
[function]
[call site]
03275
basic::test_tuple_decoding_from_iter
[function]
[call site]
03276
types::test_hashmap
[function]
[call site]
03277
&redis::sentinel::Sentinel::addr
[function]
[call site]
03278
ClientTlsParams::clone
[function]
[call site]
03279
String::from
[function]
[call site]
03280
RedisResult::unwrap
[function]
[call site]
03281
SentinelClientBuilder::new
[function]
[call site]
03282
basic::test_tuple_decoding_from_iter
[function]
[call site]
03283
types::test_hashmap
[function]
[call site]
03284
&redis::sentinel::Sentinel::addr
[function]
[call site]
03285
ClientTlsParams::clone
[function]
[call site]
03286
String::from
[function]
[call site]
03287
RedisResult::unwrap
[function]
[call site]
03288
SentinelClientBuilder::set_client_to_sentinel_protocol
[function]
[call site]
03289
redis_test::server::use_protocol
[function]
[call site]
03290
TestSentinelContext::tls_mode
[function]
[call site]
03291
SentinelClientBuilder::set_client_to_redis_tls_mode
[function]
[call site]
03292
SentinelClientBuilder::set_client_to_redis_tls_mode
[function]
[call site]
03293
Sentinel::build
[function]
[call site]
03294
unwrap
[function]
[call site]
03295
Sentinel::build
[function]
[call site]
03296
unwrap
[function]
[call site]
03297
Client::get_connection
[function]
[call site]
03298
unwrap
[function]
[call site]
03299
redis::cmd
[function]
[call site]
03300
redis::Cmd::query
[function]
[call site]
03301
RedisResult::unwrap
[function]
[call site]
03302
assert_is_connection_to_master
[function]
[call site]
03303
TestSentinelContext::sentinel_node_connection_info
[function]
[call site]
03304
TestSentinelContext::sentinel_mut
[function]
[call site]
03305
&redis::sentinel::Sentinel::master_for
[function]
[call site]
03306
Some
[function]
[call site]
03307
RedisResult::unwrap
[function]
[call site]
03308
Client::get_connection
[function]
[call site]
03309
unwrap
[function]
[call site]
03310
redis::cmd
[function]
[call site]
03311
redis::Cmd::query
[function]
[call site]
03312
RedisResult::unwrap
[function]
[call site]
03313
assert_connection_is_replica_of_correct_master
[function]
[call site]
03314
RedisServer::new
[function]
[call site]
03315
Sentinel::build
[function]
[call site]
03316
RedisResult::map_err
[function]
[call site]
03317
rustls::Error::from
[function]
[call site]
03318
io::Error::from
[function]
[call site]
03319
Self::into
[function]
[call site]
03320
rustls::OtherError
[function]
[call site]
03321
RedisServer::new
[function]
[call site]
03322
Self::with_root_certificates
[function]
[call site]
03323
with_no_client_auth
[function]
[call site]
03324
rustls::crypto::CryptoProvider::get_default
[function]
[call site]
03325
Err
[function]
[call site]
03326
RedisError::from
[function]
[call site]
03327
Self::dangerous
[function]
[call site]
03328
set_certificate_verifier
[function]
[call site]
03329
RedisServer::new
[function]
[call site]
03330
Ok
[function]
[call site]
03331
fail
[function]
[call site]
03332
Ok
[function]
[call site]
03333
ClientTlsParams::clone
[function]
[call site]
03334
rustls::ClientConnection::new
[function]
[call site]
03335
RedisServer::with_modules
[function]
[call site]
03336
RedisServer::new
[function]
[call site]
03337
rustls::pki_types::ServerName::try_from
[function]
[call site]
03338
Ok
[function]
[call site]
03339
Err
[function]
[call site]
03340
to_owned
[function]
[call site]
03341
connect_tcp
[function]
[call site]
03342
RedisServer::new
[function]
[call site]
03343
RedisServer::with_modules
[function]
[call site]
03344
to_socket_addrs
[function]
[call site]
03345
connect_tcp_timeout
[function]
[call site]
03346
Some
[function]
[call site]
03347
Some
[function]
[call site]
03348
RedisServer::new
[function]
[call site]
03349
fail
[function]
[call site]
03350
fail
[function]
[call site]
03351
ActualConnection::TcpRustls
[function]
[call site]
03352
RedisServer::new
[function]
[call site]
03353
fail
[function]
[call site]
03354
ActualConnection::Unix
[function]
[call site]
03355
cluster::test_cluster_reconnect_after_complete_server_disconnect
[function]
[call site]
03356
TestClusterContext::new_insecure_with_cluster_client_builder
[function]
[call site]
03357
cluster::test_cluster_retries
[function]
[call site]
03358
TestClusterContext::get_ports
[function]
[call site]
03359
MockRedisConnection::check_connection
[function]
[call site]
03360
RedisServer::drop
[function]
[call site]
03361
cmd
[function]
[call site]
03362
ClusterConnection::route_command
[function]
[call site]
03363
RoutingInfo::SingleNode
[function]
[call site]
03364
MockRedisConnection::req_packed_command
[function]
[call site]
03365
Cmd::get_packed_command
[function]
[call site]
03366
RedisCluster::new
[function]
[call site]
03367
RedisServer::default
[function]
[call site]
03368
ClusterConnection::route_command
[function]
[call site]
03369
RoutingInfo::SingleNode
[function]
[call site]
03370
RedisResult::unwrap
[function]
[call site]
03371
fail
[function]
[call site]
03372
RedisResult::and_then
[function]
[call site]
03373
RedisResult::checked_sub
[function]
[call site]
03374
elapsed
[function]
[call site]
03375
RedisResult::is_some
[function]
[call site]
03376
is_none
[function]
[call site]
03377
Err
[function]
[call site]
03378
RedisError::from
[function]
[call site]
03379
std::io::Error::new
[function]
[call site]
03380
RedisServer::with_modules
[function]
[call site]
03381
MockConnection::set_read_timeout
[function]
[call site]
03382
Ok
[function]
[call site]
03383
MockConnection::set_write_timeout
[function]
[call site]
03384
Ok
[function]
[call site]
03385
setup_connection
[function]
[call site]
03386
execute_connection_pipeline
[function]
[call site]
03387
connection::connection_setup_pipeline
[function]
[call site]
03388
execute_connection_pipeline
[function]
[call site]
03389
connection::connection_setup_pipeline
[function]
[call site]
03390
Ok
[function]
[call site]
03391
MockConnection::set_read_timeout
[function]
[call site]
03392
MockConnection::set_write_timeout
[function]
[call site]
03393
Ok
[function]
[call site]
03394
into
[function]
[call site]
03395
is_ok
[function]
[call site]
03396
to_string
[function]
[call site]
03397
Ok
[function]
[call site]
03398
std::thread::sleep
[function]
[call site]
03399
Duration::from_millis
[function]
[call site]
03400
&'a
[call site]
03401
types::test_hashmap
[function]
[call site]
03402
{
[call site]
03403
server::get_random_available_port
[function]
[call site]
03404
RedisServer::contains
[function]
[call site]
03405
RedisServer::insert
[function]
[call site]
03406
make_server
[function]
[call site]
03407
std::thread::sleep
[function]
[call site]
03408
Duration::from_millis
[function]
[call site]
03409
verify_server
[function]
[call site]
03410
cluster_async::get_push
[function]
[call site]
03411
ClientTlsParams::clone
[function]
[call site]
03412
collect
[function]
[call site]
03413
process::Command::new
[function]
[call site]
03414
Cmd::stdout
[function]
[call site]
03415
process::Stdio::piped
[function]
[call site]
03416
types::test_is_single_arg
[function]
[call site]
03417
types::test_is_single_arg
[function]
[call site]
03418
types::test_std_types_to_redis_args
[function]
[call site]
03419
Cmd::arg
[function]
[call site]
03420
types::test_is_single_arg
[function]
[call site]
03421
to_string
[function]
[call site]
03422
Cmd::arg
[function]
[call site]
03423
Cmd::arg
[function]
[call site]
03424
Cmd::arg
[function]
[call site]
03425
Cmd::arg
[function]
[call site]
03426
Cmd::arg
[function]
[call site]
03427
Cmd::arg
[function]
[call site]
03428
Cmd::arg
[function]
[call site]
03429
Cmd::arg
[function]
[call site]
03430
None::is_some
[function]
[call site]
03431
None::as_ref
[function]
[call site]
03432
unwrap
[function]
[call site]
03433
Cmd::arg
[function]
[call site]
03434
types::test_is_single_arg
[function]
[call site]
03435
types::test_is_single_arg
[function]
[call site]
03436
Cmd::arg
[function]
[call site]
03437
types::test_is_single_arg
[function]
[call site]
03438
Cmd::output
[function]
[call site]
03439
unwrap
[function]
[call site]
03440
test_get_replica_clients_success
[function]
[call site]
03441
TestSentinelContext::new
[function]
[call site]
03442
TestSentinelContext::sentinel_node_connection_info
[function]
[call site]
03443
TestSentinelContext::sentinel_mut
[function]
[call site]
03444
&redis::sentinel::Sentinel::get_replica_clients
[function]
[call site]
03445
Sentinel::find_valid_replica_addresses
[function]
[call site]
03446
SentinelNodeConnectionInfo::unwrap_or_default
[function]
[call site]
03447
build_replica_clients
[function]
[call site]
03448
basic::test_pipeline_is_empty
[function]
[call site]
03449
fail
[function]
[call site]
03450
basic::test_tuple_decoding_from_iter
[function]
[call site]
03451
types::test_hashmap
[function]
[call site]
03452
Client::open
[function]
[call site]
03453
ClientTlsParams::clone
[function]
[call site]
03454
collect
[function]
[call site]
03455
Some
[function]
[call site]
03456
RedisResult::unwrap
[function]
[call site]
03457
std::thread::sleep
[function]
[call site]
03458
Duration::from_millis
[function]
[call site]
03459
RedisCluster::wait_for_replicas
[function]
[call site]
03460
RedisServer::connection_info
[function]
[call site]
03461
RedisServer::client_addr
[function]
[call site]
03462
&redis::ConnectionAddr::clone
[function]
[call site]
03463
ConnectionInfo::into_connection_info
[function]
[call site]
03464
RedisResult::unwrap
[function]
[call site]
03465
ConnectionInfo::set_redis_settings
[function]
[call site]
03466
redis_settings
[function]
[call site]
03467
redis::Client::open
[function]
[call site]
03468
RedisServer::connection_info
[function]
[call site]
03469
RedisResult::unwrap
[function]
[call site]
03470
Client::get_connection
[function]
[call site]
03471
RedisResult::unwrap
[function]
[call site]
03472
redis::cmd
[function]
[call site]
03473
redis::Cmd::arg
[function]
[call site]
03474
basic::test_pipeline_reuse_query
[function]
[call site]
03475
unwrap
[function]
[call site]
03476
RedisResult::from_redis_value
[function]
[call site]
03477
Ok
[function]
[call site]
03478
Err
[function]
[call site]
03479
into
[function]
[call site]
03480
from_redis_value
[function]
[call site]
03481
types::test_hashmap
[function]
[call site]
03482
Ok
[function]
[call site]
03483
Result::unwrap
[function]
[call site]
03484
basic::test_tuple_decoding_from_iter
[function]
[call site]
03485
block_on_all
[function]
[call site]
03486
panic::set_hook
[function]
[call site]
03487
RedisServer::new
[function]
[call site]
03488
RadiusOptions::store
[function]
[call site]
03489
Some
[function]
[call site]
03490
ToRedisArgs::to_redis_args
[function]
[call site]
03491
RedisServer::new
[function]
[call site]
03492
u8::write_redis_args
[function]
[call site]
03493
::itoa::Buffer::new
[function]
[call site]
03494
RedisServer::format
[function]
[call site]
03495
Vec::write_arg
[function]
[call site]
03496
TlsFilePaths::as_bytes
[function]
[call site]
03497
futures_util::FutureExt::fuse
[function]
[call site]
03498
script::test_script_load
[function]
[call site]
03499
TestContext::new
[function]
[call site]
03500
TestContext::connection
[function]
[call site]
03501
redis::Script::new
[function]
[call site]
03502
RedisServer::new
[function]
[call site]
03503
RedisServer::with_modules
[function]
[call site]
03504
SortedSetAddOptions::add_or_update
[function]
[call site]
03505
RedisServer::default
[function]
[call site]
03506
Option::as_bytes
[function]
[call site]
03507
Option::to_string
[function]
[call site]
03508
digest
[function]
[call site]
03509
to_string
[function]
[call site]
03510
script::test_script_load
[function]
[call site]
03511
Err
[function]
[call site]
03512
into
[function]
[call site]
03513
futures_time::task::sleep
[function]
[call site]
03514
tokio::time::sleep
[function]
[call site]
03515
smol::Timer::after
[function]
[call site]
03516
futures_time::time::Duration::from_millis
[function]
[call site]
03517
futures_util::FutureExt::fuse
[function]
[call site]
03518
block_on_all_using_tokio
[function]
[call site]
03519
redis::aio::prefer_tokio
[function]
[call site]
03520
set_runtime
[function]
[call site]
03521
types::test_hashbrown_hashset
[function]
[call site]
03522
parse_redis_value
[function]
[call site]
03523
Value::Array
[function]
[call site]
03524
RedisServer::new
[function]
[call site]
03525
RedisServer::insert
[function]
[call site]
03526
&str::to_string
[function]
[call site]
03527
RedisServer::insert
[function]
[call site]
03528
&str::to_string
[function]
[call site]
03529
RedisServer::insert
[function]
[call site]
03530
&str::to_string
[function]
[call site]
03531
parse_redis_value
[function]
[call site]
03532
Value::Int
[function]
[call site]
03533
RedisServer::new
[function]
[call site]
03534
test_module_json_arr_insert
[function]
[call site]
03535
&str::to_string
[function]
[call site]
03536
test_module_json_arr_insert
[function]
[call site]
03537
&str::to_string
[function]
[call site]
03538
test_module_json_arr_insert
[function]
[call site]
03539
&str::to_string
[function]
[call site]
03540
types::test_std_types_to_redis_args
[function]
[call site]
03541
&'a
[call site]
03542
std::iter::Chain::collect
[function]
[call site]
03543
map_err
[function]
[call site]
03544
RedisError::from
[function]
[call site]
03545
Result::unwrap
[function]
[call site]
03546
current_thread_runtime
[function]
[call site]
03547
tokio::runtime::Builder::new_current_thread
[function]
[call site]
03548
enable_io
[function]
[call site]
03549
enable_time
[function]
[call site]
03550
Sentinel::build
[function]
[call site]
03551
RedisResult::unwrap
[function]
[call site]
03552
tokio::runtime::Runtime::block_on
[function]
[call site]
03553
block_on_all_using_smol
[function]
[call site]
03554
redis::aio::prefer_smol
[function]
[call site]
03555
set_runtime
[function]
[call site]
03556
Result::unwrap
[function]
[call site]
03557
smol::block_on
[function]
[call site]
03558
panic::take_hook
[function]
[call site]
03559
swap
[function]
[call site]
03560
basic::test_pipeline_len
[function]
[call site]
03561
redis::pipe
[function]
[call site]
03562
cmd
[function]
[call site]
03563
cmd
[function]
[call site]
03564
types::test_is_single_arg
[function]
[call site]
03565
std::thread::sleep
[function]
[call site]
03566
Duration::from_millis
[function]
[call site]
03567
wait_for_status_ok
[function]
[call site]
03568
RedisServer::log_file
[function]
[call site]
03569
std::fs::read_to_string
[function]
[call site]
03570
expect
[function]
[call site]
03571
Option::contains
[function]
[call site]
03572
std::thread::sleep
[function]
[call site]
03573
Duration::from_millis
[function]
[call site]
03574
RedisCluster::iter_servers
[function]
[call site]
03575
types::test_hashmap
[function]
[call site]
03576
collect
[function]
[call site]
03577
redis::cluster::ClusterClientBuilder::new
[function]
[call site]
03578
ClientTlsParams::clone
[function]
[call site]
03579
ClusterClientBuilder::use_protocol
[function]
[call site]
03580
redis_test::server::use_protocol
[function]
[call site]
03581
ClusterType::get_intended
[function]
[call site]
03582
ClusterClientBuilder::certs
[function]
[call site]
03583
super::load_certs_from_file
[function]
[call site]
03584
initializer
[function]
[call site]
03585
Sentinel::build
[function]
[call site]
03586
RedisResult::unwrap
[function]
[call site]
03587
redis_test::server::use_protocol
[function]
[call site]
03588
RedisClusterConfiguration::default
[function]
[call site]
03589
cluster::test_cluster_retries
[function]
[call site]
03590
TestClusterContext::get_ports
[function]
[call site]
03591
MockRedisConnection::check_connection
[function]
[call site]
03592
RedisServer::drop
[function]
[call site]
03593
cmd
[function]
[call site]
03594
ClusterConnection::route_command
[function]
[call site]
03595
RoutingInfo::SingleNode
[function]
[call site]
03596
MockRedisConnection::req_packed_command
[function]
[call site]
03597
Cmd::get_packed_command
[function]
[call site]
03598
RedisCluster::new
[function]
[call site]
03599
RedisServer::default
[function]
[call site]
03600
ClusterConnection::route_command
[function]
[call site]
03601
RoutingInfo::SingleNode
[function]
[call site]
03602
RedisResult::unwrap
[function]
[call site]
03603
unwrap
[function]
[call site]
03604
ValueType::from
[function]
[call site]
03605
basic::test_tuple_decoding_from_iter
[function]
[call site]
03606
hscan::<_,
[call site]
03607
unwrap
[function]
[call site]
03608
unwrap
[function]
[call site]
03609
into_iter().collect::<Vec<_>>
[function]
[call site]
03610
impl
[call site]
03611
into
[function]
[call site]
03612
RedisResult::prefix
[function]
[call site]
03613
tempdir
[function]
[call site]
03614
expect
[function]
[call site]
03615
RedisServer::log_file
[function]
[call site]
03616
tests_routing::test_multi_shard_keys_and_path
[function]
[call site]
03617
join
[function]
[call site]
03618
types::test_is_single_arg
[function]
[call site]
03619
types::test_is_single_arg
[function]
[call site]
03620
ClientTlsParams::clone
[function]
[call site]
03621
ClientTlsParams::clone
[function]
[call site]
03622
Pkcs1
[function]
[call site]
03623
secret_pkcs1_der
[function]
[call site]
03624
write_command_to_vec
[function]
[call site]
03625
into
[function]
[call site]
03626
Pkcs8
[function]
[call site]
03627
secret_pkcs8_der
[function]
[call site]
03628
write_command_to_vec
[function]
[call site]
03629
into
[function]
[call site]
03630
Sec1
[function]
[call site]
03631
secret_sec1_der
[function]
[call site]
03632
write_command_to_vec
[function]
[call site]
03633
into
[function]
[call site]
03634
get_major_version
[function]
[call site]
03635
String::from_utf8
[function]
[call site]
03636
process::Command::new
[function]
[call site]
03637
types::test_is_single_arg
[function]
[call site]
03638
output
[function]
[call site]
03639
unwrap
[function]
[call site]
03640
unwrap
[function]
[call site]
03641
split_once
[function]
[call site]
03642
unwrap
[function]
[call site]
03643
split_once
[function]
[call site]
03644
unwrap
[function]
[call site]
03645
parse
[function]
[call site]
03646
unwrap
[function]
[call site]
03647
types::test_is_single_arg
[function]
[call site]
03648
types::test_is_single_arg
[function]
[call site]
03649
types::test_is_single_arg
[function]
[call site]
03650
types::test_is_single_arg
[function]
[call site]
03651
to_string
[function]
[call site]
03652
types::test_is_single_arg
[function]
[call site]
03653
types::test_is_single_arg
[function]
[call site]
03654
RedisServer::new_with_addr_tls_modules_and_spawner
[function]
[call site]
03655
process::Command::new
[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
env::var
[function]
[call site]
03660
expect
[function]
[call site]
03661
RedisServer::stdout
[function]
[call site]
03662
process::Stdio::piped
[function]
[call site]
03663
stderr
[function]
[call site]
03664
process::Stdio::piped
[function]
[call site]
03665
tempfile::Builder::new
[function]
[call site]
03666
RedisResult::prefix
[function]
[call site]
03667
tempdir
[function]
[call site]
03668
expect
[function]
[call site]
03669
RedisServer::log_file
[function]
[call site]
03670
types::test_is_single_arg
[function]
[call site]
03671
types::test_is_single_arg
[function]
[call site]
03672
ClientTlsParams::clone
[function]
[call site]
03673
get_major_version
[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
to_string
[function]
[call site]
03679
types::test_is_single_arg
[function]
[call site]
03680
types::test_is_single_arg
[function]
[call site]
03681
RedisServer::new_with_addr_tls_modules_and_spawner
[function]
[call site]
03682
Option<TlsFilePaths>::unwrap_or_else
[function]
[call site]
03683
utils::build_keys_and_certs_for_tls
[function]
[call site]
03684
build_keys_and_certs_for_tls_ext
[function]
[call site]
03685
types::test_is_single_arg
[function]
[call site]
03686
types::test_is_single_arg
[function]
[call site]
03687
TcpListener::to_string
[function]
[call site]
03688
types::test_is_single_arg
[function]
[call site]
03689
types::test_is_single_arg
[function]
[call site]
03690
types::test_is_single_arg
[function]
[call site]
03691
types::test_is_single_arg
[function]
[call site]
03692
types::test_is_single_arg
[function]
[call site]
03693
types::test_is_single_arg
[function]
[call site]
03694
types::test_is_single_arg
[function]
[call site]
03695
types::test_is_single_arg
[function]
[call site]
03696
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
ClientTlsParams::clone
[function]
[call site]
03701
RedisServer::new_with_addr_tls_modules_and_spawner
[function]
[call site]
03702
Some
[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
types::test_is_single_arg
[function]
[call site]
03707
RedisServer::new_with_addr_tls_modules_and_spawner
[function]
[call site]
03708
Option<TlsFilePaths>::unwrap_or_else
[function]
[call site]
03709
utils::build_keys_and_certs_for_tls
[function]
[call site]
03710
types::test_is_single_arg
[function]
[call site]
03711
types::test_is_single_arg
[function]
[call site]
03712
TcpListener::to_string
[function]
[call site]
03713
types::test_is_single_arg
[function]
[call site]
03714
types::test_is_single_arg
[function]
[call site]
03715
types::test_is_single_arg
[function]
[call site]
03716
types::test_is_single_arg
[function]
[call site]
03717
types::test_is_single_arg
[function]
[call site]
03718
types::test_is_single_arg
[function]
[call site]
03719
types::test_is_single_arg
[function]
[call site]
03720
types::test_is_single_arg
[function]
[call site]
03721
types::test_is_single_arg
[function]
[call site]
03722
types::test_is_single_arg
[function]
[call site]
03723
types::test_is_single_arg
[function]
[call site]
03724
types::test_is_single_arg
[function]
[call site]
03725
ClientTlsParams::clone
[function]
[call site]
03726
RedisServer::new_with_addr_tls_modules_and_spawner
[function]
[call site]
03727
Some
[function]
[call site]
03728
types::test_is_single_arg
[function]
[call site]
03729
types::test_is_single_arg
[function]
[call site]
03730
types::test_is_single_arg
[function]
[call site]
03731
types::test_is_single_arg
[function]
[call site]
03732
RedisServer::new_with_addr_tls_modules_and_spawner
[function]
[call site]
03733
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]
03734
unwrap_or_else
[function]
[call site]
03735
build_single_client
[function]
[call site]
03736
redis::Client::open
[function]
[call site]
03737
RedisServer::connection_info
[function]
[call site]
03738
RedisResult::unwrap
[function]
[call site]
03739
Duration::from_millis
[function]
[call site]
03740
Client::get_connection
[function]
[call site]
03741
RedisError::is_connection_refusal
[function]
[call site]
03742
RedisError::as_io_error
[function]
[call site]
03743
Option::is_some_and
[function]
[call site]
03744
get_push_kind
[function]
[call site]
03745
std::thread::sleep
[function]
[call site]
03746
flushdb::<()>
[function]
[call site]
03747
unwrap
[function]
[call site]
03748
redis_test::server::use_protocol
[function]
[call site]
03749
TestContext::connection
[function]
[call site]
03750
redis::Connection::json_set
[function]
[call site]
03751
redis::Connection::json_arr_insert
[function]
[call site]
03752
redis::Connection::json_set
[function]
[call site]
03753
redis::Connection::json_arr_insert
[function]
[call site]
03754
&str::into
[function]
[call site]
03755
PathBuf::insert
[function]
[call site]
03756
&str::into
[function]
[call site]
03757
PathBuf::insert
[function]
[call site]
03758
&str::into
[function]
[call site]
03759
parse_redis_value
[function]
[call site]
03760
Value::Array
[function]
[call site]
03761
RedisServer::default
[function]
[call site]
03762
HashMap::with_hasher
[function]
[call site]
03763
PathBuf::insert
[function]
[call site]
03764
&str::into
[function]
[call site]
03765
PathBuf::insert
[function]
[call site]
03766
&str::into
[function]
[call site]
03767
PathBuf::insert
[function]
[call site]
03768
&str::into
[function]
[call site]
03769
parse_redis_value
[function]
[call site]
03770
Value::Array
[function]
[call site]
03771
Ok
[function]
[call site]
03772
types::test_hashmap
[function]
[call site]
03773
Ok
[function]
[call site]
03774
ClientTlsParams::clone
[function]
[call site]
03775
ClientTlsParams::clone
[function]
[call site]
03776
Pkcs1
[function]
[call site]
03777
secret_pkcs1_der
[function]
[call site]
03778
write_command_to_vec
[function]
[call site]
03779
into
[function]
[call site]
03780
Pkcs8
[function]
[call site]
03781
secret_pkcs8_der
[function]
[call site]
03782
write_command_to_vec
[function]
[call site]
03783
into
[function]
[call site]
03784
Sec1
[function]
[call site]
03785
secret_sec1_der
[function]
[call site]
03786
write_command_to_vec
[function]
[call site]
03787
into
[function]
[call site]
03788
t::e::s::t::s::::::::t::e::s::t::_::i::s::_::s::e::n::d::assert_send
[function]
[call site]
03789
Some
[function]
[call site]
03790
map_err
[function]
[call site]
03791
map_err
[function]
[call site]
03792
and_then
[function]
[call site]
03793
map_err
[function]
[call site]
03794
Runtime::locate
[function]
[call site]
03795
async_tests::sentinel_client_async_with_connection_timeout
[function]
[call site]
03796
TestSentinelContext::new
[function]
[call site]
03797
SentinelClient::build
[function]
[call site]
03798
TestSentinelContext::sentinels_connection_info
[function]
[call site]
03799
ClientTlsParams::clone
[function]
[call site]
03800
String::from
[function]
[call site]
03801
Some
[function]
[call site]
03802
TestSentinelContext::sentinel_node_connection_info
[function]
[call site]
03803
RedisResult::unwrap
[function]
[call site]
03804
SentinelClient::build
[function]
[call site]
03805
TestSentinelContext::sentinels_connection_info
[function]
[call site]
03806
ClientTlsParams::clone
[function]
[call site]
03807
String::from
[function]
[call site]
03808
Some
[function]
[call site]
03809
TestSentinelContext::sentinel_node_connection_info
[function]
[call site]
03810
RedisResult::unwrap
[function]
[call site]
03811
AsyncConnectionConfig::new
[function]
[call site]
03812
AsyncConnectionConfig::set_connection_timeout
[function]
[call site]
03813
Some
[function]
[call site]
03814
Duration::from_secs
[function]
[call site]
03815
SentinelClient::get_async_connection_with_config
[function]
[call site]
03816
async_tests::async_assert_is_connection_to_master
[function]
[call site]
03817
TestSentinelContext::sentinel_node_connection_info
[function]
[call site]
03818
TestSentinelContext::sentinel_mut
[function]
[call site]
03819
&redis::sentinel::Sentinel::async_master_for
[function]
[call site]
03820
Some
[function]
[call site]
03821
SentinelClient::get_async_connection_with_config
[function]
[call site]
03822
async_tests::async_assert_connection_is_replica_of_correct_master
[function]
[call site]
03823
Ok::<(),
[call site]
03824
Err
[function]
[call site]
03825
Some
[function]
[call site]
03826
into
[function]
[call site]
03827
map_err
[function]
[call site]
03828
unwrap_or_else
[function]
[call site]
03829
async_tests::sentinel_client_async_with_connection_timeout
[function]
[call site]
03830
futures_time::time::Duration::from_millis
[function]
[call site]
03831
unwrap
[function]
[call site]
03832
unwrap
[function]
[call site]
03833
to_owned
[function]
[call site]
03834
TlsFilePaths::as_bytes
[function]
[call site]
03835
Cmd::arg
[function]
[call site]
03836
types::test_is_single_arg
[function]
[call site]
03837
types::test_is_single_arg
[function]
[call site]
03838
types::test_is_single_arg
[function]
[call site]
03839
types::test_is_single_arg
[function]
[call site]
03840
RoutingInfo::for_routable
[function]
[call site]
03841
std::collections::HashMap::new
[function]
[call site]
03842
RedisServer::insert
[function]
[call site]
03843
Route
[function]
[call site]
03844
RedisServer::insert
[function]
[call site]
03845
Route
[function]
[call site]
03846
RedisServer::insert
[function]
[call site]
03847
Route
[function]
[call site]
03848
join
[function]
[call site]
03849
std::fs::read_to_string
[function]
[call site]
03850
expect
[function]
[call site]
03851
Option::contains
[function]
[call site]
03852
std::thread::sleep
[function]
[call site]
03853
Duration::from_millis
[function]
[call site]
03854
as_ref
[function]
[call site]
03855
types::test_hashmap
[function]
[call site]
03856
&str::to_string
[function]
[call site]
03857
redis::ConnectionAddr::Tcp
[function]
[call site]
03858
&str::to_string
[function]
[call site]
03859
rand::random::<(u64,
[call site]
03860
redis::ConnectionAddr::Unix
[function]
[call site]
03861
ValueType::from
[function]
[call site]
03862
RedisServer::new_with_addr_tls_modules_and_spawner
[function]
[call site]
03863
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]
03864
unwrap_or_else
[function]
[call site]
03865
Parser::parse_value
[function]
[call site]
03866