Public Member Functions | |
| DdtClientFake () | |
| void | Initialize (const DdtClientConfig &config, 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 () |
| DdtLogger * | get_logger () |
| bool | get_hb_active () |
| bool | get_connected () |
Public Member Functions inherited from ddt::DdtClient | |
| DdtClient () | |
| DdtClient (const DdtClientConfig &config, 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 DdtClientConfig &config, 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 |
| int32_t | wait_for_connection |
| DdtLogger * | logger |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |