AddUuid(std::string uuid, SubscriberType type) | ddt::DdtDataConsumer | |
data_stream_identifier | ddt::DdtDataConsumer | protected |
DdtDataConsumer(const std::string &data_stream_identifier, const int32_t latency, const int32_t deadline, DdtLogger *ddt_logger) | ddt::DdtDataConsumer | |
DdtDataConsumer(const std::string &data_stream_identifier, const std::string &subscription_uri, const int32_t latency, const int32_t deadline, DdtLogger *ddt_logger) | ddt::DdtDataConsumer | |
DdtDataConsumerFake(const std::string &data_stream_identifier, const int32_t latency, const int32_t deadline, DdtLogger *ddt_logger) | DdtDataConsumerFake | inline |
DdtProducerConsumerBase(DdtLogger *ddt_logger) | ddt::DdtProducerConsumerBase | explicit |
get_mem_acc() | DdtDataConsumerFake | inline |
get_noti_port() | DdtDataConsumerFake | inline |
get_notification_port() const | ddt::DdtDataConsumer | |
get_num_samples() | DdtDataConsumerFake | inline |
get_number_of_remote_subscribers() | ddt::DdtDataConsumer | |
get_number_of_subscribers() | ddt::DdtDataConsumer | |
get_pub_uri() | DdtDataConsumerFake | inline |
get_publishing_uri() const | ddt::DdtDataConsumer | |
get_remote_broker_uri() const | ddt::DdtDataConsumer | |
get_statistics() | ddt::DdtDataConsumer | |
get_stream_id() | DdtDataConsumerFake | inline |
get_subscribers() | ddt::DdtDataConsumer | |
GetFreePort() const | ddt::DdtProducerConsumerBase | protected |
Init(const std::string &ds_id, DdtLogger *ddt_logger) | ddt::DdtDataConsumer | protected |
ddt::DdtProducerConsumerBase::Init(DdtLogger *ddt_logger) | ddt::DdtProducerConsumerBase | protected |
Initialize(const std::string &dsi, DdtLogger *logger) | DdtDataConsumerFake | inline |
last_received | ddt::DdtDataConsumer | protected |
LINE_LENGTH | ddt::DdtProducerConsumerBase | protected |
LoadDefaults() | ddt::DdtProducerConsumerBase | protected |
LOCAL enum value | ddt::DdtDataConsumer | |
logger | ddt::DdtProducerConsumerBase | protected |
max_port | ddt::DdtProducerConsumerBase | protected |
MAX_PORT_DEFAULT | ddt::DdtProducerConsumerBase | protected |
memory_accessor | ddt::DdtDataConsumer | protected |
min_port | ddt::DdtProducerConsumerBase | protected |
MIN_PORT_DEFAULT | ddt::DdtProducerConsumerBase | protected |
MIN_RANGE | ddt::DdtProducerConsumerBase | protected |
NEW_DATA enum value | ddt::DdtProducerConsumerBase | |
notification_port | ddt::DdtDataConsumer | protected |
notification_signal | ddt::DdtDataConsumer | |
NotificationType enum name | ddt::DdtProducerConsumerBase | |
Notify(const NotificationType type) override | ddt::DdtDataConsumer | virtual |
number_of_samples | ddt::DdtDataConsumer | protected |
PrintConfigValues() | ddt::DdtProducerConsumerBase | protected |
PUB_REG enum value | ddt::DdtProducerConsumerBase | |
PUB_UNREG enum value | ddt::DdtProducerConsumerBase | |
publishing_uri | ddt::DdtDataConsumer | protected |
ReadIni() | ddt::DdtProducerConsumerBase | protected |
REMOTE enum value | ddt::DdtDataConsumer | |
RemoveUuid(const std::string uuid) | ddt::DdtDataConsumer | |
ResetStatistics() | ddt::DdtDataConsumer | |
set_memory_accessor(DdtMemoryAccessor *mem_accessor) | ddt::DdtDataConsumer | |
set_notification_port(const int32_t noti_port) | ddt::DdtDataConsumer | |
set_number_of_samples(const int32_t num_samples) | ddt::DdtDataConsumer | |
set_originating_broker(const std::string orig_broker) | ddt::DdtDataConsumer | |
set_publishing_uri(const std::string pub_uri) | ddt::DdtDataConsumer | |
set_remote_broker_uri(const std::string &remote_uri) | ddt::DdtDataConsumer | |
set_total_bytes(uint64_t bytes) | DdtDataConsumerFake | inline |
set_total_latency(uint64_t latency) | DdtDataConsumerFake | inline |
SHM_DEL enum value | ddt::DdtProducerConsumerBase | |
StartSubscription() | ddt::DdtDataConsumer | |
StopSubscription() | ddt::DdtDataConsumer | |
SubscriberType enum name | ddt::DdtDataConsumer | |
total_bytes | ddt::DdtDataConsumer | protected |
total_latency | ddt::DdtDataConsumer | protected |
total_samples | ddt::DdtDataConsumer | protected |
~DdtDataConsumer() override | ddt::DdtDataConsumer | |
~DdtProducerConsumerBase() | ddt::DdtProducerConsumerBase | virtual |