NRP Core  1.4.1
DPInputMQTTNode< MSG_TYPE > Member List

This is the complete list of members for DPInputMQTTNode< MSG_TYPE >, including all inherited members.

_msgCachePolicyInputNode< DataPack< MSG_TYPE > >protected
_msgFromStringInputMQTTNode< DataPack< MSG_TYPE > >protected
_msgPublishPolicyInputNode< DataPack< MSG_TYPE > >protected
_portMapInputNode< DataPack< MSG_TYPE > >protected
_queueSizeInputNode< DataPack< MSG_TYPE > >protected
ComputationalNode()=deleteComputationalNode
ComputationalNode(std::string id, NodeType type)ComputationalNodeinline
compute() override finalInputNode< DataPack< MSG_TYPE > >inlineprotectedvirtual
configure() overrideInputMQTTNode< DataPack< MSG_TYPE > >inlineprotectedvirtual
doCompute() constComputationalNodeinlinevirtual
DPInputMQTTNode(const std::string &id, const std::string &address)DPInputMQTTNode< MSG_TYPE >inline
Functional enum valueComputationalNode
getListPort(const std::string &id)InputNode< DataPack< MSG_TYPE > >inline
getSinglePort(const std::string &id)InputNode< DataPack< MSG_TYPE > >inline
graphCycleStartCB()ComputationalNodeinlineprotectedvirtual
graphLoadedCB()ComputationalNodeinlineprotectedvirtual
id() constComputationalNodeinline
Input enum valueComputationalNode
InputMQTTNode(const std::string &id, const std::string &address)InputMQTTNode< DataPack< MSG_TYPE > >inline
InputNode(const std::string &id, InputNodePolicies::MsgPublishPolicy msgPublishPolicy=InputNodePolicies::MsgPublishPolicy::LAST, InputNodePolicies::MsgCachePolicy msgCachePolicy=InputNodePolicies::MsgCachePolicy::KEEP_CACHE, size_t queue_size=10)InputNode< DataPack< MSG_TYPE > >inline
isVisited() constComputationalNodeinline
msgCachePolicy()InputNode< DataPack< MSG_TYPE > >inline
msgPublishPolicy()InputNode< DataPack< MSG_TYPE > >inline
NodeType enum nameComputationalNode
nodeTypeStrComputationalNodestatic
Output enum valueComputationalNode
parseNodeAddress(const std::string &address, bool hasPort=true)ComputationalNodeinlinestatic
registerOutput(const std::string &id)InputNode< DataPack< MSG_TYPE > >inline
setDoCompute(bool doCompute)ComputationalNodeinline
setMsgCachePolicy(InputNodePolicies::MsgCachePolicy msgCachePolicy)InputNode< DataPack< MSG_TYPE > >inline
setMsgFromString() overrideDPInputMQTTNode< MSG_TYPE >inlineprotectedvirtual
setMsgPublishPolicy(InputNodePolicies::MsgPublishPolicy msgPublishPolicy)InputNode< DataPack< MSG_TYPE > >inline
setVisited(bool visited)ComputationalNodeinline
topic_callback(const std::string &msg)InputMQTTNode< DataPack< MSG_TYPE > >inlineprotected
type() constComputationalNodeinline
typeStr() const overrideInputMQTTNode< DataPack< MSG_TYPE > >inline
InputNode< DataPack< MSG_TYPE > >::typeStr() constComputationalNodeinlinevirtual
updatePortData(const std::string &id) overrideInputMQTTNode< DataPack< MSG_TYPE > >inlineprotectedvirtual
~ComputationalNode()=defaultComputationalNodevirtual