3 #include <Distributor.hh> 4 #include <TaskInfo.pb.h> 22 virtual void onEnter(
Message * pInMsg, std::vector<std::string> & out, std::string type);
23 virtual void onExit(
Message * pInMsg, std::vector<std::string> & out);
Feeder(std::string uuid, std::shared_ptr< Socket > pPipe, NodeManager *pNM)
std::map< std::string, std::vector< TaskInfo * > > mWorkerTasks
Worker tasks.
virtual void onExit(Message *pInMsg, std::vector< std::string > &out)
void terminateJob(std::string uuid)
void subscribe(std::string uuid)
virtual void onEnter(Message *pInMsg, std::vector< std::string > &out, std::string type)
TODO Three horsemen of apocalypse.
std::string uuid() const
Returns distributor's UUID.
virtual void onWhisper(Message *pInMsg, std::vector< std::string > &out)
void removeWorkerTask(TaskInfo *pTI)