salsa 0.7.1
Loading...
Searching...
No Matches
NodeManagerZyre.hh
1#pragma once
2
3#include "NodeManager.hh"
4#include "NodeZyre.hh"
5#include "PollerZmq.hh"
6
7namespace Salsa {
16
18public:
19 NodeManagerZyre(NodeZyre * pNodeZyre);
20 virtual ~NodeManagerZyre();
21
22 virtual void resultTaskToExternal(Job * job, TaskInfo * task);
23
24 virtual Socket * onEnter(std::string self, std::string fromType, Message * pMsg, std::vector<std::string> & out);
25 virtual Socket * onExit(std::string self, Message * pMsg, std::vector<std::string> & out);
26 virtual Socket * onWhisper(std::string self, Message * pMsg, std::vector<std::string> & out);
27
28 virtual bool handleTaskPool(void * pPool);
29 virtual void addTaskSlot();
30 virtual void runTask(TaskState * pTaskState, std::string wk, std::string upstream);
31 virtual bool sendWhisper(Socket * pSocket, std::string to, std::vector<std::string> & vect);
32
33private:
34 NodeZyre * mpNodeZyre = nullptr;
35};
36} // namespace Salsa
Job class.
Definition Job.hh:16
Base Message class.
Definition Message.hh:15
virtual Socket * onEnter(std::string self, std::string fromType, Message *pMsg, std::vector< std::string > &out)
NodeZyre * mpNodeZyre
Current zyre node.
virtual void runTask(TaskState *pTaskState, std::string wk, std::string upstream)
Run task interface.
virtual bool handleTaskPool(void *pPool)
virtual void resultTaskToExternal(Job *job, TaskInfo *task)
Handle return of task and send it to external client.
virtual Socket * onExit(std::string self, Message *pMsg, std::vector< std::string > &out)
virtual bool sendWhisper(Socket *pSocket, std::string to, std::vector< std::string > &vect)
NodeManagerZyre(NodeZyre *pNodeZyre)
virtual Socket * onWhisper(std::string self, Message *pMsg, std::vector< std::string > &out)
Job * job(std::string uuid)
salsa node class
Definition NodeZyre.hh:20
Base Socket class.
Definition Socket.hh:15
Base salsa TaskState class.
Definition TaskState.hh:16