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);
std::string uuid() const
Returns distributor's UUID.
Distributor(std::string uuid, std::shared_ptr< Socket > pPipe, NodeManager *pNM)
virtual void onEnter(Message *pInMsg, std::vector< std::string > &out, std::string type)
TODO Three horsemen of apocalypse.
void terminateJob(std::string uuid)
virtual void onExit(Message *pInMsg, std::vector< std::string > &out)
void removeWorkerTask(TaskInfo *pTI)
virtual void onWhisper(Message *pInMsg, std::vector< std::string > &out)
std::map< std::string, std::vector< TaskInfo * > > mWorkerTasks
Worker tasks.
void subscribe(std::string uuid)
Feeder(std::string uuid, std::shared_ptr< Socket > pPipe, NodeManager *pNM)