iceflow::IceflowConsumer Class Reference

#include <consumer.hpp>

Public Member Functions
	IceflowConsumer (std::shared_ptr< ndn::svs::SVSPubSub > svsPubSub, const std::string &syncPrefix, const std::string &upstreamEdgeName, std::optional< std::shared_ptr< CongestionReporter > > congestionReporter)
void	setConsumerCallback (ConsumerCallback consumerCallback)
bool	repartition (std::vector< uint32_t > partitions)
std::vector< u_int32_t >	getPartitions ()
EdgeConsumptionStats	getConsumptionStats ()

Detailed Description

Allows for subscribing to data published by IceflowProducers.

---

The documentation for this class was generated from the following files:

• include/iceflow/consumer.hpp
• src/consumer.cpp