IceFlow NDN-based stream processing library written in C++
|
This is the complete list of members for iceflow::IceflowConsumer, including all inherited members.
getConsumptionStats() (defined in iceflow::IceflowConsumer) | iceflow::IceflowConsumer | |
getPartitions() (defined in iceflow::IceflowConsumer) | iceflow::IceflowConsumer | |
IceflowConsumer(std::shared_ptr< ndn::svs::SVSPubSub > svsPubSub, const std::string &syncPrefix, const std::string &upstreamEdgeName, std::optional< std::shared_ptr< CongestionReporter > > congestionReporter) (defined in iceflow::IceflowConsumer) | iceflow::IceflowConsumer | |
repartition(std::vector< uint32_t > partitions) (defined in iceflow::IceflowConsumer) | iceflow::IceflowConsumer | |
setConsumerCallback(ConsumerCallback consumerCallback) (defined in iceflow::IceflowConsumer) | iceflow::IceflowConsumer | |
~IceflowConsumer() (defined in iceflow::IceflowConsumer) | iceflow::IceflowConsumer |