soa/logger/remote_input.h

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

   The input side of a remote logging connection.
*/

#pragma once

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


namespace Datacratic {

struct RemoteInput {
    
    RemoteInput();

    ~RemoteInput();

    void listen(int port,
                const std::string & address,
                boost::function<void ()> onShutdown = boost::function<void ()>());

    void shutdown();

    int port() const
    {
        return endpoint.port();
    }

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

private:
    PassiveEndpointT<SocketTransport> endpoint;
    boost::function<void ()> onShutdown;
};

} // namespace Datacratic