4 #include "MessageZyre.hh" 7 #include "PollerZmq.hh" 8 #include "SocketZyre.hh" 19 class NodeManagerZyre;
31 void addSocket(std::shared_ptr<SocketZyre> socket);
32 std::vector<std::shared_ptr<SocketZyre>>
sockets()
const;
58 std::vector<std::shared_ptr<SocketZyre>>
mSockets{};
virtual ~NodeZyre()
Destruct Zyre node.
virtual int init()
First function.
virtual int exec()
Main function.
std::string mJobInfoClientUrl
JobInfo url for client (salsa-broker –out ...)
void jobInfoClientUrl(std::string url)
Sets JobInfo client url.
virtual int finish()
Last function.
void jobInfoGroupName(std::string n)
Sets JobInfo Group name.
int mJobCheckTimeout
Job check timeout.
NodeZyre(std::string name="")
Construct Zyre node with provided name (and packetizer)
std::vector< zsock_t * > mZmqSockets
List of zmq sockets.
std::string mJobInfoGroupName
JobInfo Group name.
ZeroMQ implementation of salsa actor class.
std::string jobInfoGroupName()
Returns JobInfo Group name.
void addSocket(std::shared_ptr< SocketZyre > socket)
void handleExternalZmq(zmsg_t *pMsg, zsock_t *pSocket)
std::string mJobInfoBrokerUrl
JobInfo broker url (salsa-broker –in ...)
void jobInfoBrokerUrl(std::string url)
Sets JobInfo broker url.
std::vector< std::shared_ptr< SocketZyre > > mSockets
List of zyre sockets.
std::string mSubmitClientUrl
Submit url for client.
std::string submitClientUrl()
Returns Submit client url.
zsock_t * socketExternal(int i)
Rerturns external socket.
void submitClientUrl(std::string url)
Sets Submit client url.
std::vector< std::shared_ptr< SocketZyre > > sockets() const
std::string jobInfoClientUrl()
Returns JobInfo client url.
std::string jobInfoBrokerUrl()
Returns JobInfo broker url.
std::string name() const
Returns node name.
NodeManagerZyre * mpNodeManager
Job manager.