The delegator is the intermediary between requesters and workers. It acts as the server to which workers connect, and requesters submit jobs. More...
#include <set>#include <string>#include <deque>#include <glog/logging.h>#include <zmq.hpp>#include "comms/settings.hpp"#include "comms/messages.hpp"#include "comms/transport.hpp"#include "comms/router.hpp"#include "comms/serverheartbeat.hpp"

Classes | |
| class | stateline::comms::Delegator | 
| Requester object that takes jobs and returns results. Communicates with a delegator living in a (possibly) different thread.  More... | |
Namespaces | |
| stateline | |
| stateline::comms | |
Variables | |
| const std::string | DELEGATOR_SOCKET_ADDR = "inproc://delegator" | 
| Address that the requesters connect their sockets to.  | |
The delegator is the intermediary between requesters and workers. It acts as the server to which workers connect, and requesters submit jobs.