rti package

Submodules

rti.connextdds Module

class rti.connextdds.ACTMember

Bases: rti.connextdds.DynamicType

INVALID_INDEX = 4294967295
cdr_serialized_sample_max_size(self: rti.connextdds.ACTMember, arg0: int) → int

Gets the maximum serialized size of samples of this type.

extensibility_kind(self: rti.connextdds.ACTMember)rti.connextdds.ExtensibilityKind

Gets the extensibility kind.

find_member_by_name(self: rti.connextdds.ACTMember, arg0: str) → int

Obtains the member index from its name.

member(*args, **kwargs)

Overloaded function.

  1. member(self: rti.connextdds.ACTMember, arg0: int) -> rti.connextdds.Member

Gets a member by its index.

  1. member(self: rti.connextdds.ACTMember, arg0: str) -> rti.connextdds.Member

Gets a member by its name.

property member_count

Gets the number of members.

members(self: rti.connextdds.ACTMember)rti.connextdds.MemberSeq

Gets a copy of all the members

class rti.connextdds.ACTUnionMember

Bases: rti.connextdds.DynamicType

INVALID_INDEX = 4294967295
cdr_serialized_sample_max_size(self: rti.connextdds.ACTUnionMember, arg0: int) → int

Gets the maximum serialized size of samples of this type.

extensibility_kind(self: rti.connextdds.ACTUnionMember)rti.connextdds.ExtensibilityKind

Gets the extensibility kind.

find_member_by_name(self: rti.connextdds.ACTUnionMember, arg0: str) → int

Obtains the member index from its name.

member(*args, **kwargs)

Overloaded function.

  1. member(self: rti.connextdds.ACTUnionMember, arg0: int) -> rti.connextdds.UnionMember

Gets a member by its index.

  1. member(self: rti.connextdds.ACTUnionMember, arg0: str) -> rti.connextdds.UnionMember

Gets a member by its name.

property member_count

Gets the number of members.

members(self: rti.connextdds.ACTUnionMember)rti.connextdds.UnionMemberSeq

Gets a copy of all the members

class rti.connextdds.AckResponseData

Bases: pybind11_builtins.pybind11_object

property value

Gets the subscription handle of the acknowledging DataReade

class rti.connextdds.AcknowledgmentInfo

Bases: pybind11_builtins.pybind11_object

property response_data

User data payload of application-level acknowledgment.

property sample_identity

Get the identity of the sample being acknowledged.

property subscription_handle

Gets the subscription handle of the acknowledging DataReader

property valid_response_data

Flag indicating validity of the use response data in the acknowledgment.

class rti.connextdds.AcknowledgmentKind

Bases: pybind11_builtins.pybind11_object

APPLICATION_AUTO = AcknowledgmentKind.APPLICATION_AUTO
APPLICATION_EXPLICIT = AcknowledgmentKind.APPLICATION_EXPLICIT
APPLICATION_ORDERED = AcknowledgmentKind.APPLICATION_ORDERED
class AcknowledgmentKind

Bases: pybind11_builtins.pybind11_object

Members:

PROTOCOL : Samples are acknowledged by RTPS protocol.

Samples are acknowledged according to the Real-Time Publish-Subscribe (RTPS) interoperability protocol.

APPLICATION_AUTO : Samples are acknowledged automatically after a subscribing application has accessed them.

The DataReader automatically acknowledges a sample after it has been taken and the loan returned.

APPLICATION_ORDERED : Samples up to a specified sequence number are acknowledged.

APPLICATION_EXPLICIT : Samples are acknowledged after the subscribing application explicitly calls acknowledge on the samples.

Samples received by a DataReader are explicitly acknowledged by the subscribing application, after it calls either DataReader.acknowledge_all or DataReader.acknowledge_sample.

APPLICATION_AUTO = AcknowledgmentKind.APPLICATION_AUTO
APPLICATION_EXPLICIT = AcknowledgmentKind.APPLICATION_EXPLICIT
APPLICATION_ORDERED = AcknowledgmentKind.APPLICATION_ORDERED
PROTOCOL = AcknowledgmentKind.PROTOCOL
property name

(self: handle) -> str

PROTOCOL = AcknowledgmentKind.PROTOCOL
property underlying

Retrieves the actual enumerated value.

class rti.connextdds.AliasType

Bases: rti.connextdds.DynamicType

Represents a typedef.

property is_pointer

Gets whether this alias makes related_type a pointer

related_type(self: rti.connextdds.AliasType)rti.connextdds.DynamicType

Gets the related type.

resolve(self: rti.connextdds.DynamicType)rti.connextdds.DynamicType

Resolves an AliasType recursively to get the final underlying type.

static resolve_type(alias_type: rti.connextdds.DynamicType)rti.connextdds.DynamicType

Resolves an AliasType recursively to get the final underlying type.

class rti.connextdds.AllocationSettings

Bases: pybind11_builtins.pybind11_object

AUTO_COUNT = -2
property incremental_count

Incremental count of resources.

property initial_count

Initial count of resources.

property max_count

Max count of resources.

exception rti.connextdds.AlreadyClosedError

Bases: rti.connextdds.Exception

class rti.connextdds.AnyDataReader

Bases: rti.connextdds.IAnyDataReader

class rti.connextdds.AnyDataReaderListener

Bases: pybind11_builtins.pybind11_object

on_data_available(self: rti.connextdds.AnyDataReaderListener, arg0: rti.connextdds.AnyDataReader) → None

Data available callback.

on_liveliness_changed(self: rti.connextdds.AnyDataReaderListener, arg0: rti.connextdds.AnyDataReader, arg1: rti.connextdds.LivelinessChangedStatus) → None

Liveliness changed callback.

on_requested_deadline_missed(self: rti.connextdds.AnyDataReaderListener, arg0: rti.connextdds.AnyDataReader, arg1: rti.connextdds.RequestedDeadlineMissedStatus) → None

Requested deadline missed callback.

on_requested_incompatible_qos(self: rti.connextdds.AnyDataReaderListener, arg0: rti.connextdds.AnyDataReader, arg1: rti.connextdds.RequestedIncompatibleQosStatus) → None

Requested incompatible QoS callback.

on_sample_lost(self: rti.connextdds.AnyDataReaderListener, arg0: rti.connextdds.AnyDataReader, arg1: rti.connextdds.SampleLostStatus) → None

Sample lost callback.

on_sample_rejected(self: rti.connextdds.AnyDataReaderListener, arg0: rti.connextdds.AnyDataReader, arg1: rti.connextdds.SampleRejectedStatus) → None

Sample rejected callback.

on_subscription_matched(self: rti.connextdds.AnyDataReaderListener, arg0: rti.connextdds.AnyDataReader, arg1: rti.connextdds.SubscriptionMatchedStatus) → None

Subscription matched callback.

class rti.connextdds.AnyDataReaderSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.AnyDataReaderSeq, x: rti.connextdds.AnyDataReader) → None

Add an item to the end of the list

clear(self: rti.connextdds.AnyDataReaderSeq) → None

Clear the contents

count(self: rti.connextdds.AnyDataReaderSeq, x: rti.connextdds.AnyDataReader) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.AnyDataReaderSeq, L: rti.connextdds.AnyDataReaderSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.AnyDataReaderSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.AnyDataReaderSeq, i: int, x: rti.connextdds.AnyDataReader) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.AnyDataReaderSeq) -> rti.connextdds.AnyDataReader

Remove and return the last item

  1. pop(self: rti.connextdds.AnyDataReaderSeq, i: int) -> rti.connextdds.AnyDataReader

Remove and return the item at index i

remove(self: rti.connextdds.AnyDataReaderSeq, x: rti.connextdds.AnyDataReader) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.AnyDataWriter

Bases: rti.connextdds.IAnyDataWriter

class rti.connextdds.AnyDataWriterListener

Bases: pybind11_builtins.pybind11_object

on_application_acknowledgment(self: rti.connextdds.AnyDataWriterListener, arg0: rti.connextdds.AnyDataWriter, arg1: rti.connextdds.AcknowledgmentInfo) → None

On application acknowledgment callback

on_instance_replaced(self: rti.connextdds.AnyDataWriterListener, arg0: rti.connextdds.AnyDataWriter, arg1: rti.connextdds.InstanceHandle) → None

On instance replaced callback.

on_liveliness_lost(self: rti.connextdds.AnyDataWriterListener, arg0: rti.connextdds.AnyDataWriter, arg1: rti.connextdds.LivelinessLostStatus) → None

Liveliness lost callback.

on_offered_deadline_missed(self: rti.connextdds.AnyDataWriterListener, arg0: rti.connextdds.AnyDataWriter, arg1: rti.connextdds.OfferedDeadlineMissedStatus) → None

Offered deadline missed callback.

on_offered_incompatible_qos(self: rti.connextdds.AnyDataWriterListener, arg0: rti.connextdds.AnyDataWriter, arg1: rti.connextdds.OfferedIncompatibleQosStatus) → None

Offered incompatible QoS callback.

on_publication_matched(self: rti.connextdds.AnyDataWriterListener, arg0: rti.connextdds.AnyDataWriter, arg1: rti.connextdds.PublicationMatchedStatus) → None

Publication matched callback.

on_reliable_reader_activity_changed(self: rti.connextdds.AnyDataWriterListener, arg0: rti.connextdds.AnyDataWriter, arg1: rti.connextdds.ReliableReaderActivityChangedStatus) → None

Reliable reader activity changed callback.

on_reliable_writer_cache_changed(self: rti.connextdds.AnyDataWriterListener, arg0: rti.connextdds.AnyDataWriter, arg1: rti.connextdds.ReliableWriterCacheChangedStatus) → None

Reliable writer cache changed callback.

on_service_request_accepted(self: rti.connextdds.AnyDataWriterListener, arg0: rti.connextdds.AnyDataWriter, arg1: rti.connextdds.ServiceRequestAcceptedStatus) → None

On service request accepted callback.

class rti.connextdds.AnyDataWriterSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.AnyDataWriterSeq, x: rti.connextdds.AnyDataWriter) → None

Add an item to the end of the list

clear(self: rti.connextdds.AnyDataWriterSeq) → None

Clear the contents

count(self: rti.connextdds.AnyDataWriterSeq, x: rti.connextdds.AnyDataWriter) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.AnyDataWriterSeq, L: rti.connextdds.AnyDataWriterSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.AnyDataWriterSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.AnyDataWriterSeq, i: int, x: rti.connextdds.AnyDataWriter) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.AnyDataWriterSeq) -> rti.connextdds.AnyDataWriter

Remove and return the last item

  1. pop(self: rti.connextdds.AnyDataWriterSeq, i: int) -> rti.connextdds.AnyDataWriter

Remove and return the item at index i

remove(self: rti.connextdds.AnyDataWriterSeq, x: rti.connextdds.AnyDataWriter) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.AnyTopic

Bases: pybind11_builtins.pybind11_object

class rti.connextdds.AnyTopicListener

Bases: pybind11_builtins.pybind11_object

on_inconsistent_topic(self: rti.connextdds.AnyTopicListener, arg0: rti.connextdds.AnyTopic, arg1: rti.connextdds.InconsistentTopicStatus) → None

Inconsistent topic callback.

class rti.connextdds.AnyTopicSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.AnyTopicSeq, x: rti.connextdds.AnyTopic) → None

Add an item to the end of the list

clear(self: rti.connextdds.AnyTopicSeq) → None

Clear the contents

count(self: rti.connextdds.AnyTopicSeq, x: rti.connextdds.AnyTopic) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.AnyTopicSeq, L: rti.connextdds.AnyTopicSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.AnyTopicSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.AnyTopicSeq, i: int, x: rti.connextdds.AnyTopic) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.AnyTopicSeq) -> rti.connextdds.AnyTopic

Remove and return the last item

  1. pop(self: rti.connextdds.AnyTopicSeq, i: int) -> rti.connextdds.AnyTopic

Remove and return the item at index i

remove(self: rti.connextdds.AnyTopicSeq, x: rti.connextdds.AnyTopic) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.ArrayType

Bases: rti.connextdds.CollectionType

dimension(self: rti.connextdds.ArrayType, index: int) → int

Returns the size of the ith dimension

property dimension_count

Number of dimensions.

property total_element_count

Total element count across all dimensions.

class rti.connextdds.AsynchronousPublisher

Bases: pybind11_builtins.pybind11_object

property asynchronous_batch_thread

Get/set the settings associated with the asynchronous batch flush thread.

property disable_asynchronous_batch

Get/set the asynchronous batch flushing capability for this policy.

property disable_asynchronous_write

Get/set the asynchronous write capability for this policy.

property disable_topic_query_publication

Get/set the topic query publication capability for this policy.

static disabled()rti.connextdds.AsynchronousPublisher

Create an AsynchronousPublisher QoS policy with asynchronous publication completely disabled.

static enabled(enable_async_batch: bool = False)rti.connextdds.AsynchronousPublisher

Create an AsynchronousPublisher QoS policy with asynchronous write (and optionally asynchronous batch flushing) enabled.

property thread

Get/set the settings associated with the asynchronous publisher thread.

property topic_query_publication_thread

Get/set the settings associated with the topic query publication thread.

class rti.connextdds.Availability

Bases: pybind11_builtins.pybind11_object

property enable_required_subscriptions

Get/set the status of required subscriptions for this policy.

property max_data_availability_waiting_time

Get/set the amount of time to wait before delivering a sample to the application without having received some of the previous samples.

property max_endpoint_availability_waiting_time

Get/set the amount of time to wait to discover DataWriters providing samples for the same data source (virtual GUID).

property required_matched_endpoint_groups

Get/set a copy of the required endpoint groups.

class rti.connextdds.Batch

Bases: pybind11_builtins.pybind11_object

static disabled()rti.connextdds.Batch

Create a Batch policy with batching disabled.

property enable

Get/set boolean that specifies whether batching is enabled.

static enabled()rti.connextdds.Batch

Create a Batch policy with batching enabled.

static enabled_with_max_data_bytes(max_data_bytes: int)rti.connextdds.Batch

Create a Batch policy with batching enabled that will flush based on the cummulative size of serialized samples.

static enabled_with_max_samples(max_samples: int)rti.connextdds.Batch

Create a Batch policy with batching enabled that will flush based on the number of samples written to the batch.

property max_data_bytes

Get/set the maximum cummulative size of serialized samples in a batch. When this limit is reached the batch will be flushed.

property max_flush_delay

Get/set the maximum delay to flush a batch, measured from the time the first sample in the batch is written.

property max_samples

Get/set the maximum number of serialized samples in a batch. When this limit is reached the batch will be flushed.

property source_timestamp_resolution

Get/set the timestamp resolution of the samples in the batch.

property thread_safe_write

Get/set boolean that specifies whether batch writes must be thread safe.

class rti.connextdds.BoolSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.BoolSeq, x: bool) → None

Add an item to the end of the list

clear(self: rti.connextdds.BoolSeq) → None

Clear the contents

count(self: rti.connextdds.BoolSeq, x: bool) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.BoolSeq, L: rti.connextdds.BoolSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.BoolSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.BoolSeq, i: int, x: bool) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.BoolSeq) -> bool

Remove and return the last item

  1. pop(self: rti.connextdds.BoolSeq, i: int) -> bool

Remove and return the item at index i

remove(self: rti.connextdds.BoolSeq, x: bool) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.BoolType

Bases: rti.connextdds.DynamicType

class rti.connextdds.BuiltinProfiles

Bases: pybind11_builtins.pybind11_object

baseline = 'BuiltinQosLib::Baseline'
baseline_5_0_0 = 'BuiltinQosLib::Baseline.5.0.0'
baseline_5_1_0 = 'BuiltinQosLib::Baseline.5.1.0'
baseline_5_2_0 = 'BuiltinQosLib::Baseline.5.2.0'
baseline_5_3_0 = 'BuiltinQosLib::Baseline.5.3.0'
baseline_6_0_0 = 'BuiltinQosLib::Baseline.6.0.0'
generic_auto_tuning = 'BuiltinQosLib::Generic.AutoTuning'
generic_best_effort = 'BuiltinQosLib::Generic.BestEffort'
generic_common = 'BuiltinQosLib::Generic.Common'
generic_connext_micro_compatibility = 'BuiltinQosLib::Generic.ConnextMicroCompatibility'
generic_connext_micro_compatibility_2_4_3 = 'BuiltinQosLib::Generic.ConnextMicroCompatibility.2.4.3'
generic_connext_micro_compatibility_2_4_9 = 'BuiltinQosLib::Generic.ConnextMicroCompatibility.2.4.9'
generic_keep_last_reliable = 'BuiltinQosLib::Generic.KeepLastReliable'
generic_keep_last_reliable_large_data = 'BuiltinQosLib::Generic.KeepLastReliable.LargeData'
generic_keep_last_reliable_large_data_fast_flow = 'BuiltinQosLib::Generic.KeepLastReliable.LargeData.FastFlow'
generic_keep_last_reliable_large_data_medium_flow = 'BuiltinQosLib::Generic.KeepLastReliable.LargeData.MediumFlow'
generic_keep_last_reliable_large_data_slow_flow = 'BuiltinQosLib::Generic.KeepLastReliable.LargeData.SlowFlow'
generic_keep_last_reliable_persistent = 'BuiltinQosLib::Generic.KeepLastReliable.Persistent'
generic_keep_last_reliable_transient = 'BuiltinQosLib::Generic.KeepLastReliable.Transient'
generic_keep_last_reliable_transient_local = 'BuiltinQosLib::Generic.KeepLastReliable.TransientLocal'
generic_minimal_memory_footprint = 'BuiltinQosLib::Generic.MinimalMemoryFootprint'
generic_monitoring_common = 'BuiltinQosLib::Generic.Monitoring.Common'
generic_other_dds_vendor_compatibility = 'BuiltinQosLib::Generic.510TransportCompatibility'
generic_participant_large_data = 'BuiltinQosLib::Generic.Participant.LargeData'
generic_participant_large_data_monitoring = 'BuiltinQosLib::Generic.Participant.LargeData.Monitoring'
generic_security = 'BuiltinQosLib::Generic.Security'
generic_strict_reliable = 'BuiltinQosLib::Generic.StrictReliable'
generic_strict_reliable_high_throughput = 'BuiltinQosLib::Generic.StrictReliable.HighThroughput'
generic_strict_reliable_large_data = 'BuiltinQosLib::Generic.StrictReliable.LargeData'
generic_strict_reliable_large_data_fast_flow = 'BuiltinQosLib::Generic.StrictReliable.LargeData.FastFlow'
generic_strict_reliable_large_data_medium_flow = 'BuiltinQosLib::Generic.StrictReliable.LargeData.MediumFlow'
generic_strict_reliable_large_data_slow_flow = 'BuiltinQosLib::Generic.StrictReliable.LargeData.SlowFlow'
generic_strict_reliable_low_latency = 'BuiltinQosLib::Generic.StrictReliable.LowLatency'
library_name = 'BuiltinQosLib'
pattern_alarm_event = 'BuiltinQosLib::Pattern.AlarmEvent'
pattern_alarm_status = 'BuiltinQosLib::Pattern.AlarmStatus'
pattern_event = 'BuiltinQosLib::Pattern.Event'
pattern_last_value_cache = 'BuiltinQosLib::Pattern.LastValueCache'
pattern_periodic_data = 'BuiltinQosLib::Pattern.PeriodicData'
pattern_reliable_streaming = 'BuiltinQosLib::Pattern.ReliableStreaming'
pattern_status = 'BuiltinQosLib::Pattern.Status'
pattern_streaming = 'BuiltinQosLib::Pattern.Streaming'
class rti.connextdds.BuiltinTopicKey

Bases: pybind11_builtins.pybind11_object

property value

Returns a copy of the four integers that represent the key.

class rti.connextdds.BuiltinTopicReaderResourceLimits

Bases: pybind11_builtins.pybind11_object

property disable_fragmentation_support

Determines whether the DataReader can receive fragmented samples.

property dynamically_allocate_fragmented_samples

Determines whether the DataReader pre-allocates storage for storing fragmented samples.

property initial_fragmented_samples

The initial number of samples for which a DataReader may store fragments.

property initial_infos

Initial number of sample infos.

property initial_outstanding_reads

The initial number of outstanding calls to read/take (or one of their variants) on the same DataReader for which memory has not been returned by calling LoanedSamples.return_loan().

property initial_samples

Initial number of samples

property max_fragmented_samples

The maximum number of samples for which the DataReader may store fragments at a given point in time.

property max_fragments_per_sample

Maximum number of fragments for a single sample.

property max_infos

Maximum number of sample infos.

property max_outstanding_reads

The max number of outstanding calls to read/take (or one of their variants) on the same DataReader for which memory has not been returned by calling LoanedSamples.return_loan().

property max_samples

Maximum number of samples

property max_samples_per_read

The maximum number of data samples that the application can receive from the middleware in a single call to DataReader.read() or DataReader.take(). If more data exists in the middleware, the application will need to issue multiple read/take calls.

class rti.connextdds.ByteVector

Bases: pybind11_builtins.pybind11_object

A DDS standard container with functionality similar to a C++ vector.

clear(self: rti.connextdds.ByteVector) → None

Resize ByteVector to 0.

resize(self: rti.connextdds.ByteVector, size: int) → None

Resize ByteVector.

class rti.connextdds.BytesTopicType

Bases: pybind11_builtins.pybind11_object

class ContentFilter

Bases: rti.connextdds.ContentFilterBase

compile(self: rti.connextdds.BytesTopicType.ContentFilter, expression: str, parameters: rti.connextdds.StringSeq, type_code: Optional[rti.connextdds.DynamicType], type_class_name: str, old_compile_data: Optional[object]) → Optional[object]

Compile an instance of the content filter according to the filter expression and parameters of the given data type.

evaluate(self: rti.connextdds.BytesTopicType.ContentFilter, compile_data: Optional[object], sample: rti.connextdds.BytesTopicType, meta_data: rti.connextdds.FilterSampleInfo) → bool

Evaluate whether the sample is passing the filter or not according to the sample content.

finalize(self: rti.connextdds.BytesTopicType.ContentFilter, compile_data: Optional[object]) → None

A previously compiled instance of the content filter is no longer in use and resources can now be cleaned up.

class ContentFilteredTopic

Bases: rti.connextdds.BytesTopicType.ITopicDescription, rti.connextdds.IAnyTopic

append_to_expression_parameter(self: rti.connextdds.BytesTopicType.ContentFilteredTopic, index: int, extension: str) → None

Append the extension to the end of parameter at the provided index, separated by a comma.

property filter_expression

Get the filter expression

property filter_parameters

Get/set the filter parameters.

remove_from_expression_parameter(self: rti.connextdds.BytesTopicType.ContentFilteredTopic, index: int, remove_term: str) → None

Removes the specified term from the parameter at the provided index.

set_filter(self: rti.connextdds.BytesTopicType.ContentFilteredTopic, arg0: rti.connextdds.Filter) → None

Set the filter.

property topic

Get the underlying Topic.

class ContentFilteredTopicSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.BytesTopicType.ContentFilteredTopicSeq, x: rti.connextdds.BytesTopicType.ContentFilteredTopic) → None

Add an item to the end of the list

clear(self: rti.connextdds.BytesTopicType.ContentFilteredTopicSeq) → None

Clear the contents

count(self: rti.connextdds.BytesTopicType.ContentFilteredTopicSeq, x: rti.connextdds.BytesTopicType.ContentFilteredTopic) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.BytesTopicType.ContentFilteredTopicSeq, L: rti.connextdds.BytesTopicType.ContentFilteredTopicSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.BytesTopicType.ContentFilteredTopicSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.BytesTopicType.ContentFilteredTopicSeq, i: int, x: rti.connextdds.BytesTopicType.ContentFilteredTopic) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.BytesTopicType.ContentFilteredTopicSeq) -> rti.connextdds.BytesTopicType.ContentFilteredTopic

Remove and return the last item

  1. pop(self: rti.connextdds.BytesTopicType.ContentFilteredTopicSeq, i: int) -> rti.connextdds.BytesTopicType.ContentFilteredTopic

Remove and return the item at index i

remove(self: rti.connextdds.BytesTopicType.ContentFilteredTopicSeq, x: rti.connextdds.BytesTopicType.ContentFilteredTopic) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class DataReader

Bases: rti.connextdds.IDataReader

class Selector

Bases: pybind11_builtins.pybind11_object

condition(self: rti.connextdds.BytesTopicType.DataReader.Selector, condition: rti.connextdds.IReadCondition)rti.connextdds.BytesTopicType.DataReader.Selector

Select samples based on a ReadCondition.

content(self: rti.connextdds.BytesTopicType.DataReader.Selector, query: rti.connextdds.Query)rti.connextdds.BytesTopicType.DataReader.Selector

Select samples based on a Query.

instance(self: rti.connextdds.BytesTopicType.DataReader.Selector, handle: rti.connextdds.InstanceHandle)rti.connextdds.BytesTopicType.DataReader.Selector

Select a specific instance to read/take.

max_samples(self: rti.connextdds.BytesTopicType.DataReader.Selector, max: int)rti.connextdds.BytesTopicType.DataReader.Selector

Limit the number of samples read/taken by the Select.

next_instance(self: rti.connextdds.BytesTopicType.DataReader.Selector, previous: rti.connextdds.InstanceHandle)rti.connextdds.BytesTopicType.DataReader.Selector

Select the instance after the specified instance to read/take.

read(self: rti.connextdds.BytesTopicType.DataReader.Selector)rti.connextdds.BytesTopicType.LoanedSamples

Read samples based on Selector settings.

read_valid(self: rti.connextdds.BytesTopicType.DataReader.Selector)rti.connextdds.BytesTopicType.ValidLoanedSamples

Read valid samples based on Selector settings.

state(self: rti.connextdds.BytesTopicType.DataReader.Selector, state: rti.connextdds.DataState)rti.connextdds.BytesTopicType.DataReader.Selector

Select samples with a specified data state.

take(self: rti.connextdds.BytesTopicType.DataReader.Selector)rti.connextdds.BytesTopicType.LoanedSamples

Take samples based on Selector settings.

take_valid(self: rti.connextdds.BytesTopicType.DataReader.Selector)rti.connextdds.BytesTopicType.ValidLoanedSamples

Take valid samples based on Selector settings.

acknowledge_all(*args, **kwargs)

Overloaded function.

  1. acknowledge_all(self: rti.connextdds.BytesTopicType.DataReader) -> None

Acknowledge all previously accessed samples.

  1. acknowledge_all(self: rti.connextdds.BytesTopicType.DataReader, arg0: rti.connextdds.AckResponseData) -> None

Acknowledge all previously accessed samples.

acknowledge_sample(self: rti.connextdds.BytesTopicType.DataReader, sample_info: rti.connextdds.SampleInfo) → None

Acknowledge a single sample.

bind_listener(self: rti.connextdds.BytesTopicType.DataReader, listener: Optional[rti.connextdds.BytesTopicType.DataReaderListener], event_mask: rti.connextdds.StatusMask) → None

Set the listener and associated event mask.

close(self: rti.connextdds.BytesTopicType.DataReader) → None

Close this DataReader.

property datareader_cache_status

Get the DataReaderCacheStatus for the DataReader.

property datareader_protocol_status

Get the DataReaderProtocolStatus for the DataReader.

property default_filter_state

Returns the filter state for the read/take operations.

static find_all_by_topic(subscriber: rti.connextdds.Subscriber, topic_name: str)rti.connextdds.BytesTopicType.DataReaderSeq

Retrieve all DataReaders for the given topic name in the subscriber.

static find_by_name(*args, **kwargs)

Overloaded function.

  1. find_by_name(participant: rti.connextdds.DomainParticipant, name: str) -> Optional[rti.connextdds.BytesTopicType.DataReader]

Find DataReader in DomainParticipant with the DataReader’s name, returning the first found.

  1. find_by_name(subscriber: rti.connextdds.Subscriber, name: str) -> Optional[rti.connextdds.BytesTopicType.DataReader]

Find DataReader in Subscriber with the DataReader’s name, returning the first found.

static find_by_topic(subscriber: rti.connextdds.Subscriber, name: str) → Optional[rti.connextdds.BytesTopicType.DataReader]

Find DataReader in Subscriber with a topic name, returning the first found.

is_data_consistent(*args, **kwargs)

Overloaded function.

  1. is_data_consistent(self: rti.connextdds.BytesTopicType.DataReader, sample_data: rti.connextdds.BytesTopicType, sample_info: rti.connextdds.SampleInfo) -> bool

Checks if the sample has been overwritten by the DataWriter.

  1. is_data_consistent(self: rti.connextdds.BytesTopicType.DataReader, sample: rti.connextdds.BytesTopicType.Sample) -> bool

Checks if the sample has been overwritten by the DataWriter.

  1. is_data_consistent(self: rti.connextdds.BytesTopicType.DataReader, sample: rti.connextdds.BytesTopicType.LoanedSample) -> bool

Checks if the sample has been overwritten by the DataWriter.

key_value(self: rti.connextdds.BytesTopicType.DataReader, handle: rti.connextdds.InstanceHandle)rti.connextdds.BytesTopicType

Retrieve the instance key that corresponds to an instance handle.

property listener

Get the listener object.

property liveliness_changed_status

Get the LivelinessChangedStatus for this DataReader.

matched_publication_datareader_protocol_status(self: rti.connextdds.BytesTopicType.DataReader, publication_handle: rti.connextdds.InstanceHandle)rti.connextdds.DataReaderProtocolStatus

Get the DataReaderProtocolStatus for the DataReader based on the matched publication handle.

property qos

The DataReaderQos for this DataReader.

This property’s getter returns a deep copy.

read(self: rti.connextdds.BytesTopicType.DataReader)rti.connextdds.BytesTopicType.LoanedSamples

Read all samples using the default filter state

read_next(self: rti.connextdds.BytesTopicType.DataReader) → Optional[rti.connextdds.BytesTopicType.Sample]

Copy the next not-previously-accessed data value from the DataReader via a read operation.

read_valid(self: rti.connextdds.BytesTopicType.DataReader)rti.connextdds.BytesTopicType.ValidLoanedSamples

Read only valid samples.

property requested_deadline_missed_status

Get the RequestedDeadlineMissed status for the DataReader

property requested_incompatible_qos_status

Get the RequestedIncompatibleQosStatus for the DataReader.

property sample_lost_status

Get the SampleLostStatus for the DataReader.

property sample_rejected_status

Get the SampleRejectedStatus for the DataReader.

select(self: rti.connextdds.BytesTopicType.DataReader)rti.connextdds.BytesTopicType.DataReader.Selector

Get a Selector to perform complex data selections, such as per-instance selection, content, and status filtering.

property subscriber

Returns the parent Subscriber of the DataReader.

property subscription_matched_status

Get the SubscriptionMatchedStatus for the DataReader.

take(self: rti.connextdds.BytesTopicType.DataReader)rti.connextdds.BytesTopicType.LoanedSamples

Take all samples using the default filter state

take_next(self: rti.connextdds.BytesTopicType.DataReader) → Optional[rti.connextdds.BytesTopicType.Sample]

Copy the next not-previously-accessed data value from the DataReader via a take operation.

take_valid(self: rti.connextdds.BytesTopicType.DataReader)rti.connextdds.BytesTopicType.ValidLoanedSamples

Take only valid samples.

property topic_description

Returns the TopicDescription associated with the DataReader.

topic_instance_key_value(self: rti.connextdds.BytesTopicType.DataReader, handle: rti.connextdds.InstanceHandle)rti.connextdds.BytesTopicType.TopicInstance

Retrieve the instance key that corresponds to an instance handle.

property topic_name

Get the topic name associated with this DataReader.

property type_name

Get the type name associated with this DataReader.

wait_for_historical_data(self: rti.connextdds.BytesTopicType.DataReader, max_wait: rti.connextdds.Duration) → None

Waits until all “historical” data is received for DataReaders that have a non-VOLATILE Durability Qos kind.

wait_for_historical_data_async(self: rti.connextdds.BytesTopicType.DataReader, max_wait: rti.connextdds.Duration) → object

Waits until all “historical” data is received for DataReaders that have a non-VOLATILE Durability Qos kind. This call is awaitable and only for use with asyncio.

class DataReaderListener

Bases: pybind11_builtins.pybind11_object

on_data_available(self: rti.connextdds.BytesTopicType.DataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader) → None

Data available callback.

on_liveliness_changed(self: rti.connextdds.BytesTopicType.DataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.LivelinessChangedStatus) → None

Liveliness changed callback.

on_requested_deadline_missed(self: rti.connextdds.BytesTopicType.DataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.RequestedDeadlineMissedStatus) → None

Requested deadline missed callback.

on_requested_incompatible_qos(self: rti.connextdds.BytesTopicType.DataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.RequestedIncompatibleQosStatus) → None

Requested incompatible QoS callback.

on_sample_lost(self: rti.connextdds.BytesTopicType.DataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.SampleLostStatus) → None

Sample lost callback.

on_sample_rejected(self: rti.connextdds.BytesTopicType.DataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.SampleRejectedStatus) → None

Sample rejected callback.

on_subscription_matched(self: rti.connextdds.BytesTopicType.DataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.SubscriptionMatchedStatus) → None

Subscription matched callback.

class DataReaderSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.BytesTopicType.DataReaderSeq, x: rti.connextdds.BytesTopicType.DataReader) → None

Add an item to the end of the list

clear(self: rti.connextdds.BytesTopicType.DataReaderSeq) → None

Clear the contents

count(self: rti.connextdds.BytesTopicType.DataReaderSeq, x: rti.connextdds.BytesTopicType.DataReader) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.BytesTopicType.DataReaderSeq, L: rti.connextdds.BytesTopicType.DataReaderSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.BytesTopicType.DataReaderSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.BytesTopicType.DataReaderSeq, i: int, x: rti.connextdds.BytesTopicType.DataReader) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.BytesTopicType.DataReaderSeq) -> rti.connextdds.BytesTopicType.DataReader

Remove and return the last item

  1. pop(self: rti.connextdds.BytesTopicType.DataReaderSeq, i: int) -> rti.connextdds.BytesTopicType.DataReader

Remove and return the item at index i

remove(self: rti.connextdds.BytesTopicType.DataReaderSeq, x: rti.connextdds.BytesTopicType.DataReader) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class DataWriter

Bases: rti.connextdds.IEntity, rti.connextdds.IAnyDataWriter

assert_liveliness(self: rti.connextdds.BytesTopicType.DataWriter) → None

Manually asserts the liveliness of the DataWriter.

bind_listener(self: rti.connextdds.BytesTopicType.DataWriter, listener: Optional[rti.connextdds.BytesTopicType.DataWriterListener], event_mask: rti.connextdds.StatusMask) → None

Set the listener and event mask for the DataWriter.

create_data(self: rti.connextdds.BytesTopicType.DataWriter)rti.connextdds.BytesTopicType

Create data of the writer’s associated type and initialize it.

property datawriter_cache_status

Get a copy of the cache status for this writer.

property datawriter_protocol_status

Get a copy of the protocol status for this writer.

dispose_instance(*args, **kwargs)

Overloaded function.

  1. dispose_instance(self: rti.connextdds.BytesTopicType.DataWriter, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.BytesTopicType.DataWriter

Dispose an instance.

  1. dispose_instance(self: rti.connextdds.BytesTopicType.DataWriter, handle: rti.connextdds.InstanceHandle, timestamp: rti.connextdds.Time) -> rti.connextdds.BytesTopicType.DataWriter

Dispose an instance with a timestamp.

  1. dispose_instance(self: rti.connextdds.BytesTopicType.DataWriter, key_holder: rti.connextdds.BytesTopicType) -> rti.connextdds.BytesTopicType.DataWriter

Dispose the instance associated with key_holder.

  1. dispose_instance(self: rti.connextdds.BytesTopicType.DataWriter, key_holder: rti.connextdds.BytesTopicType, timestamp: rti.connextdds.Time) -> rti.connextdds.BytesTopicType.DataWriter

Dispose the instance associated with key_holder using a timestamp

  1. dispose_instance(self: rti.connextdds.BytesTopicType.DataWriter, params: rti.connextdds.WriteParams) -> None

Dispose an instance with params.

static find_all_by_topic(publisher: rti.connextdds.Publisher, topic_name: str)rti.connextdds.BytesTopicType.DataWriterSeq

Retrieve all DataWriters for the given topic name in the publisher.

static find_by_name(*args, **kwargs)

Overloaded function.

  1. find_by_name(participant: rti.connextdds.DomainParticipant, name: str) -> Optional[rti.connextdds.BytesTopicType.DataWriter]

Find DataWriter in DomainParticipant with the provided name, returning the first found.

  1. find_by_name(publisher: rti.connextdds.Publisher, name: str) -> Optional[rti.connextdds.BytesTopicType.DataWriter]

Find DataWriter in Publisher with the DataReader’s name, returning the first found.

static find_by_topic(publisher: rti.connextdds.Publisher, name: str) → Optional[rti.connextdds.BytesTopicType.DataWriter]

Find DataWriter in publisher with a topic name, returning the first found.

flush(self: rti.connextdds.BytesTopicType.DataWriter) → None

Flushes the batch in progress in the context of the calling thread.

is_sample_app_acknowledged(self: rti.connextdds.BytesTopicType.DataWriter, sample_id: rti.connextdds.SampleIdentity) → bool

Indicates if a sample is considered application-acknowledged.

key_value(*args, **kwargs)

Overloaded function.

  1. key_value(self: rti.connextdds.BytesTopicType.DataWriter, key_holder: rti.connextdds.BytesTopicType, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.BytesTopicType

Retrieve the instance key that corresponds to an instance handle.

  1. key_value(self: rti.connextdds.BytesTopicType.DataWriter, topic_instance: rti.connextdds.BytesTopicType.TopicInstance, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.BytesTopicType.TopicInstance

Retrieve the instance key that corresponds to an instance handle.

  1. key_value(self: rti.connextdds.BytesTopicType.DataWriter, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.BytesTopicType

Retrieve the instance key that corresponds to an instance handle.

property listener

Get the listener associated with the DataWriter or set the listener and status mask as a tuple.

property liveliness_lost_status

Get a copy of the LivelinessLostStatus.

lookup_instance(self: rti.connextdds.BytesTopicType.DataWriter, key_holder: rti.connextdds.BytesTopicType)rti.connextdds.InstanceHandle

Retrieve the instance handle that corresponds to an instance key_holder

matched_subscription_data(self: rti.connextdds.BytesTopicType.DataWriter, handle: rti.connextdds.InstanceHandle)rti.connextdds.SubscriptionBuiltinTopicData

Get the SubscriptionBuiltinTopicData for a subscription matched to this DataWriter.

matched_subscription_datawriter_procotol_status(*args, **kwargs)

Overloaded function.

  1. matched_subscription_datawriter_procotol_status(self: rti.connextdds.BytesTopicType.DataWriter, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.DataWriterProtocolStatus

Get a copy of the protocol status for this writer per a matched subscription handle.

  1. matched_subscription_datawriter_procotol_status(self: rti.connextdds.BytesTopicType.DataWriter, locator: rti.connextdds.Locator) -> rti.connextdds.DataWriterProtocolStatus

Get a copy of the protocol status for this writer per a matched subscription locator.

property matched_subscriptions

Get a copy of the list of the currently matched subscription handles.

property offered_deadline_missed_status

Get a copy of the OfferedDeadlineMissedStatus.

property offered_incompatible_qos_status

Get a copy of the OfferedIncompatibleQosStatus

property publication_matched_status

Get a copy of the PublicationMatchedStatus

property publisher

Get the Publisher that owns this DataWriter.

property qos

The DataWriterQos for this DataWriter.

This property’s getter returns a deep copy.

register_instance(*args, **kwargs)

Overloaded function.

  1. register_instance(self: rti.connextdds.BytesTopicType.DataWriter, handle: rti.connextdds.BytesTopicType) -> rti.connextdds.InstanceHandle

Informs RTI Connext that the application will be modifying a particular instance.

  1. register_instance(self: rti.connextdds.BytesTopicType.DataWriter, handle: rti.connextdds.BytesTopicType, timestamp: rti.connextdds.Time) -> rti.connextdds.InstanceHandle

Informs RTI Connext that the application will be modifying a particular instance and specified the timestamp.

  1. register_instance(self: rti.connextdds.BytesTopicType.DataWriter, key_holder: rti.connextdds.BytesTopicType, params: rti.connextdds.WriteParams) -> None

Registers instance with parameters.

property reliable_reader_activity_changed_status

Get a copy of the reliable reader activity changed status for this writer.

property reliable_writer_cache_changed_status

Get a copy of the reliable cache status for this writer.

property service_request_accepted_status

Get a copy of the service request accepted status for this writer.

property topic

Get the Topic object associated with this DataWriter.

topic_instance_key_value(self: rti.connextdds.BytesTopicType.DataWriter, handle: rti.connextdds.InstanceHandle)rti.connextdds.BytesTopicType.TopicInstance

Retrieve the instance key that corresponds to an instance handle.

property topic_name

Get the topic name associated with this DataWriter.

property type_name

Get the type name for the topic object associated with this DataWriter.

unregister_instance(*args, **kwargs)

Overloaded function.

  1. unregister_instance(self: rti.connextdds.BytesTopicType.DataWriter, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.BytesTopicType.DataWriter

Unregister an instance.

  1. unregister_instance(self: rti.connextdds.BytesTopicType.DataWriter, handle: rti.connextdds.InstanceHandle, timestamp: rti.connextdds.Time) -> rti.connextdds.BytesTopicType.DataWriter

Unregister an instance with timestamp.

  1. unregister_instance(self: rti.connextdds.BytesTopicType.DataWriter, key_holder: rti.connextdds.BytesTopicType) -> rti.connextdds.BytesTopicType.DataWriter

Unregister the instance associated with key_holder.

  1. unregister_instance(self: rti.connextdds.BytesTopicType.DataWriter, key_holder: rti.connextdds.BytesTopicType, timestamp: rti.connextdds.Time) -> rti.connextdds.BytesTopicType.DataWriter

Unregister the instance associate with key_holder using a timestamp.

  1. unregister_instance(self: rti.connextdds.BytesTopicType.DataWriter, params: rti.connextdds.WriteParams) -> None

Unregister an instance with parameters.

wait_for_acknowledgments(self: rti.connextdds.BytesTopicType.DataWriter, max_wait: rti.connextdds.Duration) → None

Blocks the calling thread until all data written by a realiable DataWriter is acknowledged or until the timeout expires.

wait_for_asynchronous_publishing(self: rti.connextdds.BytesTopicType.DataWriter, max_wait: rti.connextdds.Duration) → None

This operation blocks the calling thread (up to max_wait) until all data written by the asynchronous DataWriter is sent and acknowledged (if reliable) by all matched DataReader entities. A successful completion indicates that all the samples written have been sent and acknowledged where applicable; a time out indicates that max_wait elapsed before all the data was sent and/or acknowledged.

In other words, this guarantees that sending to best effort DataReader is complete in addition to what DataWriter.wait_for_acknowledgments() provides.

If the DataWriter does not have PublishMode kind set to PublishModeKind.ASYNCHRONOUS the operation will complete immediately

write(*args, **kwargs)

Overloaded function.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, sample: rti.connextdds.BytesTopicType) -> None

Write a sample.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, sample: rti.connextdds.BytesTopicType, timestamp: rti.connextdds.Time) -> None

Write a sample with a specified timestamp.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, sample: rti.connextdds.BytesTopicType, handle: rti.connextdds.InstanceHandle) -> None

Write a sample with an instance handle.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, sample: rti.connextdds.BytesTopicType, handle: rti.connextdds.InstanceHandle, timestamp: rti.connextdds.Time) -> None

Write a sample with an instance handle and specified timestamp.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, topic_instance: rti.connextdds.BytesTopicType.TopicInstance) -> None

Write a sample given a topic instance.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, topic_instance: rti.connextdds.BytesTopicType.TopicInstance, timestamp: rti.connextdds.Time) -> None

Write a sample given a topic instance and specified timestamp.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, samples: rti.connextdds.BytesTopicTypeSeq) -> None

Write a sequence of samples.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, topic_instances: rti.connextdds.BytesTopicType.TopicInstanceSeq) -> None

Write a sequence of topic instances.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, samples: rti.connextdds.BytesTopicTypeSeq, timestamp: rti.connextdds.Time) -> None

Write a sequence of samples with a timestamp.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, topic_instances: rti.connextdds.BytesTopicType.TopicInstanceSeq, timestamp: rti.connextdds.Time) -> None

Write a sequence of topic instances with a timestamp.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, samples: rti.connextdds.BytesTopicTypeSeq, handles: rti.connextdds.InstanceHandleSeq) -> None

Write a sequence of samples with their instance handles.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, samples: rti.connextdds.BytesTopicTypeSeq, handles: rti.connextdds.InstanceHandleSeq, timestamp: rti.connextdds.Time) -> None

Write a sequence of samples with their instance handles and a timestamp.

  1. write(self: rti.connextdds.BytesTopicType.DataWriter, sample: rti.connextdds.BytesTopicType, params: rti.connextdds.WriteParams) -> None

Write with advanced parameters.

write_async(*args, **kwargs)

Overloaded function.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, sample: rti.connextdds.BytesTopicType) -> object

Write a sample. This method is awaitable and is only for use with asyncio.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, sample: rti.connextdds.BytesTopicType, timestamp: rti.connextdds.Time) -> object

Write a sample with a specified timestamp. This methods is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, sample: rti.connextdds.BytesTopicType, handle: rti.connextdds.InstanceHandle) -> object

Write a sample with an instance handle. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, sample: rti.connextdds.BytesTopicType, handle: rti.connextdds.InstanceHandle, timestamp: rti.connextdds.Time) -> object

Write a sample with an instance handle and specified timestamp. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, topic_instance: rti.connextdds.BytesTopicType.TopicInstance) -> object

Write a sample given a topic instance. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, topic_instance: rti.connextdds.BytesTopicType.TopicInstance, timestamp: rti.connextdds.Time) -> object

Write a sample given a topic instance and specified timestamp. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, samples: rti.connextdds.BytesTopicTypeSeq) -> object

Write a sequence of samples. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, topic_instances: rti.connextdds.BytesTopicType.TopicInstanceSeq) -> object

Write a sequence of topic instances. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, samples: rti.connextdds.BytesTopicTypeSeq, timestamp: rti.connextdds.Time) -> object

Write a sequence of samples with a timestamp. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, topic_instances: rti.connextdds.BytesTopicType.TopicInstanceSeq, timestamp: rti.connextdds.Time) -> object

Write a sequence of topic instances with a timestamp. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, samples: rti.connextdds.BytesTopicTypeSeq, handles: rti.connextdds.InstanceHandleSeq) -> object

Write a sequence of samples with their instance handles. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.BytesTopicType.DataWriter, samples: rti.connextdds.BytesTopicTypeSeq, handles: rti.connextdds.InstanceHandleSeq, timestamp: rti.connextdds.Time) -> object

Write a sequence of samples with their instance handles and a timestamp. This method is awaitable and only for use with asyncio.

class DataWriterListener

Bases: pybind11_builtins.pybind11_object

on_application_acknowledgment(self: rti.connextdds.BytesTopicType.DataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.AcknowledgmentInfo) → None

On application acknowledgment callback

on_instance_replaced(self: rti.connextdds.BytesTopicType.DataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.InstanceHandle) → None

On instance replaced callback.

on_liveliness_lost(self: rti.connextdds.BytesTopicType.DataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.LivelinessLostStatus) → None

Liveliness lost callback.

on_offered_deadline_missed(self: rti.connextdds.BytesTopicType.DataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.OfferedDeadlineMissedStatus) → None

Offered deadline missed callback.

on_offered_incompatible_qos(self: rti.connextdds.BytesTopicType.DataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.OfferedIncompatibleQosStatus) → None

Offered incompatible QoS callback.

on_publication_matched(self: rti.connextdds.BytesTopicType.DataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.PublicationMatchedStatus) → None

Publication matched callback.

on_reliable_reader_activity_changed(self: rti.connextdds.BytesTopicType.DataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.ReliableReaderActivityChangedStatus) → None

Reliable reader activity changed callback.

on_reliable_writer_cache_changed(self: rti.connextdds.BytesTopicType.DataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.ReliableWriterCacheChangedStatus) → None

Reliable writer cache changed callback.

on_service_request_accepted(self: rti.connextdds.BytesTopicType.DataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.ServiceRequestAcceptedStatus) → None

On service request accepted callback.

class DataWriterSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.BytesTopicType.DataWriterSeq, x: rti.connextdds.BytesTopicType.DataWriter) → None

Add an item to the end of the list

clear(self: rti.connextdds.BytesTopicType.DataWriterSeq) → None

Clear the contents

count(self: rti.connextdds.BytesTopicType.DataWriterSeq, x: rti.connextdds.BytesTopicType.DataWriter) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.BytesTopicType.DataWriterSeq, L: rti.connextdds.BytesTopicType.DataWriterSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.BytesTopicType.DataWriterSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.BytesTopicType.DataWriterSeq, i: int, x: rti.connextdds.BytesTopicType.DataWriter) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.BytesTopicType.DataWriterSeq) -> rti.connextdds.BytesTopicType.DataWriter

Remove and return the last item

  1. pop(self: rti.connextdds.BytesTopicType.DataWriterSeq, i: int) -> rti.connextdds.BytesTopicType.DataWriter

Remove and return the item at index i

remove(self: rti.connextdds.BytesTopicType.DataWriterSeq, x: rti.connextdds.BytesTopicType.DataWriter) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class ITopicDescription

Bases: rti.connextdds.IEntity

property name

The name of the entity conforming to the ITopicDescription interface.

property participant

The parent DomainParticipant.

property type_name

The name of the associated type.

class LoanedSample

Bases: pybind11_builtins.pybind11_object

property data

Get the data associated with the sample.

property info

Get the info associated with the sample.

class LoanedSamples

Bases: pybind11_builtins.pybind11_object

property length

Get the number of samples in the loan.

return_loan(self: rti.connextdds.BytesTopicType.LoanedSamples) → None

Returns the loan to the DataReader.

class NoOpDataReaderListener

Bases: rti.connextdds.BytesTopicType.DataReaderListener

on_data_available(self: rti.connextdds.BytesTopicType.NoOpDataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader) → None

Data available callback.

on_liveliness_changed(self: rti.connextdds.BytesTopicType.NoOpDataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.LivelinessChangedStatus) → None

Liveliness changed callback.

on_requested_deadline_missed(self: rti.connextdds.BytesTopicType.NoOpDataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.RequestedDeadlineMissedStatus) → None

Requested deadline missed callback.

on_requested_incompatible_qos(self: rti.connextdds.BytesTopicType.NoOpDataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.RequestedIncompatibleQosStatus) → None

Requested incompatible QoS callback.

on_sample_lost(self: rti.connextdds.BytesTopicType.NoOpDataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.SampleLostStatus) → None

Sample lost callback.

on_sample_rejected(self: rti.connextdds.BytesTopicType.NoOpDataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.SampleRejectedStatus) → None

Sample rejected callback.

on_subscription_matched(self: rti.connextdds.BytesTopicType.NoOpDataReaderListener, arg0: rti.connextdds.BytesTopicType.DataReader, arg1: rti.connextdds.SubscriptionMatchedStatus) → None

Subscription matched callback.

class NoOpDataWriterListener

Bases: rti.connextdds.BytesTopicType.DataWriterListener

on_application_acknowledgment(self: rti.connextdds.BytesTopicType.NoOpDataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.AcknowledgmentInfo) → None

On application acknowledgment callback

on_instance_replaced(self: rti.connextdds.BytesTopicType.NoOpDataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.InstanceHandle) → None

On instance replaced callback.

on_liveliness_lost(self: rti.connextdds.BytesTopicType.NoOpDataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.LivelinessLostStatus) → None

Liveliness lost callback.

on_offered_deadline_missed(self: rti.connextdds.BytesTopicType.NoOpDataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.OfferedDeadlineMissedStatus) → None

Offered deadline missed callback.

on_offered_incompatible_qos(self: rti.connextdds.BytesTopicType.NoOpDataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.OfferedIncompatibleQosStatus) → None

Offered incompatible QoS callback.

on_publication_matched(self: rti.connextdds.BytesTopicType.NoOpDataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.PublicationMatchedStatus) → None

Publication matched callback.

on_reliable_reader_activity_changed(self: rti.connextdds.BytesTopicType.NoOpDataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.ReliableReaderActivityChangedStatus) → None

Reliable reader activity changed callback.

on_reliable_writer_cache_changed(self: rti.connextdds.BytesTopicType.NoOpDataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.ReliableWriterCacheChangedStatus) → None

Reliable writer cache changed callback.

on_service_request_accepted(self: rti.connextdds.BytesTopicType.NoOpDataWriterListener, arg0: rti.connextdds.BytesTopicType.DataWriter, arg1: rti.connextdds.ServiceRequestAcceptedStatus) → None

On service request accepted callback.

class NoOpTopicListener

Bases: rti.connextdds.BytesTopicType.TopicListener

on_inconsistent_topic(self: rti.connextdds.BytesTopicType.NoOpTopicListener, arg0: rti.connextdds.BytesTopicType.Topic, arg1: rti.connextdds.InconsistentTopicStatus) → None

Inconsistent topic callback.

class Sample

Bases: pybind11_builtins.pybind11_object

property data

The data associated with the sample.

property info

Get the info associated with the sample.

class SharedSamples

Bases: pybind11_builtins.pybind11_object

unpack(self: rti.connextdds.BytesTopicType.SharedSamples) → List[rti.connextdds.BytesTopicType]

Unpacks all samples into a list.

class Topic

Bases: rti.connextdds.BytesTopicType.ITopicDescription, rti.connextdds.IAnyTopic

bind_listener(self: rti.connextdds.BytesTopicType.Topic, listener: Optional[rti.connextdds.BytesTopicType.TopicListener], event_mask: rti.connextdds.StatusMask) → None

Set the listener and event mask.

static find(participant: rti.connextdds.DomainParticipant, name: str) → Optional[rti.connextdds.BytesTopicType.Topic]

Look up a Topic by its name in the DomainParticipant.

property inconsistent_topic_status

Get a copy of the current InconsistentTopicStatus for this Topic.

property listener

The listener.

property qos

Get the TopicQos for this Topic.

This property’s getter returns a deep copy.

class TopicDescription

Bases: rti.connextdds.BytesTopicType.ITopicDescription

class TopicInstance

Bases: pybind11_builtins.pybind11_object

property handle

Get/set the instance handle associated with this TopicInstance.

property sample

Get/set the sample associated with this TopicInstance.

class TopicInstanceSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.BytesTopicType.TopicInstanceSeq, x: rti.connextdds.BytesTopicType.TopicInstance) → None

Add an item to the end of the list

clear(self: rti.connextdds.BytesTopicType.TopicInstanceSeq) → None

Clear the contents

count(self: rti.connextdds.BytesTopicType.TopicInstanceSeq, x: rti.connextdds.BytesTopicType.TopicInstance) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.BytesTopicType.TopicInstanceSeq, L: rti.connextdds.BytesTopicType.TopicInstanceSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.BytesTopicType.TopicInstanceSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.BytesTopicType.TopicInstanceSeq, i: int, x: rti.connextdds.BytesTopicType.TopicInstance) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.BytesTopicType.TopicInstanceSeq) -> rti.connextdds.BytesTopicType.TopicInstance

Remove and return the last item

  1. pop(self: rti.connextdds.BytesTopicType.TopicInstanceSeq, i: int) -> rti.connextdds.BytesTopicType.TopicInstance

Remove and return the item at index i

remove(self: rti.connextdds.BytesTopicType.TopicInstanceSeq, x: rti.connextdds.BytesTopicType.TopicInstance) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class TopicInstanceTimestampedSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.BytesTopicType.TopicInstanceTimestampedSeq, x: Tuple[rti.connextdds.BytesTopicType.TopicInstance, rti.connextdds.Time]) → None

Add an item to the end of the list

clear(self: rti.connextdds.BytesTopicType.TopicInstanceTimestampedSeq) → None

Clear the contents

count(self: rti.connextdds.BytesTopicType.TopicInstanceTimestampedSeq, x: Tuple[rti.connextdds.BytesTopicType.TopicInstance, rti.connextdds.Time]) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.BytesTopicType.TopicInstanceTimestampedSeq, L: rti.connextdds.BytesTopicType.TopicInstanceTimestampedSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.BytesTopicType.TopicInstanceTimestampedSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.BytesTopicType.TopicInstanceTimestampedSeq, i: int, x: Tuple[rti.connextdds.BytesTopicType.TopicInstance, rti.connextdds.Time]) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.BytesTopicType.TopicInstanceTimestampedSeq) -> Tuple[rti.connextdds.BytesTopicType.TopicInstance, rti.connextdds.Time]

Remove and return the last item

  1. pop(self: rti.connextdds.BytesTopicType.TopicInstanceTimestampedSeq, i: int) -> Tuple[rti.connextdds.BytesTopicType.TopicInstance, rti.connextdds.Time]

Remove and return the item at index i

remove(self: rti.connextdds.BytesTopicType.TopicInstanceTimestampedSeq, x: Tuple[rti.connextdds.BytesTopicType.TopicInstance, rti.connextdds.Time]) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class TopicListener

Bases: pybind11_builtins.pybind11_object

on_inconsistent_topic(self: rti.connextdds.BytesTopicType.TopicListener, arg0: rti.connextdds.BytesTopicType.Topic, arg1: rti.connextdds.InconsistentTopicStatus) → None

Inconsistent topic callback.

class TopicSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.BytesTopicType.TopicSeq, x: rti.connextdds.BytesTopicType.Topic) → None

Add an item to the end of the list

clear(self: rti.connextdds.BytesTopicType.TopicSeq) → None

Clear the contents

count(self: rti.connextdds.BytesTopicType.TopicSeq, x: rti.connextdds.BytesTopicType.Topic) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.BytesTopicType.TopicSeq, L: rti.connextdds.BytesTopicType.TopicSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.BytesTopicType.TopicSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.BytesTopicType.TopicSeq, i: int, x: rti.connextdds.BytesTopicType.Topic) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.BytesTopicType.TopicSeq) -> rti.connextdds.BytesTopicType.Topic

Remove and return the last item

  1. pop(self: rti.connextdds.BytesTopicType.TopicSeq, i: int) -> rti.connextdds.BytesTopicType.Topic

Remove and return the item at index i

remove(self: rti.connextdds.BytesTopicType.TopicSeq, x: rti.connextdds.BytesTopicType.Topic) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class ValidLoanedSamples

Bases: pybind11_builtins.pybind11_object

class WriterContentFilter

Bases: rti.connextdds.BytesTopicType.ContentFilter

writer_attach(self: rti.connextdds.BytesTopicType.WriterContentFilter) → Optional[object]

A writer-side filtering API to create some state that can facilitate filtering on the writer side.

writer_compile(self: rti.connextdds.BytesTopicType.WriterContentFilter, writer_filter_data: Optional[object], property: rti.connextdds.ExpressionProperty, expression: str, parameters: rti.connextdds.StringSeq, type_code: Optional[rti.connextdds.DynamicType], type_class_name: str, cookie: rti.connextdds.Cookie) → None

A writer-side filtering API to compile an instance of the content filter according to the filter expression and parameters specified by a matching DataReader.

writer_detach(self: rti.connextdds.BytesTopicType.WriterContentFilter, writer_filter_data: Optional[object]) → None

A writer-side filtering API to clean up a previously created state using writer_attach.

writer_evaluate(self: rti.connextdds.BytesTopicType.WriterContentFilter, writer_filter_data: Optional[object], sample: rti.connextdds.BytesTopicType, meta_data: rti.connextdds.FilterSampleInfo)rti.connextdds.CookieVector

A writer-side filtering API to compile an instance of the content filter according to the filter expression and parameters specified by a matching DataReader.

writer_finalize(self: rti.connextdds.BytesTopicType.WriterContentFilter, writer_filter_data: Optional[object], cookie: rti.connextdds.Cookie) → None

A writer-side filtering API to clean up a previously compiled instance of the content filter.

writer_return_loan(self: rti.connextdds.BytesTopicType.WriterContentFilter, writer_filter_data: Optional[object], cookies: rti.connextdds.CookieVector) → None

A writer-side filtering API to return the loan on the list of DataReaders returned by writer_evaluate.

class WriterContentFilterHelper

Bases: rti.connextdds.BytesTopicType.WriterContentFilter

A helper function which will add a Cookie to the Cookie sequence that is then returned by the writer_evaluate function.

writer_evaluate_helper(self: rti.connextdds.BytesTopicType.WriterContentFilterHelper, writer_filter_data: Optional[object], sample: rti.connextdds.BytesTopicType, meta_data: rti.connextdds.FilterSampleInfo) → None

A writer-side filtering API to compile an instance of the content filter according to the filter expression and parameters specified by a matching DataReader.

property data

The byte sequence.

This property’s getter returns a deep copy.

length(self: rti.connextdds.BytesTopicType) → int

Get the number of bytes.

class rti.connextdds.BytesTopicTypeSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.BytesTopicTypeSeq, x: rti.connextdds.BytesTopicType) → None

Add an item to the end of the list

clear(self: rti.connextdds.BytesTopicTypeSeq) → None

Clear the contents

count(self: rti.connextdds.BytesTopicTypeSeq, x: rti.connextdds.BytesTopicType) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.BytesTopicTypeSeq, L: rti.connextdds.BytesTopicTypeSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.BytesTopicTypeSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.BytesTopicTypeSeq, i: int, x: rti.connextdds.BytesTopicType) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.BytesTopicTypeSeq) -> rti.connextdds.BytesTopicType

Remove and return the last item

  1. pop(self: rti.connextdds.BytesTopicTypeSeq, i: int) -> rti.connextdds.BytesTopicType

Remove and return the item at index i

remove(self: rti.connextdds.BytesTopicTypeSeq, x: rti.connextdds.BytesTopicType) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.BytesTopicTypeTimestampedSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.BytesTopicTypeTimestampedSeq, x: Tuple[rti.connextdds.BytesTopicType, rti.connextdds.Time]) → None

Add an item to the end of the list

clear(self: rti.connextdds.BytesTopicTypeTimestampedSeq) → None

Clear the contents

count(self: rti.connextdds.BytesTopicTypeTimestampedSeq, x: Tuple[rti.connextdds.BytesTopicType, rti.connextdds.Time]) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.BytesTopicTypeTimestampedSeq, L: rti.connextdds.BytesTopicTypeTimestampedSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.BytesTopicTypeTimestampedSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.BytesTopicTypeTimestampedSeq, i: int, x: Tuple[rti.connextdds.BytesTopicType, rti.connextdds.Time]) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.BytesTopicTypeTimestampedSeq) -> Tuple[rti.connextdds.BytesTopicType, rti.connextdds.Time]

Remove and return the last item

  1. pop(self: rti.connextdds.BytesTopicTypeTimestampedSeq, i: int) -> Tuple[rti.connextdds.BytesTopicType, rti.connextdds.Time]

Remove and return the item at index i

remove(self: rti.connextdds.BytesTopicTypeTimestampedSeq, x: Tuple[rti.connextdds.BytesTopicType, rti.connextdds.Time]) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.CdrPaddingKind

Bases: pybind11_builtins.pybind11_object

AUTO = CdrPaddingKind.AUTO
class CdrPaddingKind

Bases: pybind11_builtins.pybind11_object

Members:

ZERO : Set padding bytes to zero during CDR serialization.

NOT_SET : Don’t set padding bytes to any value.

AUTO : Set the value automatically, depending on the Entity.

When set on a DomainParticipant the default behavior is NOT_SET

When set on a DataWriter or DataReader the behavior is to inherit the value from the DomainParticipant.

AUTO = CdrPaddingKind.AUTO
NOT_SET = CdrPaddingKind.NOT_SET
ZERO = CdrPaddingKind.ZERO
property name

(self: handle) -> str

NOT_SET = CdrPaddingKind.NOT_SET
ZERO = CdrPaddingKind.ZERO
property underlying

Retrieves the actual enumerated value.

class rti.connextdds.ChannelSettings

Bases: pybind11_builtins.pybind11_object

property filter_expression

A logical expression used to determine the data that will be published in the channel.

property multicast_settings

A sequence of TransportMulticastSettings used to configure the multicast addresses associated with a channel.

property priority

Publication priority.

class rti.connextdds.ChannelSettingsSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.ChannelSettingsSeq, x: rti.connextdds.ChannelSettings) → None

Add an item to the end of the list

clear(self: rti.connextdds.ChannelSettingsSeq) → None

Clear the contents

count(self: rti.connextdds.ChannelSettingsSeq, x: rti.connextdds.ChannelSettings) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.ChannelSettingsSeq, L: rti.connextdds.ChannelSettingsSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.ChannelSettingsSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.ChannelSettingsSeq, i: int, x: rti.connextdds.ChannelSettings) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.ChannelSettingsSeq) -> rti.connextdds.ChannelSettings

Remove and return the last item

  1. pop(self: rti.connextdds.ChannelSettingsSeq, i: int) -> rti.connextdds.ChannelSettings

Remove and return the item at index i

remove(self: rti.connextdds.ChannelSettingsSeq, x: rti.connextdds.ChannelSettings) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

rti.connextdds.CharSeq

alias of rti.connextdds.Int8Seq

rti.connextdds.CharType

alias of rti.connextdds.Int8Type

class rti.connextdds.CoherentAccess

Bases: pybind11_builtins.pybind11_object

end(self: rti.connextdds.CoherentAccess) → None

Explicitly indicate that the application has finished accessing the data samples in DataReader objects managed by the Subscriber.

class rti.connextdds.CoherentSet

Bases: pybind11_builtins.pybind11_object

end(self: rti.connextdds.CoherentSet) → None

Explicitly terminate a coherent set initiated by the CoherentSet constructor.

class rti.connextdds.CollectionType

Bases: rti.connextdds.DynamicType

property content_type

Gets the type of elements of this collection.

class rti.connextdds.Condition

Bases: rti.connextdds.ICondition

class rti.connextdds.ConditionSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.ConditionSeq, x: rti.connextdds.Condition) → None

Add an item to the end of the list

clear(self: rti.connextdds.ConditionSeq) → None

Clear the contents

count(self: rti.connextdds.ConditionSeq, x: rti.connextdds.Condition) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.ConditionSeq, L: rti.connextdds.ConditionSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.ConditionSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.ConditionSeq, i: int, x: rti.connextdds.Condition) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.ConditionSeq) -> rti.connextdds.Condition

Remove and return the last item

  1. pop(self: rti.connextdds.ConditionSeq, i: int) -> rti.connextdds.Condition

Remove and return the item at index i

remove(self: rti.connextdds.ConditionSeq, x: rti.connextdds.Condition) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.ContentFilterBase

Bases: pybind11_builtins.pybind11_object

class rti.connextdds.ContentFilterProperty

Bases: pybind11_builtins.pybind11_object

property content_filter_topic_name

The ContentFilteredTopic filter parameters.

property filter_class_name

Identifies the filter class this filter belongs to.

property filter_expression

The filter expression.

property related_topic_name

The name of the ContentFilteredTopic’s related Topic.

class rti.connextdds.Cookie

Bases: pybind11_builtins.pybind11_object

Unique identifier for a written data sample in the form of a sequence of bytes.

property value

Retrieve the bytes of the Cookie’s contents.

class rti.connextdds.CookieSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.CookieSeq, x: rti.connextdds.Cookie) → None

Add an item to the end of the list

clear(self: rti.connextdds.CookieSeq) → None

Clear the contents

count(self: rti.connextdds.CookieSeq, x: rti.connextdds.Cookie) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.CookieSeq, L: rti.connextdds.CookieSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.CookieSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.CookieSeq, i: int, x: rti.connextdds.Cookie) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.CookieSeq) -> rti.connextdds.Cookie

Remove and return the last item

  1. pop(self: rti.connextdds.CookieSeq, i: int) -> rti.connextdds.Cookie

Remove and return the item at index i

remove(self: rti.connextdds.CookieSeq, x: rti.connextdds.Cookie) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.CookieVector

Bases: pybind11_builtins.pybind11_object

A DDS standard container with functionality similar to a C++ vector.

clear(self: rti.connextdds.CookieVector) → None

Resize CookieVector to 0.

resize(self: rti.connextdds.CookieVector, size: int) → None

Resize CookieVector.

class rti.connextdds.DataReaderCacheStatus

Bases: pybind11_builtins.pybind11_object

property sample_count

The number of samples in the DataReader’s queue.

property sample_count_peak

The highest number of samples in the DataReader’s queue over the lifetime of the reader.

class rti.connextdds.DataReaderProtocol

Bases: pybind11_builtins.pybind11_object

property disable_positive_acks

Get/set the boolean for whether the reader will use send positive acknowledgments.

property expects_inline_qos

Get/set the boolean for whether the reader will expect inline QoS with each sample.

property propagate_dispose_of_unregistered_instances

Get/set the boolean for whether an instance can move to the not_alive_disposed state without being in the alive state.

property propagate_unregister_of_disposed_instances

Get/set the boolean for whether an instance can move to the not_alive_no_writers state without being in the alive state.

property rtps_object_id

Get/set the RTPS object ID.

property rtps_reliable_reader

Get/set the reliable reader protocol settings.

property virtual_guid

Get/set a copy of the virtual GUID.

class rti.connextdds.DataReaderProtocolStatus

Bases: pybind11_builtins.pybind11_object

Information about the DataReader’s protocol status.

property duplicate_sample_bytes

The number of bytes of sample data from a remote DataWriter received, not for the first time, by a local DataReader.

property duplicate_sample_count

The number of samples from a remote DataWriter received, not for the first time, by a local DataReader.

property first_available_sample_sequence_number

Sequence number of the first available sample in a matched DataWriters reliability queue.

property last_available_sample_sequence_number

Sequence number of the last available sample in a matched Datawriter’s reliability queue.

property last_committed_sample_sequence_number

Sequence number of the newest sample received from the matched DataWriter committed to the DataReader’s queue.

property received_gap_bytes

The number of bytes of GAP data received from remote DataWriter to this DataReader.

property received_gap_count

The number of GAPs received from remote DataWriter to this DataReader.

property received_heartbeat_bytes

The number of bytes of Heartbeat data from a remote DataWriter received by a local DataReader.

property received_heartbeat_count

The number of Heartbeats from a remote DataWriter received by a local DataReader.

property received_sample_bytes

The number of bytes from samples received by a DataReader.

property received_sample_count

The number of samples received by a DataReader.

property rejected_sample_count

The number of times samples were rejected due to exceptions in the receive path.

property sent_ack_bytes

The number of bytes of ACK data sent from a local DataReader to a matching remote DataWriter.

property sent_ack_count

The number of ACKs sent from a local DataReader to a matching remote DataWriter.

property sent_nack_bytes

The number of bytes of NACK data sent from a local DataReader to a matching remote DataWriter.

property sent_nack_count

The number of NACKs sent from a local DataReader to a matching remote DataWriter.

property uncommitted_sample_count

Number of received samples that are not yet available to be read or taken, due to being received out of order.

class rti.connextdds.DataReaderQos

Bases: pybind11_builtins.pybind11_object

property availability

Get/set Availability QoS.

property data_reader_protocol

Get/set DataReaderProtocol QoS.

property data_reader_resource_limits

Get/set DataReaderResourceLimits QoS.

property data_representation

Get/set DataRepresentation QoS.

property data_tag

Get/set DataTag QoS.

property deadline

Get/set Deadline QoS.

property destination_order

Get/set DestinationOrder QoS.

property durability

Get/set Durability QoS.

property entity_name

Get/set EntityName QoS.

property history

Get/set History QoS.

property latency_budget

Get/set LatencyBudget QoS.

property liveliness

Get/set Liveliness QoS.

property ownership

Get/set Ownership QoS.

property property

Get/set Property QoS.

property reader_data_lifecycle

Get/set ReaderDataLifecycle QoS.

property reliability

Get/set Reliability QoS.

property resource_limits

Get/set ResourceLimits QoS.

property service

Get/set Service QoS.

property time_based_filter

Get/set TimeBasedFilter QoS.

property transport_multicast

Get/set TransportMulticast QoS.

property transport_priority

Get/set TransportPriority QoS.

property transport_selection

Get/set TransportSelection QoS.

property transport_unicast

Get/set TransportUnicast QoS.

property type_consistency_enforcement

Get/set TypeConsistencyEnforcement QoS.

property type_support

Get/set TypeSupport QoS.

property user_data

Get/set UserData QoS.

class rti.connextdds.DataReaderResourceLimits

Bases: pybind11_builtins.pybind11_object

property disable_fragmentation_support

Determines whether the DataReader can receive fragmented samples.

property dynamically_allocate_fragmented_samples

Determines whether the DataReader pre-allocates storage for storing fragmented samples.

property initial_fragmented_samples

The initial number of samples for which a DataReader may store fragments.

property initial_infos

The initial number of info units that a DataReader can use to store SampleInfo.

property initial_outstanding_reads

The initial number of outstanding calls to read/take (or one of their variants) on the same DataReader for which memory has not been returned by calling LoanedSamples.return_loan().

property initial_remote_virtual_writers

The initial number of remote virtual writers from which a DataReader may read, including all instances.

property initial_remote_virtual_writers_per_instance

The initial number of virtual remote writers that can be associated with an instance.

property initial_remote_writers

The initial number of remote writers from which a DataReader may read, including all instances.

property initial_remote_writers_per_instance

The initial number of remote writers from which a DataReader may read a single instance.

property initial_topic_queries

The initial number of TopicQueries allocated by a DataReader.

property keep_minimum_state_for_instances

Whether or not keep a minimum instance state for up to DataReaderResourceLimits.max_total_instances.

property max_app_ack_response_length

Maximum length of application-level acknowledgment response data.

property max_fragmented_samples

The maximum number of samples for which the DataReader may store fragments at a given point in time.

property max_fragmented_samples_per_remote_writer

The maximum number of samples per remote writer for which a DataReader may store fragments.

property max_fragments_per_sample

Maximum number of fragments for a single sample.

property max_infos

The maximum number of info units that a DataReader can use to store SampleInfo.

property max_outstanding_reads

The max number of outstanding calls to read/take (or one of their variants) on the same DataReader for which memory has not been returned by calling LoanedSamples.return_loan().

property max_query_condition_filters

The maximum number of query condition filters a reader is allowed.

property max_remote_virtual_writers

The maximum number of remote virtual writers from which a DataReader may read, including all instances.

property max_remote_virtual_writers_per_instance

The maximum number of virtual remote writers that can be associated with an instance.

property max_remote_writers

The maximum number of remote writers from which a DataReader may read, including all instances.

property max_remote_writers_per_instance

The maximum number of remote writers from which a DataReadermay read a single instance.

property max_remote_writers_per_sample

The maximum number of remote writers allowed to write the same sample.

property max_samples_per_read

The maximum number of data samples that the application can receive from the middleware in a single call to DataReader.read() or DataReader.take(). If more data exists in the middleware, the application will need to issue multiple read/take calls.

property max_samples_per_remote_writer

The maximum number of out-of-order samples from a given remote DataWriter that a DataReader may store when maintaining a reliable connection to the DataWriter.

property max_topic_queries

The maximum number of TopicQueries allocated by a DataReader.

property max_total_instances

Maximum number of instances for which a DataReader will keep state.

property shmem_ref_transfer_mode_attached_segment_allocation

The initial number of TopicQueries allocated by a DataReader.

class rti.connextdds.DataRepresentation

Bases: pybind11_builtins.pybind11_object

AUTO_ID = -1
XCDR = 0
XCDR2 = 2
XML = 1
property value

A sequence of IDs representing the allowed data representations.

This property uses copy semantics. Changes to the sequence are not reflected in the policy unless the sequence is commited back to the policy object via the property’s setter.

class rti.connextdds.DataState

Bases: pybind11_builtins.pybind11_object

static any()rti.connextdds.DataState

Create a DataState with InstanceState.any(), ViewState.any(), and SampleState.any()

static any_data()rti.connextdds.DataState

Create a DataState with InstanceState.alive(), ViewState.any(), and SampleState.any()

property instance_state

The InstanceState of the DataState.

static new_data()rti.connextdds.DataState

Create a DataState with InstanceState.alive(), ViewState.any(), and SampleState.not_read()

static new_instance()rti.connextdds.DataState

Create a DataState with InstanceState.alive(), ViewState.new_view(), and SampleState.any()

property sample_state

The SampleState of the DataState.

property view_state

The ViewState of the DataState.

class rti.connextdds.DataStateEx

Bases: pybind11_builtins.pybind11_object

static any()rti.connextdds.DataState

Create a DataStateEx with InstanceState.any(), ViewState.any(), SampleState.any(), and StreamKind.any()

static any_data()rti.connextdds.DataState

Create a DataStateEx with InstanceState.alive(), ViewState.any(), SampleState.any(), and StreamKind.any()

property data_state

Access the view, sample and instance states.

property instance_state

The InstanceState of the DataStateEx.

static new_data()rti.connextdds.DataState

Create a DataStateEx with InstanceState.alive(), ViewState.any(), SampleState.not_read()

static new_instance()rti.connextdds.DataState

Create a DataStateEx with InstanceState.alive(), ViewState.new_view(), SampleState.any() and StreamKind.any()

property sample_state

The SampleState of the DataStateEx.

property stream_kind

The StreamKind.

property view_state

The ViewState of the DataStateEx.

class rti.connextdds.DataTag

Bases: pybind11_builtins.pybind11_object

exists(self: rti.connextdds.DataTag, key: str) → bool

Returns true if a tag exists.

get(self: rti.connextdds.DataTag, key: str) → str

Returns the value of a tag identified by a key if it exists.

get_all(self: rti.connextdds.DataTag)rti.connextdds.StringMap

Retrieves a copy of all the entries.

remove(self: rti.connextdds.DataTag, key: str) → bool

Removes the tag identified by a key.

set(*args, **kwargs)

Overloaded function.

  1. set(self: rti.connextdds.DataTag, entry_list: rti.connextdds.StringPairSeq) -> None

Adds or assigns tags from a list of string pairs.

  1. set(self: rti.connextdds.DataTag, entry_map: dict) -> None

Adds or assigns tags from a dictionary.

  1. set(self: rti.connextdds.DataTag, entry: Tuple[str, str]) -> None

Adds or assigns a tag from a pair of strings.

  1. set(self: rti.connextdds.DataTag, arg0: str, arg1: str) -> None

Adds or assigns a tag from a key string and a value string.

size(self: rti.connextdds.DataTag) → int

Returns the number of tags.

try_get(self: rti.connextdds.DataTag, key: str) → Optional[str]

Returns the value of a tag identified by a key if it exists.

class rti.connextdds.DataWriterCacheStatus

Bases: pybind11_builtins.pybind11_object

property sample_count

Number of samples in the DataWriter’s queue, including unregister and dispose samples.

property sample_count_peak

Highest number of samples in the writer’s queue over the lifetime of the writer.

class rti.connextdds.DataWriterProtocol

Bases: pybind11_builtins.pybind11_object

property disable_inline_keyhash

Controls whether a keyhash is propagated on the wire with each sample.

property disable_positive_acks

Controls whether the DataWriter expects positive acknowledgments from matched DataReaders.

property propagate_app_ack_with_no_response

Controls whether or not a DataWriter receives on_application_acknowledgment notifications with an empty or invalid response.

property push_on_write

Determines whether a sample is pushed on a call to write.

property rtps_object_id

The RTPS object ID of the DataWriter.

property rtps_reliable_writer

RTPS protocol-related configuration settings for the RTPS reliable writer associated to a DataWriter. This parameter only has effect if both the writer and the matching reader are configured with ReliabilityKind.RELIABLE.

property serialize_key_with_dispose

Controls whether or not the serialized key is propagated on the wire with dispose samples.

property virtual_guid

The virtual GUID of the DataWriter. This property uses value semantics.

class rti.connextdds.DataWriterProtocolStatus

Bases: pybind11_builtins.pybind11_object

Information about the DataWriter protocol status

property first_available_sample_sequence_number

The sequence number of the first available sample currently queued in the local DataWriter.

property first_available_sample_virtual_sequence_number

The virtual sequence number of the first available sample currently queued in the local DataWriter.

property first_unacknowledged_sample_sequence_number

The sequence number of the first unacknowledged sample currently queued in the local DataWriter.

property first_unacknowledged_sample_subscription_handle

The handle of a remote DataReader that has not acknowledged the first unacknowledged sample of the local DataWriter.

property first_unacknowledged_sample_virtual_sequence_number

The virtual sequence number of the first unacknowledged sample currently queued in the local DataWriter.

property first_unelapsed_keep_duration_sample_sequence_number

The sequence number of the first sample whose keep duration has not yet elapsed.

property last_available_sample_sequence_number

The sequence number of the last available sample currently queued in the local DataWriter.

property last_available_sample_virtual_sequence_number

The virtual sequence number of the last available sample currently queued in the local DataWriter.

property pulled_sample_bytes

The number of bytes of user samples pulled from local DataWriter by matching DataReaders.

property pulled_sample_count

The number of user samples pulled from local DataWriter by matching DataReaders.

property pushed_sample_bytes

The number of bytes of user samples pushed on write from a local DataWriter to a matching remote DataReader.

property pushed_sample_count

The number of user samples pushed on write from a local DataWriter to a matching remote DataReader.

property received_ack_bytes

The number of bytes of ACKs from a remote DataReader received by a local DataWriter.

property received_ack_count

The number of ACKs from a remote DataReader received by a local DataWriter.

property received_nack_bytes

The number of bytes of NACKs from a remote DataReader received by a local DataWriter.

property received_nack_count

The number of NACKs from a remote DataReader received by a local DataWriter.

property rejected_sample_count

The number of times a sample is rejected due to exceptions in the send path.

property send_window_size

Current maximum number of outstanding samples allowed in the DataWriter’s queue.

property sent_gap_bytes

The number of bytes of GAPs sent from local DataWriter to matching remote DataReaders.

property sent_gap_count

The number of GAPs sent from local DataWriter to matching remote DataReaders.

property sent_heartbeat_bytes

The number of bytes of Heartbeats sent between a local DataWriter and matching remote DataReader.

property sent_heartbeat_count

The number of Heartbeats sent between a local DataWriter and matching remote DataReader.

class rti.connextdds.DataWriterQos

Bases: pybind11_builtins.pybind11_object

property availability

Get/set Availability QoS.

property batch

Get/set Batch QoS.

property data_representation

Get/set DataRepresentation QoS.

property data_tag

Get/set DataTag QoS.

property data_writer_protocol

Get/set DataWriterProtocol QoS.

property data_writer_resource_limits

Get/set DataWriterResourceLimits QoS.

property data_writer_transfer_mode

Get/set DataWriterTransferMode QoS.

property deadline

Get/set Deadline QoS.

property destination_order

Get/set DestinationOrder QoS.

property durability

Get/set Durability QoS.

property durability_service

Get/set DurabilityService QoS.

property entity_name

Get/set EntityName QoS.

property history

Get/set History QoS.

property latency_budget

Get/set LatencyBudget QoS.

property lifespan

Get/set Lifespan QoS.

property liveliness

Get/set Liveliness QoS.

property multi_channel

Get/set MultiChannel QoS.

property ownership

Get/set Ownership QoS.

property ownership_strength

Get/set OwnershipStrength QoS.

property property

Get/set Property QoS.

property publish_mode

Get/set PublishMode QoS.

property reliability

Get/set Reliability QoS.

property resource_limits

Get/set ResourceLimits QoS.

property service

Get/set Service QoS.

property topic_query_dispatch

Get/set TopicQueryDispatch QoS.

property transport_priority

Get/set TransportPriority QoS.

property transport_selection

Get/set TransportSelection QoS.

property transport_unicast

Get/set TransportUnicast QoS.

property type_support

Get/set TypeSupport QoS.

property user_data

Get/set UserData QoS.

property writer_data_lifecycle

Get/set WriterDataLifecycle QoS.

class rti.connextdds.DataWriterResourceLimits

Bases: pybind11_builtins.pybind11_object

property autoregister_instances

Whether or not to automatically register new instances.

property cookie_max_length

Represents the maximum length in bytes of a Cookie.

property initial_active_topic_queries

Represents the initial number of active topic queries a DataWriter will manage.

property initial_batches

Represents the initial number of batches a DataWriter will manage.

property initial_concurrent_blocking_threads

The initial number of threads that are allowed to concurrently block on write call on the same DataWriter.

property initial_virtual_writers

The initial number of virtual writers supported by a DataWriter.

property initialize_writer_loaned_sample

Whether or not to initialize loaned samples returned by a DataWriter.

property instance_replacement

Sets the kinds of instances allowed to be replaced when instance resource limits are reached.

property max_active_topic_queries

Represents the maximum number of active topic queries a DataWriter will manage.

property max_app_ack_remote_readers

The maximum number of application-level acknowledging remote readers supported by a DataWriter.

property max_batches

Represents the maximum number of batches a DataWriter will manage.

property max_concurrent_blocking_threads

The maximum number of threads that are allowed to concurrently block on write call on the same DataWriter.

property max_remote_reader_filters

The maximum number of remote DataReaders for which the DataWriter will perform content-based filtering.

property max_remote_readers

The maximum number of remote readers supported by a DataWriter.

property max_virtual_writers

The maximum number of virtual writers supported by a DataWriter.

property replace_empty_instances

Whether or not to replace empty instances during instance replacement.

property writer_loaned_sample_allocation

Represents the allocation settings of loaned samples managed by a DataWriter.

class rti.connextdds.DataWriterResourceLimitsInstaceReplacementKind

Bases: pybind11_builtins.pybind11_object

ALIVE = DataWriterResourceLimitsInstaceReplacementKind.ALIVE
ALIVE_OR_DISPOSED = DataWriterResourceLimitsInstaceReplacementKind.ALIVE_OR_DISPOSED
ALIVE_THEN_DISPOSED = DataWriterResourceLimitsInstaceReplacementKind.ALIVE_THEN_DISPOSED
DISPOSED = DataWriterResourceLimitsInstaceReplacementKind.DISPOSED
DISPOSED_THEN_ALIVE = DataWriterResourceLimitsInstaceReplacementKind.DISPOSED_THEN_ALIVE
class DataWriterResourceLimitsInstaceReplacementKind

Bases: pybind11_builtins.pybind11_object

Members:

UNREGISTERED : Allows a DataWriter to reclaim unregistered acknowledged instances.

By default, all instance replacement kinds first attempt to reclaim an unregistered, acknowledged instance. Used in DataWriterResourceLimits.instance_replacement [default]

ALIVE : Allows a DataWriter to reclaim alive, acknowledged instances.

When an unregistered, acknowledged instance is not available to reclaim, this kind allows a DataWriter to reclaim an alive, acknowledged instance, where an alive instance is a registered, non-disposed instance. The least recently registered or written alive instance will be reclaimed.

DISPOSED : Allows a DataWriter to reclaim disposed acknowledged instances.

When an unregistered, acknowledged instance is not available to reclaim, this kind allows a DataWriter to reclaim a disposed, acknowledged instance. The least recently disposed instance will be reclaimed.

ALIVE_THEN_DISPOSED : Allows a DataWriter first to reclaim an alive, acknowledged instance, and then, if necessary, a disposed, acknowledged instance.

When an unregistered, acknowledged instance is not available to reclaim, this kind allows a DataWriter to first try reclaiming an alive, acknowledged instance. If no instance is reclaimable, then it tries reclaiming a disposed, acknowledged instance. The least recently used (i.e., registered, written, or disposed) instance will be reclaimed.

DISPOSED_THEN_ALIVE : Allows a DataWriter first to reclaim a disposed, acknowledged instance, and then, if necessary, an alive, acknowledged instance.

When an unregistered, acknowledged instance is not available to reclaim, this kind allows a DataWriter to first try reclaiming a disposed, acknowledged instance. If no instance is reclaimable, then it tries reclaiming an alive, acknowledged instance. The least recently used (i.e., disposed, registered, or written) instance will be reclaimed.

ALIVE_OR_DISPOSED : Allows a DataWriter to reclaim a either an alive acknowledged instance or a disposed acknowledged instance.

When an unregistered acknowledged instance is not available to reclaim, this kind allows a DataWriter to reclaim either an alive, acknowledged instance or a disposed, acknowledged instance. If both instance kinds are available to reclaim, the DataWriter will reclaim the least recently used (i.e. disposed, registered, or written) instance.

ALIVE = DataWriterResourceLimitsInstaceReplacementKind.ALIVE
ALIVE_OR_DISPOSED = DataWriterResourceLimitsInstaceReplacementKind.ALIVE_OR_DISPOSED
ALIVE_THEN_DISPOSED = DataWriterResourceLimitsInstaceReplacementKind.ALIVE_THEN_DISPOSED
DISPOSED = DataWriterResourceLimitsInstaceReplacementKind.DISPOSED
DISPOSED_THEN_ALIVE = DataWriterResourceLimitsInstaceReplacementKind.DISPOSED_THEN_ALIVE
UNREGISTERED = DataWriterResourceLimitsInstaceReplacementKind.UNREGISTERED
property name

(self: handle) -> str

UNREGISTERED = DataWriterResourceLimitsInstaceReplacementKind.UNREGISTERED
property underlying

Retrieves the actual enumerated value.

class rti.connextdds.DataWriterShmemRefTransferModeSettings

Bases: pybind11_builtins.pybind11_object

property enable_data_consistency_check

Controls if samples can be checked for consistency.

class rti.connextdds.DataWriterTransferMode

Bases: pybind11_builtins.pybind11_object

property shmem_ref_settings

Settings related to transferring data using shared memory references.

class rti.connextdds.Database

Bases: pybind11_builtins.pybind11_object

property cleanup_period

Get/set the cleanup period.

property initial_records

Get/set the number of database records to be allocated initially.

property initial_weak_references

Get/set the initial number of weak references.

property max_skiplist_level

Get/set the skiplist level.

property max_weak_references

Get/set the maximum number of weak references.

property shutdown_cleanup_period

Get/set the shutdown cleanup period.

property shutdown_timeout

Get/set the shutdown timeout.

property thread

Get/set the thread settings for the Database thread.

class rti.connextdds.Deadline

Bases: pybind11_builtins.pybind11_object

property period

The duration of the deadline period.

class rti.connextdds.DestinationOrder

Bases: pybind11_builtins.pybind11_object

property kind

The destination order kind.

property scope

The destination order scope.

property source_timestamp_tolerance

The allowed tolerance between source timestamps of consecutive samples.

class rti.connextdds.DestinationOrderKind

Bases: pybind11_builtins.pybind11_object

BY_RECEPTION_TIMESTAMP = DestinationOrderKind.BY_RECEPTION_TIMESTAMP
BY_SOURCE_TIMESTAMP = DestinationOrderKind.BY_SOURCE_TIMESTAMP
class DestinationOrderKind

Bases: pybind11_builtins.pybind11_object

Members:

BY_RECEPTION_TIMESTAMP : [default] Indicates that data is ordered based on the reception time at each Subscriber.

Since each subscriber may receive the data at different times there is no guaranteed that the changes will be seen in the same order. Consequently, it is possible for each subscriber to end up with a different final value for the data.

BY_SOURCE_TIMESTAMP : Indicates that data is ordered based on a time-stamp placed at the source (by RTI Connext or by the application).

In any case this guarantees a consistent final value for the data in all subscribers.

Note: If Batching is needed along with DestinationOrderKind.BY_SOURCE_TIMESTAMP and DestinationOrderScopeKind.INSTANCE, then the Batch.source_timestamp_resolution and Batch.thread_safe_write setting of Batch should be set to Duration.zero() and true respectively.

BY_RECEPTION_TIMESTAMP = DestinationOrderKind.BY_RECEPTION_TIMESTAMP
BY_SOURCE_TIMESTAMP = DestinationOrderKind.BY_SOURCE_TIMESTAMP
property name

(self: handle) -> str

property underlying

Retrieves the actual enumerated value.

class rti.connextdds.DestinationOrderScopeKind

Bases: pybind11_builtins.pybind11_object

class DestinationOrderScopeKind

Bases: pybind11_builtins.pybind11_object

Members:

INSTANCE : [default] Indicates that data is ordered on a per instance basis if used along with DestinationOrderKind.BY_SOURCE_TIMESTAMP.

The source timestamp of the current sample is compared to the source timestamp of the previously received sample for the same instance. The tolerance check is also applied per instance.

TOPIC : Indicates that data is ordered on a per topic basis if used along with DestinationOrderKind.BY_SOURCE_TIMESTAMP.

The source timestamp of the current sample is compared to the source timestamp of the previously received sample for the same topic. The tolerance check is also applied per topic.

INSTANCE = DestinationOrderScopeKind.INSTANCE
TOPIC = DestinationOrderScopeKind.TOPIC
property name

(self: handle) -> str

INSTANCE = DestinationOrderScopeKind.INSTANCE
TOPIC = DestinationOrderScopeKind.TOPIC
property underlying

Retrieves the actual enumerated value.

class rti.connextdds.Discovery

Bases: pybind11_builtins.pybind11_object

property accept_unknown_peers

Whether to accept a new participant that is not in the initial peers list.

property enable_endpoint_discovery

Whether to automatically enable endpoint discovery for all the remote participants.

property enabled_transports

The transports (by their aliases) available for the discovery mechanism.

This property’s getter returns a deep copy.

property initial_peers

The initial list of peers that the discovery mechanism will contact to announce this DomainParticipant.

This property’s getter returns a deep copy.

property metatraffic_transport_priority

The transport priority to use for the Discovery meta-traffic.

property multicast_receive_addresses

The multicast group addresses on which discovery-related meta-traffic can be received by the DomainParticipant.

This property’s getter returns a deep copy.

class rti.connextdds.DiscoveryConfig

Bases: pybind11_builtins.pybind11_object

property asynchronous_publisher

Asynchronous publishing settings for the discovery Publisher and all entities that are created by it.

property builtin_discovery_plugins

The kind mask for built-in discovery plugins.

property default_domain_announcement_period

The period to announce a participant to the default domain 0.

This property’s getter returns a deep copy.

property endpoint_type_object_lb_serialization_threshold

Option to reduce the size required to propagate a TypeObject in Simple Endpoint Discovery.

property ignore_default_domain_announcements

Used to ignore the announcements received by a participant on the default domain 0 corresponding to participants running on domains IDs other than 0.

property initial_participant_announcements

The number of initial announcements sent when a participant is first enabled or when a remote participant is newly discovered.

property locator_reachability_assert_period

Period at which this DomainParticipant will assert the locators discovered from other DomainParticipants.

This property’s getter returns a deep copy.

property locator_reachability_change_detection_period

Period at which this DomainParticipant will check if its locators are reachable from other DomainParticipants.

This property’s getter returns a deep copy.

property locator_reachability_lease_duration

The time period after which other DomainParticipants can consider one of their locators as “unreachable” if they do not receive a REACHABILITY PING from this DomainParticipant.

This property’s getter returns a deep copy.

property max_initial_participant_announcement_period

The maximum period between initial announcements when a participant is first enabled or when a remote participant is newly discovered.

property max_liveliness_loss_detection_period

The period to assert liveliness for the participant.

This property’s getter returns a deep copy.

property min_initial_participant_announcement_period

The minimum period between initial announcements when a participant is first enabled or when a remote participant is newly discovered.

This property’s getter returns a deep copy.

property participant_liveliness_assert_period

The period to assert liveliness for the participant.

This property’s getter returns a deep copy.

property participant_liveliness_lease_duration

The liveliness lease duration for the participant.

property participant_message_reader

Reliability policy for a built-in participant message reader.

property participant_message_reader_reliability_kind

Reliability policy for a built-in participant message reader.

property participant_message_writer

Reliability policy for a built-in participant message writer.

property participant_reader_resource_limits

Resource limits.

property publication_reader

RTPS protocol-related configuration settings for the RTPS reliable reader associated to a built-in publication reader.

property publication_reader_resource_limits

Publication reader resource limits.

property publication_writer

RTPS protocol-related configuration settings for the RTPS reliable writer associated to a built-in publication reader.

property publication_writer_data_lifecycle

riter data lifecycle settings for a built-in publication writer.

property publication_writer_publish_mode

Publish mode policy for the built-in publication writer.

property remote_participant_purge_kind

The participant’s behavior for maintaining knowledge of remote participants (and their contained entities) with which discovery communication has been lost.

property secure_volatile_writer_publish_mode

Publish mode policy for the built-in secure volatile writer.

property service_request_reader

RTPS protocol-related configuration settings for the RTPS reliable reader associated to a built-in publication reader.

property service_request_writer

RTPS protocol-related configuration settings for the RTPS reliable writer associated to the built-in ServiceRequest writer.

property service_request_writer_data_lifecycle

Writer data lifecycle settings for a built-in ServiceRequest writer.

property service_request_writer_publish_mode

Publish mode policy for the built-in service request writer.

property subscription_reader

RTPS protocol-related configuration settings for the RTPS reliable reader associated to a built-in subscription reader.

property subscription_reader_resource_limits

Subscription reader resource limits.

property subscription_writer

RTPS protocol-related configuration settings for the RTPS reliable writer associated to a built-in subscription reader.

property subscription_writer_data_lifecycle

riter data lifecycle settings for a built-in subscription writer.

property subscription_writer_publish_mode

Publish mode policy for the built-in subscription writer.

class rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Bases: pybind11_builtins.pybind11_object

static all()rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Create a mask with all bits set.

count(self: std::__1::bitset<3ul>) → int

Returns the number of bits set in the mask.

flip(*args, **kwargs)

Overloaded function.

  1. flip(self: rti.connextdds.DiscoveryConfigBuiltinPluginKindMask) -> rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Flip all bits in the mask.

  1. flip(self: rti.connextdds.DiscoveryConfigBuiltinPluginKindMask, pos: int) -> rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Flip the mask bit at the specified position.

static none()rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Create a mask with no bits set.

reset(*args, **kwargs)

Overloaded function.

  1. reset(self: rti.connextdds.DiscoveryConfigBuiltinPluginKindMask) -> rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Clear all bits in the mask.

  1. reset(self: rti.connextdds.DiscoveryConfigBuiltinPluginKindMask, pos: int) -> rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Clear the mask bit at the specified position.

static sdp()rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Create a mask that selects the Simple Discovery Protocol (SDP).

static sedp()rti.connextdds.DiscoveryConfigBuiltinPluginKindMask
set(*args, **kwargs)

Overloaded function.

  1. set(self: rti.connextdds.DiscoveryConfigBuiltinPluginKindMask) -> rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Set all bits in the mask.

  1. set(self: rti.connextdds.DiscoveryConfigBuiltinPluginKindMask, pos: int, value: bool = True) -> rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Set the mask bit at the specified position to the provided value (default: true).

size(self: std::__1::bitset<3ul>) → int

Returns the number of bits in the mask type.

static spdp()rti.connextdds.DiscoveryConfigBuiltinPluginKindMask
test(self: rti.connextdds.DiscoveryConfigBuiltinPluginKindMask, pos: int) → bool

Test whether the mask bit at postition “pos” is set.

test_all()rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Test if all bits are set.

test_any(self: std::__1::bitset<3ul>) → bool

Test if any bits are set.

test_none()rti.connextdds.DiscoveryConfigBuiltinPluginKindMask

Test if any bits are set.

class rti.connextdds.DomainParticipant

Bases: rti.connextdds.IEntity

Container for all Entity objects. * It acts as a container for all other Entity objects. * It acts as a factory for the Publisher, Subscriber, Topic and Entity objects. * It represents the participation of the application on a communication plane that isolates applications running on the same set of physical computers from each other. A domain establishes a virtual network linking all applications that share the same domainId and isolating them from applications running on different domains. In this way, several independent distributed applications can coexist in the same physical network without interfering, or even being aware of each other. * It provides administration services in the domain, offering operations that allow the application to ignore locally any information about a given participant (DomainParticipant.ignore), publication (ignore_publication), subscription (ignore_subscription) or topic (ignore_topic).

add_peer(self: rti.connextdds.DomainParticipant, peer: str) → None

Attempt to contact an additional peer participant.

add_peers(self: rti.connextdds.DomainParticipant, peers: rti.connextdds.StringSeq) → None

Add a sequence of peers to be contacted.

assert_liveliness(self: rti.connextdds.DomainParticipant) → None

Manually assert the liveliness of the DomainParticipant.

bind_listener(self: rti.connextdds.DomainParticipant, listener: Optional[rti.connextdds.DomainParticipantListener], event_mask: rti.connextdds.StatusMask) → None

Bind the listener and event mask to the DomainParticipant.

property builtin_subscriber

Get the built-in subscriber for the DomainParticipant.

contains_entity(self: rti.connextdds.DomainParticipant, handle: rti.connextdds.InstanceHandle) → bool

Check whether or not the given handle represents an Entity that was created from the DomainParticipant.

property current_time

Get the current time.

property default_datareader_qos

The default DataReaderQos.

This property’s getter returns a deep copy.

property default_datawriter_qos

The default DataWriterQos.

This property’s getter returns a deep copy.

default_participant_qos = <rti.connextdds.DomainParticipantQos object>
property default_publisher_qos

The default PublisherQos.

This property’s getter returns a deep copy.

property default_subscriber_qos

The default SubscriberQos.

This property’s getter returns a deep copy.

property default_topic_qos

The default TopicQos.

This property’s getter returns a deep copy.

delete_durable_subscription(self: rti.connextdds.DomainParticipant, group: rti.connextdds.EndpointGroup) → None

Deletes an existing Durable Subscription on all Persistence Services.

discovered_participant_data(*args, **kwargs)

Overloaded function.

  1. discovered_participant_data(self: rti.connextdds.DomainParticipant, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.ParticipantBuiltinTopicData

Retrieve DomainParticipant information by handle.

  1. discovered_participant_data(self: rti.connextdds.DomainParticipant, handles: rti.connextdds.InstanceHandleSeq) -> rti.connextdds.ParticipantBuiltinTopicDataSeq

Retrieve DomainParticipant information with a sequence of handles.

discovered_participants(self: rti.connextdds.DomainParticipant)rti.connextdds.InstanceHandleSeq

Retrieves the instance handles of other DomainParticipants discovered by this one.

discovered_topic_data(*args, **kwargs)

Overloaded function.

  1. discovered_topic_data(self: rti.connextdds.DomainParticipant, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.TopicBuiltinTopicData

Get information about a discovered topic using its handle.

  1. discovered_topic_data(self: rti.connextdds.DomainParticipant, topic: rti.connextdds.IEntity) -> rti.connextdds.TopicBuiltinTopicData

Get information about a discovered topic.

  1. discovered_topic_data(self: rti.connextdds.DomainParticipant, handles: rti.connextdds.InstanceHandleSeq) -> rti.connextdds.TopicBuiltinTopicDataSeq

Get information about a discovered topic.

  1. discovered_topic_data(self: rti.connextdds.DomainParticipant) -> rti.connextdds.TopicBuiltinTopicDataSeq

Get information about all discovered topics.

discovered_topics(self: rti.connextdds.DomainParticipant)rti.connextdds.InstanceHandleSeq

Get all Topic handles discovered by this DomainParticipant.

property domain_id

The unique domain identifier.

static finalize_participant_factory() → None

Finalize the DomainParticipantFactory

static find(*args, **kwargs)

Overloaded function.

  1. find(name: str) -> Optional[rti.connextdds.DomainParticipant]

Find a local DomainParticipant by its name.

  1. find() -> rti.connextdds.DomainParticipantSeq

Find all local DomainParticipants.

  1. find(domain_id: int) -> Optional[rti.connextdds.DomainParticipant]

Find a local DomainParticipant with the given domain ID. If more than one DomainParticipant on the same domain exists in the application, it is not specified which will be returned.

find_contentfilter(self: rti.connextdds.DomainParticipant, name: str) → Optional[rti.connextdds.ContentFilterBase]

Find content filter previously registered to this DomainParticipant.

find_datareader(self: rti.connextdds.DomainParticipant, name: str)rti.connextdds.AnyDataReader

Find a DataReader by its name.

find_datawriter(self: rti.connextdds.DomainParticipant, name: str)rti.connextdds.AnyDataWriter

Find a DataWriter by its name.

find_publisher(self: rti.connextdds.DomainParticipant, name: str)rti.connextdds.Publisher

Lookup a Publisher within the DomainParticipant by its entity name.

find_publishers(self: rti.connextdds.DomainParticipant)rti.connextdds.PublisherSeq

Find all Publishers within the DomainParticipant.

find_registered_content_filters(self: rti.connextdds.DomainParticipant)rti.connextdds.StringSeq

Retrieve a list of all registered content filter names.

find_subscriber(self: rti.connextdds.DomainParticipant, name: str)rti.connextdds.Subscriber

Find a Subscriber in the DomainParticipant by its entity name.

find_subscribers(self: rti.connextdds.DomainParticipant)rti.connextdds.SubscriberSeq

Find all subscribers within the DomainParticipant.

find_topics(self: rti.connextdds.DomainParticipant)rti.connextdds.AnyTopicSeq

Find all Topics in the DomainParticipant.

ignore_datareader(self: rti.connextdds.DomainParticipant, handle: rti.connextdds.InstanceHandle) → None

Ignore a DataReader matching the provided handle.

ignore_datareaders(self: rti.connextdds.DomainParticipant, handles: rti.connextdds.InstanceHandleSeq) → None

Ignore a list of DataReaders specified by their handles.

ignore_datawriter(self: rti.connextdds.DomainParticipant, handle: rti.connextdds.InstanceHandle) → None

Ignore a DataWriter matching the provided handle.

ignore_datawriters(self: rti.connextdds.DomainParticipant, handles: rti.connextdds.InstanceHandleSeq) → None

Ignore a list of DataWriters specified by their handles.

ignore_participant(self: rti.connextdds.DomainParticipant, handle: rti.connextdds.InstanceHandle) → None

Ignore a DomainParticipant given it’s handle.

ignore_participants(self: rti.connextdds.DomainParticipant, arg0: rti.connextdds.InstanceHandleSeq) → None
ignore_topic(self: rti.connextdds.DomainParticipant, handle: rti.connextdds.InstanceHandle) → None

Ignore a Topic matching the provided handle.

ignore_topics(self: rti.connextdds.DomainParticipant, handles: rti.connextdds.InstanceHandleSeq) → None

Ignore a list of Topics specified by their handles.

property implicit_publisher

Get the implicit Publisher for the DomainParticipant.

property implicit_subscriber

Get the implicit Subscriber for the DomainParticipant.

is_type_registered(self: rti.connextdds.DomainParticipant, name: str) → bool

Check if a type has been registered to this DomainParticipant.

property listener

Get the listener.

participant_factory_qos = <rti.connextdds.DomainParticipantFactoryQos object>
property participant_protocol_status

Get the protocol status for this participant

property participant_reader

Get the DomainParticipant built-in topic reader.

publication_data(*args, **kwargs)

Overloaded function.

  1. publication_data(self: rti.connextdds.DomainParticipant, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.PublicationBuiltinTopicData

Retrieve publication data by handle.

  1. publication_data(self: rti.connextdds.DomainParticipant, handles: rti.connextdds.InstanceHandleSeq) -> rti.connextdds.PublicationBuiltinTopicDataSeq

Retrieve publication data for a sequence of handles.

property publication_reader

Get the publication built-in topic reader.

property qos

Get the domain participant’s QoS.

This property’s getter returns a deep copy.

register_contentfilter(self: rti.connextdds.DomainParticipant, filter: rti.connextdds.ContentFilterBase, name: str) → None

Register a content filter which can be used to create a ContentFiltertedTopic.

register_durable_subscription(self: rti.connextdds.DomainParticipant, group: rti.connextdds.EndpointGroup, topic_name: str) → None

Registers a Durable Subscription on the specified Topic on all Persistence Services

register_type(self: rti.connextdds.DomainParticipant, name: str, type: rti.connextdds.DynamicType, serialization_property: rti.connextdds.DynamicDataTypeSerializationProperty = DynamicDataTypeSerializationProperty.DEFAULT) → None

Registers a DynamicType with specific serialization properties.

remove_peer(self: rti.connextdds.DomainParticipant, peer: str) → None

Remove a peer participant from this list that this DomainParticipant will attempt to communicate with.

remove_peers(self: rti.connextdds.DomainParticipant, peers: rti.connextdds.StringSeq) → None

Remove a sequence of peers from the contact list.

resume_endpoint_discovery(self: rti.connextdds.DomainParticipant, handle: rti.connextdds.InstanceHandle) → None

Initiates endpoint discovery with the remote DomainParticipant identified by its InstanceHandle.

property service_request_reader

Get the ServiceRequest built-in topic reader.

subscription_data(*args, **kwargs)

Overloaded function.

  1. subscription_data(self: rti.connextdds.DomainParticipant, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.SubscriptionBuiltinTopicData

Retrieve subscription data by handle.

  1. subscription_data(self: rti.connextdds.DomainParticipant, handles: rti.connextdds.InstanceHandleSeq) -> rti.connextdds.SubscriptionBuiltinTopicDataSeq

Retrieve subscription data for a sequence of handles.

property subscription_reader

Get the subscription built-in topic reader.

property topic_reader

Get the topic built-in topic reader.

unregister_contentfilter(self: rti.connextdds.DomainParticipant, name: str) → None

Unregister content filter previously registered to this DomainParticipant.

unregister_type(self: rti.connextdds.DomainParticipant, name: str) → None

Unregister a type previously registered to this DomainParticipant.

class rti.connextdds.DomainParticipantConfigParams

Bases: pybind11_builtins.pybind11_object

DOMAIN_ID_USE_XML_CONFIG = -1
ENTITY_NAME_USE_XML_CONFIG = 'com.rti.dds.domain.entity_name_use_xml_config'
QOS_ELEMENT_NAME_USE_XML_CONFIG = 'com.rti.dds.domain.qos_element_name_use_xml_config'
property domain_entity_qos_library_name

The QoS library name containing the QoS profile from which the all the entities defined under the participant configuraton are created.

property domain_entity_qos_profile_name

The QoS profile name from which the all the entities defined under the participant configuraton are created.

property domain_id

The domain id from which the DomainParticipant is created.

property participant_name

The name assigned to the DomainParticipant.

property participant_qos_library_name

The name of the library containing the DomainParticipant’s QoS.

property participant_qos_profile_name

The name of the profile containing the DomainParticipant’s QoS.

class rti.connextdds.DomainParticipantFactoryQos

Bases: pybind11_builtins.pybind11_object

property entity_factory

Get/set EntityFactory QoS.

property system_resource_limits

Get/set SystemResourceLimits QoS.

class rti.connextdds.DomainParticipantListener

Bases: rti.connextdds.PublisherListener, rti.connextdds.SubscriberListener, rti.connextdds.AnyTopicListener

class rti.connextdds.DomainParticipantProtocolStatus

Bases: pybind11_builtins.pybind11_object

Protocol status of a DomainParticipant

property corrupted_rtps_message_count

The number of corrupted RTPS messages detected by the domain participant.

property corrupted_rtps_message_count_change

The incremental change in the number of corrupted RTPS messages detected by the domain participant since the last time the status was read.

property last_corrupted_message_timestamp

The timestamp when the last corrupted RTPS message was detected by the domain participant.

class rti.connextdds.DomainParticipantQos

Bases: pybind11_builtins.pybind11_object

property database

Get/set Database QoS.

property discovery

Get/set Discovery QoS.

property discovery_config

Get/set DiscoveryConfig QoS.

property entity_factory

Get/set EntityFactory QoS.

property event

Get/set Event QoS.

property participant_name

Get/set EntityName QoS.

property property

Get/set Property QoS.

property receiver_pool

Get/set ReceiverPool QoS.

property resource_limits

Get/set DomainParticipantResourceLimits QoS.

property service

Get/set Service QoS.

property transport_builtin

Get/set TransportBuiltin QoS.

property transport_multicast_mapping

Get/set TransportMulticastMapping QoS.

property user_data

Get/set UserData QoS.

property wire_protocol

Get/set WireProtocol QoS.

class rti.connextdds.DomainParticipantResourceLimits

Bases: pybind11_builtins.pybind11_object

property channel_filter_expression_max_length

Maximum length of a channel ChannelSettings.filter_expression in a MultiChannel DataWriter.

property channel_seq_max_length

Maximum number of channels that can be specified in MultiChannel for MultiChannel DataWriters.

property content_filter_allocation

Allocation settings applied to content filter.

This property’s getter returns a deep copy.

property content_filter_hash_buckets

Number of hash buckets for content filters.

property content_filtered_topic_allocation

Allocation settings applied to content filtered topic.

This property’s getter returns a deep copy.

property content_filtered_topic_hash_buckets

Number of hash buckets for content filtered topics.

property contentfilter_property_max_length

This field is the maximum length of all data related to a Content-filtered topic.

property deserialized_type_object_dynamic_allocation_threshold

A threshold, in bytes, for dynamic memory allocation for the deserialized TypeObject.

property flow_controller_allocation

Allocation settings applied to flow controllers.

This property’s getter returns a deep copy.

property flow_controller_hash_buckets

Number of hash buckets for flow controllers.

property ignored_entity_allocation

Allocation settings applied to ignored entities.

This property’s getter returns a deep copy.

property ignored_entity_hash_buckets

Number of hash buckets for ignored entities.

property ignored_entity_replacement_kind

Replacement policy for the ignored entities. It sets what entity can be replaced when resource limits set in DomainParticipantResourceLimits.ignored_entity_allocation are reached.

property local_publisher_allocation

Allocation settings applied to local Publisher.

This property’s getter returns a deep copy.

property local_publisher_hash_buckets

Number of hash buckets for local Publisher.

property local_reader_allocation

Allocation settings applied to local DataReaders.

This property’s getter returns a deep copy.

property local_reader_hash_buckets

Hash buckets settings applied to local DataReaders.

property local_subscriber_allocation

Allocation settings applied to local Subscriber.

This property’s getter returns a deep copy.

property local_subscriber_hash_buckets

Number of hash buckets for local Subscriber.

property local_topic_allocation

Allocation settings applied to local Topic.

This property’s getter returns a deep copy.

property local_topic_hash_buckets

Number of hash buckets for local Topic.

property local_writer_allocation

Allocation settings applied to local DataWriters.

This property’s getter returns a deep copy.

property local_writer_hash_buckets

Hash buckets settings applied to local DataWriters.

property matching_reader_writer_pair_allocation

Allocation settings applied to matching local reader and remote/local writer pairs.

This property’s getter returns a deep copy.

property matching_reader_writer_pair_hash_buckets

Number of hash buckets for matching local reader and remote/local writer pairs.

property matching_writer_reader_pair_allocation

Allocation settings applied to matching local writer and remote/local reader pairs.

This property’s getter returns a deep copy.

property matching_writer_reader_pair_hash_buckets

Number of hash buckets for matching local writer and remote/local reader pairs.

property max_endpoint_group_cumulative_characters

Maximum number of combined role_name characters allowed in all EndpointGroup in a Availability.

property max_endpoint_groups

Maximum number of EndpointGroup allowable in a Availability.

property max_gather_destinations

Maximum number of destinations per RTI Connext send.

property max_partition_cumulative_characters

Maximum number of combined characters allowable in all partition names in a Partition.

property max_partitions

Maximum number of partition name strings allowable in a Partition.

property outstanding_asynchronous_sample_allocation

Allocation settings applied to the maximum number of samples (from DataWriter) waiting to be asynchronously written.

This property’s getter returns a deep copy.

property participant_property_list_max_length

Maximum number of properties associated with the DomainParticipant.

property participant_property_string_max_length

Maximum string length of the properties associated with the DomainParticipant.

property participant_user_data_max_length

Maximum length of user data in DomainParticipantQos and ParticipantBuiltinTopicData.

property publisher_group_data_max_length

Maximum length of group data in PublisherQos and PublicationBuiltinTopicData.

property query_condition_allocation

Allocation settings applied to query condition pool.

This property’s getter returns a deep copy.

property read_condition_allocation

Allocation settings applied to read condition pool.

This property’s getter returns a deep copy.

property reader_data_tag_list_max_length

Maximum number of data tags associated with a DataReader.

property reader_data_tag_string_max_length

Maximum string length of the data tags associated with a DataReader.

property reader_property_list_max_length

Maximum number of properties associated with a DataReader.

property reader_property_string_max_length

Maximum string length of the properties associated with a DataReader.

property reader_user_data_max_length

Maximum length of user data in DataReaderQos and SubscriptionBuiltinTopicData.

property remote_participant_allocation

Allocation settings applied to remote DomainParticipants.

This property’s getter returns a deep copy.

property remote_participant_hash_buckets

Number of hash buckets for remote DomainParticipants.

property remote_reader_allocation

Allocation settings applied to remote DataReaders.

This property’s getter returns a deep copy.

property remote_reader_hash_buckets

Number of hash buckets for remote DataReaders.

property remote_topic_query_allocation

Allocation settings applied to remote TopicQueries.

This property’s getter returns a deep copy.

property remote_topic_query_hash_buckets

Number of hash buckets for remote TopicQueries.

property remote_writer_allocation

Allocation settings applied to remote DataWriters.

This property’s getter returns a deep copy.

property remote_writer_hash_buckets

Number of hash buckets for remote DataWriters.

property shmem_ref_transfer_mode_max_segments

Maximum number of segments created by all DataWriters belonging to a DomainParticipant.

property subscriber_group_data_max_length

Maximum length of group data in SubscriberQos and SubscriptionBuiltinTopicData.

property topic_data_max_length

Maximum length of topic data in TopicQos, TopicBuiltinTopicData, PublicationBuiltinTopicData and SubscriptionBuiltinTopicData.

property transport_info_list_max_length

Maximum number of installed transports to send and receive information about in ParticipantBuiltinTopicData.transport_info.

property type_code_max_serialized_length

Maximum size of serialized string for type code.

property type_object_max_deserialized_length

The maximum number of bytes that a deserialized TypeObject can consume.

property type_object_max_serialized_length

The maximum length, in bytes, that the buffer to serialize a TypeObject can consume.

property writer_data_tag_list_max_length

Maximum number of data tags associated with a DataWriter.

property writer_data_tag_string_max_length

Maximum string length of the data tags associated with a DataWriter.

property writer_property_list_max_length

Maximum number of properties associated with a DataWriter.

property writer_property_string_max_length

Maximum string length of the properties associated with a DataWriter.

property writer_user_data_max_length

Maximum length of user data in DataWriterQos and PublicationBuiltinTopicData.

class rti.connextdds.DomainParticipantSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.DomainParticipantSeq, x: rti.connextdds.DomainParticipant) → None

Add an item to the end of the list

clear(self: rti.connextdds.DomainParticipantSeq) → None

Clear the contents

count(self: rti.connextdds.DomainParticipantSeq, x: rti.connextdds.DomainParticipant) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.DomainParticipantSeq, L: rti.connextdds.DomainParticipantSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.DomainParticipantSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.DomainParticipantSeq, i: int, x: rti.connextdds.DomainParticipant) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.DomainParticipantSeq) -> rti.connextdds.DomainParticipant

Remove and return the last item

  1. pop(self: rti.connextdds.DomainParticipantSeq, i: int) -> rti.connextdds.DomainParticipant

Remove and return the item at index i

remove(self: rti.connextdds.DomainParticipantSeq, x: rti.connextdds.DomainParticipant) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

rti.connextdds.DoubleSeq

alias of rti.connextdds.Float64Seq

rti.connextdds.DoubleType

alias of rti.connextdds.Float64Type

class rti.connextdds.Durability

Bases: pybind11_builtins.pybind11_object

property direct_communication

Get/set whether a DataReader should receive samples directly from a TRANSIENT or PERSISTENT DataWriter.

property kind

Get/set the Durability kind.

static persistent()rti.connextdds.Durability

Create a Durability QoS policy with kind set to PERSISTENT.

static transient()rti.connextdds.Durability

Create a Durability QoS policy with kind set to TRANSIENT.

static transient_local()rti.connextdds.Durability

Create a Durability QoS policy with kind set to TRANSIENT_LOCAL.

static volatile()rti.connextdds.Durability

Create a Durability QoS policy with kind set to VOLATILE.

class rti.connextdds.DurabilityKind

Bases: pybind11_builtins.pybind11_object

class DurabilityKind

Bases: pybind11_builtins.pybind11_object

Members:

VOLATILE : [default] RTI Connext does not need to keep any samples of data instances on behalf of any DataReader that is unknown by the DataWriter at the time the instance is written.

In other words, RTI Connext will only attempt to provide the data to existing subscribers.

This option does not require RTI Persistence Service.

TRANSIENT_LOCAL : RTI Connext will attempt to keep some samples so that they can be delivered to any potential late-joining DataReader.

Which particular samples are kept depends on other QoS such as History and ResourceLimits. RTI Connext is only required to keep the data in memory of the DataWriter that wrote the data.

Data is not required to survive the DataWriter.

For this setting to be effective, you must also set the Reliability.kind to ReliabilityKind.RELIABLE.

This option does not require RTI Persistence Service.

TRANSIENT : RTI Connext will attempt to keep some samples so that they can be delivered to any potential late-joining DataReader.

Which particular samples are kept depends on other QoS such as History and ResourceLimits. RTI Connext is only required to keep the data in memory and not in permanent storage.

Data is not tied to the lifecycle of the DataWriter.

Data will survive the DataWriter.

This option requires RTI Persistence Service.

PERSISTENT : Data is kept on permanent storage, so that they can outlive a system session.

This option requires RTI Persistence Service.

PERSISTENT = DurabilityKind.PERSISTENT
TRANSIENT = DurabilityKind.TRANSIENT
TRANSIENT_LOCAL = DurabilityKind.TRANSIENT_LOCAL
VOLATILE = DurabilityKind.VOLATILE
property name

(self: handle) -> str

PERSISTENT = DurabilityKind.PERSISTENT
TRANSIENT = DurabilityKind.TRANSIENT
TRANSIENT_LOCAL = DurabilityKind.TRANSIENT_LOCAL
VOLATILE = DurabilityKind.VOLATILE
property underlying

Retrieves the actual enumerated value.

class rti.connextdds.DurabilityService

Bases: pybind11_builtins.pybind11_object

property history_depth

Controls when the service is able to remove all information regarding a data instances.

property history_kind

Controls when the service is able to remove all information regarding a data instances.

property max_instances

Controls when the service is able to remove all information regarding a data instances.

property max_samples

Controls when the service is able to remove all information regarding a data instances.

property max_samples_per_instance

Controls when the service is able to remove all information regarding a data instances.

property service_cleanup_delay

Controls when the service is able to remove all information regarding a data instances.

class rti.connextdds.Duration

Bases: pybind11_builtins.pybind11_object

static automatic()rti.connextdds.Duration

Create a special Duration value to indicate a value should be selected automatically.

compare(self: rti.connextdds.Duration, other: rti.connextdds.Duration) → int

Compare this Duration to another. Returns -1 if this Duration is less, 0 if they are equal, and 1 if this Duration is greate

static from_microseconds(microseconds: int)rti.connextdds.Duration

Get a Duration from microseconds.

static from_milliseconds(milliseconds: int)rti.connextdds.Duration

Get a Duration from milliseconds.

static from_seconds(seconds: float)rti.connextdds.Duration

Get a Duration from seconds

static infinite()rti.connextdds.Duration

Create an infinite Duration

property nanosec

Get/set the number of nanoseconds in the Duration.

property sec

Get/set the number of seconds in the Duration.

to_microseconds(self: rti.connextdds.Duration) → int

Returns Duration in microseconds.

to_milliseconds(self: rti.connextdds.Duration) → int

Returns Duration in milliseconds.

to_seconds(self: rti.connextdds.Duration) → float

Return the Duration in seconds.

to_timedelta(self: rti.connextdds.Duration) → datetime.timedelta

Return the datetime.timedelta conversion of this Duration.

static zero()rti.connextdds.Duration

Create a Duration of zero.

class rti.connextdds.DynamicData

Bases: pybind11_builtins.pybind11_object

class ContentFilter

Bases: rti.connextdds.ContentFilterBase

compile(self: rti.connextdds.DynamicData.ContentFilter, expression: str, parameters: rti.connextdds.StringSeq, type_code: Optional[rti.connextdds.DynamicType], type_class_name: str, old_compile_data: Optional[object]) → Optional[object]

Compile an instance of the content filter according to the filter expression and parameters of the given data type.

evaluate(self: rti.connextdds.DynamicData.ContentFilter, compile_data: Optional[object], sample: rti.connextdds.DynamicData, meta_data: rti.connextdds.FilterSampleInfo) → bool

Evaluate whether the sample is passing the filter or not according to the sample content.

finalize(self: rti.connextdds.DynamicData.ContentFilter, compile_data: Optional[object]) → None

A previously compiled instance of the content filter is no longer in use and resources can now be cleaned up.

class ContentFilteredTopic

Bases: rti.connextdds.DynamicData.ITopicDescription, rti.connextdds.IAnyTopic

append_to_expression_parameter(self: rti.connextdds.DynamicData.ContentFilteredTopic, index: int, extension: str) → None

Append the extension to the end of parameter at the provided index, separated by a comma.

property filter_expression

Get the filter expression

property filter_parameters

Get/set the filter parameters.

remove_from_expression_parameter(self: rti.connextdds.DynamicData.ContentFilteredTopic, index: int, remove_term: str) → None

Removes the specified term from the parameter at the provided index.

set_filter(self: rti.connextdds.DynamicData.ContentFilteredTopic, arg0: rti.connextdds.Filter) → None

Set the filter.

property topic

Get the underlying Topic.

class ContentFilteredTopicSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.DynamicData.ContentFilteredTopicSeq, x: rti.connextdds.DynamicData.ContentFilteredTopic) → None

Add an item to the end of the list

clear(self: rti.connextdds.DynamicData.ContentFilteredTopicSeq) → None

Clear the contents

count(self: rti.connextdds.DynamicData.ContentFilteredTopicSeq, x: rti.connextdds.DynamicData.ContentFilteredTopic) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.DynamicData.ContentFilteredTopicSeq, L: rti.connextdds.DynamicData.ContentFilteredTopicSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.DynamicData.ContentFilteredTopicSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.DynamicData.ContentFilteredTopicSeq, i: int, x: rti.connextdds.DynamicData.ContentFilteredTopic) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.DynamicData.ContentFilteredTopicSeq) -> rti.connextdds.DynamicData.ContentFilteredTopic

Remove and return the last item

  1. pop(self: rti.connextdds.DynamicData.ContentFilteredTopicSeq, i: int) -> rti.connextdds.DynamicData.ContentFilteredTopic

Remove and return the item at index i

remove(self: rti.connextdds.DynamicData.ContentFilteredTopicSeq, x: rti.connextdds.DynamicData.ContentFilteredTopic) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class DataReader

Bases: rti.connextdds.IDataReader

class Selector

Bases: pybind11_builtins.pybind11_object

condition(self: rti.connextdds.DynamicData.DataReader.Selector, condition: rti.connextdds.IReadCondition)rti.connextdds.DynamicData.DataReader.Selector

Select samples based on a ReadCondition.

content(self: rti.connextdds.DynamicData.DataReader.Selector, query: rti.connextdds.Query)rti.connextdds.DynamicData.DataReader.Selector

Select samples based on a Query.

instance(self: rti.connextdds.DynamicData.DataReader.Selector, handle: rti.connextdds.InstanceHandle)rti.connextdds.DynamicData.DataReader.Selector

Select a specific instance to read/take.

max_samples(self: rti.connextdds.DynamicData.DataReader.Selector, max: int)rti.connextdds.DynamicData.DataReader.Selector

Limit the number of samples read/taken by the Select.

next_instance(self: rti.connextdds.DynamicData.DataReader.Selector, previous: rti.connextdds.InstanceHandle)rti.connextdds.DynamicData.DataReader.Selector

Select the instance after the specified instance to read/take.

read(self: rti.connextdds.DynamicData.DataReader.Selector)rti.connextdds.DynamicData.LoanedSamples

Read samples based on Selector settings.

read_valid(self: rti.connextdds.DynamicData.DataReader.Selector)rti.connextdds.DynamicData.ValidLoanedSamples

Read valid samples based on Selector settings.

state(self: rti.connextdds.DynamicData.DataReader.Selector, state: rti.connextdds.DataState)rti.connextdds.DynamicData.DataReader.Selector

Select samples with a specified data state.

take(self: rti.connextdds.DynamicData.DataReader.Selector)rti.connextdds.DynamicData.LoanedSamples

Take samples based on Selector settings.

take_valid(self: rti.connextdds.DynamicData.DataReader.Selector)rti.connextdds.DynamicData.ValidLoanedSamples

Take valid samples based on Selector settings.

acknowledge_all(*args, **kwargs)

Overloaded function.

  1. acknowledge_all(self: rti.connextdds.DynamicData.DataReader) -> None

Acknowledge all previously accessed samples.

  1. acknowledge_all(self: rti.connextdds.DynamicData.DataReader, arg0: rti.connextdds.AckResponseData) -> None

Acknowledge all previously accessed samples.

acknowledge_sample(self: rti.connextdds.DynamicData.DataReader, sample_info: rti.connextdds.SampleInfo) → None

Acknowledge a single sample.

bind_listener(self: rti.connextdds.DynamicData.DataReader, listener: Optional[rti.connextdds.DynamicData.DataReaderListener], event_mask: rti.connextdds.StatusMask) → None

Set the listener and associated event mask.

close(self: rti.connextdds.DynamicData.DataReader) → None

Close this DataReader.

property datareader_cache_status

Get the DataReaderCacheStatus for the DataReader.

property datareader_protocol_status

Get the DataReaderProtocolStatus for the DataReader.

property default_filter_state

Returns the filter state for the read/take operations.

static find_all_by_topic(subscriber: rti.connextdds.Subscriber, topic_name: str)rti.connextdds.DynamicData.DataReaderSeq

Retrieve all DataReaders for the given topic name in the subscriber.

static find_by_name(*args, **kwargs)

Overloaded function.

  1. find_by_name(participant: rti.connextdds.DomainParticipant, name: str) -> Optional[rti.connextdds.DynamicData.DataReader]

Find DataReader in DomainParticipant with the DataReader’s name, returning the first found.

  1. find_by_name(subscriber: rti.connextdds.Subscriber, name: str) -> Optional[rti.connextdds.DynamicData.DataReader]

Find DataReader in Subscriber with the DataReader’s name, returning the first found.

static find_by_topic(subscriber: rti.connextdds.Subscriber, name: str) → Optional[rti.connextdds.DynamicData.DataReader]

Find DataReader in Subscriber with a topic name, returning the first found.

is_data_consistent(*args, **kwargs)

Overloaded function.

  1. is_data_consistent(self: rti.connextdds.DynamicData.DataReader, sample_data: rti.connextdds.DynamicData, sample_info: rti.connextdds.SampleInfo) -> bool

Checks if the sample has been overwritten by the DataWriter.

  1. is_data_consistent(self: rti.connextdds.DynamicData.DataReader, sample: rti.connextdds.DynamicData.Sample) -> bool

Checks if the sample has been overwritten by the DataWriter.

  1. is_data_consistent(self: rti.connextdds.DynamicData.DataReader, sample: rti.connextdds.DynamicData.LoanedSample) -> bool

Checks if the sample has been overwritten by the DataWriter.

key_value(self: rti.connextdds.DynamicData.DataReader, handle: rti.connextdds.InstanceHandle)rti.connextdds.DynamicData

Retrieve the instance key that corresponds to an instance handle.

property listener

Get the listener object.

property liveliness_changed_status

Get the LivelinessChangedStatus for this DataReader.

matched_publication_datareader_protocol_status(self: rti.connextdds.DynamicData.DataReader, publication_handle: rti.connextdds.InstanceHandle)rti.connextdds.DataReaderProtocolStatus

Get the DataReaderProtocolStatus for the DataReader based on the matched publication handle.

property qos

The DataReaderQos for this DataReader.

This property’s getter returns a deep copy.

read(self: rti.connextdds.DynamicData.DataReader)rti.connextdds.DynamicData.LoanedSamples

Read all samples using the default filter state

read_next(self: rti.connextdds.DynamicData.DataReader) → Optional[rti.connextdds.DynamicData.Sample]

Copy the next not-previously-accessed data value from the DataReader via a read operation.

read_valid(self: rti.connextdds.DynamicData.DataReader)rti.connextdds.DynamicData.ValidLoanedSamples

Read only valid samples.

property requested_deadline_missed_status

Get the RequestedDeadlineMissed status for the DataReader

property requested_incompatible_qos_status

Get the RequestedIncompatibleQosStatus for the DataReader.

property sample_lost_status

Get the SampleLostStatus for the DataReader.

property sample_rejected_status

Get the SampleRejectedStatus for the DataReader.

select(self: rti.connextdds.DynamicData.DataReader)rti.connextdds.DynamicData.DataReader.Selector

Get a Selector to perform complex data selections, such as per-instance selection, content, and status filtering.

property subscriber

Returns the parent Subscriber of the DataReader.

property subscription_matched_status

Get the SubscriptionMatchedStatus for the DataReader.

take(self: rti.connextdds.DynamicData.DataReader)rti.connextdds.DynamicData.LoanedSamples

Take all samples using the default filter state

take_next(self: rti.connextdds.DynamicData.DataReader) → Optional[rti.connextdds.DynamicData.Sample]

Copy the next not-previously-accessed data value from the DataReader via a take operation.

take_valid(self: rti.connextdds.DynamicData.DataReader)rti.connextdds.DynamicData.ValidLoanedSamples

Take only valid samples.

property topic_description

Returns the TopicDescription associated with the DataReader.

topic_instance_key_value(self: rti.connextdds.DynamicData.DataReader, handle: rti.connextdds.InstanceHandle)rti.connextdds.DynamicData.TopicInstance

Retrieve the instance key that corresponds to an instance handle.

property topic_name

Get the topic name associated with this DataReader.

property type_name

Get the type name associated with this DataReader.

wait_for_historical_data(self: rti.connextdds.DynamicData.DataReader, max_wait: rti.connextdds.Duration) → None

Waits until all “historical” data is received for DataReaders that have a non-VOLATILE Durability Qos kind.

wait_for_historical_data_async(self: rti.connextdds.DynamicData.DataReader, max_wait: rti.connextdds.Duration) → object

Waits until all “historical” data is received for DataReaders that have a non-VOLATILE Durability Qos kind. This call is awaitable and only for use with asyncio.

class DataReaderListener

Bases: pybind11_builtins.pybind11_object

on_data_available(self: rti.connextdds.DynamicData.DataReaderListener, arg0: rti.connextdds.DynamicData.DataReader) → None

Data available callback.

on_liveliness_changed(self: rti.connextdds.DynamicData.DataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.LivelinessChangedStatus) → None

Liveliness changed callback.

on_requested_deadline_missed(self: rti.connextdds.DynamicData.DataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.RequestedDeadlineMissedStatus) → None

Requested deadline missed callback.

on_requested_incompatible_qos(self: rti.connextdds.DynamicData.DataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.RequestedIncompatibleQosStatus) → None

Requested incompatible QoS callback.

on_sample_lost(self: rti.connextdds.DynamicData.DataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.SampleLostStatus) → None

Sample lost callback.

on_sample_rejected(self: rti.connextdds.DynamicData.DataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.SampleRejectedStatus) → None

Sample rejected callback.

on_subscription_matched(self: rti.connextdds.DynamicData.DataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.SubscriptionMatchedStatus) → None

Subscription matched callback.

class DataReaderSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.DynamicData.DataReaderSeq, x: rti.connextdds.DynamicData.DataReader) → None

Add an item to the end of the list

clear(self: rti.connextdds.DynamicData.DataReaderSeq) → None

Clear the contents

count(self: rti.connextdds.DynamicData.DataReaderSeq, x: rti.connextdds.DynamicData.DataReader) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.DynamicData.DataReaderSeq, L: rti.connextdds.DynamicData.DataReaderSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.DynamicData.DataReaderSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.DynamicData.DataReaderSeq, i: int, x: rti.connextdds.DynamicData.DataReader) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.DynamicData.DataReaderSeq) -> rti.connextdds.DynamicData.DataReader

Remove and return the last item

  1. pop(self: rti.connextdds.DynamicData.DataReaderSeq, i: int) -> rti.connextdds.DynamicData.DataReader

Remove and return the item at index i

remove(self: rti.connextdds.DynamicData.DataReaderSeq, x: rti.connextdds.DynamicData.DataReader) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class DataWriter

Bases: rti.connextdds.IEntity, rti.connextdds.IAnyDataWriter

assert_liveliness(self: rti.connextdds.DynamicData.DataWriter) → None

Manually asserts the liveliness of the DataWriter.

bind_listener(self: rti.connextdds.DynamicData.DataWriter, listener: Optional[rti.connextdds.DynamicData.DataWriterListener], event_mask: rti.connextdds.StatusMask) → None

Set the listener and event mask for the DataWriter.

create_data(self: rti.connextdds.DynamicData.DataWriter)rti.connextdds.DynamicData

Create data of the writer’s associated type and initialize it.

property datawriter_cache_status

Get a copy of the cache status for this writer.

property datawriter_protocol_status

Get a copy of the protocol status for this writer.

dispose_instance(*args, **kwargs)

Overloaded function.

  1. dispose_instance(self: rti.connextdds.DynamicData.DataWriter, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.DynamicData.DataWriter

Dispose an instance.

  1. dispose_instance(self: rti.connextdds.DynamicData.DataWriter, handle: rti.connextdds.InstanceHandle, timestamp: rti.connextdds.Time) -> rti.connextdds.DynamicData.DataWriter

Dispose an instance with a timestamp.

  1. dispose_instance(self: rti.connextdds.DynamicData.DataWriter, key_holder: rti.connextdds.DynamicData) -> rti.connextdds.DynamicData.DataWriter

Dispose the instance associated with key_holder.

  1. dispose_instance(self: rti.connextdds.DynamicData.DataWriter, key_holder: rti.connextdds.DynamicData, timestamp: rti.connextdds.Time) -> rti.connextdds.DynamicData.DataWriter

Dispose the instance associated with key_holder using a timestamp

  1. dispose_instance(self: rti.connextdds.DynamicData.DataWriter, params: rti.connextdds.WriteParams) -> None

Dispose an instance with params.

static find_all_by_topic(publisher: rti.connextdds.Publisher, topic_name: str)rti.connextdds.DynamicData.DataWriterSeq

Retrieve all DataWriters for the given topic name in the publisher.

static find_by_name(*args, **kwargs)

Overloaded function.

  1. find_by_name(participant: rti.connextdds.DomainParticipant, name: str) -> Optional[rti.connextdds.DynamicData.DataWriter]

Find DataWriter in DomainParticipant with the provided name, returning the first found.

  1. find_by_name(publisher: rti.connextdds.Publisher, name: str) -> Optional[rti.connextdds.DynamicData.DataWriter]

Find DataWriter in Publisher with the DataReader’s name, returning the first found.

static find_by_topic(publisher: rti.connextdds.Publisher, name: str) → Optional[rti.connextdds.DynamicData.DataWriter]

Find DataWriter in publisher with a topic name, returning the first found.

flush(self: rti.connextdds.DynamicData.DataWriter) → None

Flushes the batch in progress in the context of the calling thread.

is_sample_app_acknowledged(self: rti.connextdds.DynamicData.DataWriter, sample_id: rti.connextdds.SampleIdentity) → bool

Indicates if a sample is considered application-acknowledged.

key_value(*args, **kwargs)

Overloaded function.

  1. key_value(self: rti.connextdds.DynamicData.DataWriter, key_holder: rti.connextdds.DynamicData, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.DynamicData

Retrieve the instance key that corresponds to an instance handle.

  1. key_value(self: rti.connextdds.DynamicData.DataWriter, topic_instance: rti.connextdds.DynamicData.TopicInstance, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.DynamicData.TopicInstance

Retrieve the instance key that corresponds to an instance handle.

  1. key_value(self: rti.connextdds.DynamicData.DataWriter, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.DynamicData

Retrieve the instance key that corresponds to an instance handle.

property listener

Get the listener associated with the DataWriter or set the listener and status mask as a tuple.

property liveliness_lost_status

Get a copy of the LivelinessLostStatus.

lookup_instance(self: rti.connextdds.DynamicData.DataWriter, key_holder: rti.connextdds.DynamicData)rti.connextdds.InstanceHandle

Retrieve the instance handle that corresponds to an instance key_holder

matched_subscription_data(self: rti.connextdds.DynamicData.DataWriter, handle: rti.connextdds.InstanceHandle)rti.connextdds.SubscriptionBuiltinTopicData

Get the SubscriptionBuiltinTopicData for a subscription matched to this DataWriter.

matched_subscription_datawriter_procotol_status(*args, **kwargs)

Overloaded function.

  1. matched_subscription_datawriter_procotol_status(self: rti.connextdds.DynamicData.DataWriter, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.DataWriterProtocolStatus

Get a copy of the protocol status for this writer per a matched subscription handle.

  1. matched_subscription_datawriter_procotol_status(self: rti.connextdds.DynamicData.DataWriter, locator: rti.connextdds.Locator) -> rti.connextdds.DataWriterProtocolStatus

Get a copy of the protocol status for this writer per a matched subscription locator.

property matched_subscriptions

Get a copy of the list of the currently matched subscription handles.

property offered_deadline_missed_status

Get a copy of the OfferedDeadlineMissedStatus.

property offered_incompatible_qos_status

Get a copy of the OfferedIncompatibleQosStatus

property publication_matched_status

Get a copy of the PublicationMatchedStatus

property publisher

Get the Publisher that owns this DataWriter.

property qos

The DataWriterQos for this DataWriter.

This property’s getter returns a deep copy.

register_instance(*args, **kwargs)

Overloaded function.

  1. register_instance(self: rti.connextdds.DynamicData.DataWriter, handle: rti.connextdds.DynamicData) -> rti.connextdds.InstanceHandle

Informs RTI Connext that the application will be modifying a particular instance.

  1. register_instance(self: rti.connextdds.DynamicData.DataWriter, handle: rti.connextdds.DynamicData, timestamp: rti.connextdds.Time) -> rti.connextdds.InstanceHandle

Informs RTI Connext that the application will be modifying a particular instance and specified the timestamp.

  1. register_instance(self: rti.connextdds.DynamicData.DataWriter, key_holder: rti.connextdds.DynamicData, params: rti.connextdds.WriteParams) -> None

Registers instance with parameters.

property reliable_reader_activity_changed_status

Get a copy of the reliable reader activity changed status for this writer.

property reliable_writer_cache_changed_status

Get a copy of the reliable cache status for this writer.

property service_request_accepted_status

Get a copy of the service request accepted status for this writer.

property topic

Get the Topic object associated with this DataWriter.

topic_instance_key_value(self: rti.connextdds.DynamicData.DataWriter, handle: rti.connextdds.InstanceHandle)rti.connextdds.DynamicData.TopicInstance

Retrieve the instance key that corresponds to an instance handle.

property topic_name

Get the topic name associated with this DataWriter.

property type_name

Get the type name for the topic object associated with this DataWriter.

unregister_instance(*args, **kwargs)

Overloaded function.

  1. unregister_instance(self: rti.connextdds.DynamicData.DataWriter, handle: rti.connextdds.InstanceHandle) -> rti.connextdds.DynamicData.DataWriter

Unregister an instance.

  1. unregister_instance(self: rti.connextdds.DynamicData.DataWriter, handle: rti.connextdds.InstanceHandle, timestamp: rti.connextdds.Time) -> rti.connextdds.DynamicData.DataWriter

Unregister an instance with timestamp.

  1. unregister_instance(self: rti.connextdds.DynamicData.DataWriter, key_holder: rti.connextdds.DynamicData) -> rti.connextdds.DynamicData.DataWriter

Unregister the instance associated with key_holder.

  1. unregister_instance(self: rti.connextdds.DynamicData.DataWriter, key_holder: rti.connextdds.DynamicData, timestamp: rti.connextdds.Time) -> rti.connextdds.DynamicData.DataWriter

Unregister the instance associate with key_holder using a timestamp.

  1. unregister_instance(self: rti.connextdds.DynamicData.DataWriter, params: rti.connextdds.WriteParams) -> None

Unregister an instance with parameters.

wait_for_acknowledgments(self: rti.connextdds.DynamicData.DataWriter, max_wait: rti.connextdds.Duration) → None

Blocks the calling thread until all data written by a realiable DataWriter is acknowledged or until the timeout expires.

wait_for_asynchronous_publishing(self: rti.connextdds.DynamicData.DataWriter, max_wait: rti.connextdds.Duration) → None

This operation blocks the calling thread (up to max_wait) until all data written by the asynchronous DataWriter is sent and acknowledged (if reliable) by all matched DataReader entities. A successful completion indicates that all the samples written have been sent and acknowledged where applicable; a time out indicates that max_wait elapsed before all the data was sent and/or acknowledged.

In other words, this guarantees that sending to best effort DataReader is complete in addition to what DataWriter.wait_for_acknowledgments() provides.

If the DataWriter does not have PublishMode kind set to PublishModeKind.ASYNCHRONOUS the operation will complete immediately

write(*args, **kwargs)

Overloaded function.

  1. write(self: rti.connextdds.DynamicData.DataWriter, sample: rti.connextdds.DynamicData) -> None

Write a sample.

  1. write(self: rti.connextdds.DynamicData.DataWriter, sample: rti.connextdds.DynamicData, timestamp: rti.connextdds.Time) -> None

Write a sample with a specified timestamp.

  1. write(self: rti.connextdds.DynamicData.DataWriter, sample: rti.connextdds.DynamicData, handle: rti.connextdds.InstanceHandle) -> None

Write a sample with an instance handle.

  1. write(self: rti.connextdds.DynamicData.DataWriter, sample: rti.connextdds.DynamicData, handle: rti.connextdds.InstanceHandle, timestamp: rti.connextdds.Time) -> None

Write a sample with an instance handle and specified timestamp.

  1. write(self: rti.connextdds.DynamicData.DataWriter, topic_instance: rti.connextdds.DynamicData.TopicInstance) -> None

Write a sample given a topic instance.

  1. write(self: rti.connextdds.DynamicData.DataWriter, topic_instance: rti.connextdds.DynamicData.TopicInstance, timestamp: rti.connextdds.Time) -> None

Write a sample given a topic instance and specified timestamp.

  1. write(self: rti.connextdds.DynamicData.DataWriter, samples: rti.connextdds.DynamicDataSeq) -> None

Write a sequence of samples.

  1. write(self: rti.connextdds.DynamicData.DataWriter, topic_instances: rti.connextdds.DynamicData.TopicInstanceSeq) -> None

Write a sequence of topic instances.

  1. write(self: rti.connextdds.DynamicData.DataWriter, samples: rti.connextdds.DynamicDataSeq, timestamp: rti.connextdds.Time) -> None

Write a sequence of samples with a timestamp.

  1. write(self: rti.connextdds.DynamicData.DataWriter, topic_instances: rti.connextdds.DynamicData.TopicInstanceSeq, timestamp: rti.connextdds.Time) -> None

Write a sequence of topic instances with a timestamp.

  1. write(self: rti.connextdds.DynamicData.DataWriter, samples: rti.connextdds.DynamicDataSeq, handles: rti.connextdds.InstanceHandleSeq) -> None

Write a sequence of samples with their instance handles.

  1. write(self: rti.connextdds.DynamicData.DataWriter, samples: rti.connextdds.DynamicDataSeq, handles: rti.connextdds.InstanceHandleSeq, timestamp: rti.connextdds.Time) -> None

Write a sequence of samples with their instance handles and a timestamp.

  1. write(self: rti.connextdds.DynamicData.DataWriter, sample: rti.connextdds.DynamicData, params: rti.connextdds.WriteParams) -> None

Write with advanced parameters.

  1. write(self: rti.connextdds.DynamicData.DataWriter, sample_data: dict) -> None

Create a DynamicData object and write it with the given dictionary containing field names as keys.

write_async(*args, **kwargs)

Overloaded function.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, sample: rti.connextdds.DynamicData) -> object

Write a sample. This method is awaitable and is only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, sample: rti.connextdds.DynamicData, timestamp: rti.connextdds.Time) -> object

Write a sample with a specified timestamp. This methods is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, sample: rti.connextdds.DynamicData, handle: rti.connextdds.InstanceHandle) -> object

Write a sample with an instance handle. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, sample: rti.connextdds.DynamicData, handle: rti.connextdds.InstanceHandle, timestamp: rti.connextdds.Time) -> object

Write a sample with an instance handle and specified timestamp. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, topic_instance: rti.connextdds.DynamicData.TopicInstance) -> object

Write a sample given a topic instance. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, topic_instance: rti.connextdds.DynamicData.TopicInstance, timestamp: rti.connextdds.Time) -> object

Write a sample given a topic instance and specified timestamp. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, samples: rti.connextdds.DynamicDataSeq) -> object

Write a sequence of samples. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, topic_instances: rti.connextdds.DynamicData.TopicInstanceSeq) -> object

Write a sequence of topic instances. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, samples: rti.connextdds.DynamicDataSeq, timestamp: rti.connextdds.Time) -> object

Write a sequence of samples with a timestamp. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, topic_instances: rti.connextdds.DynamicData.TopicInstanceSeq, timestamp: rti.connextdds.Time) -> object

Write a sequence of topic instances with a timestamp. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, samples: rti.connextdds.DynamicDataSeq, handles: rti.connextdds.InstanceHandleSeq) -> object

Write a sequence of samples with their instance handles. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, samples: rti.connextdds.DynamicDataSeq, handles: rti.connextdds.InstanceHandleSeq, timestamp: rti.connextdds.Time) -> object

Write a sequence of samples with their instance handles and a timestamp. This method is awaitable and only for use with asyncio.

  1. write_async(self: rti.connextdds.DynamicData.DataWriter, sample_data: dict) -> object

Create a DynamicData object and write it with the given dictionary containing field names as keys. This method is awaitable and is only for use with asyncio.

class DataWriterListener

Bases: pybind11_builtins.pybind11_object

on_application_acknowledgment(self: rti.connextdds.DynamicData.DataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.AcknowledgmentInfo) → None

On application acknowledgment callback

on_instance_replaced(self: rti.connextdds.DynamicData.DataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.InstanceHandle) → None

On instance replaced callback.

on_liveliness_lost(self: rti.connextdds.DynamicData.DataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.LivelinessLostStatus) → None

Liveliness lost callback.

on_offered_deadline_missed(self: rti.connextdds.DynamicData.DataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.OfferedDeadlineMissedStatus) → None

Offered deadline missed callback.

on_offered_incompatible_qos(self: rti.connextdds.DynamicData.DataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.OfferedIncompatibleQosStatus) → None

Offered incompatible QoS callback.

on_publication_matched(self: rti.connextdds.DynamicData.DataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.PublicationMatchedStatus) → None

Publication matched callback.

on_reliable_reader_activity_changed(self: rti.connextdds.DynamicData.DataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.ReliableReaderActivityChangedStatus) → None

Reliable reader activity changed callback.

on_reliable_writer_cache_changed(self: rti.connextdds.DynamicData.DataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.ReliableWriterCacheChangedStatus) → None

Reliable writer cache changed callback.

on_service_request_accepted(self: rti.connextdds.DynamicData.DataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.ServiceRequestAcceptedStatus) → None

On service request accepted callback.

class DataWriterSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.DynamicData.DataWriterSeq, x: rti.connextdds.DynamicData.DataWriter) → None

Add an item to the end of the list

clear(self: rti.connextdds.DynamicData.DataWriterSeq) → None

Clear the contents

count(self: rti.connextdds.DynamicData.DataWriterSeq, x: rti.connextdds.DynamicData.DataWriter) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.DynamicData.DataWriterSeq, L: rti.connextdds.DynamicData.DataWriterSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.DynamicData.DataWriterSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.DynamicData.DataWriterSeq, i: int, x: rti.connextdds.DynamicData.DataWriter) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.DynamicData.DataWriterSeq) -> rti.connextdds.DynamicData.DataWriter

Remove and return the last item

  1. pop(self: rti.connextdds.DynamicData.DataWriterSeq, i: int) -> rti.connextdds.DynamicData.DataWriter

Remove and return the item at index i

remove(self: rti.connextdds.DynamicData.DataWriterSeq, x: rti.connextdds.DynamicData.DataWriter) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class FieldsIterator

Bases: pybind11_builtins.pybind11_object

class FieldsView

Bases: pybind11_builtins.pybind11_object

class ITopicDescription

Bases: rti.connextdds.IEntity

property name

The name of the entity conforming to the ITopicDescription interface.

property participant

The parent DomainParticipant.

property type_name

The name of the associated type.

class IndexIterator

Bases: pybind11_builtins.pybind11_object

class ItemsIterator

Bases: pybind11_builtins.pybind11_object

class ItemsView

Bases: pybind11_builtins.pybind11_object

class LoanedSample

Bases: pybind11_builtins.pybind11_object

property data

Get the data associated with the sample.

property info

Get the info associated with the sample.

class LoanedSamples

Bases: pybind11_builtins.pybind11_object

property length

Get the number of samples in the loan.

return_loan(self: rti.connextdds.DynamicData.LoanedSamples) → None

Returns the loan to the DataReader.

class NoOpDataReaderListener

Bases: rti.connextdds.DynamicData.DataReaderListener

on_data_available(self: rti.connextdds.DynamicData.NoOpDataReaderListener, arg0: rti.connextdds.DynamicData.DataReader) → None

Data available callback.

on_liveliness_changed(self: rti.connextdds.DynamicData.NoOpDataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.LivelinessChangedStatus) → None

Liveliness changed callback.

on_requested_deadline_missed(self: rti.connextdds.DynamicData.NoOpDataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.RequestedDeadlineMissedStatus) → None

Requested deadline missed callback.

on_requested_incompatible_qos(self: rti.connextdds.DynamicData.NoOpDataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.RequestedIncompatibleQosStatus) → None

Requested incompatible QoS callback.

on_sample_lost(self: rti.connextdds.DynamicData.NoOpDataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.SampleLostStatus) → None

Sample lost callback.

on_sample_rejected(self: rti.connextdds.DynamicData.NoOpDataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.SampleRejectedStatus) → None

Sample rejected callback.

on_subscription_matched(self: rti.connextdds.DynamicData.NoOpDataReaderListener, arg0: rti.connextdds.DynamicData.DataReader, arg1: rti.connextdds.SubscriptionMatchedStatus) → None

Subscription matched callback.

class NoOpDataWriterListener

Bases: rti.connextdds.DynamicData.DataWriterListener

on_application_acknowledgment(self: rti.connextdds.DynamicData.NoOpDataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.AcknowledgmentInfo) → None

On application acknowledgment callback

on_instance_replaced(self: rti.connextdds.DynamicData.NoOpDataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.InstanceHandle) → None

On instance replaced callback.

on_liveliness_lost(self: rti.connextdds.DynamicData.NoOpDataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.LivelinessLostStatus) → None

Liveliness lost callback.

on_offered_deadline_missed(self: rti.connextdds.DynamicData.NoOpDataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.OfferedDeadlineMissedStatus) → None

Offered deadline missed callback.

on_offered_incompatible_qos(self: rti.connextdds.DynamicData.NoOpDataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.OfferedIncompatibleQosStatus) → None

Offered incompatible QoS callback.

on_publication_matched(self: rti.connextdds.DynamicData.NoOpDataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.PublicationMatchedStatus) → None

Publication matched callback.

on_reliable_reader_activity_changed(self: rti.connextdds.DynamicData.NoOpDataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.ReliableReaderActivityChangedStatus) → None

Reliable reader activity changed callback.

on_reliable_writer_cache_changed(self: rti.connextdds.DynamicData.NoOpDataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.ReliableWriterCacheChangedStatus) → None

Reliable writer cache changed callback.

on_service_request_accepted(self: rti.connextdds.DynamicData.NoOpDataWriterListener, arg0: rti.connextdds.DynamicData.DataWriter, arg1: rti.connextdds.ServiceRequestAcceptedStatus) → None

On service request accepted callback.

class NoOpTopicListener

Bases: rti.connextdds.DynamicData.TopicListener

on_inconsistent_topic(self: rti.connextdds.DynamicData.NoOpTopicListener, arg0: rti.connextdds.DynamicData.Topic, arg1: rti.connextdds.InconsistentTopicStatus) → None

Inconsistent topic callback.

class Sample

Bases: pybind11_builtins.pybind11_object

property data

The data associated with the sample.

property info

Get the info associated with the sample.

class SharedSamples

Bases: pybind11_builtins.pybind11_object

unpack(self: rti.connextdds.DynamicData.SharedSamples) → List[rti.connextdds.DynamicData]

Unpacks all samples into a list.

class Topic

Bases: rti.connextdds.DynamicData.ITopicDescription, rti.connextdds.IAnyTopic

bind_listener(self: rti.connextdds.DynamicData.Topic, listener: Optional[rti.connextdds.DynamicData.TopicListener], event_mask: rti.connextdds.StatusMask) → None

Set the listener and event mask.

static find(participant: rti.connextdds.DomainParticipant, name: str) → Optional[rti.connextdds.DynamicData.Topic]

Look up a Topic by its name in the DomainParticipant.

property inconsistent_topic_status

Get a copy of the current InconsistentTopicStatus for this Topic.

property listener

The listener.

property qos

Get the TopicQos for this Topic.

This property’s getter returns a deep copy.

class TopicDescription

Bases: rti.connextdds.DynamicData.ITopicDescription

class TopicInstance

Bases: pybind11_builtins.pybind11_object

property handle

Get/set the instance handle associated with this TopicInstance.

property sample

Get/set the sample associated with this TopicInstance.

class TopicInstanceSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.DynamicData.TopicInstanceSeq, x: rti.connextdds.DynamicData.TopicInstance) → None

Add an item to the end of the list

clear(self: rti.connextdds.DynamicData.TopicInstanceSeq) → None

Clear the contents

count(self: rti.connextdds.DynamicData.TopicInstanceSeq, x: rti.connextdds.DynamicData.TopicInstance) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.DynamicData.TopicInstanceSeq, L: rti.connextdds.DynamicData.TopicInstanceSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.DynamicData.TopicInstanceSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.DynamicData.TopicInstanceSeq, i: int, x: rti.connextdds.DynamicData.TopicInstance) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.DynamicData.TopicInstanceSeq) -> rti.connextdds.DynamicData.TopicInstance

Remove and return the last item

  1. pop(self: rti.connextdds.DynamicData.TopicInstanceSeq, i: int) -> rti.connextdds.DynamicData.TopicInstance

Remove and return the item at index i

remove(self: rti.connextdds.DynamicData.TopicInstanceSeq, x: rti.connextdds.DynamicData.TopicInstance) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class TopicInstanceTimestampedSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.DynamicData.TopicInstanceTimestampedSeq, x: Tuple[rti.connextdds.DynamicData.TopicInstance, rti.connextdds.Time]) → None

Add an item to the end of the list

clear(self: rti.connextdds.DynamicData.TopicInstanceTimestampedSeq) → None

Clear the contents

count(self: rti.connextdds.DynamicData.TopicInstanceTimestampedSeq, x: Tuple[rti.connextdds.DynamicData.TopicInstance, rti.connextdds.Time]) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.DynamicData.TopicInstanceTimestampedSeq, L: rti.connextdds.DynamicData.TopicInstanceTimestampedSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.DynamicData.TopicInstanceTimestampedSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.DynamicData.TopicInstanceTimestampedSeq, i: int, x: Tuple[rti.connextdds.DynamicData.TopicInstance, rti.connextdds.Time]) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.DynamicData.TopicInstanceTimestampedSeq) -> Tuple[rti.connextdds.DynamicData.TopicInstance, rti.connextdds.Time]

Remove and return the last item

  1. pop(self: rti.connextdds.DynamicData.TopicInstanceTimestampedSeq, i: int) -> Tuple[rti.connextdds.DynamicData.TopicInstance, rti.connextdds.Time]

Remove and return the item at index i

remove(self: rti.connextdds.DynamicData.TopicInstanceTimestampedSeq, x: Tuple[rti.connextdds.DynamicData.TopicInstance, rti.connextdds.Time]) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class TopicListener

Bases: pybind11_builtins.pybind11_object

on_inconsistent_topic(self: rti.connextdds.DynamicData.TopicListener, arg0: rti.connextdds.DynamicData.Topic, arg1: rti.connextdds.InconsistentTopicStatus) → None

Inconsistent topic callback.

class TopicSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.DynamicData.TopicSeq, x: rti.connextdds.DynamicData.Topic) → None

Add an item to the end of the list

clear(self: rti.connextdds.DynamicData.TopicSeq) → None

Clear the contents

count(self: rti.connextdds.DynamicData.TopicSeq, x: rti.connextdds.DynamicData.Topic) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.DynamicData.TopicSeq, L: rti.connextdds.DynamicData.TopicSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.DynamicData.TopicSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.DynamicData.TopicSeq, i: int, x: rti.connextdds.DynamicData.Topic) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.DynamicData.TopicSeq) -> rti.connextdds.DynamicData.Topic

Remove and return the last item

  1. pop(self: rti.connextdds.DynamicData.TopicSeq, i: int) -> rti.connextdds.DynamicData.Topic

Remove and return the item at index i

remove(self: rti.connextdds.DynamicData.TopicSeq, x: rti.connextdds.DynamicData.Topic) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class TopicTypeSupport

Bases: pybind11_builtins.pybind11_object

static from_cdr_buffer(sample: rti.connextdds.DynamicData, buffer: rti.connextdds.Int8Seq) → None

Deserialize a sample from a CDR buffer.

static initialize_sample(arg0: rti.connextdds.DynamicData) → None
static register_type(participant: rti.connextdds.DomainParticipant, type_name: str) → None

Register a type with a participant.

static to_cdr_buffer(buffer: rti.connextdds.Int8Seq, sample: rti.connextdds.DynamicData, representation_id: int = - 1)rti.connextdds.Int8Seq

Serialize sample to a CDR buffer.

class ValidLoanedSamples

Bases: pybind11_builtins.pybind11_object

class WriterContentFilter

Bases: rti.connextdds.DynamicData.ContentFilter

writer_attach(self: rti.connextdds.DynamicData.WriterContentFilter) → Optional[object]

A writer-side filtering API to create some state that can facilitate filtering on the writer side.

writer_compile(self: rti.connextdds.DynamicData.WriterContentFilter, writer_filter_data: Optional[object], property: rti.connextdds.ExpressionProperty, expression: str, parameters: rti.connextdds.StringSeq, type_code: Optional[rti.connextdds.DynamicType], type_class_name: str, cookie: rti.connextdds.Cookie) → None

A writer-side filtering API to compile an instance of the content filter according to the filter expression and parameters specified by a matching DataReader.

writer_detach(self: rti.connextdds.DynamicData.WriterContentFilter, writer_filter_data: Optional[object]) → None

A writer-side filtering API to clean up a previously created state using writer_attach.

writer_evaluate(self: rti.connextdds.DynamicData.WriterContentFilter, writer_filter_data: Optional[object], sample: rti.connextdds.DynamicData, meta_data: rti.connextdds.FilterSampleInfo)rti.connextdds.CookieVector

A writer-side filtering API to compile an instance of the content filter according to the filter expression and parameters specified by a matching DataReader.

writer_finalize(self: rti.connextdds.DynamicData.WriterContentFilter, writer_filter_data: Optional[object], cookie: rti.connextdds.Cookie) → None

A writer-side filtering API to clean up a previously compiled instance of the content filter.

writer_return_loan(self: rti.connextdds.DynamicData.WriterContentFilter, writer_filter_data: Optional[object], cookies: rti.connextdds.CookieVector) → None

A writer-side filtering API to return the loan on the list of DataReaders returned by writer_evaluate.

class WriterContentFilterHelper

Bases: rti.connextdds.DynamicData.WriterContentFilter

A helper function which will add a Cookie to the Cookie sequence that is then returned by the writer_evaluate function.

writer_evaluate_helper(self: rti.connextdds.DynamicData.WriterContentFilterHelper, writer_filter_data: Optional[object], sample: rti.connextdds.DynamicData, meta_data: rti.connextdds.FilterSampleInfo) → None

A writer-side filtering API to compile an instance of the content filter according to the filter expression and parameters specified by a matching DataReader.

append(self: rti.connextdds.DynamicData, value: object) → None

Append a value to a sequence.

clear_all_members(self: rti.connextdds.DynamicData) → None

Clear the contents of all data members of this object, including key members.

clear_member(*args, **kwargs)

Overloaded function.

  1. clear_member(self: rti.connextdds.DynamicData, name: str) -> None

Clear the contents of a single data member of this object.

  1. clear_member(self: rti.connextdds.DynamicData, index: int) -> None

Clear the contents of a single data member of this object.

clear_optional_member(*args, **kwargs)

Overloaded function.

  1. clear_optional_member(self: rti.connextdds.DynamicData, name: str) -> None

Clear the contents of a single optional data member of this object.

  1. clear_optional_member(self: rti.connextdds.DynamicData, index: int) -> None

Clear the contents of a single optional data member of this object.

count(self: rti.connextdds.DynamicData, arg0: object) → int
property discriminator_value

Obtains the value of the union discriminator (valid for UnionType only).

property estimated_max_buffer_size

Get the estimated maximum buffer size for a DynamicData object.

extend(self: rti.connextdds.DynamicData, values: iterable) → None

Extend a sequence.

fields(self: rti.connextdds.DynamicData)rti.connextdds.DynamicData.FieldsView
from_cdr_buffer(self: rti.connextdds.DynamicData, buffer: rti.connextdds.Int8Seq)rti.connextdds.DynamicData

Populates a DynamicData sample by deserializing a CDR buffer.

get_boolean(*args, **kwargs)

Overloaded function.

  1. get_boolean(self: rti.connextdds.DynamicData, name: str) -> bool

Get a boolean value by field name.

  1. get_boolean(self: rti.connextdds.DynamicData, name: int) -> bool

Get a boolean value by field name.

get_char(*args, **kwargs)

Overloaded function.

  1. get_char(self: rti.connextdds.DynamicData, name: str) -> str

Get a character value by field name.

  1. get_char(self: rti.connextdds.DynamicData, name: int) -> str

Get a character value by field name.

get_char_values(*args, **kwargs)

Overloaded function.

  1. get_char_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Int8Seq

Get multiple character values by field name.

  1. get_char_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Int8Seq

Get multiple character values by field name.

get_complex(*args, **kwargs)

Overloaded function.

  1. get_complex(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.DynamicData

Get a complex data type value by field name.

  1. get_complex(self: rti.connextdds.DynamicData, name: int) -> rti.connextdds.DynamicData

Get a complex data type value by field name.

get_complex_values(*args, **kwargs)

Overloaded function.

  1. get_complex_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.DynamicDataSeq

Get a list of complex values by field name.

  1. get_complex_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.DynamicDataSeq

Get a list of complex fields by index.

get_double(*args, **kwargs)

Overloaded function.

  1. get_double(self: rti.connextdds.DynamicData, name: str) -> float

Get a 64-bit floating point value by field name.

  1. get_double(self: rti.connextdds.DynamicData, name: int) -> float

Get a 64-bit floating point value by field name.

get_double_values(*args, **kwargs)

Overloaded function.

  1. get_double_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Float64Seq

Get multiple 64-bit floating point values by field name.

  1. get_double_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Float64Seq

Get multiple 64-bit floating point values by field name.

get_float(*args, **kwargs)

Overloaded function.

  1. get_float(self: rti.connextdds.DynamicData, name: str) -> float

Get a 32-bit floating point value by field name.

  1. get_float(self: rti.connextdds.DynamicData, name: int) -> float

Get a 32-bit floating point value by field name.

get_float128(*args, **kwargs)

Overloaded function.

  1. get_float128(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.LongDouble

Get a 128-bit floating point value by field name.

  1. get_float128(self: rti.connextdds.DynamicData, name: int) -> rti.connextdds.LongDouble

Get a 128-bit floating point value by field name.

get_float32(*args, **kwargs)

Overloaded function.

  1. get_float32(self: rti.connextdds.DynamicData, name: str) -> float

Get a 32-bit floating point value by field name.

  1. get_float32(self: rti.connextdds.DynamicData, name: int) -> float

Get a 32-bit floating point value by field name.

get_float32_values(*args, **kwargs)

Overloaded function.

  1. get_float32_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Float32Seq

Get multiple 32-bit floating point values by field name.

  1. get_float32_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Float32Seq

Get multiple 32-bit floating point values by field name.

get_float64(*args, **kwargs)

Overloaded function.

  1. get_float64(self: rti.connextdds.DynamicData, name: str) -> float

Get a 64-bit floating point value by field name.

  1. get_float64(self: rti.connextdds.DynamicData, name: int) -> float

Get a 64-bit floating point value by field name.

get_float64_values(*args, **kwargs)

Overloaded function.

  1. get_float64_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Float64Seq

Get multiple 64-bit floating point values by field name.

  1. get_float64_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Float64Seq

Get multiple 64-bit floating point values by field name.

get_float_values(*args, **kwargs)

Overloaded function.

  1. get_float_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Float32Seq

Get multiple 32-bit floating point values by field name.

  1. get_float_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Float32Seq

Get multiple 32-bit floating point values by field name.

get_int(*args, **kwargs)

Overloaded function.

  1. get_int(self: rti.connextdds.DynamicData, name: str) -> int

Get a int (signed) value by field name.

  1. get_int(self: rti.connextdds.DynamicData, name: int) -> int

Get a int (signed) value by field name.

get_int16(*args, **kwargs)

Overloaded function.

  1. get_int16(self: rti.connextdds.DynamicData, name: str) -> int

Get a 16-bit signed int value by field name.

  1. get_int16(self: rti.connextdds.DynamicData, name: int) -> int

Get a 16-bit signed int value by field name.

get_int16_values(*args, **kwargs)

Overloaded function.

  1. get_int16_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Int16Seq

Get multiple 16-bit signed int values by field name.

  1. get_int16_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Int16Seq

Get multiple 16-bit signed int values by field name.

get_int32(*args, **kwargs)

Overloaded function.

  1. get_int32(self: rti.connextdds.DynamicData, name: str) -> int

Get a 32-bit signed int value by field name.

  1. get_int32(self: rti.connextdds.DynamicData, name: int) -> int

Get a 32-bit signed int value by field name.

get_int32_values(*args, **kwargs)

Overloaded function.

  1. get_int32_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Int32Seq

Get multiple 32-bit signed int values by field name.

  1. get_int32_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Int32Seq

Get multiple 32-bit signed int values by field name.

get_int64(*args, **kwargs)

Overloaded function.

  1. get_int64(self: rti.connextdds.DynamicData, name: str) -> int

Get a 64-bit signed int value by field name.

  1. get_int64(self: rti.connextdds.DynamicData, name: int) -> int

Get a 64-bit signed int value by field name.

get_int64_values(*args, **kwargs)

Overloaded function.

  1. get_int64_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Int64Seq

Get multiple 64-bit signed int values by field name.

  1. get_int64_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Int64Seq

Get multiple 64-bit signed int values by field name.

get_int8(*args, **kwargs)

Overloaded function.

  1. get_int8(self: rti.connextdds.DynamicData, name: str) -> str

Get a 8-bit signed int value by field name.

  1. get_int8(self: rti.connextdds.DynamicData, name: int) -> str

Get a 8-bit signed int value by field name.

get_int8_values(*args, **kwargs)

Overloaded function.

  1. get_int8_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Int8Seq

Get multiple 8-bit signed int values by field name.

  1. get_int8_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Int8Seq

Get multiple 8-bit signed int values by field name.

get_long(*args, **kwargs)

Overloaded function.

  1. get_long(self: rti.connextdds.DynamicData, name: str) -> int

Get a 32-bit signed int value by field name.

  1. get_long(self: rti.connextdds.DynamicData, name: int) -> int

Get a 32-bit signed int value by field name.

get_long_values(*args, **kwargs)

Overloaded function.

  1. get_long_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Int32Seq

Get multiple 32-bit signed int values by field name.

  1. get_long_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Int32Seq

Get multiple 32-bit signed int values by field name.

get_longdouble(*args, **kwargs)

Overloaded function.

  1. get_longdouble(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.LongDouble

Get a 128-bit floating point value by field name.

  1. get_longdouble(self: rti.connextdds.DynamicData, name: int) -> rti.connextdds.LongDouble

Get a 128-bit floating point value by field name.

get_longlong(*args, **kwargs)

Overloaded function.

  1. get_longlong(self: rti.connextdds.DynamicData, name: str) -> int

Get a 64-bit signed int value by field name.

  1. get_longlong(self: rti.connextdds.DynamicData, name: int) -> int

Get a 64-bit signed int value by field name.

get_longlong_values(*args, **kwargs)

Overloaded function.

  1. get_longlong_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Int64Seq

Get multiple 64-bit signed int values by field name.

  1. get_longlong_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Int64Seq

Get multiple 64-bit signed int values by field name.

get_octet(*args, **kwargs)

Overloaded function.

  1. get_octet(self: rti.connextdds.DynamicData, name: str) -> int

Get a 8-bit unsigned int value by field name.

  1. get_octet(self: rti.connextdds.DynamicData, name: int) -> int

Get a 8-bit unsigned int value by field name.

get_octet_values(*args, **kwargs)

Overloaded function.

  1. get_octet_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Uint8Seq

Get multiple 8-bit unsigned int values by field name.

  1. get_octet_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Uint8Seq

Get multiple 8-bit unsigned int values by field name.

get_short(*args, **kwargs)

Overloaded function.

  1. get_short(self: rti.connextdds.DynamicData, name: str) -> int

Get a 16-bit signed int value by field name.

  1. get_short(self: rti.connextdds.DynamicData, name: int) -> int

Get a 16-bit signed int value by field name.

get_short_values(*args, **kwargs)

Overloaded function.

  1. get_short_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Int16Seq

Get multiple 16-bit signed int values by field name.

  1. get_short_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Int16Seq

Get multiple 16-bit signed int values by field name.

get_string(*args, **kwargs)

Overloaded function.

  1. get_string(self: rti.connextdds.DynamicData, name: str) -> str

Get a string value by field name.

  1. get_string(self: rti.connextdds.DynamicData, name: int) -> str

Get a string value by field name.

get_uint(*args, **kwargs)

Overloaded function.

  1. get_uint(self: rti.connextdds.DynamicData, name: str) -> int

Get a 32-bit unsigned int value by field name.

  1. get_uint(self: rti.connextdds.DynamicData, name: int) -> int

Get a 32-bit unsigned int value by field name.

get_uint16(*args, **kwargs)

Overloaded function.

  1. get_uint16(self: rti.connextdds.DynamicData, name: str) -> int

Get a 16-bit unsigned int value by field name.

  1. get_uint16(self: rti.connextdds.DynamicData, name: int) -> int

Get a 16-bit unsigned int value by field name.

get_uint16_values(*args, **kwargs)

Overloaded function.

  1. get_uint16_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Uint16Seq

Get multiple 16-bit unsigned int values by field name.

  1. get_uint16_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Uint16Seq

Get multiple 16-bit unsigned int values by field name.

get_uint32(*args, **kwargs)

Overloaded function.

  1. get_uint32(self: rti.connextdds.DynamicData, name: str) -> int

Get a 32-bit unsigned int value by field name.

  1. get_uint32(self: rti.connextdds.DynamicData, name: int) -> int

Get a 32-bit unsigned int value by field name.

get_uint32_values(*args, **kwargs)

Overloaded function.

  1. get_uint32_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Uint32Seq

Get multiple 32-bit unsigned int values by field name.

  1. get_uint32_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Uint32Seq

Get multiple 32-bit unsigned int values by field name.

get_uint64(*args, **kwargs)

Overloaded function.

  1. get_uint64(self: rti.connextdds.DynamicData, name: str) -> int

Get a 64-bit unsigned int value by field name.

  1. get_uint64(self: rti.connextdds.DynamicData, name: int) -> int

Get a 64-bit unsigned int value by field name.

get_uint64_values(*args, **kwargs)

Overloaded function.

  1. get_uint64_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Uint64Seq

Get multiple 64-bit unsigned int values by field name.

  1. get_uint64_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Uint64Seq

Get multiple 64-bit unsigned int values by field name.

get_uint8(*args, **kwargs)

Overloaded function.

  1. get_uint8(self: rti.connextdds.DynamicData, name: str) -> int

Get a 8-bit unsigned int value by field name.

  1. get_uint8(self: rti.connextdds.DynamicData, name: int) -> int

Get a 8-bit unsigned int value by field name.

get_uint8_values(*args, **kwargs)

Overloaded function.

  1. get_uint8_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Uint8Seq

Get multiple 8-bit unsigned int values by field name.

  1. get_uint8_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Uint8Seq

Get multiple 8-bit unsigned int values by field name.

get_ulong(*args, **kwargs)

Overloaded function.

  1. get_ulong(self: rti.connextdds.DynamicData, name: str) -> int

Get a 32-bit unsigned int value by field name.

  1. get_ulong(self: rti.connextdds.DynamicData, name: int) -> int

Get a 32-bit unsigned int value by field name.

get_ulong_values(*args, **kwargs)

Overloaded function.

  1. get_ulong_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Uint32Seq

Get multiple 32-bit unsigned int values by field name.

  1. get_ulong_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Uint32Seq

Get multiple 32-bit unsigned int values by field name.

get_ulonglong(*args, **kwargs)

Overloaded function.

  1. get_ulonglong(self: rti.connextdds.DynamicData, name: str) -> int

Get a 64-bit unsigned int value by field name.

  1. get_ulonglong(self: rti.connextdds.DynamicData, name: int) -> int

Get a 64-bit unsigned int value by field name.

get_ulonglong_values(*args, **kwargs)

Overloaded function.

  1. get_ulonglong_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Uint64Seq

Get multiple 64-bit unsigned int values by field name.

  1. get_ulonglong_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Uint64Seq

Get multiple 64-bit unsigned int values by field name.

get_ushort(*args, **kwargs)

Overloaded function.

  1. get_ushort(self: rti.connextdds.DynamicData, name: str) -> int

Get a 16-bit unsigned int value by field name.

  1. get_ushort(self: rti.connextdds.DynamicData, name: int) -> int

Get a 16-bit unsigned int value by field name.

get_ushort_values(*args, **kwargs)

Overloaded function.

  1. get_ushort_values(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.Uint16Seq

Get multiple 16-bit unsigned int values by field name.

  1. get_ushort_values(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.Uint16Seq

Get multiple 16-bit unsigned int values by field name.

get_value(*args, **kwargs)

Overloaded function.

  1. get_value(self: rti.connextdds.DynamicData, field_path: str) -> object

Automatically resolve type and return value for a field.

  1. get_value(self: rti.connextdds.DynamicData, field_path: int) -> object

Automatically resolve type and return value for a field.

get_values(*args, **kwargs)

Overloaded function.

  1. get_values(self: rti.connextdds.DynamicData, field_path: str) -> object

Automatically resolve type and return collection for a field.

  1. get_values(self: rti.connextdds.DynamicData, field_path: int) -> object

Automatically resolve type and return collection for a field.

get_wchar(*args, **kwargs)

Overloaded function.

  1. get_wchar(self: rti.connextdds.DynamicData, name: str) -> str

Get a wchar value by field name.

  1. get_wchar(self: rti.connextdds.DynamicData, index: int) -> str

Get a wchar value by field index.

get_wstring(*args, **kwargs)

Overloaded function.

  1. get_wstring(self: rti.connextdds.DynamicData, name: str) -> str

Get a wstring value by field name.

  1. get_wstring(self: rti.connextdds.DynamicData, index: int) -> str

Get a wstring value by field index.

property info

Returns info about this sample

is_member_key(*args, **kwargs)

Overloaded function.

  1. is_member_key(self: rti.connextdds.DynamicData, name: str) -> bool

Returns whether a member is a key.

  1. is_member_key(self: rti.connextdds.DynamicData, index: int) -> bool

Returns whether a member is a key.

items(self: rti.connextdds.DynamicData)rti.connextdds.DynamicData.ItemsView
loan_value(*args, **kwargs)

Overloaded function.

  1. loan_value(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.LoanedDynamicData

Gets a view of a complex member.

  1. loan_value(self: rti.connextdds.DynamicData, data: rti.connextdds.LoanedDynamicData, index: int) -> rti.connextdds.LoanedDynamicData

Gets a view of a complex member.

  1. loan_value(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.LoanedDynamicData

Gets a view of a complex member.

  1. loan_value(self: rti.connextdds.DynamicData, data: rti.connextdds.LoanedDynamicData, name: str) -> rti.connextdds.LoanedDynamicData

Gets a view of a complex member.

property member_count

Get the number of members in this sample.

member_exists(*args, **kwargs)

Overloaded function.

  1. member_exists(self: rti.connextdds.DynamicData, name: str) -> bool

Determine if an optional member is set by member name.

  1. member_exists(self: rti.connextdds.DynamicData, index: int) -> bool

Determine if an optional member is set by member index.

member_exists_in_type(*args, **kwargs)

Overloaded function.

  1. member_exists_in_type(self: rti.connextdds.DynamicData, name: str) -> bool

Determine if a member with a particular name exists in the type.

  1. member_exists_in_type(self: rti.connextdds.DynamicData, index: int) -> bool

Determine if a member with a particular index exists in the type.

member_index(self: rti.connextdds.DynamicData, name: str) → int

Translates from member name to member index.

member_info(*args, **kwargs)

Overloaded function.

  1. member_info(self: rti.connextdds.DynamicData, name: str) -> rti.connextdds.DynamicDataMemberInfo

Returns info about a member.

  1. member_info(self: rti.connextdds.DynamicData, index: int) -> rti.connextdds.DynamicDataMemberInfo

Returns info about a member.

set_boolean(*args, **kwargs)

Overloaded function.

  1. set_boolean(self: rti.connextdds.DynamicData, name: str, value: bool) -> None

Set a boolean value by name.

  1. set_boolean(self: rti.connextdds.DynamicData, index: int, value: bool) -> None

Set a boolean value by index.

set_buffer(self: rti.connextdds.DynamicData, storage: int, size: int) → None

Associate a buffer with this dynamic data object.

set_char(*args, **kwargs)

Overloaded function.

  1. set_char(self: rti.connextdds.DynamicData, name: str, value: str) -> None

Set a character value by name.

  1. set_char(self: rti.connextdds.DynamicData, index: int, value: str) -> None

Set a character value by index.

set_char_values(*args, **kwargs)

Overloaded function.

  1. set_char_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple character values by field name.

  1. set_char_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple character values by field name.

set_complex(*args, **kwargs)

Overloaded function.

  1. set_complex(self: rti.connextdds.DynamicData, name: str, value: rti.connextdds.DynamicData) -> None

Set a complex data type value by name.

  1. set_complex(self: rti.connextdds.DynamicData, index: int, value: rti.connextdds.DynamicData) -> None

Set a complex data type value by index.

set_complex_values(*args, **kwargs)

Overloaded function.

  1. set_complex_values(self: rti.connextdds.DynamicData, name: str, values: iterable) -> None

Set a list of complex values by field name.

  1. set_complex_values(self: rti.connextdds.DynamicData, index: int, values: iterable) -> None

Set a list of complex values by index.

set_double(*args, **kwargs)

Overloaded function.

  1. set_double(self: rti.connextdds.DynamicData, name: str, value: float) -> None

Set a 64-bit floating point value by name.

  1. set_double(self: rti.connextdds.DynamicData, index: int, value: float) -> None

Set a 64-bit floating point value by index.

set_double_values(*args, **kwargs)

Overloaded function.

  1. set_double_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 64-bit floating point values by field name.

  1. set_double_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 64-bit floating point values by field name.

set_float(*args, **kwargs)

Overloaded function.

  1. set_float(self: rti.connextdds.DynamicData, name: str, value: float) -> None

Set a 32-bit floating point value by name.

  1. set_float(self: rti.connextdds.DynamicData, index: int, value: float) -> None

Set a 32-bit floating point value by index.

set_float128(*args, **kwargs)

Overloaded function.

  1. set_float128(self: rti.connextdds.DynamicData, name: str, value: rti.connextdds.LongDouble) -> None

Set a 128-bit floating point value by name.

  1. set_float128(self: rti.connextdds.DynamicData, index: int, value: rti.connextdds.LongDouble) -> None

Set a 128-bit floating point value by index.

set_float32(*args, **kwargs)

Overloaded function.

  1. set_float32(self: rti.connextdds.DynamicData, name: str, value: float) -> None

Set a 32-bit floating point value by name.

  1. set_float32(self: rti.connextdds.DynamicData, index: int, value: float) -> None

Set a 32-bit floating point value by index.

set_float32_values(*args, **kwargs)

Overloaded function.

  1. set_float32_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 32-bit floating point values by field name.

  1. set_float32_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 32-bit floating point values by field name.

set_float64(*args, **kwargs)

Overloaded function.

  1. set_float64(self: rti.connextdds.DynamicData, name: str, value: float) -> None

Set a 64-bit floating point value by name.

  1. set_float64(self: rti.connextdds.DynamicData, index: int, value: float) -> None

Set a 64-bit floating point value by index.

set_float64_values(*args, **kwargs)

Overloaded function.

  1. set_float64_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 64-bit floating point values by field name.

  1. set_float64_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 64-bit floating point values by field name.

set_float_values(*args, **kwargs)

Overloaded function.

  1. set_float_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 32-bit floating point values by field name.

  1. set_float_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 32-bit floating point values by field name.

set_int(*args, **kwargs)

Overloaded function.

  1. set_int(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a int (signed) value by name.

  1. set_int(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a int (signed) value by index.

set_int16(*args, **kwargs)

Overloaded function.

  1. set_int16(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 16-bit signed int value by name.

  1. set_int16(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 16-bit signed int value by index.

set_int16_values(*args, **kwargs)

Overloaded function.

  1. set_int16_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 16-bit signed int values by field name.

  1. set_int16_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 16-bit signed int values by field name.

set_int32(*args, **kwargs)

Overloaded function.

  1. set_int32(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 32-bit signed int value by name.

  1. set_int32(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 32-bit signed int value by index.

set_int32_values(*args, **kwargs)

Overloaded function.

  1. set_int32_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 32-bit signed int values by field name.

  1. set_int32_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 32-bit signed int values by field name.

set_int64(*args, **kwargs)

Overloaded function.

  1. set_int64(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 64-bit signed int value by name.

  1. set_int64(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 64-bit signed int value by index.

set_int64_values(*args, **kwargs)

Overloaded function.

  1. set_int64_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 64-bit signed int values by field name.

  1. set_int64_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 64-bit signed int values by field name.

set_int8(*args, **kwargs)

Overloaded function.

  1. set_int8(self: rti.connextdds.DynamicData, name: str, value: str) -> None

Set a 8-bit signed int value by name.

  1. set_int8(self: rti.connextdds.DynamicData, index: int, value: str) -> None

Set a 8-bit signed int value by index.

set_int8_values(*args, **kwargs)

Overloaded function.

  1. set_int8_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 8-bit signed int values by field name.

  1. set_int8_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 8-bit signed int values by field name.

set_long(*args, **kwargs)

Overloaded function.

  1. set_long(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 32-bit signed int value by name.

  1. set_long(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 32-bit signed int value by index.

set_long_values(*args, **kwargs)

Overloaded function.

  1. set_long_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 32-bit signed int values by field name.

  1. set_long_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 32-bit signed int values by field name.

set_longdouble(*args, **kwargs)

Overloaded function.

  1. set_longdouble(self: rti.connextdds.DynamicData, name: str, value: rti.connextdds.LongDouble) -> None

Set a 128-bit floating point value by name.

  1. set_longdouble(self: rti.connextdds.DynamicData, index: int, value: rti.connextdds.LongDouble) -> None

Set a 128-bit floating point value by index.

set_longlong(*args, **kwargs)

Overloaded function.

  1. set_longlong(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 64-bit signed int value by name.

  1. set_longlong(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 64-bit signed int value by index.

set_longlong_values(*args, **kwargs)

Overloaded function.

  1. set_longlong_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 64-bit signed int values by field name.

  1. set_longlong_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 64-bit signed int values by field name.

set_octet(*args, **kwargs)

Overloaded function.

  1. set_octet(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 8-bit unsigned int value by name.

  1. set_octet(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 8-bit unsigned int value by index.

set_octet_values(*args, **kwargs)

Overloaded function.

  1. set_octet_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 8-bit unsigned int values by field name.

  1. set_octet_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 8-bit unsigned int values by field name.

set_short(*args, **kwargs)

Overloaded function.

  1. set_short(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 16-bit signed int value by name.

  1. set_short(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 16-bit signed int value by index.

set_short_values(*args, **kwargs)

Overloaded function.

  1. set_short_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 16-bit signed int values by field name.

  1. set_short_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 16-bit signed int values by field name.

set_string(*args, **kwargs)

Overloaded function.

  1. set_string(self: rti.connextdds.DynamicData, name: str, value: str) -> None

Set a string value by name.

  1. set_string(self: rti.connextdds.DynamicData, index: int, value: str) -> None

Set a string value by index.

set_uint(*args, **kwargs)

Overloaded function.

  1. set_uint(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 32-bit unsigned int value by name.

  1. set_uint(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 32-bit unsigned int value by index.

set_uint16(*args, **kwargs)

Overloaded function.

  1. set_uint16(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 16-bit unsigned int value by name.

  1. set_uint16(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 16-bit unsigned int value by index.

set_uint16_values(*args, **kwargs)

Overloaded function.

  1. set_uint16_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 16-bit unsigned int values by field name.

  1. set_uint16_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 16-bit unsigned int values by field name.

set_uint32(*args, **kwargs)

Overloaded function.

  1. set_uint32(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 32-bit unsigned int value by name.

  1. set_uint32(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 32-bit unsigned int value by index.

set_uint32_values(*args, **kwargs)

Overloaded function.

  1. set_uint32_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 32-bit unsigned int values by field name.

  1. set_uint32_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 32-bit unsigned int values by field name.

set_uint64(*args, **kwargs)

Overloaded function.

  1. set_uint64(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 64-bit unsigned int value by name.

  1. set_uint64(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 64-bit unsigned int value by index.

set_uint64_values(*args, **kwargs)

Overloaded function.

  1. set_uint64_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 64-bit unsigned int values by field name.

  1. set_uint64_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 64-bit unsigned int values by field name.

set_uint8(*args, **kwargs)

Overloaded function.

  1. set_uint8(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 8-bit unsigned int value by name.

  1. set_uint8(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 8-bit unsigned int value by index.

set_uint8_values(*args, **kwargs)

Overloaded function.

  1. set_uint8_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 8-bit unsigned int values by field name.

  1. set_uint8_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 8-bit unsigned int values by field name.

set_ulong(*args, **kwargs)

Overloaded function.

  1. set_ulong(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 32-bit unsigned int value by name.

  1. set_ulong(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 32-bit unsigned int value by index.

set_ulong_values(*args, **kwargs)

Overloaded function.

  1. set_ulong_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 32-bit unsigned int values by field name.

  1. set_ulong_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 32-bit unsigned int values by field name.

set_ulonglong(*args, **kwargs)

Overloaded function.

  1. set_ulonglong(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 64-bit unsigned int value by name.

  1. set_ulonglong(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 64-bit unsigned int value by index.

set_ulonglong_values(*args, **kwargs)

Overloaded function.

  1. set_ulonglong_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 64-bit unsigned int values by field name.

  1. set_ulonglong_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 64-bit unsigned int values by field name.

set_ushort(*args, **kwargs)

Overloaded function.

  1. set_ushort(self: rti.connextdds.DynamicData, name: str, value: int) -> None

Set a 16-bit unsigned int value by name.

  1. set_ushort(self: rti.connextdds.DynamicData, index: int, value: int) -> None

Set a 16-bit unsigned int value by index.

set_ushort_values(*args, **kwargs)

Overloaded function.

  1. set_ushort_values(self: rti.connextdds.DynamicData, name: str, values: object) -> None

Get multiple 16-bit unsigned int values by field name.

  1. set_ushort_values(self: rti.connextdds.DynamicData, index: int, values: object) -> None

Get multiple 16-bit unsigned int values by field name.

set_value(*args, **kwargs)

Overloaded function.

  1. set_value(self: rti.connextdds.DynamicData, field_path: str, value: object) -> None

Automatically resolve type and set value for a field.

  1. set_value(self: rti.connextdds.DynamicData, field_path: int, value: object) -> None

Automatically resolve type and set value for a field.

set_values(*args, **kwargs)

Overloaded function.

  1. set_values(self: rti.connextdds.DynamicData, field_path: str, values: object) -> None

Automatically resolve type and set collection for a field.

  1. set_values(self: rti.connextdds.DynamicData, field_path: int, values: object) -> None

Automatically resolve type and set collection for a field.

set_wchar(*args, **kwargs)

Overloaded function.

  1. set_wchar(self: rti.connextdds.DynamicData, name: str, value: str) -> None

Get a wchar value by field name.

  1. set_wchar(self: rti.connextdds.DynamicData, index: int, value: str) -> None

Get a wchar value by field index.

set_wstring(*args, **kwargs)

Overloaded function.

  1. set_wstring(self: rti.connextdds.DynamicData, name: str, value: str) -> None

Set a wstring by field name.

  1. set_wstring(self: rti.connextdds.DynamicData, index: int, value: str) -> None

Get a wchar value by field index.

to_cdr_buffer(self: rti.connextdds.DynamicData)rti.connextdds.Int8Seq

Serializes a DynamicData sample to CDR format

property type

Gets the data type of this DynamicData.

property type_kind

Gets this data type kind of this DynamicData.

update(self: rti.connextdds.DynamicData, arg0: dict) → None
class rti.connextdds.DynamicDataEncapsulationKind

Bases: pybind11_builtins.pybind11_object

CDR_BIG_ENDIAN = DynamicDataEncapsulationKind.CDR_BIG_ENDIAN
CDR_LITTLE_ENDIAN = DynamicDataEncapsulationKind.CDR_LITTLE_ENDIAN
DEFAULT = DynamicDataEncapsulationKind.DEFAULT
class DynamicDataEncapsulationKind

Bases: pybind11_builtins.pybind11_object

Members:

CDR_BIG_ENDIAN : CDR big endian encapsulation.

CDR_LITTLE_ENDIAN : CDR little endian encapsulation.

PL_CDR_BIG_ENDIAN : PL CDR big endian encapsulation.

PL_CDR_LITTLE_ENDIAN : PL CDR little endian encapsulation.

DEFAULT : Default encapsulation.

CDR_BIG_ENDIAN = DynamicDataEncapsulationKind.CDR_BIG_ENDIAN
CDR_LITTLE_ENDIAN = DynamicDataEncapsulationKind.CDR_LITTLE_ENDIAN
DEFAULT = DynamicDataEncapsulationKind.DEFAULT
PL_CDR_BIG_ENDIAN = DynamicDataEncapsulationKind.PL_CDR_BIG_ENDIAN
PL_CDR_LITTLE_ENDIAN = DynamicDataEncapsulationKind.PL_CDR_LITTLE_ENDIAN
property name

(self: handle) -> str

PL_CDR_BIG_ENDIAN = DynamicDataEncapsulationKind.PL_CDR_BIG_ENDIAN
PL_CDR_LITTLE_ENDIAN = DynamicDataEncapsulationKind.PL_CDR_LITTLE_ENDIAN
property underlying

Retrieves the actual enumerated value.

class rti.connextdds.DynamicDataInfo

Bases: pybind11_builtins.pybind11_object

property encapsulation_kind

The encapsulation kind.

property is_optimized_storage

Flag indicating whether storage is optimized.

property member_count

The number of members of this sample.

property stored_size

The number of bytes currently used to store the data of this sample.

class rti.connextdds.DynamicDataMemberInfo

Bases: pybind11_builtins.pybind11_object

property element_count

The number of elements in the member.

property element_kind

The type kind of the elements in the member

property index

The member index

property kind

The member type kind

property name

The member name

class rti.connextdds.DynamicDataProperty

Bases: pybind11_builtins.pybind11_object

property check_buffer_size

Check buffer size.

property initial_buffer_size

Initial buffer size.

property max_buffer_size

Max buffer size.

property max_buffer_size_increment

Max buffer size.

class rti.connextdds.DynamicDataSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.DynamicDataSeq, x: rti.connextdds.DynamicData) → None

Add an item to the end of the list

clear(self: rti.connextdds.DynamicDataSeq) → None

Clear the contents

count(self: rti.connextdds.DynamicDataSeq, x: rti.connextdds.DynamicData) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.DynamicDataSeq, L: rti.connextdds.DynamicDataSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.DynamicDataSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.DynamicDataSeq, i: int, x: rti.connextdds.DynamicData) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.DynamicDataSeq) -> rti.connextdds.DynamicData

Remove and return the last item

  1. pop(self: rti.connextdds.DynamicDataSeq, i: int) -> rti.connextdds.DynamicData

Remove and return the item at index i

remove(self: rti.connextdds.DynamicDataSeq, x: rti.connextdds.DynamicData) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.DynamicDataTimestampedSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.DynamicDataTimestampedSeq, x: Tuple[rti.connextdds.DynamicData, rti.connextdds.Time]) → None

Add an item to the end of the list

clear(self: rti.connextdds.DynamicDataTimestampedSeq) → None

Clear the contents

count(self: rti.connextdds.DynamicDataTimestampedSeq, x: Tuple[rti.connextdds.DynamicData, rti.connextdds.Time]) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.DynamicDataTimestampedSeq, L: rti.connextdds.DynamicDataTimestampedSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.DynamicDataTimestampedSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.DynamicDataTimestampedSeq, i: int, x: Tuple[rti.connextdds.DynamicData, rti.connextdds.Time]) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.DynamicDataTimestampedSeq) -> Tuple[rti.connextdds.DynamicData, rti.connextdds.Time]

Remove and return the last item

  1. pop(self: rti.connextdds.DynamicDataTimestampedSeq, i: int) -> Tuple[rti.connextdds.DynamicData, rti.connextdds.Time]

Remove and return the item at index i

remove(self: rti.connextdds.DynamicDataTimestampedSeq, x: Tuple[rti.connextdds.DynamicData, rti.connextdds.Time]) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.DynamicDataTypeSerializationProperty

Bases: pybind11_builtins.pybind11_object

DEFAULT = <rti.connextdds.DynamicDataTypeSerializationProperty object>
property enable_fast_deserialization

Fast deserialization setting.

property max_serialized_size

The maximum number of bytes that objects of a given type could consume when serialized on the network. [DEPRECATED]

property min_serialized_size

The minimum number of bytes that objects of a given type could consume when serialized on the network. [DEPRECATED]

property trim_to_size

Controls the growth of the buffer in a DynamicData object.

class rti.connextdds.DynamicType

Bases: pybind11_builtins.pybind11_object

is_aggregation_type(self: rti.connextdds.DynamicType) → bool

Determines if this DynamicType is an aggregation type.

is_collection_type(self: rti.connextdds.DynamicType) → bool

Determins if this DynamicType is a CollectionType.

is_constructed_type(self: rti.connextdds.DynamicType) → bool

Determines if this DynamicType is a constructed type.

is_primitive_type(self: rti.connextdds.DynamicType) → bool

Determines if this DynamicType is a PrimitiveType

property kind

Get the type kind.

property name

Gets the name.

print_idl(self: rti.connextdds.DynamicType, index: int = 0) → None

Prints the IDL representation of this type to the standard output.

class rti.connextdds.EndpointGroup

Bases: pybind11_builtins.pybind11_object

property quorum_count

Get/set the EndpointGroup’s quorum count.

property role_name

Get/set the EndpointGroup’s role name.

class rti.connextdds.EndpointGroupSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.EndpointGroupSeq, x: rti.connextdds.EndpointGroup) → None

Add an item to the end of the list

clear(self: rti.connextdds.EndpointGroupSeq) → None

Clear the contents

count(self: rti.connextdds.EndpointGroupSeq, x: rti.connextdds.EndpointGroup) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.EndpointGroupSeq, L: rti.connextdds.EndpointGroupSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.EndpointGroupSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.EndpointGroupSeq, i: int, x: rti.connextdds.EndpointGroup) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.EndpointGroupSeq) -> rti.connextdds.EndpointGroup

Remove and return the last item

  1. pop(self: rti.connextdds.EndpointGroupSeq, i: int) -> rti.connextdds.EndpointGroup

Remove and return the item at index i

remove(self: rti.connextdds.EndpointGroupSeq, x: rti.connextdds.EndpointGroup) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.EndpointGroupVector

Bases: pybind11_builtins.pybind11_object

A DDS standard container with functionality similar to a C++ vector.

clear(self: rti.connextdds.EndpointGroupVector) → None

Resize EndpointGroupVector to 0.

resize(self: rti.connextdds.EndpointGroupVector, size: int) → None

Resize EndpointGroupVector.

class rti.connextdds.Entity

Bases: rti.connextdds.IEntity

class rti.connextdds.EntityFactory

Bases: pybind11_builtins.pybind11_object

static auto_enable()rti.connextdds.EntityFactory

Creates EntityFactory(true)

property autoenable_created_entities

Whether the entity acting as a factory automatically enables the instances it creates.

static manually_enable()rti.connextdds.EntityFactory

Creates EntityFactory(false)

class rti.connextdds.EntityName

Bases: pybind11_builtins.pybind11_object

property name

Sets the entity name.

property role_name

Sets the role name.

class rti.connextdds.EntitySeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.EntitySeq, x: rti.connextdds.Entity) → None

Add an item to the end of the list

clear(self: rti.connextdds.EntitySeq) → None

Clear the contents

count(self: rti.connextdds.EntitySeq, x: rti.connextdds.Entity) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.EntitySeq, L: rti.connextdds.EntitySeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.EntitySeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.EntitySeq, i: int, x: rti.connextdds.Entity) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.EntitySeq) -> rti.connextdds.Entity

Remove and return the last item

  1. pop(self: rti.connextdds.EntitySeq, i: int) -> rti.connextdds.Entity

Remove and return the item at index i

remove(self: rti.connextdds.EntitySeq, x: rti.connextdds.Entity) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.EnumMember

Bases: pybind11_builtins.pybind11_object

property name

The member name.

property ordinal

The member’s ordinal.

class rti.connextdds.EnumMemberSeq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.EnumMemberSeq, x: rti.connextdds.EnumMember) → None

Add an item to the end of the list

clear(self: rti.connextdds.EnumMemberSeq) → None

Clear the contents

count(self: rti.connextdds.EnumMemberSeq, x: rti.connextdds.EnumMember) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.EnumMemberSeq, L: rti.connextdds.EnumMemberSeq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.EnumMemberSeq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.EnumMemberSeq, i: int, x: rti.connextdds.EnumMember) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.EnumMemberSeq) -> rti.connextdds.EnumMember

Remove and return the last item

  1. pop(self: rti.connextdds.EnumMemberSeq, i: int) -> rti.connextdds.EnumMember

Remove and return the item at index i

remove(self: rti.connextdds.EnumMemberSeq, x: rti.connextdds.EnumMember) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.EnumType

Bases: rti.connextdds.AbstractConstructedType

add_member(self: rti.connextdds.EnumType, member: rti.connextdds.EnumMember)rti.connextdds.EnumType

Adds a member at the end.

add_members(self: rti.connextdds.EnumType, members: rti.connextdds.EnumMemberSeq)rti.connextdds.EnumType

Adds a member at the end.

find_member_by_ordinal(self: rti.connextdds.EnumType, ordinal: int) → int

Gets the index of the member with this ordinal value.

exception rti.connextdds.Error

Bases: rti.connextdds.Exception

class rti.connextdds.Event

Bases: pybind11_builtins.pybind11_object

property initial_count

Event thread QoS.

property max_count

Event thread QoS.

property thread

Event thread QoS.

class rti.connextdds.EventCount32

Bases: pybind11_builtins.pybind11_object

property change

The incremental count.

property total

The total count.

class rti.connextdds.EventCount64

Bases: pybind11_builtins.pybind11_object

property change

The incremental count.

property total

The total count.

exception rti.connextdds.Exception

Bases: Exception

class rti.connextdds.ExclusiveArea

Bases: pybind11_builtins.pybind11_object

static exclusive_ea()rti.connextdds.ExclusiveArea

Returns ExclusiveArea(false)

static shared_ea()rti.connextdds.ExclusiveArea

Returns ExclusiveArea(true)

property use_shared_exclusive_area

Whether the Entity is protected by its own exclusive area or the shared one.

class rti.connextdds.ExpressionProperty

Bases: pybind11_builtins.pybind11_object

property key_only_filter

The value for key_only_filter, indicating if the filter expression is based only on key fields. In this case, RTI Connext itself can cache the filtering results.

property writer_side_filter_optimization

The value for writer_side_filter_optimization, indicating if the filter implementation can cache the filtering result for the provided expression.

class rti.connextdds.ExtensibilityKind

Bases: pybind11_builtins.pybind11_object

EXTENSIBLE = ExtensibilityKind.EXTENSIBLE
class ExtensibilityKind

Bases: pybind11_builtins.pybind11_object

Members:

FINAL : Final extensibility.

EXTENSIBLE : Extensible extensibility.

MUTABLE : Mutable extensibility.

EXTENSIBLE = ExtensibilityKind.EXTENSIBLE
FINAL = ExtensibilityKind.FINAL
MUTABLE = ExtensibilityKind.MUTABLE
property name

(self: handle) -> str

FINAL = ExtensibilityKind.FINAL
MUTABLE = ExtensibilityKind.MUTABLE
property underlying

Retrieves the actual enumerated value.

class rti.connextdds.Filter

Bases: pybind11_builtins.pybind11_object

add_parameters(self: rti.connextdds.Filter, parameter: str)rti.connextdds.Filter

Append a parameter to the Filter.

property expression

Get the Filter’s expression.

property name

The name of the type of Filter.

property parameter_count

Get the number of parameters.

set_parameters(self: rti.connextdds.Filter, arg0: rti.connextdds.StringSeq) → None

Set the parameters for the Filter.

sql_filter_name = 'DDSSQL'
stringmatch_filter_name = 'DDSSTRINGMATCH'
class rti.connextdds.FilterSampleInfo

Bases: pybind11_builtins.pybind11_object

property priority

Get a positive integer designating the relative priority of the sample, used to determine the transmission order of pending transmissions.

property related_sample_identity

The Identity of another sample related to this one.

class rti.connextdds.Float128Seq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.Float128Seq, x: rti.connextdds.LongDouble) → None

Add an item to the end of the list

clear(self: rti.connextdds.Float128Seq) → None

Clear the contents

count(self: rti.connextdds.Float128Seq, x: rti.connextdds.LongDouble) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.Float128Seq, L: rti.connextdds.Float128Seq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.Float128Seq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.Float128Seq, i: int, x: rti.connextdds.LongDouble) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.Float128Seq) -> rti.connextdds.LongDouble

Remove and return the last item

  1. pop(self: rti.connextdds.Float128Seq, i: int) -> rti.connextdds.LongDouble

Remove and return the item at index i

remove(self: rti.connextdds.Float128Seq, x: rti.connextdds.LongDouble) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.Float128Type

Bases: rti.connextdds.DynamicType

class rti.connextdds.Float32Seq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.Float32Seq, x: float) → None

Add an item to the end of the list

clear(self: rti.connextdds.Float32Seq) → None

Clear the contents

count(self: rti.connextdds.Float32Seq, x: float) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.Float32Seq, L: rti.connextdds.Float32Seq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.Float32Seq, L: iterable) -> None

Extend the list by appending all the items in the given list

insert(self: rti.connextdds.Float32Seq, i: int, x: float) → None

Insert an item at a given position.

pop(*args, **kwargs)

Overloaded function.

  1. pop(self: rti.connextdds.Float32Seq) -> float

Remove and return the last item

  1. pop(self: rti.connextdds.Float32Seq, i: int) -> float

Remove and return the item at index i

remove(self: rti.connextdds.Float32Seq, x: float) → None

Remove the first item from the list whose value is x. It is an error if there is no such item.

class rti.connextdds.Float32Type

Bases: rti.connextdds.DynamicType

class rti.connextdds.Float64Seq

Bases: pybind11_builtins.pybind11_object

append(self: rti.connextdds.Float64Seq, x: float) → None

Add an item to the end of the list

clear(self: rti.connextdds.Float64Seq) → None

Clear the contents

count(self: rti.connextdds.Float64Seq, x: float) → int

Return the number of times x appears in the list

extend(*args, **kwargs)

Overloaded function.

  1. extend(self: rti.connextdds.Float64Seq, L: rti.connextdds.Float64Seq) -> None

Extend the list by appending all the items in the given list

  1. extend(self: rti.connextdds.Float64Seq