_computePeriod | OutputNode< DataPack< MSG_TYPE > * > | protected |
_inputPorts | OutputNode< DataPack< MSG_TYPE > * > | protected |
_isConfigured | OutputNode< DataPack< MSG_TYPE > * > | protected |
_maxPortConnections | OutputNode< DataPack< MSG_TYPE > * > | protected |
_nLoop | OutputNode< DataPack< MSG_TYPE > * > | protected |
_publishFormatPolicy | OutputNode< DataPack< MSG_TYPE > * > | protected |
_publishFromCache | OutputNode< DataPack< MSG_TYPE > * > | protected |
_storedMsgs | OutputNode< DataPack< MSG_TYPE > * > | protected |
ComputationalNode()=delete | ComputationalNode | |
ComputationalNode(std::string id, NodeType type) | ComputationalNode | inline |
compute() override final | OutputNode< DataPack< MSG_TYPE > * > | inlineprotectedvirtual |
configure() override | OutputNode< DataPack< MSG_TYPE > * > | inlineprotectedvirtual |
DataPackPtr typedef | DPOutputMQTTNode< MSG_TYPE > | |
doCompute() const override final | OutputNode< DataPack< MSG_TYPE > * > | inlinevirtual |
ComputationalNode::doCompute() const | ComputationalNode | inlinevirtual |
DPOutputMQTTNode(const std::string &id, const std::string &address, bool publishFromCache=false, unsigned int computePeriod=1) | DPOutputMQTTNode< MSG_TYPE > | inline |
Functional enum value | ComputationalNode | |
getComputePeriod() | OutputNode< DataPack< MSG_TYPE > * > | inline |
getOrRegisterInput(const std::string &id) | OutputNode< DataPack< MSG_TYPE > * > | inline |
graphCycleStartCB() override final | OutputNode< DataPack< MSG_TYPE > * > | inlineprotectedvirtual |
graphLoadedCB() | ComputationalNode | inlineprotectedvirtual |
id() const | ComputationalNode | inline |
Input enum value | ComputationalNode | |
isVisited() const | ComputationalNode | inline |
NodeType enum name | ComputationalNode | |
nodeTypeStr | ComputationalNode | static |
Output enum value | ComputationalNode | |
OutputMQTTNode(const std::string &id, const std::string &address, bool publishFromCache=false, unsigned int computePeriod=1) | OutputMQTTNode< DataPack< MSG_TYPE > * > | inline |
OutputNode(const std::string &id, OutputNodePolicies::PublishFormatPolicy publishFormatPolicy=OutputNodePolicies::PublishFormatPolicy::SERIES, bool publishFromCache=false, int maxPortConnections=0, unsigned int computePeriod=1) | OutputNode< DataPack< MSG_TYPE > * > | inline |
parseNodeAddress(const std::string &address, bool hasPort=true) | ComputationalNode | inlinestatic |
publishFromCache() | OutputNode< DataPack< MSG_TYPE > * > | inline |
publishMqttMsg(const PUB_TYPE *data) | OutputMQTTNode< DataPack< MSG_TYPE > * > | inlineprotected |
sendBatchMsg(const std::string &, const std::vector< const DataPack< MSG_TYPE > * * > &) override | OutputMQTTNode< DataPack< MSG_TYPE > * > | inlineprotectedvirtual |
sendMsgs(const std::string &id) | OutputNode< DataPack< MSG_TYPE > * > | inlineprotected |
sendSingleMsg(const std::string &, const DataPackPtr *data) override | DPOutputMQTTNode< MSG_TYPE > | inlineprotected |
OutputMQTTNode< DataPack< MSG_TYPE > * >::sendSingleMsg(const std::string &, const DataPack< MSG_TYPE > * *data) override | OutputMQTTNode< DataPack< MSG_TYPE > * > | inlineprotectedvirtual |
setComputePeriod(unsigned int computePeriod) | OutputNode< DataPack< MSG_TYPE > * > | inline |
setDoCompute(bool doCompute) | ComputationalNode | inline |
setVisited(bool visited) | ComputationalNode | inline |
storeMsg(const std::string &id, const DataPack< MSG_TYPE > * *data) | OutputNode< DataPack< MSG_TYPE > * > | inlineprotected |
type() const | ComputationalNode | inline |
typeStr() const override | OutputMQTTNode< DataPack< MSG_TYPE > * > | inline |
OutputNode< DataPack< MSG_TYPE > * >::typeStr() const | ComputationalNode | inlinevirtual |
~ComputationalNode()=default | ComputationalNode | virtual |