plugins/data_logger/data_logger.h

/* data_logger.h                                 -*- C++ -*-
   Jeremy Barnes, March 2011
   Wolfgang Sourdeau, February 2013
   Copyright (c) 2012, 2013 Datacratic.  All rights reserved.

   DataLogger class
*/

#pragma once

#include <string>
#include <boost/function.hpp>
#include <boost/shared_ptr.hpp>

#include "soa/service/service_base.h"
#include "soa/service/zmq_named_pub_sub.h"
#include "rtbkit/core/monitor/monitor_provider.h"

#include "soa/logger/logger.h"

namespace RTBKIT {

struct DataLogger : public Datacratic::ServiceBase,
                    public MonitorProvider,
                    public Datacratic::Logger {
    DataLogger(std::shared_ptr<Datacratic::ServiceProxies> proxies);
    ~DataLogger();

    void init();
    void shutdown();

    void start(std::function<void ()> onStop = 0);

    void connectAllServiceProviders(const std::string & serviceClass,
                                    const std::string & epName);

    // Subscription object to the named services
    Datacratic::ZmqNamedMultipleSubscriber multipleSubscriber;

    MonitorProviderClient monitorProviderClient;

    /* MonitorProvider interface */
    std::string getProviderName() const;
    Json::Value getProviderIndicators() const;
};

} // namespace RTKBIT