HistoryRepository.h

Go to the documentation of this file.

#ifndef LINTEL_HISTORYREPOSITORY_H
#define LINTEL_HISTORYREPOSITORY_H
 
#include "lintel/core/configuration/DatabaseConnectionEntry.h"
#include "lintel/core/persistence/DatabaseConnectionConfigurations.h"
#include "lintel/features/base/models/HistoryEntry.h"
#include <chrono>
 
namespace lintel {
class HistoryRepository
{
private:
  // injections
  std::shared_ptr<DatabaseConnectionConfigurations> m_connectionConfigurations;
  std::shared_ptr<DatabaseConnectionEntry> m_connectionEntry;
 
public:
  [[nodiscard]] std::vector<HistoryEntry> allOf() const;
 
  [[nodiscard]] std::vector<HistoryEntry> allOf(const std::string &label) const;
 
  [[nodiscard]] std::vector<HistoryEntry> allOf(const std::string &processName, const std::string &serviceName) const;
 
  [[nodiscard]] std::vector<HistoryEntry>
    allOf(const std::string &processName, const std::string &serviceName, const std::string &label) const;
 
  [[nodiscard]] std::vector<HistoryEntry> allOfProcess(const std::string &processName) const;
 
  [[nodiscard]] std::vector<HistoryEntry> allOfService(const std::string &serviceName) const;
 
  void insertOf(const std::vector<HistoryEntry> &entries) const;
 
  void cleanAllOlderThan(std::chrono::sys_time<std::chrono::microseconds> timestamp) const;
 
  explicit HistoryRepository(const std::shared_ptr<DatabaseConnectionConfigurations> &databaseConnectionConfigurations);
};
 
}// namespace lintel
#endif// LINTEL_HISTORYREPOSITORY_H