core/monitor/monitor_service_runner.cc

/* monitor_service_runner.cc
   Wolfgang Sourdeau, February 2013
   Copyright (c) 2013 Datacratic.  All rights reserved.

   Monitor service runner
*/

#include <boost/program_options/parsers.hpp>
#include <boost/program_options/variables_map.hpp>
#include <boost/make_shared.hpp>

#include "jml/arch/timers.h"
#include "soa/service/service_utils.h"
#include "monitor_endpoint.h"

using namespace boost::program_options;
using namespace std;

using namespace Datacratic;
using namespace RTBKIT;


int main(int argc, char ** argv)
{
    Datacratic::ServiceProxyArguments args;

    options_description options = args.makeProgramOptions("Monitor Service");
    options.add_options() ("help,h", "Print this message");

    variables_map vm;
    store(command_line_parser(argc, argv) .options(options) .run(), vm);
    notify(vm);

    if (vm.count("help")) {
        cerr << options << endl;
        exit(1);
    }

    auto proxies = args.makeServiceProxies();

    MonitorEndpoint monitor(proxies, "monitor");
    monitor.init({"router", "postAuction", "masterBanker", "data_logger",
                "agentConfigurationService"});
    auto addr = monitor.bindTcp(
            proxies->ports->getRange("monitor.zmq"),
            proxies->ports->getRange("monitor.http"));
    cerr << "monitor is listening on "
         << addr.first << "," << addr.second << endl;

    proxies->config->dump(cerr);

    monitor.startSync();

    return 0;
}