#include <ddtStatisticsClient.hpp>

Inheritance diagram for ddt::DdtStatisticsClient:

	DdtStatisticsClient (DdtLogger *ddt_logger, const std::string broker_uri)

	~DdtStatisticsClient () override

DdtStatistics	GetStatistics (const std::string data_stream_identifier)

std::vector< std::string >	GetRegisteredStreams ()

std::vector< std::string >	GetConnectedBrokers ()

Additional Inherited Members
Public Member Functions inherited from ddt::DdtDataTransferLib
virtual int	RegisterPublisher (const std::string uri, const std::string dsi, const bool compute_crc)

virtual int	UnregisterPublisher ()

virtual void	PublishData ()

virtual int	RegisterSubscriber (const std::string uri, const std::string dsi, const std::string remote_uri, const int32_t interval=10)

virtual int	UnregisterSubscriber ()

virtual DataSample *	ReadData ()

	DdtDataTransferLib (DdtLogger *ddt_logger)

	DdtDataTransferLib (log4cplus::Logger const &log4cplus_logger)

virtual	~DdtDataTransferLib ()

void	SetQoS (const int ddt_latency, const int ddt_deadline)

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

int	InitMAL (const std::string broker_uri)

std::unique_ptr< datatransfer::DataBrokerRegistrationSync, std::default_delete< datatransfer::DataBrokerRegistrationSync > >	GetBrokerClient ()

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	GetConfigFilePath ()

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

DdtLogger *	my_logger = nullptr

const int32_t	REPLY_TIME_DEFAULT = 6

const int32_t	REPLY_TIME_MIN = 2

Detailed Description

This class provides an API to query the statistics from a broker.

Constructor & Destructor Documentation

◆ DdtStatisticsClient()

DdtStatisticsClient::DdtStatisticsClient	(	DdtLogger *	ddt_logger,
		const std::string	broker_uri
	)

Constructor

Parameters

ddt_logger	A DDT logger object (no transfer of ownership).
broker_uri	The URI of the broker.

◆ ~DdtStatisticsClient()

DdtStatisticsClient::~DdtStatisticsClient ( )

overridedefault

Destructor

Member Function Documentation

◆ GetConnectedBrokers()

std::vector< std::string > DdtStatisticsClient::GetConnectedBrokers ( )

Requests from a broker the URIs of connected brokers.

Returns: A vector containing the URIs of connected brokers.

◆ GetRegisteredStreams()

std::vector< std::string > DdtStatisticsClient::GetRegisteredStreams ( )

Requests the streams that are registered at a broker.

Returns: A vector containing all registered streams.

◆ GetStatistics()

DdtStatistics DdtStatisticsClient::GetStatistics ( const std::string data_stream_identifier )

Requests the statistics from the broker.