All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator Friends
Public Member Functions | Public Attributes | List of all members
Akumuli::TcpServer Struct Reference
Inheritance diagram for Akumuli::TcpServer:

Public Member Functions

 TcpServer (std::shared_ptr< IngestionPipeline > pipeline, int concurrency, int port)
virtual void start (SignalHandler *sig_handler, int id)
 Run IO service.
void stop ()
 Stop the server (should be called from signal handler)

Public Attributes

< IngestionPipeline
std::shared_ptr< TcpAcceptorserv
boost::asio::io_service io
std::vector< IOServiceT * > iovec
boost::barrier barrier
std::atomic< int > stopped
Logger logger_

The documentation for this struct was generated from the following files: