Redis client. More...
Classes | |
class | Client |
Redis client. More... | |
class | Config |
class | EmptyTransactionException |
struct | GeoPoint |
struct | MemberScore |
class | NotStartedTransactionException |
struct | Point |
class | Request |
class | RequestDataBase |
class | RequestEval |
class | RequestEvalSha |
class | RequestScanData |
class | RequestScanDataBase |
class | ScanOptionsBase |
class | ScanOptionsTmpl |
struct | ScanReplyElem |
struct | ScanReplyElem< ScanTag::kHscan > |
struct | ScanReplyElem< ScanTag::kScan > |
struct | ScanReplyElem< ScanTag::kSscan > |
struct | ScanReplyElem< ScanTag::kZscan > |
class | ScanRequest |
class | SubscribeClient |
Client that allows subscribing to Redis channel messages. More... | |
class | SubscriptionToken |
RAII subscription guard, that is usually retrieved from storages::redis::SubscribeClient. More... | |
struct | To |
class | Transaction |
Typedefs | |
using | RetryNilFromMaster = ::redis::RetryNilFromMaster |
using | ClientPtr = std::shared_ptr< Client > |
using | SubscribeClientPtr = std::shared_ptr< SubscribeClient > |
using | Longitude = ::redis::Longitude |
using | Latitude = ::redis::Latitude |
using | BoxWidth = ::redis::BoxWidth |
using | BoxHeight = ::redis::BoxHeight |
using | CommandControl = ::redis::CommandControl |
using | RangeOptions = ::redis::RangeOptions |
using | GeoaddArg = ::redis::GeoaddArg |
using | GeoradiusOptions = ::redis::GeoradiusOptions |
using | GeosearchOptions = ::redis::GeosearchOptions |
using | ZaddOptions = ::redis::ZaddOptions |
using | ScanOptions = ScanOptionsTmpl< ScanTag::kScan > |
using | SscanOptions = ScanOptionsTmpl< ScanTag::kSscan > |
using | HscanOptions = ScanOptionsTmpl< ScanTag::kHscan > |
using | ZscanOptions = ScanOptionsTmpl< ScanTag::kZscan > |
using | ReplyData = ::redis::ReplyData |
using | Reply = ::redis::Reply |
using | ReplyPtr = std::shared_ptr< Reply > |
using | ExpireReply = ::redis::ExpireReply |
using | TtlReply = ::redis::TtlReply |
using | RequestAppend = Request< size_t > |
using | RequestDbsize = Request< size_t > |
using | RequestDel = Request< size_t > |
using | RequestUnlink = Request< size_t > |
using | RequestEvalCommon = Request< ReplyData > |
using | RequestEvalShaCommon = Request< ReplyData > |
using | RequestScriptLoad = Request< std::string > |
using | RequestExec = Request< ReplyData, void > |
using | RequestExists = Request< size_t > |
using | RequestExpire = Request< ExpireReply > |
using | RequestGeoadd = Request< size_t > |
using | RequestGeoradius = Request< std::vector< GeoPoint > > |
using | RequestGeosearch = Request< std::vector< GeoPoint > > |
using | RequestGet = Request< std::optional< std::string > > |
using | RequestGetset = Request< std::optional< std::string > > |
using | RequestHdel = Request< size_t > |
using | RequestHexists = Request< size_t > |
using | RequestHget = Request< std::optional< std::string > > |
using | RequestHgetall = Request< std::unordered_map< std::string, std::string > > |
using | RequestHincrby = Request< int64_t > |
using | RequestHincrbyfloat = Request< double > |
using | RequestHkeys = Request< std::vector< std::string > > |
using | RequestHlen = Request< size_t > |
using | RequestHmget = Request< std::vector< std::optional< std::string > > > |
using | RequestHmset = Request< StatusOk, void > |
using | RequestHscan = ScanRequest< ScanTag::kHscan > |
using | RequestHset = Request< HsetReply > |
using | RequestHsetnx = Request< size_t, bool > |
using | RequestHvals = Request< std::vector< std::string > > |
using | RequestIncr = Request< int64_t > |
using | RequestKeys = Request< std::vector< std::string > > |
using | RequestLindex = Request< std::optional< std::string > > |
using | RequestLlen = Request< size_t > |
using | RequestLpop = Request< std::optional< std::string > > |
using | RequestLpush = Request< size_t > |
using | RequestLpushx = Request< size_t > |
using | RequestLrange = Request< std::vector< std::string > > |
using | RequestLrem = Request< size_t > |
using | RequestLtrim = Request< StatusOk, void > |
using | RequestMget = Request< std::vector< std::optional< std::string > > > |
using | RequestMset = Request< StatusOk, void > |
using | RequestPersist = Request< PersistReply > |
using | RequestPexpire = Request< ExpireReply > |
using | RequestPing = Request< StatusPong, void > |
using | RequestPingMessage = Request< std::string > |
using | RequestPublish = Request< size_t > |
using | RequestRename = Request< StatusOk, void > |
using | RequestRpop = Request< std::optional< std::string > > |
using | RequestRpush = Request< size_t > |
using | RequestRpushx = Request< size_t > |
using | RequestSadd = Request< size_t > |
using | RequestScan = ScanRequest< ScanTag::kScan > |
using | RequestScard = Request< size_t > |
using | RequestSet = Request< StatusOk, void > |
using | RequestSetIfExist = Request< std::optional< StatusOk >, bool > |
using | RequestSetIfNotExist = Request< std::optional< StatusOk >, bool > |
using | RequestSetOptions = Request< SetReply > |
using | RequestSetex = Request< StatusOk, void > |
using | RequestSismember = Request< size_t > |
using | RequestSmembers = Request< std::unordered_set< std::string > > |
using | RequestSrandmember = Request< std::optional< std::string > > |
using | RequestSrandmembers = Request< std::vector< std::string > > |
using | RequestSrem = Request< size_t > |
using | RequestSscan = ScanRequest< ScanTag::kSscan > |
using | RequestStrlen = Request< size_t > |
using | RequestTime = Request< std::chrono::system_clock::time_point > |
using | RequestTtl = Request< TtlReply > |
using | RequestType = Request< KeyType > |
using | RequestZadd = Request< size_t > |
using | RequestZaddIncr = Request< double > |
using | RequestZaddIncrExisting = Request< std::optional< double > > |
using | RequestZcard = Request< size_t > |
using | RequestZcount = Request< size_t > |
using | RequestZrange = Request< std::vector< std::string > > |
using | RequestZrangeWithScores = Request< std::vector< MemberScore > > |
using | RequestZrangebyscore = Request< std::vector< std::string > > |
using | RequestZrangebyscoreWithScores = Request< std::vector< MemberScore > > |
using | RequestZrem = Request< size_t > |
using | RequestZremrangebyrank = Request< size_t > |
using | RequestZremrangebyscore = Request< size_t > |
using | RequestZscan = ScanRequest< ScanTag::kZscan > |
using | RequestZscore = Request< std::optional< double > > |
using | TransactionPtr = std::unique_ptr< Transaction > |
Functions | |
std::string | CreateTmpKey (const std::string &key, std::string prefix) |
void | PutArg (::redis::CmdArgs::CmdArgsArray &args_, std::optional< ScanOptionsBase::Match > arg) |
void | PutArg (::redis::CmdArgs::CmdArgsArray &args_, std::optional< ScanOptionsBase::Count > arg) |
KeyType | ParseKeyType (std::string_view str) |
std::string | ToString (KeyType key_type) |
std::vector< std::string > | ParseReplyDataArray (ReplyData &&array_data, const std::string &request_description, To< std::vector< std::string > >) |
std::vector< std::optional< std::string > > | ParseReplyDataArray (ReplyData &&array_data, const std::string &request_description, To< std::vector< std::optional< std::string > > >) |
std::vector< std::pair< std::string, std::string > > | ParseReplyDataArray (ReplyData &&array_data, const std::string &request_description, To< std::vector< std::pair< std::string, std::string > > >) |
std::vector< MemberScore > | ParseReplyDataArray (ReplyData &&array_data, const std::string &request_description, To< std::vector< MemberScore > >) |
std::vector< GeoPoint > | ParseReplyDataArray (ReplyData &&array_data, const std::string &request_description, To< std::vector< GeoPoint > >) |
std::string | Parse (ReplyData &&reply_data, const std::string &request_description, To< std::string >) |
double | Parse (ReplyData &&reply_data, const std::string &request_description, To< double >) |
size_t | Parse (ReplyData &&reply_data, const std::string &request_description, To< size_t >) |
bool | Parse (ReplyData &&reply_data, const std::string &request_description, To< size_t, bool >) |
int64_t | Parse (ReplyData &&reply_data, const std::string &request_description, To< int64_t >) |
std::chrono::system_clock::time_point | Parse (ReplyData &&reply_data, const std::string &request_description, To< std::chrono::system_clock::time_point >) |
HsetReply | Parse (ReplyData &&reply_data, const std::string &request_description, To< HsetReply >) |
PersistReply | Parse (ReplyData &&reply_data, const std::string &request_description, To< PersistReply >) |
KeyType | Parse (ReplyData &&reply_data, const std::string &request_description, To< KeyType >) |
void | Parse (ReplyData &&reply_data, const std::string &request_description, To< StatusOk, void >) |
bool | Parse (ReplyData &&reply_data, const std::string &request_description, To< std::optional< StatusOk >, bool >) |
void | Parse (ReplyData &&reply_data, const std::string &request_description, To< StatusPong, void >) |
SetReply | Parse (ReplyData &&reply_data, const std::string &request_description, To< SetReply >) |
std::unordered_set< std::string > | Parse (ReplyData &&reply_data, const std::string &request_description, To< std::unordered_set< std::string > >) |
std::unordered_map< std::string, std::string > | Parse (ReplyData &&reply_data, const std::string &request_description, To< std::unordered_map< std::string, std::string > >) |
ReplyData | Parse (ReplyData &&reply_data, const std::string &request_description, To< ReplyData >) |
template<typename Result , typename ReplyType = Result> | |
std::enable_if_t< impl::HasParseFunctionFromRedisReply< Result, ReplyType >::value, ReplyType > | Parse (ReplyData &&reply_data, const std::string &request_description, To< Result, ReplyType >) |
template<typename T > | |
std::vector< T > | Parse (ReplyData &&reply_data, const std::string &request_description, To< std::vector< T > >) |
template<typename T > | |
std::optional< T > | Parse (ReplyData &&reply_data, const std::string &request_description, To< std::optional< T > >) |
template<typename Result , typename ReplyType = Result> | |
ReplyType | ParseReply (ReplyPtr reply, const std::string &request_description={}) |
Variables | |
constexpr RetryNilFromMaster | kRetryNilFromMaster {} |
Redis client.
using storages::redis::BoxHeight = typedef ::redis::BoxHeight |
Definition at line 19 of file command_options.hpp.
using storages::redis::BoxWidth = typedef ::redis::BoxWidth |
Definition at line 18 of file command_options.hpp.
using storages::redis::ClientPtr = typedef std::shared_ptr<Client> |
Definition at line 10 of file client_fwd.hpp.
using storages::redis::CommandControl = typedef ::redis::CommandControl |
Definition at line 20 of file command_options.hpp.
using storages::redis::ExpireReply = typedef ::redis::ExpireReply |
Definition at line 19 of file reply_types.hpp.
using storages::redis::GeoaddArg = typedef ::redis::GeoaddArg |
Definition at line 22 of file command_options.hpp.
using storages::redis::GeoradiusOptions = typedef ::redis::GeoradiusOptions |
Definition at line 23 of file command_options.hpp.
using storages::redis::GeosearchOptions = typedef ::redis::GeosearchOptions |
Definition at line 24 of file command_options.hpp.
using storages::redis::HscanOptions = typedef ScanOptionsTmpl<ScanTag::kHscan> |
Definition at line 93 of file command_options.hpp.
using storages::redis::Latitude = typedef ::redis::Latitude |
Definition at line 17 of file command_options.hpp.
using storages::redis::Longitude = typedef ::redis::Longitude |
Definition at line 16 of file command_options.hpp.
using storages::redis::RangeOptions = typedef ::redis::RangeOptions |
Definition at line 21 of file command_options.hpp.
using storages::redis::Reply = typedef ::redis::Reply |
Definition at line 15 of file reply_fwd.hpp.
using storages::redis::ReplyData = typedef ::redis::ReplyData |
Definition at line 14 of file reply_fwd.hpp.
using storages::redis::ReplyPtr = typedef std::shared_ptr<Reply> |
Definition at line 17 of file reply_fwd.hpp.
using storages::redis::RequestAppend = typedef Request<size_t> |
Definition at line 145 of file request.hpp.
using storages::redis::RequestDbsize = typedef Request<size_t> |
Definition at line 146 of file request.hpp.
using storages::redis::RequestDel = typedef Request<size_t> |
Definition at line 147 of file request.hpp.
using storages::redis::RequestEvalCommon = typedef Request<ReplyData> |
Definition at line 149 of file request.hpp.
using storages::redis::RequestEvalShaCommon = typedef Request<ReplyData> |
Definition at line 150 of file request.hpp.
using storages::redis::RequestExec = typedef Request<ReplyData, void> |
Definition at line 152 of file request.hpp.
using storages::redis::RequestExists = typedef Request<size_t> |
Definition at line 153 of file request.hpp.
using storages::redis::RequestExpire = typedef Request<ExpireReply> |
Definition at line 154 of file request.hpp.
using storages::redis::RequestGeoadd = typedef Request<size_t> |
Definition at line 155 of file request.hpp.
using storages::redis::RequestGeoradius = typedef Request<std::vector<GeoPoint> > |
Definition at line 156 of file request.hpp.
using storages::redis::RequestGeosearch = typedef Request<std::vector<GeoPoint> > |
Definition at line 157 of file request.hpp.
using storages::redis::RequestGet = typedef Request<std::optional<std::string> > |
Definition at line 158 of file request.hpp.
using storages::redis::RequestGetset = typedef Request<std::optional<std::string> > |
Definition at line 159 of file request.hpp.
using storages::redis::RequestHdel = typedef Request<size_t> |
Definition at line 160 of file request.hpp.
using storages::redis::RequestHexists = typedef Request<size_t> |
Definition at line 161 of file request.hpp.
using storages::redis::RequestHget = typedef Request<std::optional<std::string> > |
Definition at line 162 of file request.hpp.
using storages::redis::RequestHgetall = typedef Request<std::unordered_map<std::string, std::string> > |
Definition at line 163 of file request.hpp.
using storages::redis::RequestHincrby = typedef Request<int64_t> |
Definition at line 164 of file request.hpp.
using storages::redis::RequestHincrbyfloat = typedef Request<double> |
Definition at line 165 of file request.hpp.
using storages::redis::RequestHkeys = typedef Request<std::vector<std::string> > |
Definition at line 166 of file request.hpp.
using storages::redis::RequestHlen = typedef Request<size_t> |
Definition at line 167 of file request.hpp.
using storages::redis::RequestHmget = typedef Request<std::vector<std::optional<std::string> >> |
Definition at line 168 of file request.hpp.
using storages::redis::RequestHmset = typedef Request<StatusOk, void> |
Definition at line 169 of file request.hpp.
using storages::redis::RequestHscan = typedef ScanRequest<ScanTag::kHscan> |
Definition at line 170 of file request.hpp.
using storages::redis::RequestHset = typedef Request<HsetReply> |
Definition at line 171 of file request.hpp.
using storages::redis::RequestHsetnx = typedef Request<size_t, bool> |
Definition at line 172 of file request.hpp.
using storages::redis::RequestHvals = typedef Request<std::vector<std::string> > |
Definition at line 173 of file request.hpp.
using storages::redis::RequestIncr = typedef Request<int64_t> |
Definition at line 174 of file request.hpp.
using storages::redis::RequestKeys = typedef Request<std::vector<std::string> > |
Definition at line 175 of file request.hpp.
using storages::redis::RequestLindex = typedef Request<std::optional<std::string> > |
Definition at line 176 of file request.hpp.
using storages::redis::RequestLlen = typedef Request<size_t> |
Definition at line 177 of file request.hpp.
using storages::redis::RequestLpop = typedef Request<std::optional<std::string> > |
Definition at line 178 of file request.hpp.
using storages::redis::RequestLpush = typedef Request<size_t> |
Definition at line 179 of file request.hpp.
using storages::redis::RequestLpushx = typedef Request<size_t> |
Definition at line 180 of file request.hpp.
using storages::redis::RequestLrange = typedef Request<std::vector<std::string> > |
Definition at line 181 of file request.hpp.
using storages::redis::RequestLrem = typedef Request<size_t> |
Definition at line 182 of file request.hpp.
using storages::redis::RequestLtrim = typedef Request<StatusOk, void> |
Definition at line 183 of file request.hpp.
using storages::redis::RequestMget = typedef Request<std::vector<std::optional<std::string> >> |
Definition at line 184 of file request.hpp.
using storages::redis::RequestMset = typedef Request<StatusOk, void> |
Definition at line 185 of file request.hpp.
using storages::redis::RequestPersist = typedef Request<PersistReply> |
Definition at line 186 of file request.hpp.
using storages::redis::RequestPexpire = typedef Request<ExpireReply> |
Definition at line 187 of file request.hpp.
using storages::redis::RequestPing = typedef Request<StatusPong, void> |
Definition at line 188 of file request.hpp.
using storages::redis::RequestPingMessage = typedef Request<std::string> |
Definition at line 189 of file request.hpp.
using storages::redis::RequestPublish = typedef Request<size_t> |
Definition at line 190 of file request.hpp.
using storages::redis::RequestRename = typedef Request<StatusOk, void> |
Definition at line 191 of file request.hpp.
using storages::redis::RequestRpop = typedef Request<std::optional<std::string> > |
Definition at line 192 of file request.hpp.
using storages::redis::RequestRpush = typedef Request<size_t> |
Definition at line 193 of file request.hpp.
using storages::redis::RequestRpushx = typedef Request<size_t> |
Definition at line 194 of file request.hpp.
using storages::redis::RequestSadd = typedef Request<size_t> |
Definition at line 195 of file request.hpp.
using storages::redis::RequestScan = typedef ScanRequest<ScanTag::kScan> |
Definition at line 196 of file request.hpp.
using storages::redis::RequestScard = typedef Request<size_t> |
Definition at line 197 of file request.hpp.
using storages::redis::RequestScriptLoad = typedef Request<std::string> |
Definition at line 151 of file request.hpp.
using storages::redis::RequestSet = typedef Request<StatusOk, void> |
Definition at line 198 of file request.hpp.
using storages::redis::RequestSetex = typedef Request<StatusOk, void> |
Definition at line 202 of file request.hpp.
using storages::redis::RequestSetIfExist = typedef Request<std::optional<StatusOk>, bool> |
Definition at line 199 of file request.hpp.
using storages::redis::RequestSetIfNotExist = typedef Request<std::optional<StatusOk>, bool> |
Definition at line 200 of file request.hpp.
using storages::redis::RequestSetOptions = typedef Request<SetReply> |
Definition at line 201 of file request.hpp.
using storages::redis::RequestSismember = typedef Request<size_t> |
Definition at line 203 of file request.hpp.
using storages::redis::RequestSmembers = typedef Request<std::unordered_set<std::string> > |
Definition at line 204 of file request.hpp.
using storages::redis::RequestSrandmember = typedef Request<std::optional<std::string> > |
Definition at line 205 of file request.hpp.
using storages::redis::RequestSrandmembers = typedef Request<std::vector<std::string> > |
Definition at line 206 of file request.hpp.
using storages::redis::RequestSrem = typedef Request<size_t> |
Definition at line 207 of file request.hpp.
using storages::redis::RequestSscan = typedef ScanRequest<ScanTag::kSscan> |
Definition at line 208 of file request.hpp.
using storages::redis::RequestStrlen = typedef Request<size_t> |
Definition at line 209 of file request.hpp.
using storages::redis::RequestTime = typedef Request<std::chrono::system_clock::time_point> |
Definition at line 210 of file request.hpp.
using storages::redis::RequestTtl = typedef Request<TtlReply> |
Definition at line 211 of file request.hpp.
using storages::redis::RequestType = typedef Request<KeyType> |
Definition at line 212 of file request.hpp.
using storages::redis::RequestUnlink = typedef Request<size_t> |
Definition at line 148 of file request.hpp.
using storages::redis::RequestZadd = typedef Request<size_t> |
Definition at line 213 of file request.hpp.
using storages::redis::RequestZaddIncr = typedef Request<double> |
Definition at line 214 of file request.hpp.
using storages::redis::RequestZaddIncrExisting = typedef Request<std::optional<double> > |
Definition at line 215 of file request.hpp.
using storages::redis::RequestZcard = typedef Request<size_t> |
Definition at line 216 of file request.hpp.
using storages::redis::RequestZcount = typedef Request<size_t> |
Definition at line 217 of file request.hpp.
using storages::redis::RequestZrange = typedef Request<std::vector<std::string> > |
Definition at line 218 of file request.hpp.
using storages::redis::RequestZrangebyscore = typedef Request<std::vector<std::string> > |
Definition at line 220 of file request.hpp.
using storages::redis::RequestZrangebyscoreWithScores = typedef Request<std::vector<MemberScore> > |
Definition at line 221 of file request.hpp.
using storages::redis::RequestZrangeWithScores = typedef Request<std::vector<MemberScore> > |
Definition at line 219 of file request.hpp.
using storages::redis::RequestZrem = typedef Request<size_t> |
Definition at line 222 of file request.hpp.
using storages::redis::RequestZremrangebyrank = typedef Request<size_t> |
Definition at line 223 of file request.hpp.
using storages::redis::RequestZremrangebyscore = typedef Request<size_t> |
Definition at line 224 of file request.hpp.
using storages::redis::RequestZscan = typedef ScanRequest<ScanTag::kZscan> |
Definition at line 225 of file request.hpp.
using storages::redis::RequestZscore = typedef Request<std::optional<double> > |
Definition at line 226 of file request.hpp.
using storages::redis::RetryNilFromMaster = typedef ::redis::RetryNilFromMaster |
Definition at line 29 of file client.hpp.
using storages::redis::ScanOptions = typedef ScanOptionsTmpl<ScanTag::kScan> |
Definition at line 91 of file command_options.hpp.
using storages::redis::SscanOptions = typedef ScanOptionsTmpl<ScanTag::kSscan> |
Definition at line 92 of file command_options.hpp.
using storages::redis::SubscribeClientPtr = typedef std::shared_ptr<SubscribeClient> |
Definition at line 13 of file client_fwd.hpp.
using storages::redis::TransactionPtr = typedef std::unique_ptr<Transaction> |
Definition at line 305 of file transaction.hpp.
using storages::redis::TtlReply = typedef ::redis::TtlReply |
Definition at line 112 of file reply_types.hpp.
using storages::redis::ZaddOptions = typedef ::redis::ZaddOptions |
Definition at line 25 of file command_options.hpp.
using storages::redis::ZscanOptions = typedef ScanOptionsTmpl<ScanTag::kZscan> |
Definition at line 94 of file command_options.hpp.
|
strong |
Definition at line 21 of file reply_types.hpp.
|
strong |
Definition at line 10 of file key_type.hpp.
|
strong |
Definition at line 81 of file reply_types.hpp.
|
strong |
Definition at line 24 of file client.hpp.
|
strong |
Definition at line 7 of file scan_tag.hpp.
|
strong |
Definition at line 106 of file reply_types.hpp.
|
strong |
Definition at line 108 of file reply_types.hpp.
|
strong |
Definition at line 110 of file reply_types.hpp.
std::enable_if_t< impl::HasParseFunctionFromRedisReply< Result, ReplyType >::value, ReplyType > storages::redis::Parse | ( | ReplyData && | reply_data, |
const std::string & | request_description, | ||
To< Result, ReplyType > | |||
) |
Definition at line 128 of file parse_reply.hpp.
std::optional< T > storages::redis::Parse | ( | ReplyData && | reply_data, |
const std::string & | request_description, | ||
To< std::optional< T > > | |||
) |
Definition at line 143 of file parse_reply.hpp.
std::vector< T > storages::redis::Parse | ( | ReplyData && | reply_data, |
const std::string & | request_description, | ||
To< std::vector< T > > | |||
) |
Definition at line 134 of file parse_reply.hpp.
ReplyType storages::redis::ParseReply | ( | ReplyPtr | reply, |
const std::string & | request_description = {} |
||
) |
Definition at line 151 of file parse_reply.hpp.
|
inlineconstexpr |
Definition at line 31 of file client.hpp.