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