![]() |
cpp_redis
4.0.0
cpp_redis is a C++11 Asynchronous Multi-Platform Lightweight Redis Client, with support for synchronous operations and pipelining.
|
#include <client.hpp>
Classes | |
struct | command_request |
Public Types | |
enum | client_type { client_type::normal, client_type::master, client_type::pubsub, client_type::slave } |
enum | connect_state { connect_state::dropped, connect_state::start, connect_state::sleeping, connect_state::ok, connect_state::failed, connect_state::lookup_failed, connect_state::stopped } |
typedef std::function< void(const std::string &host, std::size_t port, connect_state status)> | connect_callback_t |
typedef std::function< void(reply &)> | reply_callback_t |
Public Member Functions | |
client (void) | |
ctor More... | |
client (const std::shared_ptr< network::tcp_client_iface > &tcp_client) | |
~client (void) | |
dtor More... | |
client (const client &)=delete | |
copy ctor More... | |
client & | operator= (const client &)=delete |
assignment operator More... | |
void | connect (const std::string &host="127.0.0.1", std::size_t port=6379, const connect_callback_t &connect_callback=nullptr, std::uint32_t timeout_msecs=0, std::int32_t max_reconnects=0, std::uint32_t reconnect_interval_msecs=0) |
void | connect (const std::string &name, const connect_callback_t &connect_callback=nullptr, std::uint32_t timeout_msecs=0, std::int32_t max_reconnects=0, std::uint32_t reconnect_interval_msecs=0) |
bool | is_connected (void) const |
void | disconnect (bool wait_for_removal=false) |
bool | is_reconnecting (void) const |
void | cancel_reconnect (void) |
client & | send (const std::vector< std::string > &redis_cmd, const reply_callback_t &callback) |
std::future< reply > | send (const std::vector< std::string > &redis_cmd) |
client & | commit (void) |
client & | sync_commit (void) |
template<class Rep , class Period > | |
client & | sync_commit (const std::chrono::duration< Rep, Period > &timeout) |
void | add_sentinel (const std::string &host, std::size_t port) |
const sentinel & | get_sentinel (void) const |
sentinel & | get_sentinel (void) |
void | clear_sentinels (void) |
client & | append (const std::string &key, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | append (const std::string &key, const std::string &value) |
client & | auth (const std::string &password, const reply_callback_t &reply_callback) |
std::future< reply > | auth (const std::string &password) |
client & | bgrewriteaof (const reply_callback_t &reply_callback) |
std::future< reply > | bgrewriteaof () |
client & | bgsave (const reply_callback_t &reply_callback) |
std::future< reply > | bgsave () |
client & | bitcount (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | bitcount (const std::string &key) |
client & | bitcount (const std::string &key, int start, int end, const reply_callback_t &reply_callback) |
std::future< reply > | bitcount (const std::string &key, int start, int end) |
client & | bitop (const std::string &operation, const std::string &destkey, const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | bitop (const std::string &operation, const std::string &destkey, const std::vector< std::string > &keys) |
client & | bitpos (const std::string &key, int bit, const reply_callback_t &reply_callback) |
std::future< reply > | bitpos (const std::string &key, int bit) |
client & | bitpos (const std::string &key, int bit, int start, const reply_callback_t &reply_callback) |
std::future< reply > | bitpos (const std::string &key, int bit, int start) |
client & | bitpos (const std::string &key, int bit, int start, int end, const reply_callback_t &reply_callback) |
std::future< reply > | bitpos (const std::string &key, int bit, int start, int end) |
client & | blpop (const std::vector< std::string > &keys, int timeout, const reply_callback_t &reply_callback) |
std::future< reply > | blpop (const std::vector< std::string > &keys, int timeout) |
client & | brpop (const std::vector< std::string > &keys, int timeout, const reply_callback_t &reply_callback) |
std::future< reply > | brpop (const std::vector< std::string > &keys, int timeout) |
client & | brpoplpush (const std::string &src, const std::string &dst, int timeout, const reply_callback_t &reply_callback) |
std::future< reply > | brpoplpush (const std::string &src, const std::string &dst, int timeout) |
template<typename T , typename... Ts> | |
client & | client_kill (const std::string &host, int port, const T &arg, const Ts &... args) |
client & | client_kill (const std::string &host, int port) |
template<typename... Ts> | |
client & | client_kill (const char *host, int port, const Ts &... args) |
template<typename T , typename... Ts> | |
client & | client_kill (const T &, const Ts &...) |
template<typename T , typename... Ts> | |
std::future< reply > | client_kill_future (const T, const Ts...) |
client & | client_list (const reply_callback_t &reply_callback) |
std::future< reply > | client_list () |
client & | client_getname (const reply_callback_t &reply_callback) |
std::future< reply > | client_getname () |
client & | client_pause (int timeout, const reply_callback_t &reply_callback) |
std::future< reply > | client_pause (int timeout) |
client & | client_reply (const std::string &mode, const reply_callback_t &reply_callback) |
std::future< reply > | client_reply (const std::string &mode) |
client & | client_setname (const std::string &name, const reply_callback_t &reply_callback) |
std::future< reply > | client_setname (const std::string &name) |
client & | cluster_addslots (const std::vector< std::string > &p_slots, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_addslots (const std::vector< std::string > &p_slots) |
client & | cluster_count_failure_reports (const std::string &node_id, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_count_failure_reports (const std::string &node_id) |
client & | cluster_countkeysinslot (const std::string &slot, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_countkeysinslot (const std::string &slot) |
client & | cluster_delslots (const std::vector< std::string > &p_slots, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_delslots (const std::vector< std::string > &p_slots) |
client & | cluster_failover (const reply_callback_t &reply_callback) |
std::future< reply > | cluster_failover () |
client & | cluster_failover (const std::string &mode, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_failover (const std::string &mode) |
client & | cluster_forget (const std::string &node_id, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_forget (const std::string &node_id) |
client & | cluster_getkeysinslot (const std::string &slot, int count, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_getkeysinslot (const std::string &slot, int count) |
client & | cluster_info (const reply_callback_t &reply_callback) |
std::future< reply > | cluster_info () |
client & | cluster_keyslot (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_keyslot (const std::string &key) |
client & | cluster_meet (const std::string &ip, int port, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_meet (const std::string &ip, int port) |
client & | cluster_nodes (const reply_callback_t &reply_callback) |
std::future< reply > | cluster_nodes () |
client & | cluster_replicate (const std::string &node_id, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_replicate (const std::string &node_id) |
client & | cluster_reset (const reply_callback_t &reply_callback) |
client & | cluster_reset (const std::string &mode, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_reset (const std::string &mode="soft") |
client & | cluster_saveconfig (const reply_callback_t &reply_callback) |
std::future< reply > | cluster_saveconfig () |
client & | cluster_set_config_epoch (const std::string &epoch, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_set_config_epoch (const std::string &epoch) |
client & | cluster_setslot (const std::string &slot, const std::string &mode, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_setslot (const std::string &slot, const std::string &mode) |
client & | cluster_setslot (const std::string &slot, const std::string &mode, const std::string &node_id, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_setslot (const std::string &slot, const std::string &mode, const std::string &node_id) |
client & | cluster_slaves (const std::string &node_id, const reply_callback_t &reply_callback) |
std::future< reply > | cluster_slaves (const std::string &node_id) |
client & | cluster_slots (const reply_callback_t &reply_callback) |
std::future< reply > | cluster_slots () |
client & | command (const reply_callback_t &reply_callback) |
std::future< reply > | command () |
client & | command_count (const reply_callback_t &reply_callback) |
std::future< reply > | command_count () |
client & | command_getkeys (const reply_callback_t &reply_callback) |
std::future< reply > | command_getkeys () |
client & | command_info (const std::vector< std::string > &command_name, const reply_callback_t &reply_callback) |
std::future< reply > | command_info (const std::vector< std::string > &command_name) |
client & | config_get (const std::string ¶m, const reply_callback_t &reply_callback) |
std::future< reply > | config_get (const std::string ¶m) |
client & | config_rewrite (const reply_callback_t &reply_callback) |
std::future< reply > | config_rewrite () |
client & | config_set (const std::string ¶m, const std::string &val, const reply_callback_t &reply_callback) |
std::future< reply > | config_set (const std::string ¶m, const std::string &val) |
client & | config_resetstat (const reply_callback_t &reply_callback) |
std::future< reply > | config_resetstat () |
client & | dbsize (const reply_callback_t &reply_callback) |
std::future< reply > | dbsize () |
client & | debug_object (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | debug_object (const std::string &key) |
client & | debug_segfault (const reply_callback_t &reply_callback) |
std::future< reply > | debug_segfault () |
client & | decr (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | decr (const std::string &key) |
client & | decrby (const std::string &key, int val, const reply_callback_t &reply_callback) |
std::future< reply > | decrby (const std::string &key, int val) |
client & | del (const std::vector< std::string > &key, const reply_callback_t &reply_callback) |
std::future< reply > | del (const std::vector< std::string > &key) |
client & | discard (const reply_callback_t &reply_callback) |
std::future< reply > | discard () |
client & | dump (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | dump (const std::string &key) |
client & | echo (const std::string &msg, const reply_callback_t &reply_callback) |
std::future< reply > | echo (const std::string &msg) |
client & | eval (const std::string &script, int numkeys, const std::vector< std::string > &keys, const std::vector< std::string > &args, const reply_callback_t &reply_callback) |
std::future< reply > | eval (const std::string &script, int numkeys, const std::vector< std::string > &keys, const std::vector< std::string > &args) |
client & | evalsha (const std::string &sha1, int numkeys, const std::vector< std::string > &keys, const std::vector< std::string > &args, const reply_callback_t &reply_callback) |
std::future< reply > | evalsha (const std::string &sha1, int numkeys, const std::vector< std::string > &keys, const std::vector< std::string > &args) |
client & | exec (const reply_callback_t &reply_callback) |
std::future< reply > | exec () |
client & | exists (const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | exists (const std::vector< std::string > &keys) |
client & | expire (const std::string &key, int seconds, const reply_callback_t &reply_callback) |
std::future< reply > | expire (const std::string &key, int seconds) |
client & | expireat (const std::string &key, int timestamp, const reply_callback_t &reply_callback) |
std::future< reply > | expireat (const std::string &key, int timestamp) |
client & | flushall (const reply_callback_t &reply_callback) |
std::future< reply > | flushall () |
client & | flushdb (const reply_callback_t &reply_callback) |
std::future< reply > | flushdb () |
client & | geoadd (const std::string &key, const std::vector< std::tuple< std::string, std::string, std::string >> &long_lat_memb, const reply_callback_t &reply_callback) |
std::future< reply > | geoadd (const std::string &key, const std::vector< std::tuple< std::string, std::string, std::string >> &long_lat_memb) |
client & | geohash (const std::string &key, const std::vector< std::string > &members, const reply_callback_t &reply_callback) |
std::future< reply > | geohash (const std::string &key, const std::vector< std::string > &members) |
client & | geopos (const std::string &key, const std::vector< std::string > &members, const reply_callback_t &reply_callback) |
std::future< reply > | geopos (const std::string &key, const std::vector< std::string > &members) |
client & | geodist (const std::string &key, const std::string &member_1, const std::string &member_2, const reply_callback_t &reply_callback) |
client & | geodist (const std::string &key, const std::string &member_1, const std::string &member_2, const std::string &unit, const reply_callback_t &reply_callback) |
std::future< reply > | geodist (const std::string &key, const std::string &member_1, const std::string &member_2, const std::string &unit="m") |
client & | get (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | get (const std::string &key) |
client & | getbit (const std::string &key, int offset, const reply_callback_t &reply_callback) |
std::future< reply > | getbit (const std::string &key, int offset) |
client & | getrange (const std::string &key, int start, int end, const reply_callback_t &reply_callback) |
std::future< reply > | getrange (const std::string &key, int start, int end) |
client & | getset (const std::string &key, const std::string &val, const reply_callback_t &reply_callback) |
std::future< reply > | getset (const std::string &key, const std::string &val) |
client & | hdel (const std::string &key, const std::vector< std::string > &fields, const reply_callback_t &reply_callback) |
std::future< reply > | hdel (const std::string &key, const std::vector< std::string > &fields) |
client & | hexists (const std::string &key, const std::string &field, const reply_callback_t &reply_callback) |
std::future< reply > | hexists (const std::string &key, const std::string &field) |
client & | hget (const std::string &key, const std::string &field, const reply_callback_t &reply_callback) |
std::future< reply > | hget (const std::string &key, const std::string &field) |
client & | hgetall (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | hgetall (const std::string &key) |
client & | hincrby (const std::string &key, const std::string &field, int incr, const reply_callback_t &reply_callback) |
std::future< reply > | hincrby (const std::string &key, const std::string &field, int incr) |
client & | hincrbyfloat (const std::string &key, const std::string &field, float incr, const reply_callback_t &reply_callback) |
std::future< reply > | hincrbyfloat (const std::string &key, const std::string &field, float incr) |
client & | hkeys (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | hkeys (const std::string &key) |
client & | hlen (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | hlen (const std::string &key) |
client & | hmget (const std::string &key, const std::vector< std::string > &fields, const reply_callback_t &reply_callback) |
std::future< reply > | hmget (const std::string &key, const std::vector< std::string > &fields) |
client & | hmset (const std::string &key, const std::vector< std::pair< std::string, std::string >> &field_val, const reply_callback_t &reply_callback) |
std::future< reply > | hmset (const std::string &key, const std::vector< std::pair< std::string, std::string >> &field_val) |
client & | hset (const std::string &key, const std::string &field, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | hset (const std::string &key, const std::string &field, const std::string &value) |
client & | hsetnx (const std::string &key, const std::string &field, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | hsetnx (const std::string &key, const std::string &field, const std::string &value) |
client & | hstrlen (const std::string &key, const std::string &field, const reply_callback_t &reply_callback) |
std::future< reply > | hstrlen (const std::string &key, const std::string &field) |
client & | hvals (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | hvals (const std::string &key) |
client & | incr (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | incr (const std::string &key) |
client & | incrby (const std::string &key, int incr, const reply_callback_t &reply_callback) |
std::future< reply > | incrby (const std::string &key, int incr) |
client & | incrbyfloat (const std::string &key, float incr, const reply_callback_t &reply_callback) |
std::future< reply > | incrbyfloat (const std::string &key, float incr) |
client & | info (const reply_callback_t &reply_callback) |
client & | info (const std::string §ion, const reply_callback_t &reply_callback) |
std::future< reply > | info (const std::string §ion="default") |
client & | keys (const std::string &pattern, const reply_callback_t &reply_callback) |
std::future< reply > | keys (const std::string &pattern) |
client & | lastsave (const reply_callback_t &reply_callback) |
std::future< reply > | lastsave () |
client & | lindex (const std::string &key, int index, const reply_callback_t &reply_callback) |
std::future< reply > | lindex (const std::string &key, int index) |
client & | linsert (const std::string &key, const std::string &before_after, const std::string &pivot, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | linsert (const std::string &key, const std::string &before_after, const std::string &pivot, const std::string &value) |
client & | llen (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | llen (const std::string &key) |
client & | lpop (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | lpop (const std::string &key) |
client & | lpush (const std::string &key, const std::vector< std::string > &values, const reply_callback_t &reply_callback) |
std::future< reply > | lpush (const std::string &key, const std::vector< std::string > &values) |
client & | lpushx (const std::string &key, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | lpushx (const std::string &key, const std::string &value) |
client & | lrange (const std::string &key, int start, int stop, const reply_callback_t &reply_callback) |
std::future< reply > | lrange (const std::string &key, int start, int stop) |
client & | lrem (const std::string &key, int count, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | lrem (const std::string &key, int count, const std::string &value) |
client & | lset (const std::string &key, int index, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | lset (const std::string &key, int index, const std::string &value) |
client & | ltrim (const std::string &key, int start, int stop, const reply_callback_t &reply_callback) |
std::future< reply > | ltrim (const std::string &key, int start, int stop) |
client & | mget (const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | mget (const std::vector< std::string > &keys) |
client & | migrate (const std::string &host, int port, const std::string &key, const std::string &dest_db, int timeout, const reply_callback_t &reply_callback) |
client & | migrate (const std::string &host, int port, const std::string &key, const std::string &dest_db, int timeout, bool copy, bool replace, const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | migrate (const std::string &host, int port, const std::string &key, const std::string &dest_db, int timeout, bool copy=false, bool replace=false, const std::vector< std::string > &keys={}) |
client & | monitor (const reply_callback_t &reply_callback) |
std::future< reply > | monitor () |
client & | move (const std::string &key, const std::string &db, const reply_callback_t &reply_callback) |
std::future< reply > | move (const std::string &key, const std::string &db) |
client & | mset (const std::vector< std::pair< std::string, std::string >> &key_vals, const reply_callback_t &reply_callback) |
std::future< reply > | mset (const std::vector< std::pair< std::string, std::string >> &key_vals) |
client & | msetnx (const std::vector< std::pair< std::string, std::string >> &key_vals, const reply_callback_t &reply_callback) |
std::future< reply > | msetnx (const std::vector< std::pair< std::string, std::string >> &key_vals) |
client & | multi (const reply_callback_t &reply_callback) |
std::future< reply > | multi () |
client & | object (const std::string &subcommand, const std::vector< std::string > &args, const reply_callback_t &reply_callback) |
std::future< reply > | object (const std::string &subcommand, const std::vector< std::string > &args) |
client & | persist (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | persist (const std::string &key) |
client & | pexpire (const std::string &key, int milliseconds, const reply_callback_t &reply_callback) |
std::future< reply > | pexpire (const std::string &key, int milliseconds) |
client & | pexpireat (const std::string &key, int milliseconds_timestamp, const reply_callback_t &reply_callback) |
std::future< reply > | pexpireat (const std::string &key, int milliseconds_timestamp) |
client & | pfadd (const std::string &key, const std::vector< std::string > &elements, const reply_callback_t &reply_callback) |
std::future< reply > | pfadd (const std::string &key, const std::vector< std::string > &elements) |
client & | pfcount (const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | pfcount (const std::vector< std::string > &keys) |
client & | pfmerge (const std::string &destkey, const std::vector< std::string > &sourcekeys, const reply_callback_t &reply_callback) |
std::future< reply > | pfmerge (const std::string &destkey, const std::vector< std::string > &sourcekeys) |
client & | ping (const reply_callback_t &reply_callback) |
std::future< reply > | ping () |
client & | ping (const std::string &message, const reply_callback_t &reply_callback) |
std::future< reply > | ping (const std::string &message) |
client & | psetex (const std::string &key, int milliseconds, const std::string &val, const reply_callback_t &reply_callback) |
std::future< reply > | psetex (const std::string &key, int milliseconds, const std::string &val) |
client & | publish (const std::string &channel, const std::string &message, const reply_callback_t &reply_callback) |
std::future< reply > | publish (const std::string &channel, const std::string &message) |
client & | pubsub (const std::string &subcommand, const std::vector< std::string > &args, const reply_callback_t &reply_callback) |
std::future< reply > | pubsub (const std::string &subcommand, const std::vector< std::string > &args) |
client & | pttl (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | pttl (const std::string &key) |
client & | quit (const reply_callback_t &reply_callback) |
std::future< reply > | quit () |
client & | randomkey (const reply_callback_t &reply_callback) |
std::future< reply > | randomkey () |
client & | readonly (const reply_callback_t &reply_callback) |
std::future< reply > | readonly () |
client & | readwrite (const reply_callback_t &reply_callback) |
std::future< reply > | readwrite () |
client & | rename (const std::string &key, const std::string &newkey, const reply_callback_t &reply_callback) |
std::future< reply > | rename (const std::string &key, const std::string &newkey) |
client & | renamenx (const std::string &key, const std::string &newkey, const reply_callback_t &reply_callback) |
std::future< reply > | renamenx (const std::string &key, const std::string &newkey) |
client & | restore (const std::string &key, int ttl, const std::string &serialized_value, const reply_callback_t &reply_callback) |
std::future< reply > | restore (const std::string &key, int ttl, const std::string &serialized_value) |
client & | restore (const std::string &key, int ttl, const std::string &serialized_value, const std::string &replace, const reply_callback_t &reply_callback) |
std::future< reply > | restore (const std::string &key, int ttl, const std::string &serialized_value, const std::string &replace) |
client & | role (const reply_callback_t &reply_callback) |
std::future< reply > | role () |
client & | rpop (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | rpop (const std::string &key) |
client & | rpoplpush (const std::string &source, const std::string &destination, const reply_callback_t &reply_callback) |
std::future< reply > | rpoplpush (const std::string &src, const std::string &dst) |
client & | rpush (const std::string &key, const std::vector< std::string > &values, const reply_callback_t &reply_callback) |
std::future< reply > | rpush (const std::string &key, const std::vector< std::string > &values) |
client & | rpushx (const std::string &key, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | rpushx (const std::string &key, const std::string &value) |
client & | sadd (const std::string &key, const std::vector< std::string > &members, const reply_callback_t &reply_callback) |
std::future< reply > | sadd (const std::string &key, const std::vector< std::string > &members) |
client & | save (const reply_callback_t &reply_callback) |
std::future< reply > | save () |
client & | scan (int cursor, const std::string &pattern, int count, const reply_callback_t &reply_callback) |
std::future< reply > | scan (int cursor, const std::string &pattern, int count) |
client & | scard (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | scard (const std::string &key) |
client & | script_debug (const std::string &mode, const reply_callback_t &reply_callback) |
std::future< reply > | script_debug (const std::string &mode) |
client & | script_exists (const std::vector< std::string > &scripts, const reply_callback_t &reply_callback) |
std::future< reply > | script_exists (const std::vector< std::string > &scripts) |
client & | script_flush (const reply_callback_t &reply_callback) |
std::future< reply > | script_flush () |
client & | script_kill (const reply_callback_t &reply_callback) |
std::future< reply > | script_kill () |
client & | script_load (const std::string &script, const reply_callback_t &reply_callback) |
std::future< reply > | script_load (const std::string &script) |
client & | sdiff (const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | sdiff (const std::vector< std::string > &keys) |
client & | sdiffstore (const std::string &destination, const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | sdiffstore (const std::string &dst, const std::vector< std::string > &keys) |
client & | select (int index, const reply_callback_t &reply_callback) |
std::future< reply > | select (int index) |
client & | set (const std::string &key, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | set (const std::string &key, const std::string &value) |
client & | set_advanced (const std::string &key, const std::string &value, const reply_callback_t &reply_callback) |
client & | set_advanced (const std::string &key, const std::string &value, bool ex, int ex_sec, bool px, int px_milli, bool nx, bool xx, const reply_callback_t &reply_callback) |
std::future< reply > | set_advanced (const std::string &key, const std::string &value, bool ex=false, int ex_sec=0, bool px=false, int px_milli=0, bool nx=false, bool xx=false) |
client & | setbit_ (const std::string &key, int offset, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | setbit_ (const std::string &key, int offset, const std::string &value) |
client & | setex (const std::string &key, int seconds, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | setex (const std::string &key, int seconds, const std::string &value) |
client & | setnx (const std::string &key, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | setnx (const std::string &key, const std::string &value) |
client & | setrange (const std::string &key, int offset, const std::string &value, const reply_callback_t &reply_callback) |
std::future< reply > | setrange (const std::string &key, int offset, const std::string &value) |
client & | shutdown (const reply_callback_t &reply_callback) |
std::future< reply > | shutdown () |
client & | shutdown (const std::string &save, const reply_callback_t &reply_callback) |
std::future< reply > | shutdown (const std::string &save) |
client & | sinter (const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | sinter (const std::vector< std::string > &keys) |
client & | sinterstore (const std::string &destination, const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | sinterstore (const std::string &dst, const std::vector< std::string > &keys) |
client & | sismember (const std::string &key, const std::string &member, const reply_callback_t &reply_callback) |
std::future< reply > | sismember (const std::string &key, const std::string &member) |
client & | slaveof (const std::string &host, int port, const reply_callback_t &reply_callback) |
std::future< reply > | slaveof (const std::string &host, int port) |
client & | slowlog (const std::string subcommand, const reply_callback_t &reply_callback) |
std::future< reply > | slowlog (const std::string &subcommand) |
client & | slowlog (const std::string subcommand, const std::string &argument, const reply_callback_t &reply_callback) |
std::future< reply > | slowlog (const std::string &subcommand, const std::string &argument) |
client & | smembers (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | smembers (const std::string &key) |
client & | smove (const std::string &source, const std::string &destination, const std::string &member, const reply_callback_t &reply_callback) |
std::future< reply > | smove (const std::string &src, const std::string &dst, const std::string &member) |
client & | spop (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | spop (const std::string &key) |
client & | spop (const std::string &key, int count, const reply_callback_t &reply_callback) |
std::future< reply > | spop (const std::string &key, int count) |
client & | srandmember (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | srandmember (const std::string &key) |
client & | srandmember (const std::string &key, int count, const reply_callback_t &reply_callback) |
std::future< reply > | srandmember (const std::string &key, int count) |
client & | srem (const std::string &key, const std::vector< std::string > &members, const reply_callback_t &reply_callback) |
std::future< reply > | srem (const std::string &key, const std::vector< std::string > &members) |
client & | strlen (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | strlen (const std::string &key) |
client & | sunion (const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | sunion (const std::vector< std::string > &keys) |
client & | sunionstore (const std::string &destination, const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | sunionstore (const std::string &dst, const std::vector< std::string > &keys) |
client & | sync (const reply_callback_t &reply_callback) |
std::future< reply > | sync () |
client & | time (const reply_callback_t &reply_callback) |
std::future< reply > | time () |
client & | ttl (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | ttl (const std::string &key) |
client & | type (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | type (const std::string &key) |
client & | unwatch (const reply_callback_t &reply_callback) |
std::future< reply > | unwatch () |
client & | wait (int numslaves, int timeout, const reply_callback_t &reply_callback) |
std::future< reply > | wait (int numslaves, int timeout) |
client & | watch (const std::vector< std::string > &keys, const reply_callback_t &reply_callback) |
std::future< reply > | watch (const std::vector< std::string > &keys) |
client & | zadd (const std::string &key, const std::vector< std::string > &options, const std::map< std::string, std::string > &score_members, const reply_callback_t &reply_callback) |
std::future< reply > | zadd (const std::string &key, const std::vector< std::string > &options, const std::map< std::string, std::string > &score_members) |
client & | zcard (const std::string &key, const reply_callback_t &reply_callback) |
std::future< reply > | zcard (const std::string &key) |
client & | zcount (const std::string &key, int min, int max, const reply_callback_t &reply_callback) |
std::future< reply > | zcount (const std::string &key, int min, int max) |
client & | zcount (const std::string &key, double min, double max, const reply_callback_t &reply_callback) |
std::future< reply > | zcount (const std::string &key, double min, double max) |
client & | zcount (const std::string &key, const std::string &min, const std::string &max, const reply_callback_t &reply_callback) |
std::future< reply > | zcount (const std::string &key, const std::string &min, const std::string &max) |
client & | zincrby (const std::string &key, int incr, const std::string &member, const reply_callback_t &reply_callback) |
std::future< reply > | zincrby (const std::string &key, int incr, const std::string &member) |
client & | zincrby (const std::string &key, double incr, const std::string &member, const reply_callback_t &reply_callback) |
std::future< reply > | zincrby (const std::string &key, double incr, const std::string &member) |
client & | zincrby (const std::string &key, const std::string &incr, const std::string &member, const reply_callback_t &reply_callback) |
std::future< reply > | zincrby (const std::string &key, const std::string &incr, const std::string &member) |
client & | zlexcount (const std::string &key, int min, int max, const reply_callback_t &reply_callback) |
std::future< reply > | zlexcount (const std::string &key, int min, int max) |
client & | zlexcount (const std::string &key, double min, double max, const reply_callback_t &reply_callback) |
std::future< reply > | zlexcount (const std::string &key, double min, double max) |
client & | zlexcount (const std::string &key, const std::string &min, const std::string &max, const reply_callback_t &reply_callback) |
std::future< reply > | zlexcount (const std::string &key, const std::string &min, const std::string &max) |
client & | zrange (const std::string &key, int start, int stop, const reply_callback_t &reply_callback) |
client & | zrange (const std::string &key, int start, int stop, bool withscores, const reply_callback_t &reply_callback) |
std::future< reply > | zrange (const std::string &key, int start, int stop, bool withscores=false) |
client & | zrange (const std::string &key, double start, double stop, const reply_callback_t &reply_callback) |
client & | zrange (const std::string &key, double start, double stop, bool withscores, const reply_callback_t &reply_callback) |
std::future< reply > | zrange (const std::string &key, double start, double stop, bool withscores=false) |
client & | zrange (const std::string &key, const std::string &start, const std::string &stop, const reply_callback_t &reply_callback) |
client & | zrange (const std::string &key, const std::string &start, const std::string &stop, bool withscores, const reply_callback_t &reply_callback) |
std::future< reply > | zrange (const std::string &key, const std::string &start, const std::string &stop, bool withscores=false) |
client & | zrank (const std::string &key, const std::string &member, const reply_callback_t &reply_callback) |
std::future< reply > | zrank (const std::string &key, const std::string &member) |
client & | zrem (const std::string &key, const std::vector< std::string > &members, const reply_callback_t &reply_callback) |
std::future< reply > | zrem (const std::string &key, const std::vector< std::string > &members) |
client & | zremrangebylex (const std::string &key, int min, int max, const reply_callback_t &reply_callback) |
std::future< reply > | zremrangebylex (const std::string &key, int min, int max) |
client & | zremrangebylex (const std::string &key, double min, double max, const reply_callback_t &reply_callback) |
std::future< reply > | zremrangebylex (const std::string &key, double min, double max) |
client & | zremrangebylex (const std::string &key, const std::string &min, const std::string &max, const reply_callback_t &reply_callback) |
std::future< reply > | zremrangebylex (const std::string &key, const std::string &min, const std::string &max) |
client & | zremrangebyrank (const std::string &key, int start, int stop, const reply_callback_t &reply_callback) |
std::future< reply > | zremrangebyrank (const std::string &key, int start, int stop) |
client & | zremrangebyrank (const std::string &key, double start, double stop, const reply_callback_t &reply_callback) |
std::future< reply > | zremrangebyrank (const std::string &key, double start, double stop) |
client & | zremrangebyrank (const std::string &key, const std::string &start, const std::string &stop, const reply_callback_t &reply_callback) |
std::future< reply > | zremrangebyrank (const std::string &key, const std::string &start, const std::string &stop) |
client & | zremrangebyscore (const std::string &key, int min, int max, const reply_callback_t &reply_callback) |
std::future< reply > | zremrangebyscore (const std::string &key, int min, int max) |
client & | zremrangebyscore (const std::string &key, double min, double max, const reply_callback_t &reply_callback) |
std::future< reply > | zremrangebyscore (const std::string &key, double min, double max) |
client & | zremrangebyscore (const std::string &key, const std::string &min, const std::string &max, const reply_callback_t &reply_callback) |
std::future< reply > | zremrangebyscore (const std::string &key, const std::string &min, const std::string &max) |
client & | zrevrange (const std::string &key, int start, int stop, const reply_callback_t &reply_callback) |
client & | zrevrange (const std::string &key, int start, int stop, bool withscores, const reply_callback_t &reply_callback) |
std::future< reply > | zrevrange (const std::string &key, int start, int stop, bool withscores=false) |
client & | zrevrange (const std::string &key, double start, double stop, const reply_callback_t &reply_callback) |
client & | zrevrange (const std::string &key, double start, double stop, bool withscores, const reply_callback_t &reply_callback) |
std::future< reply > | zrevrange (const std::string &key, double start, double stop, bool withscores=false) |
client & | zrevrange (const std::string &key, const std::string &start, const std::string &stop, const reply_callback_t &reply_callback) |
client & | zrevrange (const std::string &key, const std::string &start, const std::string &stop, bool withscores, const reply_callback_t &reply_callback) |
std::future< reply > | zrevrange (const std::string &key, const std::string &start, const std::string &stop, bool withscores=false) |
client & | zrevrank (const std::string &key, const std::string &member, const reply_callback_t &reply_callback) |
std::future< reply > | zrevrank (const std::string &key, const std::string &member) |
client & | zscore (const std::string &key, const std::string &member, const reply_callback_t &reply_callback) |
std::future< reply > | zscore (const std::string &key, const std::string &member) |
template<typename T, typename... Ts> | |
client & | client_kill (const T &arg, const Ts &... args) |
Private Member Functions | |
bool | should_reconnect (void) const |
void | resend_failed_commands (void) |
void | sleep_before_next_reconnect_attempt (void) |
void | reconnect (void) |
void | re_auth (void) |
void | re_select (void) |
void | unprotected_send (const std::vector< std::string > &redis_cmd, const reply_callback_t &callback) |
void | unprotected_auth (const std::string &password, const reply_callback_t &reply_callback) |
void | unprotected_select (int index, const reply_callback_t &reply_callback) |
template<typename T > | |
std::enable_if< std::is_same< T, client_type >::value >::type | client_kill_unpack_arg (std::vector< std::string > &redis_cmd, reply_callback_t &, client_type type) |
client kill impl More... | |
template<typename T > | |
std::enable_if< std::is_same< T, bool >::value >::type | client_kill_unpack_arg (std::vector< std::string > &redis_cmd, reply_callback_t &, bool skip) |
template<typename T > | |
std::enable_if< std::is_integral< T >::value >::type | client_kill_unpack_arg (std::vector< std::string > &redis_cmd, reply_callback_t &, uint64_t id) |
template<typename T > | |
std::enable_if< std::is_class< T >::value >::type | client_kill_unpack_arg (std::vector< std::string > &, reply_callback_t &reply_callback, const T &cb) |
template<typename T , typename... Ts> | |
void | client_kill_impl (std::vector< std::string > &redis_cmd, reply_callback_t &reply, const T &arg, const Ts &... args) |
template<typename T > | |
void | client_kill_impl (std::vector< std::string > &redis_cmd, reply_callback_t &reply, const T &arg) |
void | connection_receive_handler (network::redis_connection &connection, reply &reply) |
void | connection_disconnection_handler (network::redis_connection &connection) |
void | clear_callbacks (void) |
void | try_commit (void) |
std::future< reply > | exec_cmd (const std::function< client &(const reply_callback_t &)> &f) |
Execute a command on the client and tie the callback to a future. More... | |
Private Attributes | |
std::string | m_redis_server |
std::size_t | m_redis_port = 0 |
std::string | m_master_name |
std::string | m_password |
int | m_database_index = 0 |
network::redis_connection | m_client |
cpp_redis::sentinel | m_sentinel |
std::uint32_t | m_connect_timeout_msecs = 0 |
std::int32_t | m_max_reconnects = 0 |
std::int32_t | m_current_reconnect_attempts = 0 |
std::uint32_t | m_reconnect_interval_msecs = 0 |
std::atomic_bool | m_reconnecting = ATOMIC_VAR_INIT(false) |
std::atomic_bool | m_cancel = ATOMIC_VAR_INIT(false) |
std::queue< command_request > | m_commands |
connect_callback_t | m_connect_callback |
std::mutex | m_callbacks_mutex |
std::condition_variable | m_sync_condvar |
std::atomic< unsigned int > | m_callbacks_running = ATOMIC_VAR_INIT(0) |
typedef std::function<void(const std::string& host, std::size_t port, connect_state status)> cpp_redis::client::connect_callback_t |
connect handler, called whenever a new connection even occurred
typedef std::function<void(reply&)> cpp_redis::client::reply_callback_t |
reply callback called whenever a reply is received takes as parameter the received reply
|
strong |
|
strong |
high availability (re)connection states
Enumerator | |
---|---|
dropped | |
start | |
sleeping | |
ok | |
failed | |
lookup_failed | |
stopped |
cpp_redis::client::client | ( | void | ) |
ctor
|
explicit |
custom ctor to specify custom tcp_client
tcp_client | tcp client to be used for network communications |
cpp_redis::client::~client | ( | void | ) |
dtor
|
delete |
copy ctor
void cpp_redis::client::add_sentinel | ( | const std::string & | host, |
std::size_t | port | ||
) |
add a sentinel definition. Required for connect() or get_master_addr_by_name() when autoconnect is enabled.
host | sentinel host |
port | sentinel port |
client& cpp_redis::client::append | ( | const std::string & | key, |
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::append | ( | const std::string & | key, |
const std::string & | value | ||
) |
client& cpp_redis::client::auth | ( | const std::string & | password, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::auth | ( | const std::string & | password | ) |
client& cpp_redis::client::bgrewriteaof | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::bgrewriteaof | ( | ) |
client& cpp_redis::client::bgsave | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::bgsave | ( | ) |
client& cpp_redis::client::bitcount | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::bitcount | ( | const std::string & | key | ) |
client& cpp_redis::client::bitcount | ( | const std::string & | key, |
int | start, | ||
int | end, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::bitcount | ( | const std::string & | key, |
int | start, | ||
int | end | ||
) |
client& cpp_redis::client::bitop | ( | const std::string & | operation, |
const std::string & | destkey, | ||
const std::vector< std::string > & | keys, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::bitop | ( | const std::string & | operation, |
const std::string & | destkey, | ||
const std::vector< std::string > & | keys | ||
) |
client& cpp_redis::client::bitpos | ( | const std::string & | key, |
int | bit, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::bitpos | ( | const std::string & | key, |
int | bit | ||
) |
client& cpp_redis::client::bitpos | ( | const std::string & | key, |
int | bit, | ||
int | start, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::bitpos | ( | const std::string & | key, |
int | bit, | ||
int | start | ||
) |
client& cpp_redis::client::bitpos | ( | const std::string & | key, |
int | bit, | ||
int | start, | ||
int | end, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::bitpos | ( | const std::string & | key, |
int | bit, | ||
int | start, | ||
int | end | ||
) |
client& cpp_redis::client::blpop | ( | const std::vector< std::string > & | keys, |
int | timeout, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::blpop | ( | const std::vector< std::string > & | keys, |
int | timeout | ||
) |
client& cpp_redis::client::brpop | ( | const std::vector< std::string > & | keys, |
int | timeout, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::brpop | ( | const std::vector< std::string > & | keys, |
int | timeout | ||
) |
client& cpp_redis::client::brpoplpush | ( | const std::string & | src, |
const std::string & | dst, | ||
int | timeout, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::brpoplpush | ( | const std::string & | src, |
const std::string & | dst, | ||
int | timeout | ||
) |
void cpp_redis::client::cancel_reconnect | ( | void | ) |
stop any reconnect in progress
|
private |
reset the queue of pending callbacks
void cpp_redis::client::clear_sentinels | ( | void | ) |
clear all existing sentinels.
client& cpp_redis::client::client_getname | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::client_getname | ( | ) |
|
inline |
|
inline |
If we have other type than lambda, then it's a filter
|
inline |
|
inline |
client& cpp_redis::client::client_kill | ( | const T & | , |
const Ts & | ... | ||
) |
std::future< reply > cpp_redis::client::client_kill_future | ( | const T | arg, |
const Ts... | args | ||
) |
gcc 4.8 doesn't handle variadic template capture arguments (appears in 4.9) so std::bind should capture all arguments because of the compiler.
|
private |
|
private |
|
private |
client kill impl
|
private |
|
private |
|
private |
client& cpp_redis::client::client_list | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::client_list | ( | ) |
client& cpp_redis::client::client_pause | ( | int | timeout, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::client_pause | ( | int | timeout | ) |
client& cpp_redis::client::client_reply | ( | const std::string & | mode, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::client_reply | ( | const std::string & | mode | ) |
client& cpp_redis::client::client_setname | ( | const std::string & | name, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::client_setname | ( | const std::string & | name | ) |
client& cpp_redis::client::cluster_addslots | ( | const std::vector< std::string > & | p_slots, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_addslots | ( | const std::vector< std::string > & | p_slots | ) |
client& cpp_redis::client::cluster_count_failure_reports | ( | const std::string & | node_id, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_count_failure_reports | ( | const std::string & | node_id | ) |
client& cpp_redis::client::cluster_countkeysinslot | ( | const std::string & | slot, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_countkeysinslot | ( | const std::string & | slot | ) |
client& cpp_redis::client::cluster_delslots | ( | const std::vector< std::string > & | p_slots, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_delslots | ( | const std::vector< std::string > & | p_slots | ) |
client& cpp_redis::client::cluster_failover | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::cluster_failover | ( | ) |
client& cpp_redis::client::cluster_failover | ( | const std::string & | mode, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_failover | ( | const std::string & | mode | ) |
client& cpp_redis::client::cluster_forget | ( | const std::string & | node_id, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_forget | ( | const std::string & | node_id | ) |
client& cpp_redis::client::cluster_getkeysinslot | ( | const std::string & | slot, |
int | count, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_getkeysinslot | ( | const std::string & | slot, |
int | count | ||
) |
client& cpp_redis::client::cluster_info | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::cluster_info | ( | ) |
client& cpp_redis::client::cluster_keyslot | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_keyslot | ( | const std::string & | key | ) |
client& cpp_redis::client::cluster_meet | ( | const std::string & | ip, |
int | port, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_meet | ( | const std::string & | ip, |
int | port | ||
) |
client& cpp_redis::client::cluster_nodes | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::cluster_nodes | ( | ) |
client& cpp_redis::client::cluster_replicate | ( | const std::string & | node_id, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_replicate | ( | const std::string & | node_id | ) |
client& cpp_redis::client::cluster_reset | ( | const reply_callback_t & | reply_callback | ) |
client& cpp_redis::client::cluster_reset | ( | const std::string & | mode, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_reset | ( | const std::string & | mode = "soft" | ) |
client& cpp_redis::client::cluster_saveconfig | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::cluster_saveconfig | ( | ) |
client& cpp_redis::client::cluster_set_config_epoch | ( | const std::string & | epoch, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_set_config_epoch | ( | const std::string & | epoch | ) |
client& cpp_redis::client::cluster_setslot | ( | const std::string & | slot, |
const std::string & | mode, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_setslot | ( | const std::string & | slot, |
const std::string & | mode | ||
) |
client& cpp_redis::client::cluster_setslot | ( | const std::string & | slot, |
const std::string & | mode, | ||
const std::string & | node_id, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_setslot | ( | const std::string & | slot, |
const std::string & | mode, | ||
const std::string & | node_id | ||
) |
client& cpp_redis::client::cluster_slaves | ( | const std::string & | node_id, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::cluster_slaves | ( | const std::string & | node_id | ) |
client& cpp_redis::client::cluster_slots | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::cluster_slots | ( | ) |
client& cpp_redis::client::command | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::command | ( | ) |
client& cpp_redis::client::command_count | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::command_count | ( | ) |
client& cpp_redis::client::command_getkeys | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::command_getkeys | ( | ) |
client& cpp_redis::client::command_info | ( | const std::vector< std::string > & | command_name, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::command_info | ( | const std::vector< std::string > & | command_name | ) |
client& cpp_redis::client::commit | ( | void | ) |
Sends all the commands that have been stored by calling send() since the last commit() call to the redis server. That is, pipelining is supported in a very simple and efficient way: client.send(...).send(...).send(...).commit() will send the 3 commands at once (instead of sending 3 network requests, one for each command, as it would have been done without pipelining). Pipelined commands are always removed from the buffer, even in the case of an error (for example, calling commit while the client is not connected, something that throws an exception). commit() works asynchronously: it returns immediately after sending the queued requests and replies are processed asynchronously.
Please note that, while commit() can safely be called from inside a reply callback, calling sync_commit() from inside a reply callback is not permitted and will lead to undefined behavior, mostly deadlock.
client& cpp_redis::client::config_get | ( | const std::string & | param, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::config_get | ( | const std::string & | param | ) |
client& cpp_redis::client::config_resetstat | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::config_resetstat | ( | ) |
client& cpp_redis::client::config_rewrite | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::config_rewrite | ( | ) |
client& cpp_redis::client::config_set | ( | const std::string & | param, |
const std::string & | val, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::config_set | ( | const std::string & | param, |
const std::string & | val | ||
) |
void cpp_redis::client::connect | ( | const std::string & | host = "127.0.0.1" , |
std::size_t | port = 6379 , |
||
const connect_callback_t & | connect_callback = nullptr , |
||
std::uint32_t | timeout_msecs = 0 , |
||
std::int32_t | max_reconnects = 0 , |
||
std::uint32_t | reconnect_interval_msecs = 0 |
||
) |
Connect to redis server
host | host to be connected to |
port | port to be connected to |
connect_callback | connect handler to be called on connect events (may be null) |
timeout_msecs | maximum time to connect |
max_reconnects | maximum attemps of reconnection if connection dropped |
reconnect_interval_msecs | time between two attemps of reconnection |
void cpp_redis::client::connect | ( | const std::string & | name, |
const connect_callback_t & | connect_callback = nullptr , |
||
std::uint32_t | timeout_msecs = 0 , |
||
std::int32_t | max_reconnects = 0 , |
||
std::uint32_t | reconnect_interval_msecs = 0 |
||
) |
Connect to redis server
name | sentinel name |
connect_callback | connect handler to be called on connect events (may be null) |
timeout_msecs | maximum time to connect |
max_reconnects | maximum attemps of reconnection if connection dropped |
reconnect_interval_msecs | time between two attemps of reconnection |
|
private |
redis_connection disconnection handler, triggered whenever a disconnection occured
connection | redis_connection instance |
|
private |
redis connection receive handler, triggered whenever a reply has been read by the redis connection
connection | redis_connection instance |
reply | parsed reply |
client& cpp_redis::client::dbsize | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::dbsize | ( | ) |
client& cpp_redis::client::debug_object | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::debug_object | ( | const std::string & | key | ) |
client& cpp_redis::client::debug_segfault | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::debug_segfault | ( | ) |
client& cpp_redis::client::decr | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::decr | ( | const std::string & | key | ) |
client& cpp_redis::client::decrby | ( | const std::string & | key, |
int | val, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::decrby | ( | const std::string & | key, |
int | val | ||
) |
client& cpp_redis::client::del | ( | const std::vector< std::string > & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::del | ( | const std::vector< std::string > & | key | ) |
client& cpp_redis::client::discard | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::discard | ( | ) |
void cpp_redis::client::disconnect | ( | bool | wait_for_removal = false | ) |
disconnect from redis server
wait_for_removal | when sets to true, disconnect blocks until the underlying TCP client has been effectively removed from the io_service and that all the underlying callbacks have completed. |
client& cpp_redis::client::dump | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::dump | ( | const std::string & | key | ) |
client& cpp_redis::client::echo | ( | const std::string & | msg, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::echo | ( | const std::string & | msg | ) |
client& cpp_redis::client::eval | ( | const std::string & | script, |
int | numkeys, | ||
const std::vector< std::string > & | keys, | ||
const std::vector< std::string > & | args, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::eval | ( | const std::string & | script, |
int | numkeys, | ||
const std::vector< std::string > & | keys, | ||
const std::vector< std::string > & | args | ||
) |
client& cpp_redis::client::evalsha | ( | const std::string & | sha1, |
int | numkeys, | ||
const std::vector< std::string > & | keys, | ||
const std::vector< std::string > & | args, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::evalsha | ( | const std::string & | sha1, |
int | numkeys, | ||
const std::vector< std::string > & | keys, | ||
const std::vector< std::string > & | args | ||
) |
client& cpp_redis::client::exec | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::exec | ( | ) |
|
private |
Execute a command on the client and tie the callback to a future.
client& cpp_redis::client::exists | ( | const std::vector< std::string > & | keys, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::exists | ( | const std::vector< std::string > & | keys | ) |
client& cpp_redis::client::expire | ( | const std::string & | key, |
int | seconds, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::expire | ( | const std::string & | key, |
int | seconds | ||
) |
client& cpp_redis::client::expireat | ( | const std::string & | key, |
int | timestamp, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::expireat | ( | const std::string & | key, |
int | timestamp | ||
) |
client& cpp_redis::client::flushall | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::flushall | ( | ) |
client& cpp_redis::client::flushdb | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::flushdb | ( | ) |
client& cpp_redis::client::geoadd | ( | const std::string & | key, |
const std::vector< std::tuple< std::string, std::string, std::string >> & | long_lat_memb, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::geoadd | ( | const std::string & | key, |
const std::vector< std::tuple< std::string, std::string, std::string >> & | long_lat_memb | ||
) |
client& cpp_redis::client::geodist | ( | const std::string & | key, |
const std::string & | member_1, | ||
const std::string & | member_2, | ||
const reply_callback_t & | reply_callback | ||
) |
client& cpp_redis::client::geodist | ( | const std::string & | key, |
const std::string & | member_1, | ||
const std::string & | member_2, | ||
const std::string & | unit, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::geodist | ( | const std::string & | key, |
const std::string & | member_1, | ||
const std::string & | member_2, | ||
const std::string & | unit = "m" |
||
) |
client& cpp_redis::client::geohash | ( | const std::string & | key, |
const std::vector< std::string > & | members, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::geohash | ( | const std::string & | key, |
const std::vector< std::string > & | members | ||
) |
client& cpp_redis::client::geopos | ( | const std::string & | key, |
const std::vector< std::string > & | members, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::geopos | ( | const std::string & | key, |
const std::vector< std::string > & | members | ||
) |
client& cpp_redis::client::get | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::get | ( | const std::string & | key | ) |
const sentinel& cpp_redis::client::get_sentinel | ( | void | ) | const |
retrieve sentinel for current client
sentinel& cpp_redis::client::get_sentinel | ( | void | ) |
retrieve sentinel for current client non-const version
client& cpp_redis::client::getbit | ( | const std::string & | key, |
int | offset, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::getbit | ( | const std::string & | key, |
int | offset | ||
) |
client& cpp_redis::client::getrange | ( | const std::string & | key, |
int | start, | ||
int | end, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::getrange | ( | const std::string & | key, |
int | start, | ||
int | end | ||
) |
client& cpp_redis::client::getset | ( | const std::string & | key, |
const std::string & | val, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::getset | ( | const std::string & | key, |
const std::string & | val | ||
) |
client& cpp_redis::client::hdel | ( | const std::string & | key, |
const std::vector< std::string > & | fields, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hdel | ( | const std::string & | key, |
const std::vector< std::string > & | fields | ||
) |
client& cpp_redis::client::hexists | ( | const std::string & | key, |
const std::string & | field, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hexists | ( | const std::string & | key, |
const std::string & | field | ||
) |
client& cpp_redis::client::hget | ( | const std::string & | key, |
const std::string & | field, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hget | ( | const std::string & | key, |
const std::string & | field | ||
) |
client& cpp_redis::client::hgetall | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hgetall | ( | const std::string & | key | ) |
client& cpp_redis::client::hincrby | ( | const std::string & | key, |
const std::string & | field, | ||
int | incr, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hincrby | ( | const std::string & | key, |
const std::string & | field, | ||
int | incr | ||
) |
client& cpp_redis::client::hincrbyfloat | ( | const std::string & | key, |
const std::string & | field, | ||
float | incr, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hincrbyfloat | ( | const std::string & | key, |
const std::string & | field, | ||
float | incr | ||
) |
client& cpp_redis::client::hkeys | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hkeys | ( | const std::string & | key | ) |
client& cpp_redis::client::hlen | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hlen | ( | const std::string & | key | ) |
client& cpp_redis::client::hmget | ( | const std::string & | key, |
const std::vector< std::string > & | fields, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hmget | ( | const std::string & | key, |
const std::vector< std::string > & | fields | ||
) |
client& cpp_redis::client::hmset | ( | const std::string & | key, |
const std::vector< std::pair< std::string, std::string >> & | field_val, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hmset | ( | const std::string & | key, |
const std::vector< std::pair< std::string, std::string >> & | field_val | ||
) |
client& cpp_redis::client::hset | ( | const std::string & | key, |
const std::string & | field, | ||
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hset | ( | const std::string & | key, |
const std::string & | field, | ||
const std::string & | value | ||
) |
client& cpp_redis::client::hsetnx | ( | const std::string & | key, |
const std::string & | field, | ||
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hsetnx | ( | const std::string & | key, |
const std::string & | field, | ||
const std::string & | value | ||
) |
client& cpp_redis::client::hstrlen | ( | const std::string & | key, |
const std::string & | field, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hstrlen | ( | const std::string & | key, |
const std::string & | field | ||
) |
client& cpp_redis::client::hvals | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::hvals | ( | const std::string & | key | ) |
client& cpp_redis::client::incr | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::incr | ( | const std::string & | key | ) |
client& cpp_redis::client::incrby | ( | const std::string & | key, |
int | incr, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::incrby | ( | const std::string & | key, |
int | incr | ||
) |
client& cpp_redis::client::incrbyfloat | ( | const std::string & | key, |
float | incr, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::incrbyfloat | ( | const std::string & | key, |
float | incr | ||
) |
client& cpp_redis::client::info | ( | const reply_callback_t & | reply_callback | ) |
client& cpp_redis::client::info | ( | const std::string & | section, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::info | ( | const std::string & | section = "default" | ) |
bool cpp_redis::client::is_connected | ( | void | ) | const |
bool cpp_redis::client::is_reconnecting | ( | void | ) | const |
client& cpp_redis::client::keys | ( | const std::string & | pattern, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::keys | ( | const std::string & | pattern | ) |
client& cpp_redis::client::lastsave | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::lastsave | ( | ) |
client& cpp_redis::client::lindex | ( | const std::string & | key, |
int | index, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::lindex | ( | const std::string & | key, |
int | index | ||
) |
client& cpp_redis::client::linsert | ( | const std::string & | key, |
const std::string & | before_after, | ||
const std::string & | pivot, | ||
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::linsert | ( | const std::string & | key, |
const std::string & | before_after, | ||
const std::string & | pivot, | ||
const std::string & | value | ||
) |
client& cpp_redis::client::llen | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::llen | ( | const std::string & | key | ) |
client& cpp_redis::client::lpop | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::lpop | ( | const std::string & | key | ) |
client& cpp_redis::client::lpush | ( | const std::string & | key, |
const std::vector< std::string > & | values, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::lpush | ( | const std::string & | key, |
const std::vector< std::string > & | values | ||
) |
client& cpp_redis::client::lpushx | ( | const std::string & | key, |
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::lpushx | ( | const std::string & | key, |
const std::string & | value | ||
) |
client& cpp_redis::client::lrange | ( | const std::string & | key, |
int | start, | ||
int | stop, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::lrange | ( | const std::string & | key, |
int | start, | ||
int | stop | ||
) |
client& cpp_redis::client::lrem | ( | const std::string & | key, |
int | count, | ||
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::lrem | ( | const std::string & | key, |
int | count, | ||
const std::string & | value | ||
) |
client& cpp_redis::client::lset | ( | const std::string & | key, |
int | index, | ||
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::lset | ( | const std::string & | key, |
int | index, | ||
const std::string & | value | ||
) |
client& cpp_redis::client::ltrim | ( | const std::string & | key, |
int | start, | ||
int | stop, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::ltrim | ( | const std::string & | key, |
int | start, | ||
int | stop | ||
) |
client& cpp_redis::client::mget | ( | const std::vector< std::string > & | keys, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::mget | ( | const std::vector< std::string > & | keys | ) |
client& cpp_redis::client::migrate | ( | const std::string & | host, |
int | port, | ||
const std::string & | key, | ||
const std::string & | dest_db, | ||
int | timeout, | ||
const reply_callback_t & | reply_callback | ||
) |
client& cpp_redis::client::migrate | ( | const std::string & | host, |
int | port, | ||
const std::string & | key, | ||
const std::string & | dest_db, | ||
int | timeout, | ||
bool | copy, | ||
bool | replace, | ||
const std::vector< std::string > & | keys, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::migrate | ( | const std::string & | host, |
int | port, | ||
const std::string & | key, | ||
const std::string & | dest_db, | ||
int | timeout, | ||
bool | copy = false , |
||
bool | replace = false , |
||
const std::vector< std::string > & | keys = {} |
||
) |
client& cpp_redis::client::monitor | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::monitor | ( | ) |
client& cpp_redis::client::move | ( | const std::string & | key, |
const std::string & | db, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::move | ( | const std::string & | key, |
const std::string & | db | ||
) |
client& cpp_redis::client::mset | ( | const std::vector< std::pair< std::string, std::string >> & | key_vals, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::mset | ( | const std::vector< std::pair< std::string, std::string >> & | key_vals | ) |
client& cpp_redis::client::msetnx | ( | const std::vector< std::pair< std::string, std::string >> & | key_vals, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::msetnx | ( | const std::vector< std::pair< std::string, std::string >> & | key_vals | ) |
client& cpp_redis::client::multi | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::multi | ( | ) |
client& cpp_redis::client::object | ( | const std::string & | subcommand, |
const std::vector< std::string > & | args, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::object | ( | const std::string & | subcommand, |
const std::vector< std::string > & | args | ||
) |
client& cpp_redis::client::persist | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::persist | ( | const std::string & | key | ) |
client& cpp_redis::client::pexpire | ( | const std::string & | key, |
int | milliseconds, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::pexpire | ( | const std::string & | key, |
int | milliseconds | ||
) |
client& cpp_redis::client::pexpireat | ( | const std::string & | key, |
int | milliseconds_timestamp, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::pexpireat | ( | const std::string & | key, |
int | milliseconds_timestamp | ||
) |
client& cpp_redis::client::pfadd | ( | const std::string & | key, |
const std::vector< std::string > & | elements, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::pfadd | ( | const std::string & | key, |
const std::vector< std::string > & | elements | ||
) |
client& cpp_redis::client::pfcount | ( | const std::vector< std::string > & | keys, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::pfcount | ( | const std::vector< std::string > & | keys | ) |
client& cpp_redis::client::pfmerge | ( | const std::string & | destkey, |
const std::vector< std::string > & | sourcekeys, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::pfmerge | ( | const std::string & | destkey, |
const std::vector< std::string > & | sourcekeys | ||
) |
client& cpp_redis::client::ping | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::ping | ( | ) |
client& cpp_redis::client::ping | ( | const std::string & | message, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::ping | ( | const std::string & | message | ) |
client& cpp_redis::client::psetex | ( | const std::string & | key, |
int | milliseconds, | ||
const std::string & | val, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::psetex | ( | const std::string & | key, |
int | milliseconds, | ||
const std::string & | val | ||
) |
client& cpp_redis::client::pttl | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::pttl | ( | const std::string & | key | ) |
client& cpp_redis::client::publish | ( | const std::string & | channel, |
const std::string & | message, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::publish | ( | const std::string & | channel, |
const std::string & | message | ||
) |
client& cpp_redis::client::pubsub | ( | const std::string & | subcommand, |
const std::vector< std::string > & | args, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::pubsub | ( | const std::string & | subcommand, |
const std::vector< std::string > & | args | ||
) |
client& cpp_redis::client::quit | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::quit | ( | ) |
client& cpp_redis::client::randomkey | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::randomkey | ( | ) |
|
private |
re authenticate to redis server based on previously used password
|
private |
re select db to redis server based on previously selected db
client& cpp_redis::client::readonly | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::readonly | ( | ) |
client& cpp_redis::client::readwrite | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::readwrite | ( | ) |
|
private |
reconnect to the previously connected host automatically re authenticate and resubscribe to subscribed channel in case of success
client& cpp_redis::client::rename | ( | const std::string & | key, |
const std::string & | newkey, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::rename | ( | const std::string & | key, |
const std::string & | newkey | ||
) |
client& cpp_redis::client::renamenx | ( | const std::string & | key, |
const std::string & | newkey, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::renamenx | ( | const std::string & | key, |
const std::string & | newkey | ||
) |
|
private |
resend all pending commands that failed to be sent due to disconnection
client& cpp_redis::client::restore | ( | const std::string & | key, |
int | ttl, | ||
const std::string & | serialized_value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::restore | ( | const std::string & | key, |
int | ttl, | ||
const std::string & | serialized_value | ||
) |
client& cpp_redis::client::restore | ( | const std::string & | key, |
int | ttl, | ||
const std::string & | serialized_value, | ||
const std::string & | replace, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::restore | ( | const std::string & | key, |
int | ttl, | ||
const std::string & | serialized_value, | ||
const std::string & | replace | ||
) |
client& cpp_redis::client::role | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::role | ( | ) |
client& cpp_redis::client::rpop | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::rpop | ( | const std::string & | key | ) |
client& cpp_redis::client::rpoplpush | ( | const std::string & | source, |
const std::string & | destination, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::rpoplpush | ( | const std::string & | src, |
const std::string & | dst | ||
) |
client& cpp_redis::client::rpush | ( | const std::string & | key, |
const std::vector< std::string > & | values, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::rpush | ( | const std::string & | key, |
const std::vector< std::string > & | values | ||
) |
client& cpp_redis::client::rpushx | ( | const std::string & | key, |
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::rpushx | ( | const std::string & | key, |
const std::string & | value | ||
) |
client& cpp_redis::client::sadd | ( | const std::string & | key, |
const std::vector< std::string > & | members, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::sadd | ( | const std::string & | key, |
const std::vector< std::string > & | members | ||
) |
client& cpp_redis::client::save | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::save | ( | ) |
client& cpp_redis::client::scan | ( | int | cursor, |
const std::string & | pattern, | ||
int | count, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::scan | ( | int | cursor, |
const std::string & | pattern, | ||
int | count | ||
) |
client& cpp_redis::client::scard | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::scard | ( | const std::string & | key | ) |
client& cpp_redis::client::script_debug | ( | const std::string & | mode, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::script_debug | ( | const std::string & | mode | ) |
client& cpp_redis::client::script_exists | ( | const std::vector< std::string > & | scripts, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::script_exists | ( | const std::vector< std::string > & | scripts | ) |
client& cpp_redis::client::script_flush | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::script_flush | ( | ) |
client& cpp_redis::client::script_kill | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::script_kill | ( | ) |
client& cpp_redis::client::script_load | ( | const std::string & | script, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::script_load | ( | const std::string & | script | ) |
client& cpp_redis::client::sdiff | ( | const std::vector< std::string > & | keys, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::sdiff | ( | const std::vector< std::string > & | keys | ) |
client& cpp_redis::client::sdiffstore | ( | const std::string & | destination, |
const std::vector< std::string > & | keys, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::sdiffstore | ( | const std::string & | dst, |
const std::vector< std::string > & | keys | ||
) |
client& cpp_redis::client::select | ( | int | index, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::select | ( | int | index | ) |
client& cpp_redis::client::send | ( | const std::vector< std::string > & | redis_cmd, |
const reply_callback_t & | callback | ||
) |
send the given command the command is actually pipelined and only buffered, so nothing is sent to the network please call commit() / sync_commit() to flush the buffer
redis_cmd | command to be sent |
callback | callback to be called on received reply |
std::future<reply> cpp_redis::client::send | ( | const std::vector< std::string > & | redis_cmd | ) |
same as the other send method but future based: does not take any callback and return an std:;future to handle the reply
redis_cmd | command to be sent |
client& cpp_redis::client::set | ( | const std::string & | key, |
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::set | ( | const std::string & | key, |
const std::string & | value | ||
) |
client& cpp_redis::client::set_advanced | ( | const std::string & | key, |
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
client& cpp_redis::client::set_advanced | ( | const std::string & | key, |
const std::string & | value, | ||
bool | ex, | ||
int | ex_sec, | ||
bool | px, | ||
int | px_milli, | ||
bool | nx, | ||
bool | xx, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::set_advanced | ( | const std::string & | key, |
const std::string & | value, | ||
bool | ex = false , |
||
int | ex_sec = 0 , |
||
bool | px = false , |
||
int | px_milli = 0 , |
||
bool | nx = false , |
||
bool | xx = false |
||
) |
client& cpp_redis::client::setbit_ | ( | const std::string & | key, |
int | offset, | ||
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::setbit_ | ( | const std::string & | key, |
int | offset, | ||
const std::string & | value | ||
) |
client& cpp_redis::client::setex | ( | const std::string & | key, |
int | seconds, | ||
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::setex | ( | const std::string & | key, |
int | seconds, | ||
const std::string & | value | ||
) |
client& cpp_redis::client::setnx | ( | const std::string & | key, |
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::setnx | ( | const std::string & | key, |
const std::string & | value | ||
) |
client& cpp_redis::client::setrange | ( | const std::string & | key, |
int | offset, | ||
const std::string & | value, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::setrange | ( | const std::string & | key, |
int | offset, | ||
const std::string & | value | ||
) |
|
private |
client& cpp_redis::client::shutdown | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::shutdown | ( | ) |
client& cpp_redis::client::shutdown | ( | const std::string & | save, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::shutdown | ( | const std::string & | save | ) |
client& cpp_redis::client::sinter | ( | const std::vector< std::string > & | keys, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::sinter | ( | const std::vector< std::string > & | keys | ) |
client& cpp_redis::client::sinterstore | ( | const std::string & | destination, |
const std::vector< std::string > & | keys, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::sinterstore | ( | const std::string & | dst, |
const std::vector< std::string > & | keys | ||
) |
client& cpp_redis::client::sismember | ( | const std::string & | key, |
const std::string & | member, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::sismember | ( | const std::string & | key, |
const std::string & | member | ||
) |
client& cpp_redis::client::slaveof | ( | const std::string & | host, |
int | port, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::slaveof | ( | const std::string & | host, |
int | port | ||
) |
|
private |
sleep between two reconnect attemps if necessary
client& cpp_redis::client::slowlog | ( | const std::string | subcommand, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::slowlog | ( | const std::string & | subcommand | ) |
client& cpp_redis::client::slowlog | ( | const std::string | subcommand, |
const std::string & | argument, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::slowlog | ( | const std::string & | subcommand, |
const std::string & | argument | ||
) |
client& cpp_redis::client::smembers | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::smembers | ( | const std::string & | key | ) |
client& cpp_redis::client::smove | ( | const std::string & | source, |
const std::string & | destination, | ||
const std::string & | member, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::smove | ( | const std::string & | src, |
const std::string & | dst, | ||
const std::string & | member | ||
) |
client& cpp_redis::client::spop | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::spop | ( | const std::string & | key | ) |
client& cpp_redis::client::spop | ( | const std::string & | key, |
int | count, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::spop | ( | const std::string & | key, |
int | count | ||
) |
client& cpp_redis::client::srandmember | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::srandmember | ( | const std::string & | key | ) |
client& cpp_redis::client::srandmember | ( | const std::string & | key, |
int | count, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::srandmember | ( | const std::string & | key, |
int | count | ||
) |
client& cpp_redis::client::srem | ( | const std::string & | key, |
const std::vector< std::string > & | members, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::srem | ( | const std::string & | key, |
const std::vector< std::string > & | members | ||
) |
client& cpp_redis::client::strlen | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::strlen | ( | const std::string & | key | ) |
client& cpp_redis::client::sunion | ( | const std::vector< std::string > & | keys, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::sunion | ( | const std::vector< std::string > & | keys | ) |
client& cpp_redis::client::sunionstore | ( | const std::string & | destination, |
const std::vector< std::string > & | keys, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::sunionstore | ( | const std::string & | dst, |
const std::vector< std::string > & | keys | ||
) |
client& cpp_redis::client::sync | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::sync | ( | ) |
client& cpp_redis::client::sync_commit | ( | void | ) |
same as commit(), but synchronous will block until all pending commands have been sent and that a reply has been received for each of them and all underlying callbacks completed
|
inline |
same as sync_commit, but with a timeout will simply block until it completes or timeout expires
no need to call commit in case of reconnection the reconnection flow will do it for us
client& cpp_redis::client::time | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::time | ( | ) |
|
private |
try to commit the pending pipelined if client is disconnected, will throw an exception and clear all pending callbacks (call clear_callbacks())
client& cpp_redis::client::ttl | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::ttl | ( | const std::string & | key | ) |
client& cpp_redis::client::type | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::type | ( | const std::string & | key | ) |
|
private |
unprotected auth same as auth, but without any mutex lock
password | password to be used for authentication |
reply_callback | callback to be called whenever a reply is received |
|
private |
unprotected select same as select, but without any mutex lock
index | index to be used for db select |
reply_callback | callback to be called whenever a reply is received |
|
private |
unprotected send same as send, but without any mutex lock
redis_cmd | cmd to be sent |
callback | callback to be called whenever a reply is received |
client& cpp_redis::client::unwatch | ( | const reply_callback_t & | reply_callback | ) |
std::future<reply> cpp_redis::client::unwatch | ( | ) |
client& cpp_redis::client::wait | ( | int | numslaves, |
int | timeout, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::wait | ( | int | numslaves, |
int | timeout | ||
) |
client& cpp_redis::client::watch | ( | const std::vector< std::string > & | keys, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::watch | ( | const std::vector< std::string > & | keys | ) |
client& cpp_redis::client::zadd | ( | const std::string & | key, |
const std::vector< std::string > & | options, | ||
const std::map< std::string, std::string > & | score_members, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zadd | ( | const std::string & | key, |
const std::vector< std::string > & | options, | ||
const std::map< std::string, std::string > & | score_members | ||
) |
client& cpp_redis::client::zcard | ( | const std::string & | key, |
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zcard | ( | const std::string & | key | ) |
client& cpp_redis::client::zcount | ( | const std::string & | key, |
int | min, | ||
int | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zcount | ( | const std::string & | key, |
int | min, | ||
int | max | ||
) |
client& cpp_redis::client::zcount | ( | const std::string & | key, |
double | min, | ||
double | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zcount | ( | const std::string & | key, |
double | min, | ||
double | max | ||
) |
client& cpp_redis::client::zcount | ( | const std::string & | key, |
const std::string & | min, | ||
const std::string & | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zcount | ( | const std::string & | key, |
const std::string & | min, | ||
const std::string & | max | ||
) |
client& cpp_redis::client::zincrby | ( | const std::string & | key, |
int | incr, | ||
const std::string & | member, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zincrby | ( | const std::string & | key, |
int | incr, | ||
const std::string & | member | ||
) |
client& cpp_redis::client::zincrby | ( | const std::string & | key, |
double | incr, | ||
const std::string & | member, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zincrby | ( | const std::string & | key, |
double | incr, | ||
const std::string & | member | ||
) |
client& cpp_redis::client::zincrby | ( | const std::string & | key, |
const std::string & | incr, | ||
const std::string & | member, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zincrby | ( | const std::string & | key, |
const std::string & | incr, | ||
const std::string & | member | ||
) |
client& cpp_redis::client::zlexcount | ( | const std::string & | key, |
int | min, | ||
int | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zlexcount | ( | const std::string & | key, |
int | min, | ||
int | max | ||
) |
client& cpp_redis::client::zlexcount | ( | const std::string & | key, |
double | min, | ||
double | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zlexcount | ( | const std::string & | key, |
double | min, | ||
double | max | ||
) |
client& cpp_redis::client::zlexcount | ( | const std::string & | key, |
const std::string & | min, | ||
const std::string & | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zlexcount | ( | const std::string & | key, |
const std::string & | min, | ||
const std::string & | max | ||
) |
client& cpp_redis::client::zrange | ( | const std::string & | key, |
int | start, | ||
int | stop, | ||
const reply_callback_t & | reply_callback | ||
) |
client& cpp_redis::client::zrange | ( | const std::string & | key, |
int | start, | ||
int | stop, | ||
bool | withscores, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zrange | ( | const std::string & | key, |
int | start, | ||
int | stop, | ||
bool | withscores = false |
||
) |
client& cpp_redis::client::zrange | ( | const std::string & | key, |
double | start, | ||
double | stop, | ||
const reply_callback_t & | reply_callback | ||
) |
client& cpp_redis::client::zrange | ( | const std::string & | key, |
double | start, | ||
double | stop, | ||
bool | withscores, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zrange | ( | const std::string & | key, |
double | start, | ||
double | stop, | ||
bool | withscores = false |
||
) |
client& cpp_redis::client::zrange | ( | const std::string & | key, |
const std::string & | start, | ||
const std::string & | stop, | ||
const reply_callback_t & | reply_callback | ||
) |
client& cpp_redis::client::zrange | ( | const std::string & | key, |
const std::string & | start, | ||
const std::string & | stop, | ||
bool | withscores, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zrange | ( | const std::string & | key, |
const std::string & | start, | ||
const std::string & | stop, | ||
bool | withscores = false |
||
) |
client& cpp_redis::client::zrank | ( | const std::string & | key, |
const std::string & | member, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zrank | ( | const std::string & | key, |
const std::string & | member | ||
) |
client& cpp_redis::client::zrem | ( | const std::string & | key, |
const std::vector< std::string > & | members, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zrem | ( | const std::string & | key, |
const std::vector< std::string > & | members | ||
) |
client& cpp_redis::client::zremrangebylex | ( | const std::string & | key, |
int | min, | ||
int | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zremrangebylex | ( | const std::string & | key, |
int | min, | ||
int | max | ||
) |
client& cpp_redis::client::zremrangebylex | ( | const std::string & | key, |
double | min, | ||
double | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zremrangebylex | ( | const std::string & | key, |
double | min, | ||
double | max | ||
) |
client& cpp_redis::client::zremrangebylex | ( | const std::string & | key, |
const std::string & | min, | ||
const std::string & | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zremrangebylex | ( | const std::string & | key, |
const std::string & | min, | ||
const std::string & | max | ||
) |
client& cpp_redis::client::zremrangebyrank | ( | const std::string & | key, |
int | start, | ||
int | stop, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zremrangebyrank | ( | const std::string & | key, |
int | start, | ||
int | stop | ||
) |
client& cpp_redis::client::zremrangebyrank | ( | const std::string & | key, |
double | start, | ||
double | stop, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zremrangebyrank | ( | const std::string & | key, |
double | start, | ||
double | stop | ||
) |
client& cpp_redis::client::zremrangebyrank | ( | const std::string & | key, |
const std::string & | start, | ||
const std::string & | stop, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zremrangebyrank | ( | const std::string & | key, |
const std::string & | start, | ||
const std::string & | stop | ||
) |
client& cpp_redis::client::zremrangebyscore | ( | const std::string & | key, |
int | min, | ||
int | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zremrangebyscore | ( | const std::string & | key, |
int | min, | ||
int | max | ||
) |
client& cpp_redis::client::zremrangebyscore | ( | const std::string & | key, |
double | min, | ||
double | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zremrangebyscore | ( | const std::string & | key, |
double | min, | ||
double | max | ||
) |
client& cpp_redis::client::zremrangebyscore | ( | const std::string & | key, |
const std::string & | min, | ||
const std::string & | max, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zremrangebyscore | ( | const std::string & | key, |
const std::string & | min, | ||
const std::string & | max | ||
) |
client& cpp_redis::client::zrevrange | ( | const std::string & | key, |
int | start, | ||
int | stop, | ||
const reply_callback_t & | reply_callback | ||
) |
client& cpp_redis::client::zrevrange | ( | const std::string & | key, |
int | start, | ||
int | stop, | ||
bool | withscores, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zrevrange | ( | const std::string & | key, |
int | start, | ||
int | stop, | ||
bool | withscores = false |
||
) |
client& cpp_redis::client::zrevrange | ( | const std::string & | key, |
double | start, | ||
double | stop, | ||
const reply_callback_t & | reply_callback | ||
) |
client& cpp_redis::client::zrevrange | ( | const std::string & | key, |
double | start, | ||
double | stop, | ||
bool | withscores, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zrevrange | ( | const std::string & | key, |
double | start, | ||
double | stop, | ||
bool | withscores = false |
||
) |
client& cpp_redis::client::zrevrange | ( | const std::string & | key, |
const std::string & | start, | ||
const std::string & | stop, | ||
const reply_callback_t & | reply_callback | ||
) |
client& cpp_redis::client::zrevrange | ( | const std::string & | key, |
const std::string & | start, | ||
const std::string & | stop, | ||
bool | withscores, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zrevrange | ( | const std::string & | key, |
const std::string & | start, | ||
const std::string & | stop, | ||
bool | withscores = false |
||
) |
client& cpp_redis::client::zrevrank | ( | const std::string & | key, |
const std::string & | member, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zrevrank | ( | const std::string & | key, |
const std::string & | member | ||
) |
client& cpp_redis::client::zscore | ( | const std::string & | key, |
const std::string & | member, | ||
const reply_callback_t & | reply_callback | ||
) |
std::future<reply> cpp_redis::client::zscore | ( | const std::string & | key, |
const std::string & | member | ||
) |
|
private |
callbacks thread safety
|
private |
number of callbacks currently being running
|
private |
to force cancel reconnection
|
private |
tcp client for redis connection
|
private |
sent commands waiting to be executed
|
private |
user defined connect status callback
|
private |
max time to connect
|
private |
current number of attemps to reconect
|
private |
selected redis db
|
private |
master name (if we are using sentinel) we are connected to
|
private |
max number of reconnection attemps
|
private |
password used to authenticate
|
private |
time between two reconnection attemps
|
private |
reconnection status
|
private |
port we are connected to
|
private |
server we are connected to
|
private |
redis sentinel
|
private |
condvar for callbacks updates