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