soa/logger/remote_output.h

/* remote_output.h                                                 -*- C++ -*-
   Jeremy Barnes, 23 May 2011
   Copyright (c) 2011 Datacratic.  All rights reserved.

   Output source that goes to a remote sink.  TCP/IP.

   
*/

#pragma once

#include "logger.h"
#include "soa/service/active_endpoint.h"


namespace Datacratic {


struct RemoteOutputConnection;


/*****************************************************************************/
/* REMOTE OUTPUT                                                             */
/*****************************************************************************/

struct RemoteOutput
    : public LogOutput,
      protected ActiveEndpointT<SocketTransport> {

    RemoteOutput();

    virtual ~RemoteOutput();

    void connect(int port, const std::string & hostname, double timeout = 10.0);
    
    void shutdown();

    void barrier();

    void flush();

    void sync();

    void close();

    virtual void logMessage(const std::string & channel,
                            const std::string & message);

    virtual void
    notifyCloseTransport(const std::shared_ptr<TransportBase> & transport);

    boost::function<void (const std::string)> onConnectionError;

private:
    void reconnect(boost::function<void ()> onFinished,
                   boost::function<void (const std::string &)> onError,
                   double timeout);

    void setupConnection(std::shared_ptr<TransportBase> transport,
                         boost::function<void ()> onFinished,
                         boost::function<void (const std::string &)> onError);

    int port;
    std::string hostname;
    double timeout;
    std::shared_ptr<RemoteOutputConnection> connection;
    bool shuttingDown;

    std::vector<std::pair<std::string, std::string> > backlog;
};

} // namespace Datacratic