core/monitor/monitor_provider.h

/* monitor_provider.h                                              -*- C++ -*-
   Wolfgang Sourdeau, January 2013
   Copyright (c) 2013 Datacratic.  All rights reserved.
   
   Rest endpoint queried by the monitor in the provider processes
*/

#pragma once

#include <memory>

#include "soa/types/date.h"
#include "soa/service/rest_proxy.h"

namespace zmq {
    struct context_t;
} // namespace zmq

namespace Json {
    struct Value;
} // namespace Json

namespace RTBKIT {
    using namespace Datacratic;

struct MonitorProvider
{
    /* this method returns the service identifier to use when sending status
       information to the Monitor */
    virtual std::string getProviderName() const = 0;

    /* this method returns the service status: "true" indicates that all the
       service-specific conditions are fulfilled, "false" otherwise */
    virtual Json::Value getProviderIndicators() const = 0;
};

struct MonitorProviderClient : public RestProxy
{
    MonitorProviderClient(const std::shared_ptr<zmq::context_t> & context,
                          MonitorProvider & provider);

    ~MonitorProviderClient();
 
    void init(std::shared_ptr<ConfigurationService> & config,
              const std::string & serviceName = "monitor");

    void shutdown();

    void postStatus();

    void onResponseReceived(std::exception_ptr ext,
                            int responseCode, const std::string & body);

    MonitorProvider & provider_;

    bool inhibit_;

    std::string restUrlPath_;

    RestProxy::OnDone onDone;

    bool pendingRequest;

    typedef std::unique_lock<std::mutex> Guard;
    mutable std::mutex requestLock;
};

} // namespace RTBKIT