redis_client.h

#pragma once
 
#include "chrono"
#include "cpp_redis/cpp_redis"
#include "shared/constants.h"
#include "software/logger/logger.h"
#include "string"
#include "unordered_map"
 
 
class RedisClient
{
   public:
    explicit RedisClient(std::string address, size_t port);
 
    virtual ~RedisClient();
 
 
    std::string getSync(const std::string &key);
 
    void getAsync(const std::string &key,
                  const cpp_redis::reply_callback_t &reply_callback);
 
    void getAsyncNoCommit(const std::string &key,
                          const cpp_redis::reply_callback_t &reply_callback);
 
    void setAsync(const std::string &key, const std::string &value);
 
    void setSync(const std::string &key, const std::string &value);
 
    void setNoCommit(const std::string &key, const std::string &value);
 
    void asyncCommit();
 
    void syncCommit();
 
    std::unordered_map<std::string, std::string> getAllKeyValuePairs();
 
   private:
    cpp_redis::subscriber subscriber_;
    cpp_redis::client client_;
    std::unordered_map<std::string, std::string> key_value_set_;
    // Connection Parameters
    std::string host_;
    size_t port_;
};