Akumuli
 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:
Akumuli::Server

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

std::shared_ptr
< IngestionPipeline
pline
 
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: