| CheckIdInUse(const std::string &data_stream_identifier) | DdtConnectionManagerFake | inline |
| CheckPublisherExists(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| CheckPubRegistrationPermitted(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| CheckRemotePublisherExists(const std::string &remote_broker_uri, const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| CheckStreamIdInUse(const std::string &data_stream_identifier) | ddt::DdtConnectionManager | protected |
| CreateStatistics(const std::string &data_stream_identifier, const int32_t number_of_samples) | ddt::DdtConnectionManager | protected |
| CreateStats(const std::string &dsi, const int32_t num_samples) | DdtConnectionManagerFake | inline |
| CreateSubscriptionUri(const std::string publishing_uri, const std::string remote_broker_uri) const | ddt::DdtConnectionManager | protected |
| CreateSubUri(const std::string publishing_uri, const std::string remote_broker_uri) | DdtConnectionManagerFake | inline |
| DdtConnectionManager(DdtLogger *ddt_logger, const std::string uri_string, const std::string config) | ddt::DdtConnectionManager | explicit |
| DdtConnectionManager(DdtMemoryManager *const mmgr, DdtLogger *ddt_logger, const std::string uri_string, const std::string config) | ddt::DdtConnectionManager | explicit |
| DdtConnectionManagerFake(DdtLogger *logger) | DdtConnectionManagerFake | inline |
| get_broker_uri() override | ddt::DdtConnectionManager | |
| get_compute_checksum(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_heartbeat_interval() override | ddt::DdtConnectionManager | |
| get_heartbeat_interval_default() | DdtConnectionManagerFake | inline |
| get_heartbeat_timeout() override | ddt::DdtConnectionManager | |
| get_heartbeat_timeout_default() | DdtConnectionManagerFake | inline |
| get_max_data_sample_size(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_notification_port(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_number_of_samples(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_publishing_uri(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_reply_time() | DdtConnectionManagerFake | inline |
| get_reply_time_default() | DdtConnectionManagerFake | inline |
| get_shm_full_path(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_shm_id(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_shm_timeout() | DdtConnectionManagerFake | inline |
| get_shm_timeout_default() | DdtConnectionManagerFake | inline |
| get_statistics(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_waiting_time() | DdtConnectionManagerFake | inline |
| get_waiting_time_default() | DdtConnectionManagerFake | inline |
| GetConfigFilePath() | DdtConnectionManagerFake | inline |
| GetConfigPath() const | ddt::DdtConnectionManager | protected |
| GetConnectedBrokers() override | ddt::DdtConnectionManager | |
| GetMaxPossibleBufferSize(int32_t max_data_sample_size) override | ddt::DdtConnectionManager | |
| GetRegisteredStreams() override | ddt::DdtConnectionManager | |
| GetStatisticsMap() | DdtConnectionManagerFake | inline |
| heartbeat_interval | ddt::DdtConnectionManager | protected |
| HEARTBEAT_INTERVAL_DEFAULT | ddt::DdtConnectionManager | protected |
| heartbeat_timeout | ddt::DdtConnectionManager | protected |
| HEARTBEAT_TIMEOUT_DEFAULT | ddt::DdtConnectionManager | protected |
| InsertRegisteredPublisher(std::string dsi) | DdtConnectionManagerFake | inline |
| LoadDefaults() | ddt::DdtConnectionManager | protected |
| LoadDefaultValues() | DdtConnectionManagerFake | inline |
| PublishData(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| ReadIni() | ddt::DdtConnectionManager | protected |
| ReadIniFile() | DdtConnectionManagerFake | inline |
| registered_publishers | ddt::DdtConnectionManager | protected |
| RegisterPublisher(const std::string &data_stream_identifier, const int32_t latency, int32_t deadline, const int32_t max_data_sample_size, const int32_t number_of_samples, const bool compute_checksum, const std::string &publishing_uri) override | ddt::DdtConnectionManager | |
| RegisterRemoteSubscriber(const std::string &remote_broker, const std::string &subscriber_uuid, const std::string &data_stream_identifier, const int32_t latency, const int32_t deadline) override | ddt::DdtConnectionManager | |
| RegisterSubscriber(const std::string &subscriber_uuid, const std::string &data_stream_identifier, const std::string &remote_broker_uri, const int32_t latency, const int32_t deadline) override | ddt::DdtConnectionManager | |
| reply_time | ddt::DdtConnectionManager | protected |
| REPLY_TIME_DEFAULT | ddt::DdtConnectionManager | protected |
| ResetStatistics(const std::string &data_stream_identifier) | ddt::DdtConnectionManager | protected |
| ResetStats(const std::string &dsi) | DdtConnectionManagerFake | inline |
| shm_timeout | ddt::DdtConnectionManager | protected |
| SHM_TIMEOUT_DEFAULT | ddt::DdtConnectionManager | protected |
| statistics_map | ddt::DdtConnectionManager | protected |
| UnregisterPublisher(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| UnregisterPublishers() | ddt::DdtConnectionManager | |
| UnregisterSubscriber(const std::string &data_stream_identifier, const std::string &subscriber_uuid) override | ddt::DdtConnectionManager | |
| UnregisterSubscribers() | ddt::DdtConnectionManager | |
| UpdateHeartbeat(const std::string &identifier) override | ddt::DdtConnectionManager | |
| UpdateStatistics(const std::string &data_stream_identifier, const int32_t datavec_size, const uint64_t source_timestamp) override | ddt::DdtConnectionManager | |
| waiting_time | ddt::DdtConnectionManager | protected |
| WAITING_TIME_DEFAULT | ddt::DdtConnectionManager | protected |
| ~DdtConnectionManager() override | ddt::DdtConnectionManager | |
