oldbAsyncWriter.hpp

Go to the documentation of this file.

 
#ifndef RAD_OLDB_ASYNC_WRITER_HPP
#define RAD_OLDB_ASYNC_WRITER_HPP
 
#include <rad/doubleMap.hpp>
#include <rad/activityUpdateOldb.hpp>
#include <rad/cii/oldbTypes.hpp>
#include <rad/cii/oldbAdapter.hpp>
#include <scxml4cpp/Context.h>
 
namespace rad {
 
class OldbAsyncWriter {
 public:
    OldbAsyncWriter(std::chrono::seconds conn_timeout,
                    std::chrono::milliseconds period);
    virtual ~OldbAsyncWriter();
 
    void Configure(const std::chrono::seconds conn_timeout,
                   const std::chrono::milliseconds period,
                   const std::string& oldb_prefix);
 
    rad::ActivityUpdateOldb& GetActyivityUpdateOldb();
 
    rad::cii::OldbAdapter& GetOldbAdapter();
 
    void SetOldbPrefix(const std::string& prefix);
 
    void StartWriter();
 
    void StopWriter();
 
    void Set(const std::string& key, const rad::cii::OldbType& value);
 
    void Set(const std::map<std::string, rad::cii::OldbType>& kv_map);
 
    OldbAsyncWriter(const OldbAsyncWriter&) = delete;         
    OldbAsyncWriter& operator=(const OldbAsyncWriter&) = delete;  
 
 private:
    rad::DoubleMap<rad::cii::OldbType> m_oldb_map;  
    rad::ActivityUpdateOldb m_activity_update;  
    scxml4cpp::Context m_scxml_context;  
};
 
}  // namespace rad
 
#endif  // RAD_OLDB_ASYNC_WRITER_HPP