IceFlow NDN-based stream processing library written in C++
|
This is the complete list of members for iceflow::IceflowProducer, including all inherited members.
getProductionStats() (defined in iceflow::IceflowProducer) | iceflow::IceflowProducer | |
IceflowProducer(std::shared_ptr< ndn::svs::SVSPubSub > svsPubSub, const std::string &nodePrefix, const std::string &syncPrefix, const std::string &upstreamEdgeName, uint32_t numberOfPartitions, std::optional< std::shared_ptr< CongestionReporter > > congestionReporter) (defined in iceflow::IceflowProducer) | iceflow::IceflowProducer | |
pushData(const std::vector< uint8_t > &data) (defined in iceflow::IceflowProducer) | iceflow::IceflowProducer | |
setTopicPartitions(uint64_t numberOfPartitions) (defined in iceflow::IceflowProducer) | iceflow::IceflowProducer | |
~IceflowProducer() (defined in iceflow::IceflowProducer) | iceflow::IceflowProducer |