consulServiceRegistryAdapter.hpp

Go to the documentation of this file.

 
#ifndef CONSULSERVICEREGISTRYADAPTER_HPP
#define CONSULSERVICEREGISTRYADAPTER_HPP
 
#include <memory>
#include <ppconsul/agent.h>
#include <string>
 
#include <mal/Cii.hpp>
 
#include <rtctk/componentFramework/dataPointPath.hpp>
#include <rtctk/componentFramework/serviceRegistryIf.hpp>
 
namespace rtctk::componentFramework {

class ConsulServiceRegistryAdapter : public ServiceRegistryIf {
public:
    inline static const std::string SUPPORTED_URI_SCHEME = "consul";
 
    ConsulServiceRegistryAdapter(const elt::mal::Uri& endpoint);
    std::vector<std::string>
    ListComponents(const std::string& service_type = COMPONENT_TYPE) override;
    ServiceEndpoint Get(const std::string& comp_name,
                        const std::string& service_name,
                        const std::string& service_type,
                        const bool health_check) override;
    ServiceEndpoint GetOldbEndpoint() override;
    ServiceEndpoint GetRuntimeRepoEndpoint() override;
    ServiceEndpoint GetPersistentRepoEndpoint() override;
    ServiceEndpoint GetTelegrafEndpoint() override;
    bool IsComponent(const ppconsul::ServiceInfo& service_info,
                     const std::string& service_type = COMPONENT_TYPE);
    ppconsul::ServiceInfo GetComponentDefinedInConsul(const std::string& comp_name,
                                                      const std::string& service_name,
                                                      const std::string& service_type);
 
private:
    static const std::string CONSUL_COMMON_SERVICE;
    static const std::string CONSUL_NAME_KEY;
    static const std::string CONSUL_TYPE_KEY;
    static const std::string CONSUL_ENDPOINT_TYPE_KEY;
    static const std::string CONSUL_ENDPOINT_URI_KEY;
    static const std::string RUNTIME_REPO_ENDPOINT;
    static const std::string PERSISTENT_REPO_ENDPOINT;
    static const std::string OLDB_ENDPOINT;
    static const std::string TELEGRAF_ENDPOINT;
    std::unique_ptr<ppconsul::Consul> m_consul_client;
    std::unique_ptr<ppconsul::agent::Agent> m_consul_agent;
    std::map<std::string, ppconsul::ServiceInfo> services;
    elt::mal::Uri sde;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // CONSULSERVICEREGISTRYADAPTER_HPP