serviceDiscovery.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_SERVICEDISCOVERY_HPP
#define RTCTK_COMPONENTFRAMEWORK_SERVICEDISCOVERY_HPP
 
#include <memory>
#include <string>
#include <vector>
 
#include <mal/Cii.hpp>
 
#include <rtctk/componentFramework/exceptions.hpp>
#include <rtctk/componentFramework/serviceRegistryIf.hpp>
 
namespace rtctk::componentFramework {

class ServiceDiscovery {
public:
    using ServiceEndpoint = ServiceRegistryIf::ServiceEndpoint;

    explicit ServiceDiscovery(std::unique_ptr<ServiceRegistryIf>&& adapter,
                              const std::string& comp_name = "");

    explicit ServiceDiscovery(const elt::mal::Uri& registry, const std::string& comp_name = "");

    std::vector<std::string>
    ListComponents(const std::string& service_type = ServiceRegistryIf::COMPONENT_TYPE);

    ServiceEndpoint GetOldbEndpoint();
    ServiceEndpoint GetRuntimeRepoEndpoint();
    ServiceEndpoint GetPersistentRepoEndpoint();
    ServiceEndpoint GetTelegrafEndpoint();
    ServiceEndpoint
    GetReqRepEndpoint(const std::string& name = "",
                      const std::string& service_type = ServiceRegistryIf::COMPONENT_TYPE,
                      const bool health_check = true);
    ServiceEndpoint
    GetPubSubEndpoint(const std::string& component_name = "",
                      const std::string& service_type = ServiceRegistryIf::COMPONENT_TYPE,
                      const bool health_check = true);
 
private:
    std::unique_ptr<ServiceRegistryIf> m_adapter;
    const std::string m_component_name;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_SERVICEDISCOVERY_HPP