deploymentDaemonBusinessLogic.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_DEPLOYMENT_DAEMON_BUSINESSLOGIC_HPP
#define RTCTK_REUSABLECOMPONENT_DEPLOYMENT_DAEMON_BUSINESSLOGIC_HPP
 
#include "deploymentDaemonLifeCycle.hpp"
#include "rtctk/componentFramework/serviceContainer.hpp"
#include <rtctk/componentFramework/componentMetricsIf.hpp>
#include <rtctk/componentFramework/persistentRepoIf.hpp>
#include <rtctk/componentFramework/serviceDiscovery.hpp>
 
#include <pybind11/pybind11.h>
 
#include <mutex>
 
namespace rtctk::deploymentDaemon {
 
using LifeCycle = DeploymentDaemonLifeCycle;
namespace py = pybind11;
 
class RTCTK_LOCAL DeploymentDaemonBusinessLogic : public LifeCycle::BizLogicIf {
public:
    using ComponentType = LifeCycle;
    DeploymentDaemonBusinessLogic(const std::string& name,
                                  ServiceContainer& services,
                                  const elt::mal::Uri& sde);
 
    virtual ~DeploymentDaemonBusinessLogic();
 
    void ActivityDeploying(StopToken st, std::string args) override;
    void ActivityUndeploying(StopToken st) override;
 
    std::string ActionGetActiveDeployment() override;
    std::string ActionGetDescription() override;
 
    std::vector<std::string> ActionGetDeploymentSets() override;
 
    std::vector<std::string> ActionGetComponents() override;
 
    std::vector<std::string> ActionGetActiveComponents() override;
 
    void ActionStartComponent(std::string component_name) override;
    void ActionStopComponent(std::string component_name) override;
 
    void ActivityStarting(cfw::StopToken st) override;
 
    std::vector<std::string> ActionGetServices() override;
    std::vector<std::string> ActionGetActiveServices() override;
 
protected:
    void DeployServices(const DataPointPath& depl_set_path);
 
    void DeployComponents(const DataPointPath& depl_set_path);
 
    void UndeployProcesses(std::vector<std::string>& proceses);
 
    void StartProcess(const std::string& name,
                      const std::string& type,
                      const DataPointPath& depl_set_path);
 
    void StopProces(const std::string& component_name, const bool check_error = true);
 
    void GetDeploymentSets();
 
    void InitPythonObjects();
 
    void CleanupPythonObjects() noexcept;
 
    log4cplus::Logger& m_logger;
 
    const std::string m_name;
 
    rtctk::componentFramework::ServiceContainer& m_service_container;
 
    rtctk::componentFramework::ServiceDiscovery& m_service_discovery;
 
    std::unique_ptr<rtctk::componentFramework::PersistentRepoIf> m_persistent_repo;
 
    std::vector<std::string> m_deployment_sets;
 
    std::string m_active_deployment_set;
 
    std::string m_description;
 
    std::vector<std::string> m_services;
 
    std::vector<std::string> m_components;
 
    elt::mal::Uri m_sde;
 
    std::mutex m_mutex;
 
    struct PythonObjects {
        py::module m_module;
        py::object m_init_logger_config;
        py::object m_generate_nomad_job_from_dp;
    };
 
    std::unique_ptr<PythonObjects> m_pyobjects;
};
 
}  // namespace rtctk::deploymentDaemon
 
#endif  // RTCTK_REUSABLECOMPONENT_DEPLOYMENT_DAEMON_BUSINESSLOGIC_HPP