broker_config.h

#ifndef RECODEX_BROKER_CONFIG_H
#define RECODEX_BROKER_CONFIG_H

#include <iostream>
#include <map>
#include <string>
#include <yaml-cpp/yaml.h>

#define BOOST_FILESYSTEM_NO_DEPRECATED
#define BOOST_NO_CXX11_SCOPED_ENUMS
#include <boost/filesystem.hpp>
namespace fs = boost::filesystem;

#include "log_config.h"
#include "notifier_config.h"


class broker_config
{
public:
    broker_config();
    broker_config(const YAML::Node &config);
    virtual const std::string &get_client_address() const;
    virtual uint16_t get_client_port() const;
    virtual const std::string &get_worker_address() const;
    virtual uint16_t get_worker_port() const;
    virtual const std::string &get_monitor_address() const;
    virtual uint16_t get_monitor_port() const;
    virtual size_t get_max_worker_liveness() const;
    virtual size_t get_max_request_failures() const;
    virtual std::chrono::milliseconds get_worker_ping_interval() const;
    const log_config &get_log_config() const;
    const notifier_config &get_notifier_config() const;

private:
    std::string client_address_ = "*"; // '*' is any address
    uint16_t client_port_ = 0;
    std::string worker_address_ = "*"; // '*' is any address
    uint16_t worker_port_ = 0;
    std::string monitor_address_ = "127.0.0.1";
    uint16_t monitor_port_ = 7894;
    size_t max_worker_liveness_ = 4;
    size_t max_request_failures_ = 3;
    std::chrono::milliseconds worker_ping_interval_ = std::chrono::milliseconds(1000);
    log_config log_config_;
    notifier_config notifier_config_;
};


class config_error : public std::runtime_error
{
public:
    explicit config_error(const std::string &msg) : std::runtime_error(msg)
    {
    }
};

#endif // RECODEX_BROKER_CONFIG_H