Namespace astutedds::dcps
Namespace List > astutedds > dcps
Classes
| Type | Name |
|---|---|
| struct | CacheChange Represents a single data sample in a writer's history. |
| struct | ComparisonNode Comparison condition (field op value) |
| class | CompiledFilter Compiled filter expression for efficient evaluation. |
| struct | ContentFilterProperty Content filter signature for discovery. |
| class | ContentFilteredTopic Content-filtered topic description. |
| class | DataLogTool File-based logging and replay helper for DDS payload streams. |
| class | DataReader Subscribes to data samples from a topic. |
| class | DataReaderListener |
| struct | DataReaderQos |
| struct | DataRepresentationModifier |
| struct | DataRepresentationQosPolicy |
| class | DataWriter Publishes data samples to a topic. |
| class | DataWriterListener |
| struct | DataWriterQos |
| struct | DdsTime_t |
| struct | DeadlineModifier |
| struct | DeadlineQosPolicy |
| struct | DestinationOrderModifier |
| struct | DestinationOrderQosPolicy |
| class | DomainParticipant Entry point for DDS communication in a domain. |
| class | DomainParticipantFactory Singleton factory for creating DomainParticipants. |
| class | DomainParticipantListener |
| struct | DomainParticipantQos |
| struct | DurabilityQosModifier |
| struct | DurabilityQosPolicy |
| struct | DurabilityServiceQosPolicy |
| struct | Duration_t |
| struct | EntityFactoryQosPolicy |
| struct | FilterCondition Filter condition node in expression tree. |
| class | FilterExpression Parsed filter expression. |
| struct | FilterExpressionNode Filter expression tree (AND/OR combinations) |
| class | FilterExpressionParser Parses SQL-like filter expressions. |
| struct | FilterNode Base class for filter expression nodes. |
| struct | GroupDataModifier |
| struct | GroupDataQosPolicy |
| struct | HistoryKeepAllModifier |
| struct | HistoryKeepLastModifier |
| struct | HistoryQosPolicy |
| struct | InNode IN condition (field IN (val1, val2, ...)) |
| struct | InconsistentTopicStatus |
| struct | LatencyBudgetModifier |
| struct | LatencyBudgetQosPolicy |
| struct | LifespanModifier |
| struct | LifespanQosPolicy |
| class | Listener |
| struct | LivelinessChangedStatus Liveliness changed status (for reader callbacks) |
| struct | LivelinessLostStatus Liveliness lost status (for writer callbacks) |
| class | LivelinessManager Liveliness Manager for participant-level liveliness monitoring. |
| struct | LivelinessModifier |
| struct | LivelinessQosPolicy |
| struct | LivelinessStatus Liveliness status for a writer. |
| struct | LoggedSample A logged DCPS payload sample for offline recording/replay. |
| struct | LogicalNode Logical combination of conditions. |
| struct | OfferedDeadlineMissedStatus |
| struct | OfferedIncompatibleQosStatus |
| struct | OwnershipModifier |
| struct | OwnershipQosPolicy |
| struct | OwnershipStrengthModifier |
| struct | OwnershipStrengthQosPolicy |
| struct | PartitionModifier |
| struct | PartitionQosPolicy |
| struct | PersistedSample A single persisted sample stored by the Persistence Service. |
| class | PersistenceService OMG-compliant DDS Persistence Service. |
| struct | PresentationModifier |
| struct | PresentationQosPolicy |
| struct | PublicationMatchedStatus |
| class | Publisher Container for DataWriters. |
| class | PublisherListener |
| struct | PublisherQos |
| struct | QosPolicyCount |
| class | ROS2Bridge |
| struct | ReaderDataLifecycleModifier |
| struct | ReaderDataLifecycleQosPolicy |
| struct | ReaderFilterInfo Information about a reader's content filter. |
| class | ReaderLiveliness Per-reader liveliness monitoring helper. |
| struct | ReceivedSample Represents a received data sample. |
| struct | ReliabilityQosModifier |
| struct | ReliabilityQosPolicy |
| struct | RequestedDeadlineMissedStatus |
| struct | RequestedIncompatibleQosStatus |
| struct | ResourceLimitsModifier |
| struct | ResourceLimitsQosPolicy |
| struct | SampleInfo Information about a received sample. |
| struct | SampleLostStatus |
| struct | SampleRejectedStatus |
| struct | SampleRejectedStatusKind |
| class | Subscriber Container for DataReaders. |
| class | SubscriberListener |
| struct | SubscriberQos |
| struct | SubscriptionMatchedStatus |
| struct | TimeBasedFilterModifier |
| struct | TimeBasedFilterQosPolicy |
| class | Topic Represents a typed data stream within a domain. |
| struct | TopicDataQosPolicy |
| class | TopicDescription Abstract base for Topic andContentFilteredTopic . |
| class | TopicListener |
| struct | TopicQos |
| class | TopicQosBuilder |
| struct | TrackedWriter Tracked writer information. |
| struct | TransportPriorityQosPolicy |
| class | TypedDataReader <typename T, typename XCDR2Codec, typename XCDR1Codec> |
| class | TypedDataWriter <typename T, typename XCDR2Codec, typename XCDR1Codec> |
| class | TypedFieldAccessor <typename T> Create field accessor for a specific type. |
| struct | UserDataModifier |
| struct | UserDataQosPolicy |
| struct | WriterDataLifecycleModifier |
| struct | WriterDataLifecycleQosPolicy |
| class | WriterFilterManager Manages content filters for a data writer. |
| class | WriterLiveliness Per-writer liveliness assertion helper. |
| class | XmlQosLoader Loads and caches DDS XML QoS profiles. |
| struct | XmlQosProfile A parsed QoS profile entry. |
Public Types
| Type | Name |
|---|---|
| typedef std::array< int32_t, 3 > | BuiltinTopicKey_t |
| typedef std::vector< DataRepresentationId_t > | DataRepresentationIdSeq |
| typedef int16_t | DataRepresentationId_t |
| enum | DestinationOrderQosPolicyKind |
| typedef int32_t | DomainId_t |
| enum | DurabilityQosPolicyKind |
| typedef std::function< FilterValue(const void *data, const std::string &field_name)> | FieldAccessor Field accessor function type. |
| enum | FilterOperator Comparison operator types for filter expressions. |
| enum | FilterOperator Comparison operators for filter expressions. |
| typedef std::variant< int64_t, double, std::string, bool > | FilterValue Filter expression value types. |
| enum | HistoryQosPolicyKind |
| typedef int32_t | InstanceHandle_t Instance handle type. |
| typedef uint32_t | InstanceStateKind |
| typedef uint32_t | InstanceStateMask |
| typedef std::function< void(const LivelinessChangedStatus &)> | LivelinessChangedCallback Callback types for liveliness events. |
| typedef std::function< void(const LivelinessLostStatus &)> | LivelinessLostCallback |
| enum | LivelinessQosPolicyKind |
| enum | LogicalOperator Logical operator types for combining conditions. |
| enum | LogicalOperator Logical operators for combining conditions. |
| enum | OwnershipQosPolicyKind |
| enum | PresentationQosPolicyAccessScopeKind |
| typedef std::vector< QosPolicyCount > | QosPolicyCountSeq |
| typedef int32_t | QosPolicyId_t |
| enum | ReliabilityQosPolicyKind |
| enum int32_t | ReturnCode_t |
| typedef std::vector< SampleInfo > | SampleInfoSeq |
| typedef uint32_t | SampleStateKind |
| typedef uint32_t | SampleStateMask |
| typedef uint32_t | StatusMask |
| typedef std::vector< std::string > | StringSeq |
| typedef uint32_t | UInt32 |
| typedef uint32_t | ViewStateKind |
| typedef uint32_t | ViewStateMask |
Public Attributes
Public Functions
Public Types Documentation
typedef BuiltinTopicKey_t
using astutedds::dcps::BuiltinTopicKey_t = typedef std::array<int32_t, 3>;
typedef DataRepresentationIdSeq
using astutedds::dcps::DataRepresentationIdSeq = typedef std::vector<DataRepresentationId_t>;
typedef DataRepresentationId_t
using astutedds::dcps::DataRepresentationId_t = typedef int16_t;
enum DestinationOrderQosPolicyKind
enum astutedds::dcps::DestinationOrderQosPolicyKind {
BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS,
BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS
};
typedef DomainId_t
using astutedds::dcps::DomainId_t = typedef int32_t;
enum DurabilityQosPolicyKind
enum astutedds::dcps::DurabilityQosPolicyKind {
VOLATILE_DURABILITY_QOS,
TRANSIENT_LOCAL_DURABILITY_QOS,
TRANSIENT_DURABILITY_QOS,
PERSISTENT_DURABILITY_QOS
};
typedef FieldAccessor
Field accessor function type.
using astutedds::dcps::FieldAccessor = typedef std::function<FilterValue(const void* data, const std::string& field_name)>;
enum FilterOperator
Comparison operator types for filter expressions.
enum astutedds::dcps::FilterOperator {
EQUAL,
NOT_EQUAL,
LESS_THAN,
LESS_EQUAL,
GREATER_THAN,
GREATER_EQUAL,
LIKE,
BETWEEN,
IN,
IS_NULL,
IS_NOT_NULL,
EQUAL,
NOT_EQUAL,
LESS_THAN,
LESS_EQUAL,
GREATER_THAN,
GREATER_EQUAL,
LIKE,
BETWEEN,
IN,
IS_NULL,
IS_NOT_NULL
};
enum FilterOperator
Comparison operators for filter expressions.
enum astutedds::dcps::FilterOperator {
EQUAL,
NOT_EQUAL,
LESS_THAN,
LESS_EQUAL,
GREATER_THAN,
GREATER_EQUAL,
LIKE,
BETWEEN,
IN,
IS_NULL,
IS_NOT_NULL,
EQUAL,
NOT_EQUAL,
LESS_THAN,
LESS_EQUAL,
GREATER_THAN,
GREATER_EQUAL,
LIKE,
BETWEEN,
IN,
IS_NULL,
IS_NOT_NULL
};
typedef FilterValue
Filter expression value types.
typedef std::variant< std::monostate, bool, int32_t, int64_t, float, double, std::string > astutedds::dcps::FilterValue;
enum HistoryQosPolicyKind
enum astutedds::dcps::HistoryQosPolicyKind {
KEEP_LAST_HISTORY_QOS,
KEEP_ALL_HISTORY_QOS
};
typedef InstanceHandle_t
Instance handle type.
using astutedds::dcps::InstanceHandle_t = typedef int32_t;
typedef InstanceStateKind
using astutedds::dcps::InstanceStateKind = typedef uint32_t;
typedef InstanceStateMask
using astutedds::dcps::InstanceStateMask = typedef uint32_t;
typedef LivelinessChangedCallback
Callback types for liveliness events.
using astutedds::dcps::LivelinessChangedCallback = typedef std::function<void(const LivelinessChangedStatus&)>;
typedef LivelinessLostCallback
using astutedds::dcps::LivelinessLostCallback = typedef std::function<void(const LivelinessLostStatus&)>;
enum LivelinessQosPolicyKind
enum astutedds::dcps::LivelinessQosPolicyKind {
AUTOMATIC_LIVELINESS_QOS,
MANUAL_BY_PARTICIPANT_LIVELINESS_QOS,
MANUAL_BY_TOPIC_LIVELINESS_QOS
};
enum LogicalOperator
Logical operator types for combining conditions.
enum astutedds::dcps::LogicalOperator {
AND,
OR,
NOT,
AND,
OR,
NOT
};
enum LogicalOperator
Logical operators for combining conditions.
enum astutedds::dcps::LogicalOperator {
AND,
OR,
NOT,
AND,
OR,
NOT
};
enum OwnershipQosPolicyKind
enum astutedds::dcps::OwnershipQosPolicyKind {
SHARED_OWNERSHIP_QOS,
EXCLUSIVE_OWNERSHIP_QOS
};
enum PresentationQosPolicyAccessScopeKind
enum astutedds::dcps::PresentationQosPolicyAccessScopeKind {
INSTANCE_PRESENTATION_QOS,
TOPIC_PRESENTATION_QOS,
GROUP_PRESENTATION_QOS
};
typedef QosPolicyCountSeq
using astutedds::dcps::QosPolicyCountSeq = typedef std::vector<QosPolicyCount>;
typedef QosPolicyId_t
using astutedds::dcps::QosPolicyId_t = typedef int32_t;
enum ReliabilityQosPolicyKind
enum astutedds::dcps::ReliabilityQosPolicyKind {
BEST_EFFORT_RELIABILITY_QOS,
RELIABLE_RELIABILITY_QOS
};
enum ReturnCode_t
enum astutedds::dcps::ReturnCode_t {
RETCODE_OK = 0,
RETCODE_ERROR = 1,
RETCODE_UNSUPPORTED = 2,
RETCODE_BAD_PARAMETER = 3,
RETCODE_PRECONDITION_NOT_MET = 4,
RETCODE_OUT_OF_RESOURCES = 5,
RETCODE_NOT_ENABLED = 6,
RETCODE_IMMUTABLE_POLICY = 7,
RETCODE_INCONSISTENT_POLICY = 8,
RETCODE_ALREADY_DELETED = 9,
RETCODE_TIMEOUT = 10,
RETCODE_NO_DATA = 11,
RETCODE_ILLEGAL_OPERATION = 12
};
typedef SampleInfoSeq
using astutedds::dcps::SampleInfoSeq = typedef std::vector<SampleInfo>;
typedef SampleStateKind
using astutedds::dcps::SampleStateKind = typedef uint32_t;
typedef SampleStateMask
using astutedds::dcps::SampleStateMask = typedef uint32_t;
typedef StatusMask
using astutedds::dcps::StatusMask = typedef uint32_t;
typedef StringSeq
using astutedds::dcps::StringSeq = typedef std::vector<std::string>;
typedef UInt32
using astutedds::dcps::UInt32 = typedef uint32_t;
typedef ViewStateKind
using astutedds::dcps::ViewStateKind = typedef uint32_t;
typedef ViewStateMask
using astutedds::dcps::ViewStateMask = typedef uint32_t;
Public Attributes Documentation
variable ALIVE_INSTANCE_STATE
constexpr InstanceStateKind astutedds::dcps::ALIVE_INSTANCE_STATE;
variable ANY_INSTANCE_STATE
constexpr InstanceStateMask astutedds::dcps::ANY_INSTANCE_STATE;
variable ANY_SAMPLE_STATE
constexpr SampleStateMask astutedds::dcps::ANY_SAMPLE_STATE;
variable ANY_VIEW_STATE
constexpr ViewStateMask astutedds::dcps::ANY_VIEW_STATE;
variable AUTOMATIC_LIVELINESS_QOS
constexpr auto astutedds::dcps::AUTOMATIC_LIVELINESS_QOS;
variable BEST_EFFORT_RELIABILITY_QOS
constexpr auto astutedds::dcps::BEST_EFFORT_RELIABILITY_QOS;
variable BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS
constexpr auto astutedds::dcps::BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS;
variable BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS
constexpr auto astutedds::dcps::BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS;
variable DATAREADER_QOS_DEFAULT
const DataReaderQos astutedds::dcps::DATAREADER_QOS_DEFAULT;
variable DATAREPRESENTATION_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::DATAREPRESENTATION_QOS_POLICY_ID;
variable DATAWRITER_QOS_DEFAULT
const DataWriterQos astutedds::dcps::DATAWRITER_QOS_DEFAULT;
variable DATA_AVAILABLE_STATUS
constexpr StatusMask astutedds::dcps::DATA_AVAILABLE_STATUS;
variable DATA_ON_READERS_STATUS
constexpr StatusMask astutedds::dcps::DATA_ON_READERS_STATUS;
variable DATA_REPRESENTATION_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::DATA_REPRESENTATION_QOS_POLICY_ID;
variable DEADLINE_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::DEADLINE_QOS_POLICY_ID;
variable DESTINATIONORDER_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::DESTINATIONORDER_QOS_POLICY_ID;
variable DURABILITYSERVICE_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::DURABILITYSERVICE_QOS_POLICY_ID;
variable DURABILITY_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::DURABILITY_QOS_POLICY_ID;
variable ENTITYFACTORY_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::ENTITYFACTORY_QOS_POLICY_ID;
variable EXCLUSIVE_OWNERSHIP_QOS
constexpr auto astutedds::dcps::EXCLUSIVE_OWNERSHIP_QOS;
variable GROUPDATA_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::GROUPDATA_QOS_POLICY_ID;
variable GROUP_PRESENTATION_QOS
constexpr auto astutedds::dcps::GROUP_PRESENTATION_QOS;
variable HANDLE_NIL
constexpr InstanceHandle_t astutedds::dcps::HANDLE_NIL;
variable HANDLE_NIL_VALUE
constexpr InstanceHandle_t astutedds::dcps::HANDLE_NIL_VALUE;
variable HISTORY_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::HISTORY_QOS_POLICY_ID;
variable INCONSISTENT_TOPIC_STATUS
constexpr StatusMask astutedds::dcps::INCONSISTENT_TOPIC_STATUS;
variable INSTANCE_PRESENTATION_QOS
constexpr auto astutedds::dcps::INSTANCE_PRESENTATION_QOS;
variable INVALID_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::INVALID_QOS_POLICY_ID;
variable KEEP_ALL_HISTORY_QOS
constexpr auto astutedds::dcps::KEEP_ALL_HISTORY_QOS;
variable KEEP_LAST_HISTORY_QOS
constexpr auto astutedds::dcps::KEEP_LAST_HISTORY_QOS;
variable LATENCYBUDGET_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::LATENCYBUDGET_QOS_POLICY_ID;
variable LENGTH_UNLIMITED
constexpr int32_t astutedds::dcps::LENGTH_UNLIMITED;
variable LIFESPAN_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::LIFESPAN_QOS_POLICY_ID;
variable LIVELINESS_CHANGED_STATUS
constexpr StatusMask astutedds::dcps::LIVELINESS_CHANGED_STATUS;
variable LIVELINESS_LOST_STATUS
constexpr StatusMask astutedds::dcps::LIVELINESS_LOST_STATUS;
variable LIVELINESS_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::LIVELINESS_QOS_POLICY_ID;
variable MANUAL_BY_PARTICIPANT_LIVELINESS_QOS
constexpr auto astutedds::dcps::MANUAL_BY_PARTICIPANT_LIVELINESS_QOS;
variable MANUAL_BY_TOPIC_LIVELINESS_QOS
constexpr auto astutedds::dcps::MANUAL_BY_TOPIC_LIVELINESS_QOS;
variable NEW_VIEW_STATE
constexpr ViewStateKind astutedds::dcps::NEW_VIEW_STATE;
variable NOT_ALIVE_DISPOSED_INSTANCE_STATE
constexpr InstanceStateKind astutedds::dcps::NOT_ALIVE_DISPOSED_INSTANCE_STATE;
variable NOT_ALIVE_INSTANCE_STATE
constexpr InstanceStateMask astutedds::dcps::NOT_ALIVE_INSTANCE_STATE;
variable NOT_ALIVE_NO_WRITERS_INSTANCE_STATE
constexpr InstanceStateKind astutedds::dcps::NOT_ALIVE_NO_WRITERS_INSTANCE_STATE;
variable NOT_NEW_VIEW_STATE
constexpr ViewStateKind astutedds::dcps::NOT_NEW_VIEW_STATE;
variable NOT_READ_SAMPLE_STATE
constexpr SampleStateKind astutedds::dcps::NOT_READ_SAMPLE_STATE;
variable OFFERED_DEADLINE_MISSED_STATUS
constexpr StatusMask astutedds::dcps::OFFERED_DEADLINE_MISSED_STATUS;
variable OFFERED_INCOMPATIBLE_QOS_STATUS
constexpr StatusMask astutedds::dcps::OFFERED_INCOMPATIBLE_QOS_STATUS;
variable OWNERSHIPSTRENGTH_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::OWNERSHIPSTRENGTH_QOS_POLICY_ID;
variable OWNERSHIP_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::OWNERSHIP_QOS_POLICY_ID;
variable PARTICIPANT_QOS_DEFAULT
const DomainParticipantQos astutedds::dcps::PARTICIPANT_QOS_DEFAULT;
variable PARTITION_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::PARTITION_QOS_POLICY_ID;
variable PERSISTENT_DURABILITY_QOS
constexpr auto astutedds::dcps::PERSISTENT_DURABILITY_QOS;
variable PRESENTATION_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::PRESENTATION_QOS_POLICY_ID;
variable PUBLICATION_MATCHED_STATUS
constexpr StatusMask astutedds::dcps::PUBLICATION_MATCHED_STATUS;
variable PUBLISHER_QOS_DEFAULT
const PublisherQos astutedds::dcps::PUBLISHER_QOS_DEFAULT;
variable READERDATALIFECYCLE_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::READERDATALIFECYCLE_QOS_POLICY_ID;
variable READ_SAMPLE_STATE
constexpr SampleStateKind astutedds::dcps::READ_SAMPLE_STATE;
variable RELIABILITY_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::RELIABILITY_QOS_POLICY_ID;
variable RELIABLE_RELIABILITY_QOS
constexpr auto astutedds::dcps::RELIABLE_RELIABILITY_QOS;
variable REQUESTED_DEADLINE_MISSED_STATUS
constexpr StatusMask astutedds::dcps::REQUESTED_DEADLINE_MISSED_STATUS;
variable REQUESTED_INCOMPATIBLE_QOS_STATUS
constexpr StatusMask astutedds::dcps::REQUESTED_INCOMPATIBLE_QOS_STATUS;
variable RESOURCELIMITS_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::RESOURCELIMITS_QOS_POLICY_ID;
variable SAMPLE_LOST_STATUS
constexpr StatusMask astutedds::dcps::SAMPLE_LOST_STATUS;
variable SAMPLE_REJECTED_STATUS
constexpr StatusMask astutedds::dcps::SAMPLE_REJECTED_STATUS;
variable SHARED_OWNERSHIP_QOS
constexpr auto astutedds::dcps::SHARED_OWNERSHIP_QOS;
variable STATUS_MASK_ALL
constexpr StatusMask astutedds::dcps::STATUS_MASK_ALL;
variable STATUS_MASK_NONE
constexpr StatusMask astutedds::dcps::STATUS_MASK_NONE;
variable SUBSCRIBER_QOS_DEFAULT
const SubscriberQos astutedds::dcps::SUBSCRIBER_QOS_DEFAULT;
variable SUBSCRIPTION_MATCHED_STATUS
constexpr StatusMask astutedds::dcps::SUBSCRIPTION_MATCHED_STATUS;
variable TIMEBASEDFILTER_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::TIMEBASEDFILTER_QOS_POLICY_ID;
variable TOPICDATA_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::TOPICDATA_QOS_POLICY_ID;
variable TOPIC_PRESENTATION_QOS
constexpr auto astutedds::dcps::TOPIC_PRESENTATION_QOS;
variable TOPIC_QOS_DEFAULT
const TopicQos astutedds::dcps::TOPIC_QOS_DEFAULT;
variable TRANSIENT_DURABILITY_QOS
constexpr auto astutedds::dcps::TRANSIENT_DURABILITY_QOS;
variable TRANSIENT_LOCAL_DURABILITY_QOS
constexpr auto astutedds::dcps::TRANSIENT_LOCAL_DURABILITY_QOS;
variable TRANSPORTPRIORITY_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::TRANSPORTPRIORITY_QOS_POLICY_ID;
variable USERDATA_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::USERDATA_QOS_POLICY_ID;
variable VOLATILE_DURABILITY_QOS
constexpr auto astutedds::dcps::VOLATILE_DURABILITY_QOS;
variable WRITERDATALIFECYCLE_QOS_POLICY_ID
constexpr QosPolicyId_t astutedds::dcps::WRITERDATALIFECYCLE_QOS_POLICY_ID;
variable XCDR2_DATA_REPRESENTATION
constexpr DataRepresentationId_t astutedds::dcps::XCDR2_DATA_REPRESENTATION;
variable XCDR_DATA_REPRESENTATION
constexpr DataRepresentationId_t astutedds::dcps::XCDR_DATA_REPRESENTATION;
variable XML_DATA_REPRESENTATION
constexpr DataRepresentationId_t astutedds::dcps::XML_DATA_REPRESENTATION;
Public Functions Documentation
function DataRepresentation
inline DataRepresentationModifier astutedds::dcps::DataRepresentation (
std::vector< int16_t > value
)
function Deadline
inline DeadlineModifier astutedds::dcps::Deadline (
rtps::Duration_t period
)
function DestinationOrder
inline DestinationOrderModifier astutedds::dcps::DestinationOrder (
DestinationOrderQosPolicyKind kind
)
function Durability
inline DurabilityQosModifier astutedds::dcps::Durability (
DurabilityQosPolicyKind kind
)
function GroupData
inline GroupDataModifier astutedds::dcps::GroupData (
std::vector< uint8_t > value
)
function HistoryKeepAll
inline HistoryKeepAllModifier astutedds::dcps::HistoryKeepAll ()
function HistoryKeepLast
inline HistoryKeepLastModifier astutedds::dcps::HistoryKeepLast (
int32_t depth
)
function LatencyBudget
inline LatencyBudgetModifier astutedds::dcps::LatencyBudget (
rtps::Duration_t duration
)
function Lifespan
inline LifespanModifier astutedds::dcps::Lifespan (
rtps::Duration_t duration
)
function Liveliness
inline LivelinessModifier astutedds::dcps::Liveliness (
LivelinessQosPolicyKind kind,
rtps::Duration_t lease=rtps::Time_t::TIME_INFINITE ()
)
function Ownership
inline OwnershipModifier astutedds::dcps::Ownership (
OwnershipQosPolicyKind kind
)
function OwnershipStrength
inline OwnershipStrengthModifier astutedds::dcps::OwnershipStrength (
int32_t v
)
function Partition
inline PartitionModifier astutedds::dcps::Partition (
std::vector< std::string > names
)
function Presentation
inline PresentationModifier astutedds::dcps::Presentation (
PresentationQosPolicyAccessScopeKind access_scope,
bool coherent_access=false,
bool ordered_access=false
)
function ReaderDataLifecycle
inline ReaderDataLifecycleModifier astutedds::dcps::ReaderDataLifecycle (
rtps::Duration_t nowriter_delay=rtps::Time_t::TIME_INFINITE (),
rtps::Duration_t disposed_delay=rtps::Time_t::TIME_INFINITE ()
)
function Reliability
inline ReliabilityQosModifier astutedds::dcps::Reliability (
ReliabilityQosPolicyKind kind,
rtps::Duration_t max_blocking_time=rtps::Duration_t {0, 100000000}
)
function ResourceLimits
inline ResourceLimitsModifier astutedds::dcps::ResourceLimits (
int32_t max_samples,
int32_t max_instances=-1,
int32_t max_samples_per_instance=-1
)
function TimeBasedFilter
inline TimeBasedFilterModifier astutedds::dcps::TimeBasedFilter (
rtps::Duration_t minimum_separation
)
function UserData
inline UserDataModifier astutedds::dcps::UserData (
std::vector< uint8_t > value
)
function WriterDataLifecycle
inline WriterDataLifecycleModifier astutedds::dcps::WriterDataLifecycle (
bool autodispose
)
function create_content_filtered_topic
Factory function to create content-filtered topic.
std::unique_ptr< ContentFilteredTopic > astutedds::dcps::create_content_filtered_topic (
DomainParticipant & participant,
const std::string & name,
std::shared_ptr< Topic > related_topic,
const std::string & filter_expression,
const std::vector< std::string > & expression_parameters={}
)
Use this instead of direct construction for proper lifecycle management.
function is_ros2_dds_topic_name
inline bool astutedds::dcps::is_ros2_dds_topic_name (
std::string_view topic_name
)
function normalize_ros2_topic_name
inline std::string astutedds::dcps::normalize_ros2_topic_name (
std::string_view topic_name
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const ReliabilityQosModifier & mod
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const HistoryKeepLastModifier & mod
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const DurabilityQosModifier & mod
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const DataRepresentationModifier & mod
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const ReliabilityQosModifier & mod
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const HistoryKeepLastModifier & mod
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const DurabilityQosModifier & mod
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const DataRepresentationModifier & mod
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const HistoryKeepAllModifier &
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const DeadlineModifier & m
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const LivelinessModifier & m
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const OwnershipModifier & m
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const OwnershipStrengthModifier & m
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const LifespanModifier & m
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const ResourceLimitsModifier & m
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const HistoryKeepAllModifier &
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const DeadlineModifier & m
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const LivelinessModifier & m
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const OwnershipModifier & m
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const ResourceLimitsModifier & m
)
function operator<<
inline PublisherQos astutedds::dcps::operator<< (
PublisherQos qos,
const PartitionModifier & m
)
function operator<<
inline SubscriberQos astutedds::dcps::operator<< (
SubscriberQos qos,
const PartitionModifier & m
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const LatencyBudgetModifier & m
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const DestinationOrderModifier & m
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const WriterDataLifecycleModifier & m
)
function operator<<
inline DataWriterQos astutedds::dcps::operator<< (
DataWriterQos qos,
const UserDataModifier & m
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const LatencyBudgetModifier & m
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const TimeBasedFilterModifier & m
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const DestinationOrderModifier & m
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const ReaderDataLifecycleModifier & m
)
function operator<<
inline DataReaderQos astutedds::dcps::operator<< (
DataReaderQos qos,
const UserDataModifier & m
)
function operator<<
inline PublisherQos astutedds::dcps::operator<< (
PublisherQos qos,
const PresentationModifier & m
)
function operator<<
inline PublisherQos astutedds::dcps::operator<< (
PublisherQos qos,
const GroupDataModifier & m
)
function operator<<
inline SubscriberQos astutedds::dcps::operator<< (
SubscriberQos qos,
const PresentationModifier & m
)
function operator<<
inline SubscriberQos astutedds::dcps::operator<< (
SubscriberQos qos,
const GroupDataModifier & m
)
function ros2_topic_to_dds_topic
inline std::string astutedds::dcps::ros2_topic_to_dds_topic (
std::string_view topic_name
)
function ros2_type_to_dds_type
inline std::string astutedds::dcps::ros2_type_to_dds_type (
std::string_view type_name
)
The documentation for this class was generated from the following file include/astutedds/dcps/content_filtered_topic.hpp