|
IceFlow NDN-based stream processing library written in C++
|
This is the complete list of members for iceflow::IceFlow, including all inherited members.
| getApplicationConfiguration() (defined in iceflow::IceFlow) | iceflow::IceFlow | inline |
| getApplicationParameter(const std::string &key) (defined in iceflow::IceFlow) | iceflow::IceFlow | inline |
| getConsumerStats() (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| getDownstreamEdge(uint32_t index) (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| getDownstreamEdges() (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| getNodePrefix() (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| getProducerStats() (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| getSyncPrefix() (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| getUpstreamEdge(uint32_t index) (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| getUpstreamEdges() (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| IceFlow(DAGParser dagParser, const std::string &nodeName, ndn::Face &face) | iceflow::IceFlow | |
| IceFlow(DAGParser dagParser, const std::string &nodeName, ndn::Face &face, std::shared_ptr< CongestionReporter > congestionReporter) (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| IceFlow(const std::string &dagFileName, const std::string &nodeName, ndn::Face &face) (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| IceFlow(const std::string &dagFileName, const std::string &nodeName, ndn::Face &face, std::shared_ptr< CongestionReporter > congestionReporter) (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| pushData(const std::string &downstreamEdgeName, std::vector< uint8_t > payload) (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| registerConsumerCallback(const std::string &upstreamEdgeName, ConsumerCallback consumerCallback) (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| registerProsumerCallback(const std::string &upstreamEdgeName, ProsumerCallback prosumerCallback) (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| repartitionConsumer(const std::string &upstreamEdgeName, std::vector< uint32_t > partitions) (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| repartitionProducer(const std::string &downstreamEdgeName, uint64_t numberOfPartitions) (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| reportCongestion(const std::string &edgeName, CongestionReason congestionReason) (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| run() (defined in iceflow::IceFlow) | iceflow::IceFlow | |
| shutdown() (defined in iceflow::IceFlow) | iceflow::IceFlow |
1.10.0