dbAdapterRedis.hpp

Go to the documentation of this file.

 
#ifndef RAD_DB_ADAPTER_REDIS_HPP
#define RAD_DB_ADAPTER_REDIS_HPP
 
#include <rad/dbAdapter.hpp>
 
#include <hiredis.h>
 
#include <map>
#include <string>
#include <vector>
 
namespace rad {
 
class DbAdapterRedis : public DbAdapter {
   public:
    DbAdapterRedis();
    DbAdapterRedis(const std::string& ipaddr, const int port, const timeval& timeout);
    virtual ~DbAdapterRedis();
 
    void Config(const std::string& endpoint, const timeval& timeout);
 
    int Delete(const std::vector<std::string>& keys);
    bool Exists(const std::string& key);
 
    std::string Get(const std::string& key);
    std::vector<std::string> MultiGet(const std::vector<std::string>& keys);
    std::string Get(const std::string& key, const std::string& field);
    std::vector<std::string> MultiGet(const std::string& key,
                                      const std::vector<std::string>& fields);
    std::map<std::string, std::string> Scan(const std::string& key, const std::string& pattern);
 
    void Set(const std::string& key, const std::string& value);
    void MultiSet(const std::vector<std::string>& kvs);
    void Set(const std::string& key, const std::string& field, const std::string& value);
    void MultiSet(const std::string& key, const std::vector<std::string>& fvs);
 
    void Connect();
    void Disconnect();
    bool IsConnected();
 
    DbAdapterRedis(const DbAdapterRedis&) = delete;             
    DbAdapterRedis& operator=(const DbAdapterRedis&) = delete;  
 
   private:
    bool m_is_connected;
    std::string m_ip_addr;
    int m_port;
    timeval m_timeout;
    redisContext* m_context;
};
 
}  // namespace rad
 
#endif