Process.h

Go to the documentation of this file.

#ifndef LINTEL_PROCESS_H
#define LINTEL_PROCESS_H
 
#include <chrono>
#include <filesystem>
#include <functional>
#include <memory>
#include <optional>
#include <string>
#include <vector>
 
#include "lintel/core/utils/UUID.h"
 
namespace lintel {
class Process
{
private:
  // UUID
  std::string m_id = UUID::generate();
  // process
  std::filesystem::path m_path;
  std::vector<std::string> m_args;
  // configuration
  std::string m_configName;
  bool m_autoRestart = false;
  int32_t m_restarts = 0;
  int m_maxAutoRestarts = -1;
  // automation policy
  std::chrono::milliseconds m_restartDelay = std::chrono::milliseconds(0);
  std::chrono::milliseconds m_restartDelayMax = std::chrono::milliseconds(0);
  std::chrono::milliseconds m_minUptime = std::chrono::milliseconds(0);
  int m_maxRestartRate = -1;
  std::chrono::milliseconds m_restartWindow = std::chrono::milliseconds(0);
  std::chrono::milliseconds m_restartInterval = std::chrono::milliseconds(0);
  std::optional<int32_t> m_activeFromHour;
  std::optional<int32_t> m_activeToHour;
  std::optional<double> m_cpuNotify;
  std::optional<uint64_t> m_memoryNotify;
  // events
  std::shared_ptr<std::function<void(const Process &)>> m_onStart = nullptr;
  std::shared_ptr<std::function<void(const Process &)>> m_onStop = nullptr;
  std::shared_ptr<std::function<void(const Process &)>> m_onRestart = nullptr;
  std::shared_ptr<std::function<void(const Process &)>> m_onTerminate = nullptr;
  std::shared_ptr<std::function<void(const Process &)>> m_onFinish = nullptr;
 
public:
  explicit Process(std::filesystem::path path, std::vector<std::string> args, std::string configName = "");
 
  void addOnStartEvent(std::shared_ptr<std::function<void(const Process &)>> onStart);
 
  void addOnStopEvent(std::shared_ptr<std::function<void(const Process &)>> onStop);
 
  void addOnRestartEvent(std::shared_ptr<std::function<void(const Process &)>> onRestart);
 
  void addOnTerminateEvent(std::shared_ptr<std::function<void(const Process &)>> onTerminate);
 
  void addOnFinishEvent(std::shared_ptr<std::function<void(const Process &)>> onFinish);
 
  void enableAutoStart(int maxAutoRestarts = -1);
 
  void disableAutoStart();
 
  void increaseRestarts();
 
  void resetRestarts();
 
  [[nodiscard]] int currentRestarts() const;
 
  [[nodiscard]] const std::string &getId() const;
 
  [[nodiscard]] const std::filesystem::path &getPath() const;
 
  [[nodiscard]] bool isAutoRestart() const;
 
  [[nodiscard]] int getMaxAutoRestarts() const;
 
  [[nodiscard]] const std::vector<std::string> &getArgs() const;
 
  [[nodiscard]] const std::string &getConfigName() const;
 
  // --- automation policy ---
 
  void setRestartDelay(std::chrono::milliseconds delay);
 
  [[nodiscard]] std::chrono::milliseconds getRestartDelay() const;
 
  void setRestartDelayMax(std::chrono::milliseconds delayMax);
 
  [[nodiscard]] std::chrono::milliseconds getRestartDelayMax() const;
 
  void setMinUptime(std::chrono::milliseconds minUptime);
 
  [[nodiscard]] std::chrono::milliseconds getMinUptime() const;
 
  void setMaxRestartRate(int maxRestartRate);
 
  [[nodiscard]] int getMaxRestartRate() const;
 
  void setRestartWindow(std::chrono::milliseconds restartWindow);
 
  [[nodiscard]] std::chrono::milliseconds getRestartWindow() const;
 
  void setRestartInterval(std::chrono::milliseconds restartInterval);
 
  [[nodiscard]] std::chrono::milliseconds getRestartInterval() const;
 
  void setActiveFromHour(std::optional<int32_t> activeFromHour);
 
  [[nodiscard]] std::optional<int32_t> getActiveFromHour() const;
 
  void setActiveToHour(std::optional<int32_t> activeToHour);
 
  [[nodiscard]] std::optional<int32_t> getActiveToHour() const;
 
  [[nodiscard]] bool hasActiveWindow() const;
 
  [[nodiscard]] bool inActiveWindow() const;
 
  void setCpuNotify(std::optional<double> cpuNotify);
 
  [[nodiscard]] std::optional<double> getCpuNotify() const;
 
  void setMemoryNotify(std::optional<uint64_t> memoryNotify);
 
  [[nodiscard]] std::optional<uint64_t> getMemoryNotify() const;
 
  void onStart() const;
 
  void onStop() const;
 
  void onRestart() const;
 
  void onTerminate() const;
 
  void onFinish() const;
};
 
}// namespace lintel
#endif// LINTEL_PROCESS_H