iceflow::IceflowProducer Class Reference

#include <producer.hpp>

Public Member Functions
	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)
void	pushData (const std::vector< uint8_t > &data)
void	setTopicPartitions (uint64_t numberOfPartitions)
EdgeProductionStats	getProductionStats ()

Detailed Description

Allows for publishing data to IceflowConsumers.

The data is split across one or more topicPartitions whose indexes can be passed as a constructor argument.

---

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

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