ddt 1.2.1
Loading...
Searching...
No Matches
Public Member Functions | List of all members
DdtClientFake Class Reference
Inheritance diagram for DdtClientFake:
ddt::DdtClient

Public Member Functions

 DdtClientFake ()
 
void Initialize (const std::string remote_broker, const int32_t repl_time, const int32_t hb_interval, const int32_t hb_timeout, const std::string broker, DdtLogger *ddt_logger)
 
std::map< std::string, std::string > get_sub_map ()
 
std::string get_remote_uri ()
 
int32_t get_reply_time ()
 
int32_t get_hb_interval ()
 
int32_t get_hb_timeout ()
 
std::string get_broker_uri ()
 
DdtLoggerget_logger ()
 
bool get_hb_active ()
 
bool get_connected ()
 
- Public Member Functions inherited from ddt::DdtClient
 DdtClient ()
 
 DdtClient (const std::string remote_broker, const int32_t repl_time, const int32_t hb_interval, const int32_t hb_timeout, const std::string broker, DdtLogger *ddt_logger)
 
virtual ~DdtClient ()
 
void AddUuid (std::string uuid, std::string dsi)
 
void UnregisterSubscriber (const std::string uuid)
 
bool CheckIfEmpty ()
 
bool CheckPublisherExists (const std::string &data_stream_identifier) const
 
int32_t RegisterRemoteSubscriber (const std::string &subscriber_uuid, const std::string &data_stream_identifier, const int32_t latency, const int32_t deadline) const
 
std::string GetPublishingUri (const std::string &data_stream_identifier) const
 
int32_t get_max_data_sample_size (const std::string &data_stream_identifier) const
 
int32_t get_number_of_samples (const std::string &data_stream_identifier) const
 
bool get_compute_checksum (const std::string &data_stream_identifier) const
 
std::string get_broker_uri () const
 

Additional Inherited Members

- Protected Member Functions inherited from ddt::DdtClient
void Init (const std::string remote_broker, const int32_t repl_time, const int32_t hb_interval, const int32_t hb_timeout, const std::string broker, DdtLogger *ddt_logger)
 
- Protected Attributes inherited from ddt::DdtClient
std::map< std::string, std::string > subscriber_map
 
std::atomic< bool > connected_to_broker
 
std::atomic< bool > heartbeat_active
 
std::string remote_broker_uri
 
std::string broker_uri
 
int32_t reply_time
 
int32_t heartbeat_interval
 
int32_t heartbeat_timeout
 
DdtLoggerlogger
 

Constructor & Destructor Documentation

◆ DdtClientFake()

DdtClientFake::DdtClientFake ( )
inline

Member Function Documentation

◆ get_broker_uri()

std::string DdtClientFake::get_broker_uri ( )
inline

◆ get_connected()

bool DdtClientFake::get_connected ( )
inline

◆ get_hb_active()

bool DdtClientFake::get_hb_active ( )
inline

◆ get_hb_interval()

int32_t DdtClientFake::get_hb_interval ( )
inline

◆ get_hb_timeout()

int32_t DdtClientFake::get_hb_timeout ( )
inline

◆ get_logger()

DdtLogger * DdtClientFake::get_logger ( )
inline

◆ get_remote_uri()

std::string DdtClientFake::get_remote_uri ( )
inline

◆ get_reply_time()

int32_t DdtClientFake::get_reply_time ( )
inline

◆ get_sub_map()

std::map< std::string, std::string > DdtClientFake::get_sub_map ( )
inline

◆ Initialize()

void DdtClientFake::Initialize ( const std::string remote_broker,
const int32_t repl_time,
const int32_t hb_interval,
const int32_t hb_timeout,
const std::string broker,
DdtLogger * ddt_logger )
inline

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