Inheritance diagram for DdtDataPublisherFake:

Public Member Functions
	DdtDataPublisherFake (DdtLogger *logger)

int	get_topic_id ()

int32_t	get_reply_time_default ()

int32_t	get_reply_time ()

void	set_reply_time (int32_t repl_time)

void	LoadDefaultValues ()

void	ReadIniFile ()

Public Member Functions inherited from ddt::DdtDataPublisher
	DdtDataPublisher (DdtLogger *logger)

virtual	~DdtDataPublisher ()

int	RegisterPublisher (std::string broker_uri, std::string data_stream_identifier, bool compute_checksum) override

int	UnregisterPublisher () override

void	PublishData () override

void	SetBufferSize (int max_data_sample_size, int number_of_samples)

void	WriteData (int32_t sample_id, const std::vector< uint8_t > &datavec, const std::vector< uint8_t > &metadatavec)

void	set_topic_id (int topic_id)

bool	get_connected_to_broker ()

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

virtual	~DdtDataTransferLib ()

void	SetQoS (const int ddt_latency, const int ddt_deadline)

virtual int	RegisterSubscriber (std::string broker_uri, std::string data_stream_identifier, std::string remote_broker_uri, int32_t reading_interval=10)

virtual int	UnregisterSubscriber ()

virtual DataSample *	ReadData ()

Additional Inherited Members
Protected Member Functions inherited from ddt::DdtDataPublisher
void	LoadDefaults ()

void	ReadIni ()

Protected Member Functions inherited from ddt::DdtDataTransferLib
void	StartHeartbeat (const int32_t interval, const std::string id)

void	StopHeartbeat ()

void	CheckHeartbeatTimeout (int32_t &new_reply_time)

const std::string	VerifyPathInBrokerUri (std::string broker_uri)

const std::string	GetConfigFilePath ()

Protected Attributes inherited from ddt::DdtDataPublisher
int	topic_id

Protected Attributes inherited from ddt::DdtDataTransferLib
int	latency

int	deadline

int32_t	reply_time

int32_t	heartbeat_interval

std::promise< void >	exit_signal_heartbeat

std::future< void >	future_object_heartbeat

std::atomic< bool >	heartbeat_active

std::unique_ptr< datatransfer::DataBrokerRegistrationSync, std::default_delete< datatransfer::DataBrokerRegistrationSync > >	client

std::atomic< bool >	connected_to_broker

elt::mal::rr::ListenerRegistration	connection_listener

DdtLogger *	logger

const int32_t	REPLY_TIME_DEFAULT = 6

const int32_t	REPLY_TIME_MIN = 2

Constructor & Destructor Documentation

◆ DdtDataPublisherFake()

DdtDataPublisherFake::DdtDataPublisherFake ( DdtLogger * logger )

inline

int32_t DdtDataPublisherFake::get_reply_time ( )

inline

int32_t DdtDataPublisherFake::get_reply_time_default ( )

inline

int DdtDataPublisherFake::get_topic_id ( )

inline

void DdtDataPublisherFake::LoadDefaultValues ( )

inline

void DdtDataPublisherFake::ReadIniFile ( )

inline

void DdtDataPublisherFake::set_reply_time ( int32_t repl_time )

inline

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