Struct astutedds::rtps::ReaderProxy

ClassList > astutedds > rtps > ReaderProxy

Model for a DDS DataReader endpoint to be announced via SEDP. More...

• #include <endpoint_proxy.hpp>

Public Attributes

Type	Name
std::vector< uint8_t >	contentFilterPayload
dcps::DeadlineQosPolicy	deadline
dcps::DestinationOrderQosPolicy	destination_order
dcps::DurabilityQosPolicy	durability
bool	expectsInlineQos = {false}
bool	forceTypeValidation = {false}
std::vector< uint8_t >	groupData
Count_t	heartbeatCount = {0}
dcps::HistoryQosPolicy	history
bool	ignoreMemberNames = {false}
bool	ignoreSequenceBounds = {true}
bool	ignoreStringBounds = {true}
SequenceNumber_t	lastAcknowledgedSN = {0, 0}
std::chrono::steady_clock::time_point	lastHeartbeatTime
dcps::LivelinessQosPolicy	liveliness
LocatorList_t	multicastLocatorList
dcps::OwnershipQosPolicy	ownership
std::vector< std::string >	partitions
dcps::PresentationQosPolicy	presentation
bool	preventTypeWidening = {false}
GUID_t	readerGuid = {}
dcps::ReliabilityQosPolicy	reliability
dcps::DataRepresentationQosPolicy	representation
std::set< uint32_t >	requestedChanges
dcps::ResourceLimitsQosPolicy	resource_limits
std::vector< uint8_t >	topicData
std::string	topicName
uint16_t	typeConsistencyKind = {1}
std::string	typeName
LocatorList_t	unicastLocatorList
std::vector< uint8_t >	userData

Public Functions

Type	Name
std::vector< uint8_t >	serialize_to_parameter_list () const Serialize to SEDP parameter list payload.
void	set_default_qos () Initialize with default interop-friendly QoS.

Detailed Description

Tracks state for a remote reader.

Contains all the information needed to generate a complete SEDP subscription announcement that will be accepted by other DDS implementations (RTI, OpenDDS, Cyclone, FastDDS).

Used by writers to track acknowledgments from each reader.

Public Attributes Documentation

variable contentFilterPayload

std::vector<uint8_t> astutedds::rtps::ReaderProxy::contentFilterPayload;

---

variable deadline

dcps::DeadlineQosPolicy astutedds::rtps::ReaderProxy::deadline;

---

variable destination_order

dcps::DestinationOrderQosPolicy astutedds::rtps::ReaderProxy::destination_order;

---

variable durability

dcps::DurabilityQosPolicy astutedds::rtps::ReaderProxy::durability;

---

variable expectsInlineQos

bool astutedds::rtps::ReaderProxy::expectsInlineQos;

---

variable forceTypeValidation

bool astutedds::rtps::ReaderProxy::forceTypeValidation;

---

variable groupData

std::vector<uint8_t> astutedds::rtps::ReaderProxy::groupData;

---

variable heartbeatCount

Count_t astutedds::rtps::ReaderProxy::heartbeatCount;

---

variable history

dcps::HistoryQosPolicy astutedds::rtps::ReaderProxy::history;

---

variable ignoreMemberNames

bool astutedds::rtps::ReaderProxy::ignoreMemberNames;

---

variable ignoreSequenceBounds

bool astutedds::rtps::ReaderProxy::ignoreSequenceBounds;

---

variable ignoreStringBounds

bool astutedds::rtps::ReaderProxy::ignoreStringBounds;

---

variable lastAcknowledgedSN

SequenceNumber_t astutedds::rtps::ReaderProxy::lastAcknowledgedSN;

---

variable lastHeartbeatTime

std::chrono::steady_clock::time_point astutedds::rtps::ReaderProxy::lastHeartbeatTime;

---

variable liveliness

dcps::LivelinessQosPolicy astutedds::rtps::ReaderProxy::liveliness;

---

variable multicastLocatorList

LocatorList_t astutedds::rtps::ReaderProxy::multicastLocatorList;

---

variable ownership

dcps::OwnershipQosPolicy astutedds::rtps::ReaderProxy::ownership;

---

variable partitions

std::vector<std::string> astutedds::rtps::ReaderProxy::partitions;

---

variable presentation

dcps::PresentationQosPolicy astutedds::rtps::ReaderProxy::presentation;

---

variable preventTypeWidening

bool astutedds::rtps::ReaderProxy::preventTypeWidening;

---

variable readerGuid

GUID_t astutedds::rtps::ReaderProxy::readerGuid;

---

variable reliability

dcps::ReliabilityQosPolicy astutedds::rtps::ReaderProxy::reliability;

---

variable representation

dcps::DataRepresentationQosPolicy astutedds::rtps::ReaderProxy::representation;

---

variable requestedChanges

std::set<uint32_t> astutedds::rtps::ReaderProxy::requestedChanges;

---

variable resource_limits

dcps::ResourceLimitsQosPolicy astutedds::rtps::ReaderProxy::resource_limits;

---

variable topicData

std::vector<uint8_t> astutedds::rtps::ReaderProxy::topicData;

---

variable topicName

std::string astutedds::rtps::ReaderProxy::topicName;

---

variable typeConsistencyKind

uint16_t astutedds::rtps::ReaderProxy::typeConsistencyKind;

---

variable typeName

std::string astutedds::rtps::ReaderProxy::typeName;

---

variable unicastLocatorList

LocatorList_t astutedds::rtps::ReaderProxy::unicastLocatorList;

---

variable userData

std::vector<uint8_t> astutedds::rtps::ReaderProxy::userData;

---

Public Functions Documentation

function serialize_to_parameter_list

Serialize to SEDP parameter list payload.

inline std::vector< uint8_t > astutedds::rtps::ReaderProxy::serialize_to_parameter_list () const

Creates a complete parameter list suitable for SEDP subscription announcements. Includes all required PIDs for RTI interop.

Returns:

CDR-encoded parameter list (with encapsulation header)

---

function set_default_qos

Initialize with default interop-friendly QoS.

inline void astutedds::rtps::ReaderProxy::set_default_qos () 

Sets QoS values that are compatible with most DDS implementations: * BEST_EFFORT reliability

VOLATILE durability * KEEP_LAST history with depth 1

---

---

The documentation for this class was generated from the following file include/astutedds/rtps/endpoint_proxy.hpp