Inheritance diagram for ddt::DdtDataProducer:

Public Member Functions
	DdtDataProducer (DdtLogger *logger)

	DdtDataProducer (const std::string &data_stream_identifier, const int32_t latency, const int32_t deadline, const std::string publishing_uri, DdtLogger *logger)

	~DdtDataProducer () override

void	Publish (DataPacket data_packet)

void	Notify (const NotificationType type) override

std::string	get_publishing_uri () const

Public Member Functions inherited from ddt::DdtProducerConsumerBase
	DdtProducerConsumerBase (DdtLogger *ddt_logger)

virtual	~DdtProducerConsumerBase ()

Additional Inherited Members
Public Types inherited from ddt::DdtProducerConsumerBase
enum	NotificationType { NEW_DATA, PUB_REG, PUB_UNREG, SHM_DEL }

Protected Member Functions inherited from ddt::DdtProducerConsumerBase
void	Init (DdtLogger *ddt_logger)

void	LoadDefaults ()

void	ReadIni ()

void	PrintConfigValues ()

int32_t	GetFreePort () const

Protected Attributes inherited from ddt::DdtProducerConsumerBase
int32_t	min_port

int32_t	max_port

DdtLogger *	logger

const int	MIN_PORT_DEFAULT = 5100

const int	MAX_PORT_DEFAULT = 5500

const int	MIN_RANGE = 3

const int	LINE_LENGTH = 256

Detailed Description

This class provides the functionality to publish data over network and enables sending new data notifications.

Constructor & Destructor Documentation

DdtDataProducer::DdtDataProducer ( DdtLogger * logger )

explicit

Constructor

DdtDataProducer::DdtDataProducer	(	const std::string &	data_stream_identifier,
		const int32_t	latency,
		const int32_t	deadline,
		const std::string	publishing_uri,
		DdtLogger *	logger
	)

Constructor

DdtDataProducer::~DdtDataProducer ( )

overridedefault

Destructor

std::string DdtDataProducer::get_publishing_uri ( ) const

Returns publishing_uri.

void DdtDataProducer::Notify ( const NotificationType type )

overridevirtual

Attaches a notification to the data packet and sends it via MALps to remote brokers.

void DdtDataProducer::Publish ( DataPacket data_packet )

Publishes the data over network.

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