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

Type Name
constexpr InstanceStateKind ALIVE_INSTANCE_STATE = 0x0001u
constexpr InstanceStateMask ANY_INSTANCE_STATE = 0xFFFFu
constexpr SampleStateMask ANY_SAMPLE_STATE = 0xFFFFu
constexpr ViewStateMask ANY_VIEW_STATE = 0xFFFFu
constexpr auto AUTOMATIC_LIVELINESS_QOS = LivelinessQosPolicyKind::AUTOMATIC\_LIVELINESS\_QOS
constexpr auto BEST_EFFORT_RELIABILITY_QOS = ReliabilityQosPolicyKind::BEST\_EFFORT\_RELIABILITY\_QOS
constexpr auto BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS = DestinationOrderQosPolicyKind::BY\_RECEPTION\_TIMESTAMP\_DESTINATIONORDER\_QOS
constexpr auto BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS = DestinationOrderQosPolicyKind::BY\_SOURCE\_TIMESTAMP\_DESTINATIONORDER\_QOS
const DataReaderQos DATAREADER_QOS_DEFAULT = {}
constexpr QosPolicyId_t DATAREPRESENTATION_QOS_POLICY_ID = 23
const DataWriterQos DATAWRITER_QOS_DEFAULT = {}
constexpr StatusMask DATA_AVAILABLE_STATUS = 0x0400u
constexpr StatusMask DATA_ON_READERS_STATUS = 0x0200u
constexpr QosPolicyId_t DATA_REPRESENTATION_QOS_POLICY_ID = 23
constexpr QosPolicyId_t DEADLINE_QOS_POLICY_ID = 4
constexpr QosPolicyId_t DESTINATIONORDER_QOS_POLICY_ID = 12
constexpr QosPolicyId_t DURABILITYSERVICE_QOS_POLICY_ID = 22
constexpr QosPolicyId_t DURABILITY_QOS_POLICY_ID = 2
constexpr QosPolicyId_t ENTITYFACTORY_QOS_POLICY_ID = 15
constexpr auto EXCLUSIVE_OWNERSHIP_QOS = OwnershipQosPolicyKind::EXCLUSIVE\_OWNERSHIP\_QOS
constexpr QosPolicyId_t GROUPDATA_QOS_POLICY_ID = 19
constexpr auto GROUP_PRESENTATION_QOS = PresentationQosPolicyAccessScopeKind::GROUP\_PRESENTATION\_QOS
constexpr InstanceHandle_t HANDLE_NIL = 0
constexpr InstanceHandle_t HANDLE_NIL_VALUE = 0
constexpr QosPolicyId_t HISTORY_QOS_POLICY_ID = 13
constexpr StatusMask INCONSISTENT_TOPIC_STATUS = 0x0001u
constexpr auto INSTANCE_PRESENTATION_QOS = PresentationQosPolicyAccessScopeKind::INSTANCE\_PRESENTATION\_QOS
constexpr QosPolicyId_t INVALID_QOS_POLICY_ID = 0
constexpr auto KEEP_ALL_HISTORY_QOS = HistoryQosPolicyKind::KEEP\_ALL\_HISTORY\_QOS
constexpr auto KEEP_LAST_HISTORY_QOS = HistoryQosPolicyKind::KEEP\_LAST\_HISTORY\_QOS
constexpr QosPolicyId_t LATENCYBUDGET_QOS_POLICY_ID = 5
constexpr int32_t LENGTH_UNLIMITED = -1
constexpr QosPolicyId_t LIFESPAN_QOS_POLICY_ID = 21
constexpr StatusMask LIVELINESS_CHANGED_STATUS = 0x1000u
constexpr StatusMask LIVELINESS_LOST_STATUS = 0x0800u
constexpr QosPolicyId_t LIVELINESS_QOS_POLICY_ID = 8
constexpr auto MANUAL_BY_PARTICIPANT_LIVELINESS_QOS = LivelinessQosPolicyKind::MANUAL\_BY\_PARTICIPANT\_LIVELINESS\_QOS
constexpr auto MANUAL_BY_TOPIC_LIVELINESS_QOS = LivelinessQosPolicyKind::MANUAL\_BY\_TOPIC\_LIVELINESS\_QOS
constexpr ViewStateKind NEW_VIEW_STATE = 0x0001u
constexpr InstanceStateKind NOT_ALIVE_DISPOSED_INSTANCE_STATE = 0x0002u
constexpr InstanceStateMask NOT_ALIVE_INSTANCE_STATE = 0x0006u
constexpr InstanceStateKind NOT_ALIVE_NO_WRITERS_INSTANCE_STATE = 0x0004u
constexpr ViewStateKind NOT_NEW_VIEW_STATE = 0x0002u
constexpr SampleStateKind NOT_READ_SAMPLE_STATE = 0x0002u
constexpr StatusMask OFFERED_DEADLINE_MISSED_STATUS = 0x0002u
constexpr StatusMask OFFERED_INCOMPATIBLE_QOS_STATUS = 0x0020u
constexpr QosPolicyId_t OWNERSHIPSTRENGTH_QOS_POLICY_ID = 7
constexpr QosPolicyId_t OWNERSHIP_QOS_POLICY_ID = 6
const DomainParticipantQos PARTICIPANT_QOS_DEFAULT = {}
constexpr QosPolicyId_t PARTITION_QOS_POLICY_ID = 10
constexpr auto PERSISTENT_DURABILITY_QOS = DurabilityQosPolicyKind::PERSISTENT\_DURABILITY\_QOS
constexpr QosPolicyId_t PRESENTATION_QOS_POLICY_ID = 3
constexpr StatusMask PUBLICATION_MATCHED_STATUS = 0x2000u
const PublisherQos PUBLISHER_QOS_DEFAULT = {}
constexpr QosPolicyId_t READERDATALIFECYCLE_QOS_POLICY_ID = 17
constexpr SampleStateKind READ_SAMPLE_STATE = 0x0001u
constexpr QosPolicyId_t RELIABILITY_QOS_POLICY_ID = 11
constexpr auto RELIABLE_RELIABILITY_QOS = ReliabilityQosPolicyKind::RELIABLE\_RELIABILITY\_QOS
constexpr StatusMask REQUESTED_DEADLINE_MISSED_STATUS = 0x0004u
constexpr StatusMask REQUESTED_INCOMPATIBLE_QOS_STATUS = 0x0040u
constexpr QosPolicyId_t RESOURCELIMITS_QOS_POLICY_ID = 14
constexpr StatusMask SAMPLE_LOST_STATUS = 0x0080u
constexpr StatusMask SAMPLE_REJECTED_STATUS = 0x0100u
constexpr auto SHARED_OWNERSHIP_QOS = OwnershipQosPolicyKind::SHARED\_OWNERSHIP\_QOS
constexpr StatusMask STATUS_MASK_ALL = 0xFFFFFFFFu
constexpr StatusMask STATUS_MASK_NONE = 0x0000u
const SubscriberQos SUBSCRIBER_QOS_DEFAULT = {}
constexpr StatusMask SUBSCRIPTION_MATCHED_STATUS = 0x4000u
constexpr QosPolicyId_t TIMEBASEDFILTER_QOS_POLICY_ID = 9
constexpr QosPolicyId_t TOPICDATA_QOS_POLICY_ID = 18
constexpr auto TOPIC_PRESENTATION_QOS = PresentationQosPolicyAccessScopeKind::TOPIC\_PRESENTATION\_QOS
const TopicQos TOPIC_QOS_DEFAULT = {}
constexpr auto TRANSIENT_DURABILITY_QOS = DurabilityQosPolicyKind::TRANSIENT\_DURABILITY\_QOS
constexpr auto TRANSIENT_LOCAL_DURABILITY_QOS = DurabilityQosPolicyKind::TRANSIENT\_LOCAL\_DURABILITY\_QOS
constexpr QosPolicyId_t TRANSPORTPRIORITY_QOS_POLICY_ID = 20
constexpr QosPolicyId_t USERDATA_QOS_POLICY_ID = 1
constexpr auto VOLATILE_DURABILITY_QOS = DurabilityQosPolicyKind::VOLATILE\_DURABILITY\_QOS
constexpr QosPolicyId_t WRITERDATALIFECYCLE_QOS_POLICY_ID = 16
constexpr DataRepresentationId_t XCDR2_DATA_REPRESENTATION = 2
constexpr DataRepresentationId_t XCDR_DATA_REPRESENTATION = 0
constexpr DataRepresentationId_t XML_DATA_REPRESENTATION = 1

Public Functions

Type Name
DataRepresentationModifier DataRepresentation (std::vector< int16_t > value)
DeadlineModifier Deadline (rtps::Duration_t period)
DestinationOrderModifier DestinationOrder (DestinationOrderQosPolicyKind kind)
DurabilityQosModifier Durability (DurabilityQosPolicyKind kind)
GroupDataModifier GroupData (std::vector< uint8_t > value)
HistoryKeepAllModifier HistoryKeepAll ()
HistoryKeepLastModifier HistoryKeepLast (int32_t depth)
LatencyBudgetModifier LatencyBudget (rtps::Duration_t duration)
LifespanModifier Lifespan (rtps::Duration_t duration)
LivelinessModifier Liveliness (LivelinessQosPolicyKind kind, rtps::Duration_t lease=rtps::Time_t::TIME_INFINITE())
OwnershipModifier Ownership (OwnershipQosPolicyKind kind)
OwnershipStrengthModifier OwnershipStrength (int32_t v)
PartitionModifier Partition (std::vector< std::string > names)
PresentationModifier Presentation (PresentationQosPolicyAccessScopeKind access_scope, bool coherent_access=false, bool ordered_access=false)
ReaderDataLifecycleModifier ReaderDataLifecycle (rtps::Duration_t nowriter_delay=rtps::Time_t::TIME_INFINITE(), rtps::Duration_t disposed_delay=rtps::Time_t::TIME_INFINITE())
ReliabilityQosModifier Reliability (ReliabilityQosPolicyKind kind, rtps::Duration_t max_blocking_time=rtps::Duration_t)
ResourceLimitsModifier ResourceLimits (int32_t max_samples, int32_t max_instances=-1, int32_t max_samples_per_instance=-1)
TimeBasedFilterModifier TimeBasedFilter (rtps::Duration_t minimum_separation)
UserDataModifier UserData (std::vector< uint8_t > value)
WriterDataLifecycleModifier WriterDataLifecycle (bool autodispose)
std::unique_ptr< ContentFilteredTopic > 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={})
Factory function to create content-filtered topic.
bool is_ros2_dds_topic_name (std::string_view topic_name)
std::string normalize_ros2_topic_name (std::string_view topic_name)
DataWriterQos operator<< (DataWriterQos qos, const ReliabilityQosModifier & mod)
DataWriterQos operator<< (DataWriterQos qos, const HistoryKeepLastModifier & mod)
DataWriterQos operator<< (DataWriterQos qos, const DurabilityQosModifier & mod)
DataWriterQos operator<< (DataWriterQos qos, const DataRepresentationModifier & mod)
DataReaderQos operator<< (DataReaderQos qos, const ReliabilityQosModifier & mod)
DataReaderQos operator<< (DataReaderQos qos, const HistoryKeepLastModifier & mod)
DataReaderQos operator<< (DataReaderQos qos, const DurabilityQosModifier & mod)
DataReaderQos operator<< (DataReaderQos qos, const DataRepresentationModifier & mod)
DataWriterQos operator<< (DataWriterQos qos, const HistoryKeepAllModifier &)
DataWriterQos operator<< (DataWriterQos qos, const DeadlineModifier & m)
DataWriterQos operator<< (DataWriterQos qos, const LivelinessModifier & m)
DataWriterQos operator<< (DataWriterQos qos, const OwnershipModifier & m)
DataWriterQos operator<< (DataWriterQos qos, const OwnershipStrengthModifier & m)
DataWriterQos operator<< (DataWriterQos qos, const LifespanModifier & m)
DataWriterQos operator<< (DataWriterQos qos, const ResourceLimitsModifier & m)
DataReaderQos operator<< (DataReaderQos qos, const HistoryKeepAllModifier &)
DataReaderQos operator<< (DataReaderQos qos, const DeadlineModifier & m)
DataReaderQos operator<< (DataReaderQos qos, const LivelinessModifier & m)
DataReaderQos operator<< (DataReaderQos qos, const OwnershipModifier & m)
DataReaderQos operator<< (DataReaderQos qos, const ResourceLimitsModifier & m)
PublisherQos operator<< (PublisherQos qos, const PartitionModifier & m)
SubscriberQos operator<< (SubscriberQos qos, const PartitionModifier & m)
DataWriterQos operator<< (DataWriterQos qos, const LatencyBudgetModifier & m)
DataWriterQos operator<< (DataWriterQos qos, const DestinationOrderModifier & m)
DataWriterQos operator<< (DataWriterQos qos, const WriterDataLifecycleModifier & m)
DataWriterQos operator<< (DataWriterQos qos, const UserDataModifier & m)
DataReaderQos operator<< (DataReaderQos qos, const LatencyBudgetModifier & m)
DataReaderQos operator<< (DataReaderQos qos, const TimeBasedFilterModifier & m)
DataReaderQos operator<< (DataReaderQos qos, const DestinationOrderModifier & m)
DataReaderQos operator<< (DataReaderQos qos, const ReaderDataLifecycleModifier & m)
DataReaderQos operator<< (DataReaderQos qos, const UserDataModifier & m)
PublisherQos operator<< (PublisherQos qos, const PresentationModifier & m)
PublisherQos operator<< (PublisherQos qos, const GroupDataModifier & m)
SubscriberQos operator<< (SubscriberQos qos, const PresentationModifier & m)
SubscriberQos operator<< (SubscriberQos qos, const GroupDataModifier & m)
std::string ros2_topic_to_dds_topic (std::string_view topic_name)
std::string ros2_type_to_dds_type (std::string_view type_name)

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