addConsumer(std::string uuid, std::shared_ptr< Socket > s) | Salsa::NodeManager | |
addFeeder(std::string uuid, std::shared_ptr< Socket > s) | Salsa::NodeManager | |
addTask(TaskInfo *taskInfo, std::string cuuid, std::string fuuid, Salsa::Job::EQueueType t=Salsa::Job::pending) | Salsa::NodeManager | |
addTaskSlot() | Salsa::NodeManager | virtual |
addWorker(std::string uuid, std::shared_ptr< Socket > s) | Salsa::NodeManager | |
clusterAlias(std::string n) | Salsa::NodeManager | inline |
clusterAlias() | Salsa::NodeManager | inline |
consumer(std::string uuid) const | Salsa::NodeManager | |
feeder(std::string uuid) const | Salsa::NodeManager | |
finishedJobTimeout() const | Salsa::NodeManager | inline |
finishedJobTimeout(uint64_t t) | Salsa::NodeManager | inline |
getConsoleOutput() | Salsa::Object | inlinestatic |
getNextTask() | Salsa::NodeManager | |
handleTaskPool(void *p) | Salsa::NodeManager | virtual |
hasJobs() const | Salsa::NodeManager | |
haveMoreTasks() | Salsa::NodeManager | virtual |
haveMoreTasks(std::string jobUUID) | Salsa::NodeManager | virtual |
job(std::string uuid) | Salsa::NodeManager | |
jobs(std::string clientUUID, std::vector< std::string > &jobs) const | Salsa::NodeManager | |
mActiveJobs | Salsa::NodeManager | protected |
mClusterAlias | Salsa::NodeManager | protected |
mConsumers | Salsa::NodeManager | protected |
mFeeders | Salsa::NodeManager | protected |
mFinishedJobs | Salsa::NodeManager | protected |
mFinishedJobTimeout | Salsa::NodeManager | protected |
mJobs | Salsa::NodeManager | protected |
mpPublisher | Salsa::NodeManager | protected |
mpTaskPool | Salsa::NodeManager | protected |
mspConsoleLogger | Salsa::Object | privatestatic |
mWorkers | Salsa::NodeManager | protected |
NodeManager() | Salsa::NodeManager | |
noMoreTasks(std::string jobUUID) | Salsa::NodeManager | virtual |
nSlots(double mult=1.0) const | Salsa::NodeManager | |
Object() | Salsa::Object | |
onEnter(std::string self, std::string fromType, Message *msg, std::vector< std::string > &out) | Salsa::NodeManager | virtual |
onExit(std::string self, Message *msg, std::vector< std::string > &out) | Salsa::NodeManager | virtual |
onWhisper(std::string self, Message *msg, std::vector< std::string > &out) | Salsa::NodeManager | virtual |
print(std::string opt="") const | Salsa::NodeManager | |
publish(std::string id, bool force=false) const | Salsa::NodeManager | virtual |
publisher(Publisher *p) | Salsa::NodeManager | virtual |
publisher() const | Salsa::NodeManager | virtual |
resultTask(TaskInfo *task) | Salsa::NodeManager | virtual |
resultTaskToExternal(Job *, TaskInfo *) | Salsa::NodeManager | inlinevirtual |
runTask(TaskState *ts, std::string wk, std::string upstream)=0 | Salsa::NodeManager | pure virtual |
sendWhisper(Socket *s, std::string to, std::vector< std::string > &v) | Salsa::NodeManager | virtual |
setConsoleLevel(spdlog::level::level_enum level) | Salsa::Object | inlinestatic |
taskPool() | Salsa::NodeManager | |
terminateAllJobs(bool finishedonly=false) | Salsa::NodeManager | virtual |
terminateFinishedJobs() | Salsa::NodeManager | virtual |
terminateJob(std::string uuid) | Salsa::NodeManager | virtual |
worker(std::string uuid) const | Salsa::NodeManager | |
~NodeManager() | Salsa::NodeManager | virtual |
~Object() | Salsa::Object | virtual |