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 <map>
#include <string>
#include <vector>
 
// forward declatation to avoid including <hiredis.h> in the public interface
struct redisContext;
 
namespace rad {
 
class DbAdapterRedis : public DbAdapter {
   public:
    DbAdapterRedis();
    DbAdapterRedis(const std::string& ipaddr, const int port, const timeval& timeout);
 
    ~DbAdapterRedis() override;
    void Config(const std::string& endpoint, const timeval& timeout) override;
 
    int Delete(const std::vector<std::string>& keys) override;
    bool Exists(const std::string& key) override;
 
    std::string Get(const std::string& key) override;
    std::vector<std::string> MultiGet(const std::vector<std::string>& keys) override;
    std::string Get(const std::string& key, const std::string& field) override;
    std::vector<std::string> MultiGet(const std::string& key,
                                      const std::vector<std::string>& fields) override;
    std::map<std::string, std::string> Scan(const std::string& key,
                                            const std::string& pattern) override;
 
    void Set(const std::string& key, const std::string& value) override;
    void MultiSet(const std::vector<std::string>& kvs) override;
    void Set(const std::string& key,
             const std::string& field,
             const std::string& value) override;
    void MultiSet(const std::string& key, const std::vector<std::string>& fvs) override;
 
    void Connect() override;
    void Disconnect() override;
    bool IsConnected() override;
 
    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