DDSTopology.h

/********************************************************************************
 *    Copyright (C) 2019 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH    *
 *                                                                              *
 *              This software is distributed under the terms of the             *
 *              GNU Lesser General Public Licence (LGPL) version 3,             *
 *                  copied verbatim in the file "LICENSE"                       *
 ********************************************************************************/
 
#ifndef FAIR_MQ_SDK_DDSTOPOLOGY_H
#define FAIR_MQ_SDK_DDSTOPOLOGY_H
 
#include <boost/filesystem.hpp>
#include <fairmq/sdk/DDSCollection.h>
#include <fairmq/sdk/DDSEnvironment.h>
#include <fairmq/sdk/DDSInfo.h>
#include <fairmq/sdk/DDSTask.h>
#include <memory>
#include <string>
#include <vector>
 
namespace fair::mq::sdk
{
 
class DDSTopology
{
  public:
    using Path = boost::filesystem::path;
 
    DDSTopology() = delete;
 
    explicit DDSTopology(Path topoFile, DDSEnvironment env = DDSEnvironment());
 
    explicit DDSTopology(dds::topology_api::CTopology nativeTopology, DDSEnv env = {});
 
    auto GetEnv() const -> DDSEnvironment;
 
    auto GetTopoFile() const -> Path;
 
    auto GetNumRequiredAgents() const -> int;
 
    auto GetTasks(const std::string& = "") const -> std::vector<DDSTask>;
 
    auto GetCollections() const -> std::vector<DDSCollection>;
 
    auto GetName() const -> std::string;
 
    friend auto operator<<(std::ostream&, const DDSTopology&) -> std::ostream&;
 
  private:
    struct Impl;
    std::shared_ptr<Impl> fImpl;
};
 
using DDSTopo = DDSTopology;
 
} // namespace fair::mq::sdk
 
#endif /* FAIR_MQ_SDK_DDSTOPOLOGY_H */