userver: userver/storages/redis/hedged_request.hpp File Reference
Loading...
Searching...
No Matches
hedged_request.hpp File Reference

Detailed Description

Classes and functions for performing hedged requests.

Use MakeHedgedRedisRequest method to perform hedged redis request.

Example(Sync): auto result = ::redis::MakeHedgedRedisRequest<storages::redis::RequestHGet>( redis_client_shared_ptr, &storages::redis::Client::Hget, redis_cc, hedging_settings, key, field); Example(Async): auto future = ::redis::MakeHedgedRedisRequestAsync<storages::redis::RequestHGet>( redis_client_shared_ptr, &storages::redis::Client::Hget, redis_cc, hedging_settings, key, field); auto result = future.Get();

Definition in file hedged_request.hpp.

Go to the source code of this file.

Typedefs

template<typename RedisRequestType >
using redis::HedgedRedisRequest
 

Functions

template<typename RedisRequestType , typename... Args, typename M = RedisRequestType (storages::redis::Client::*)( Args..., const redis::CommandControl&)>
HedgedRedisRequest< RedisRequestType > redis::MakeHedgedRedisRequestAsync (std::shared_ptr< storages::redis::Client > redis, M method, const redis::CommandControl &cc, utils::hedging::HedgingSettings hedging_settings, Args... args)
 
template<typename RedisRequestType , typename... Args, typename M = RedisRequestType (storages::redis::Client::*)( Args..., const redis::CommandControl&)>
std::optional< typename RedisRequestType::Reply > redis::MakeHedgedRedisRequest (std::shared_ptr< storages::redis::Client > redis, M method, const redis::CommandControl &cc, utils::hedging::HedgingSettings hedging_settings, Args... args)
 
template<typename RedisRequestType , typename... Args, typename M = RedisRequestType (storages::redis::Client::*)( Args..., const redis::CommandControl&)>
std::vector< std::optional< typename RedisRequestType::Reply > > redis::MakeBulkHedgedRedisRequest (std::shared_ptr< storages::redis::Client > redis, M method, const redis::CommandControl &cc, utils::hedging::HedgingSettings hedging_settings, std::vector< std::tuple< Args... > > args)
 
template<typename RedisRequestType , typename... Args, typename M = RedisRequestType (storages::redis::Client::*)( Args..., const redis::CommandControl&)>
utils::hedging::HedgedRequestBulkFuture< redis::impl::RedisRequestStrategy< RedisRequestType > > redis::MakeBulkHedgedRedisRequestAsync (std::shared_ptr< storages::redis::Client > redis, M method, const redis::CommandControl &cc, utils::hedging::HedgingSettings hedging_settings, std::vector< std::tuple< Args... > > args)
 

Typedef Documentation

◆ HedgedRedisRequest

template<typename RedisRequestType >
using redis::HedgedRedisRequest
Initial value:
impl::RedisRequestStrategy<RedisRequestType>>

Definition at line 70 of file hedged_request.hpp.

Function Documentation

◆ MakeBulkHedgedRedisRequest()

template<typename RedisRequestType , typename... Args, typename M = RedisRequestType (storages::redis::Client::*)( Args..., const redis::CommandControl&)>
std::vector< std::optional< typename RedisRequestType::Reply > > redis::MakeBulkHedgedRedisRequest ( std::shared_ptr< storages::redis::Client > redis,
M method,
const redis::CommandControl & cc,
utils::hedging::HedgingSettings hedging_settings,
std::vector< std::tuple< Args... > > args )

Same as MakeHedgedRedisRequest but accepting a vector of argument tuples instead of a single set of arguments. And return vector of replies corresponding to input args.

< We do retries ourselves

Definition at line 134 of file hedged_request.hpp.

◆ MakeBulkHedgedRedisRequestAsync()

template<typename RedisRequestType , typename... Args, typename M = RedisRequestType (storages::redis::Client::*)( Args..., const redis::CommandControl&)>
utils::hedging::HedgedRequestBulkFuture< redis::impl::RedisRequestStrategy< RedisRequestType > > redis::MakeBulkHedgedRedisRequestAsync ( std::shared_ptr< storages::redis::Client > redis,
M method,
const redis::CommandControl & cc,
utils::hedging::HedgingSettings hedging_settings,
std::vector< std::tuple< Args... > > args )

Same as MakeHedgedRedisRequestAsync but accepting a vector of argument tuples instead of a single set of arguments. And return vector of replies corresponding to input args.

< We do retries ourselves

Definition at line 169 of file hedged_request.hpp.

◆ MakeHedgedRedisRequest()

template<typename RedisRequestType , typename... Args, typename M = RedisRequestType (storages::redis::Client::*)( Args..., const redis::CommandControl&)>
std::optional< typename RedisRequestType::Reply > redis::MakeHedgedRedisRequest ( std::shared_ptr< storages::redis::Client > redis,
M method,
const redis::CommandControl & cc,
utils::hedging::HedgingSettings hedging_settings,
Args... args )

< We do retries ourselves

Definition at line 105 of file hedged_request.hpp.

◆ MakeHedgedRedisRequestAsync()

template<typename RedisRequestType , typename... Args, typename M = RedisRequestType (storages::redis::Client::*)( Args..., const redis::CommandControl&)>
HedgedRedisRequest< RedisRequestType > redis::MakeHedgedRedisRequestAsync ( std::shared_ptr< storages::redis::Client > redis,
M method,
const redis::CommandControl & cc,
utils::hedging::HedgingSettings hedging_settings,
Args... args )

< We do retries ourselves

Definition at line 76 of file hedged_request.hpp.