Redis client.
Classes | |
class | Client |
Redis client. More... | |
struct | 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 | RequestBitop = Request<size_t> |
using | RequestDbsize = Request<size_t> |
using | RequestDecr = Request<int64_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 | ToString (BitOperation bitop) |
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 {} |
const dynamic_config::Key< Config > | kConfig |
using storages::redis::BoxHeight = ::redis::BoxHeight |
Definition at line 19 of file command_options.hpp.
using storages::redis::BoxWidth = ::redis::BoxWidth |
Definition at line 18 of file command_options.hpp.
using storages::redis::ClientPtr = std::shared_ptr<Client> |
Definition at line 10 of file client_fwd.hpp.
using storages::redis::CommandControl = ::redis::CommandControl |
Definition at line 20 of file command_options.hpp.
using storages::redis::ExpireReply = ::redis::ExpireReply |
Definition at line 19 of file reply_types.hpp.
using storages::redis::GeoaddArg = ::redis::GeoaddArg |
Definition at line 22 of file command_options.hpp.
using storages::redis::GeoradiusOptions = ::redis::GeoradiusOptions |
Definition at line 23 of file command_options.hpp.
using storages::redis::GeosearchOptions = ::redis::GeosearchOptions |
Definition at line 24 of file command_options.hpp.
using storages::redis::HscanOptions = ScanOptionsTmpl<ScanTag::kHscan> |
Definition at line 89 of file command_options.hpp.
using storages::redis::Latitude = ::redis::Latitude |
Definition at line 17 of file command_options.hpp.
using storages::redis::Longitude = ::redis::Longitude |
Definition at line 16 of file command_options.hpp.
using storages::redis::RangeOptions = ::redis::RangeOptions |
Definition at line 21 of file command_options.hpp.
using storages::redis::Reply = ::redis::Reply |
Definition at line 15 of file reply_fwd.hpp.
using storages::redis::ReplyData = ::redis::ReplyData |
Definition at line 14 of file reply_fwd.hpp.
using storages::redis::ReplyPtr = std::shared_ptr<Reply> |
Definition at line 17 of file reply_fwd.hpp.
using storages::redis::RequestAppend = Request<size_t> |
Definition at line 144 of file request.hpp.
using storages::redis::RequestBitop = Request<size_t> |
Definition at line 145 of file request.hpp.
using storages::redis::RequestDbsize = Request<size_t> |
Definition at line 146 of file request.hpp.
using storages::redis::RequestDecr = Request<int64_t> |
Definition at line 147 of file request.hpp.
using storages::redis::RequestDel = Request<size_t> |
Definition at line 148 of file request.hpp.
using storages::redis::RequestEvalCommon = Request<ReplyData> |
Definition at line 150 of file request.hpp.
using storages::redis::RequestEvalShaCommon = Request<ReplyData> |
Definition at line 151 of file request.hpp.
using storages::redis::RequestExec = Request<ReplyData, void> |
Definition at line 153 of file request.hpp.
using storages::redis::RequestExists = Request<size_t> |
Definition at line 154 of file request.hpp.
using storages::redis::RequestExpire = Request<ExpireReply> |
Definition at line 155 of file request.hpp.
using storages::redis::RequestGeoadd = Request<size_t> |
Definition at line 156 of file request.hpp.
using storages::redis::RequestGeoradius = Request<std::vector<GeoPoint>> |
Definition at line 157 of file request.hpp.
using storages::redis::RequestGeosearch = Request<std::vector<GeoPoint>> |
Definition at line 158 of file request.hpp.
using storages::redis::RequestGet = Request<std::optional<std::string>> |
Definition at line 159 of file request.hpp.
using storages::redis::RequestGetset = Request<std::optional<std::string>> |
Definition at line 160 of file request.hpp.
using storages::redis::RequestHdel = Request<size_t> |
Definition at line 161 of file request.hpp.
using storages::redis::RequestHexists = Request<size_t> |
Definition at line 162 of file request.hpp.
using storages::redis::RequestHget = Request<std::optional<std::string>> |
Definition at line 163 of file request.hpp.
using storages::redis::RequestHgetall = Request<std::unordered_map<std::string, std::string>> |
Definition at line 164 of file request.hpp.
using storages::redis::RequestHincrby = Request<int64_t> |
Definition at line 165 of file request.hpp.
using storages::redis::RequestHincrbyfloat = Request<double> |
Definition at line 166 of file request.hpp.
using storages::redis::RequestHkeys = Request<std::vector<std::string>> |
Definition at line 167 of file request.hpp.
using storages::redis::RequestHlen = Request<size_t> |
Definition at line 168 of file request.hpp.
using storages::redis::RequestHmget = Request<std::vector<std::optional<std::string>>> |
Definition at line 169 of file request.hpp.
using storages::redis::RequestHmset = Request<StatusOk, void> |
Definition at line 170 of file request.hpp.
using storages::redis::RequestHscan = ScanRequest<ScanTag::kHscan> |
Definition at line 171 of file request.hpp.
using storages::redis::RequestHset = Request<HsetReply> |
Definition at line 172 of file request.hpp.
using storages::redis::RequestHsetnx = Request<size_t, bool> |
Definition at line 173 of file request.hpp.
using storages::redis::RequestHvals = Request<std::vector<std::string>> |
Definition at line 174 of file request.hpp.
using storages::redis::RequestIncr = Request<int64_t> |
Definition at line 175 of file request.hpp.
using storages::redis::RequestKeys = Request<std::vector<std::string>> |
Definition at line 176 of file request.hpp.
using storages::redis::RequestLindex = Request<std::optional<std::string>> |
Definition at line 177 of file request.hpp.
using storages::redis::RequestLlen = Request<size_t> |
Definition at line 178 of file request.hpp.
using storages::redis::RequestLpop = Request<std::optional<std::string>> |
Definition at line 179 of file request.hpp.
using storages::redis::RequestLpush = Request<size_t> |
Definition at line 180 of file request.hpp.
using storages::redis::RequestLpushx = Request<size_t> |
Definition at line 181 of file request.hpp.
using storages::redis::RequestLrange = Request<std::vector<std::string>> |
Definition at line 182 of file request.hpp.
using storages::redis::RequestLrem = Request<size_t> |
Definition at line 183 of file request.hpp.
using storages::redis::RequestLtrim = Request<StatusOk, void> |
Definition at line 184 of file request.hpp.
using storages::redis::RequestMget = Request<std::vector<std::optional<std::string>>> |
Definition at line 185 of file request.hpp.
using storages::redis::RequestMset = Request<StatusOk, void> |
Definition at line 186 of file request.hpp.
using storages::redis::RequestPersist = Request<PersistReply> |
Definition at line 187 of file request.hpp.
using storages::redis::RequestPexpire = Request<ExpireReply> |
Definition at line 188 of file request.hpp.
using storages::redis::RequestPing = Request<StatusPong, void> |
Definition at line 189 of file request.hpp.
using storages::redis::RequestPingMessage = Request<std::string> |
Definition at line 190 of file request.hpp.
using storages::redis::RequestPublish = Request<size_t> |
Definition at line 191 of file request.hpp.
using storages::redis::RequestRename = Request<StatusOk, void> |
Definition at line 192 of file request.hpp.
using storages::redis::RequestRpop = Request<std::optional<std::string>> |
Definition at line 193 of file request.hpp.
using storages::redis::RequestRpush = Request<size_t> |
Definition at line 194 of file request.hpp.
using storages::redis::RequestRpushx = Request<size_t> |
Definition at line 195 of file request.hpp.
using storages::redis::RequestSadd = Request<size_t> |
Definition at line 196 of file request.hpp.
using storages::redis::RequestScan = ScanRequest<ScanTag::kScan> |
Definition at line 197 of file request.hpp.
using storages::redis::RequestScard = Request<size_t> |
Definition at line 198 of file request.hpp.
using storages::redis::RequestScriptLoad = Request<std::string> |
Definition at line 152 of file request.hpp.
using storages::redis::RequestSet = Request<StatusOk, void> |
Definition at line 199 of file request.hpp.
using storages::redis::RequestSetex = Request<StatusOk, void> |
Definition at line 203 of file request.hpp.
using storages::redis::RequestSetIfExist = Request<std::optional<StatusOk>, bool> |
Definition at line 200 of file request.hpp.
using storages::redis::RequestSetIfNotExist = Request<std::optional<StatusOk>, bool> |
Definition at line 201 of file request.hpp.
using storages::redis::RequestSetOptions = Request<SetReply> |
Definition at line 202 of file request.hpp.
using storages::redis::RequestSismember = Request<size_t> |
Definition at line 204 of file request.hpp.
using storages::redis::RequestSmembers = Request<std::unordered_set<std::string>> |
Definition at line 205 of file request.hpp.
using storages::redis::RequestSrandmember = Request<std::optional<std::string>> |
Definition at line 206 of file request.hpp.
using storages::redis::RequestSrandmembers = Request<std::vector<std::string>> |
Definition at line 207 of file request.hpp.
using storages::redis::RequestSrem = Request<size_t> |
Definition at line 208 of file request.hpp.
using storages::redis::RequestSscan = ScanRequest<ScanTag::kSscan> |
Definition at line 209 of file request.hpp.
using storages::redis::RequestStrlen = Request<size_t> |
Definition at line 210 of file request.hpp.
using storages::redis::RequestTime = Request<std::chrono::system_clock::time_point> |
Definition at line 211 of file request.hpp.
using storages::redis::RequestTtl = Request<TtlReply> |
Definition at line 212 of file request.hpp.
using storages::redis::RequestType = Request<KeyType> |
Definition at line 213 of file request.hpp.
using storages::redis::RequestUnlink = Request<size_t> |
Definition at line 149 of file request.hpp.
using storages::redis::RequestZadd = Request<size_t> |
Definition at line 214 of file request.hpp.
using storages::redis::RequestZaddIncr = Request<double> |
Definition at line 215 of file request.hpp.
using storages::redis::RequestZaddIncrExisting = Request<std::optional<double>> |
Definition at line 216 of file request.hpp.
using storages::redis::RequestZcard = Request<size_t> |
Definition at line 217 of file request.hpp.
using storages::redis::RequestZcount = Request<size_t> |
Definition at line 218 of file request.hpp.
using storages::redis::RequestZrange = Request<std::vector<std::string>> |
Definition at line 219 of file request.hpp.
using storages::redis::RequestZrangebyscore = Request<std::vector<std::string>> |
Definition at line 221 of file request.hpp.
using storages::redis::RequestZrangebyscoreWithScores = Request<std::vector<MemberScore>> |
Definition at line 222 of file request.hpp.
using storages::redis::RequestZrangeWithScores = Request<std::vector<MemberScore>> |
Definition at line 220 of file request.hpp.
using storages::redis::RequestZrem = Request<size_t> |
Definition at line 223 of file request.hpp.
using storages::redis::RequestZremrangebyrank = Request<size_t> |
Definition at line 224 of file request.hpp.
using storages::redis::RequestZremrangebyscore = Request<size_t> |
Definition at line 225 of file request.hpp.
using storages::redis::RequestZscan = ScanRequest<ScanTag::kZscan> |
Definition at line 226 of file request.hpp.
using storages::redis::RequestZscore = Request<std::optional<double>> |
Definition at line 227 of file request.hpp.
using storages::redis::RetryNilFromMaster = ::redis::RetryNilFromMaster |
Definition at line 30 of file client.hpp.
using storages::redis::ScanOptions = ScanOptionsTmpl<ScanTag::kScan> |
Definition at line 87 of file command_options.hpp.
using storages::redis::SscanOptions = ScanOptionsTmpl<ScanTag::kSscan> |
Definition at line 88 of file command_options.hpp.
using storages::redis::SubscribeClientPtr = std::shared_ptr<SubscribeClient> |
Definition at line 13 of file client_fwd.hpp.
using storages::redis::TransactionPtr = std::unique_ptr<Transaction> |
Definition at line 280 of file transaction.hpp.
using storages::redis::TtlReply = ::redis::TtlReply |
Definition at line 99 of file reply_types.hpp.
using storages::redis::ZaddOptions = ::redis::ZaddOptions |
Definition at line 25 of file command_options.hpp.
using storages::redis::ZscanOptions = ScanOptionsTmpl<ScanTag::kZscan> |
Definition at line 90 of file command_options.hpp.
|
strong |
Definition at line 9 of file bit_operation.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 68 of file reply_types.hpp.
|
strong |
Definition at line 25 of file client.hpp.
|
strong |
Definition at line 7 of file scan_tag.hpp.
|
strong |
Definition at line 93 of file reply_types.hpp.
|
strong |
Definition at line 95 of file reply_types.hpp.
|
strong |
Definition at line 97 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 103 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 114 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 108 of file parse_reply.hpp.
ReplyType storages::redis::ParseReply | ( | ReplyPtr | reply, |
const std::string & | request_description = {} ) |
Definition at line 120 of file parse_reply.hpp.
|
inlineconstexpr |
Definition at line 32 of file client.hpp.