Notify.h

Go to the documentation of this file.

#ifndef LINTEL_POSTGRESQL_NOTIFY_H
#define LINTEL_POSTGRESQL_NOTIFY_H
 
#include <libpq-fe.h>
 
#include <atomic>
#include <chrono>
#include <functional>
#include <string>
#include <thread>
 
#include "Connection.h"
 
namespace lintel {
namespace postgresql {
  class Notify
  {
  private:
    static constexpr int32_t kTimeoutSeconds = 1;
    std::atomic<bool> m_shutdown = false;
    Connection &m_connection;
    PGconn *m_conn = nullptr;
    std::thread m_thread;
 
    std::string m_tableName;
    std::function<void()> m_callBack;
    std::chrono::seconds m_timeout{ kTimeoutSeconds };
 
    void run();
 
    void listen();
 
  public:
    explicit Notify(Connection &connection, std::string tableName, std::function<void()> &callBack);
 
    ~Notify();
  };
}// namespace postgresql
 
}// namespace lintel
#endif// LINTEL_POSTGRESQL_NOTIFY_H