Struct SubscriptionBuiltinTopicData 

pub struct SubscriptionBuiltinTopicData {

    pub key: Guid,
    pub participant_key: Guid,
    pub topic_name: String,
    pub type_name: String,
    pub durability: DurabilityKind,
    pub reliability: ReliabilityQos,
    pub ownership: OwnershipKind,
    pub liveliness: LivelinessQosPolicy,
    pub deadline: DeadlineQosPolicy,
    pub partition: Vec<String>,
    pub user_data: Vec<u8>,
    pub topic_data: Vec<u8>,
    pub group_data: Vec<u8>,
    pub type_information: Option<Vec<u8>>,
    pub data_representation: Vec<i16>,
    pub content_filter: Option<ContentFilterProperty>,
    pub security_info: Option<EndpointSecurityInfo>,
    pub service_instance_name: Option<String>,
    pub related_entity_guid: Option<Guid>,
    pub topic_aliases: Option<Vec<String>>,
    pub type_identifier: TypeIdentifier,
}

Discovered Subscription / lokaler DataReader — Subset.

Wire-identisch zu [PublicationBuiltinTopicData] in Phase 1; getrennter Typ, damit SEDP-Publications- und Subscriptions- Caches klar unterschiedbar bleiben und Erweiterungen (z.B. expects_inline_qos, time_based_filter) nicht ueber den Publication-Typ gezogen werden.

Fields

key: Guid

Endpoint-GUID (= Reader-GUID).

participant_key: Guid

GUID des Participants, dem der Reader gehoert.

topic_name: String

Topic-Name.

type_name: String

IDL-Type-Name.

durability: DurabilityKind

Durability-QoS.

reliability: ReliabilityQos

Reliability-QoS.

ownership: OwnershipKind

Ownership-QoS (Spec §2.2.3.23). Default Shared.

liveliness: LivelinessQosPolicy

Liveliness-QoS (Spec §2.2.3.11).

deadline: DeadlineQosPolicy

Deadline-QoS (Spec §2.2.3.7).

partition: Vec<String>

Partition-QoS (Spec §2.2.3.13).

user_data: Vec<u8>

UserData-QoS (Spec §2.2.3.1) — opaque sequence.

topic_data: Vec<u8>

TopicData-QoS (Spec §2.2.3.3) — opaque sequence.

group_data: Vec<u8>

GroupData-QoS (Spec §2.2.3.2) — opaque sequence.

type_information: Option<Vec<u8>>

Type-Information als opaque bytes (XTypes §7.6.3.2.2).

data_representation: Vec<i16>

Akzeptierte Data-Representations.

content_filter: Option<ContentFilterProperty>

Content-Filter-Property (DDSI-RTPS §9.6.3.4 Table 9.14). Nur gesetzt wenn der Reader als ContentFilteredTopic erstellt wurde.

security_info: Option<EndpointSecurityInfo>

Endpoint-Security-Info (PID 0x1004, DDS-Security 1.1 §7.4.1.5). None bei Legacy-Peers. WP 4H-c-Matching prueft Writer/Reader- Paare auf Protection-Kompatibilitaet.

service_instance_name: Option<String>

PID_SERVICE_INSTANCE_NAME (DDS-RPC 1.0 §7.8.2) — logischer Service-Instance-Name eines RPC-Endpoints.

related_entity_guid: Option<Guid>

PID_RELATED_ENTITY_GUID (DDS-RPC 1.0 §7.8.2) — GUID des Pendant-Endpoints (z.B. Reply-Reader → Reply-Writer).

topic_aliases: Option<Vec<String>>

PID_TOPIC_ALIASES (DDS-RPC 1.0 §7.8.2).

type_identifier: TypeIdentifier

PID_ZERODDS_TYPE_ID (Vendor-PID 0x8002) — Reader-Type-Identifier für XTypes-aware Match (siehe PublicationBuiltinTopicData).

Implementations

impl SubscriptionBuiltinTopicData

pub fn as_reader_qos(&self) -> ReaderQos

Analog PublicationBuiltinTopicData::as_writer_qos fuer Reader.

Einschraenkung: Nur Durability + Reliability; uebrige Policies auf ReaderQos::default().

pub fn with_reader_qos(self, qos: &ReaderQos) -> Self

Analog PublicationBuiltinTopicData::with_writer_qos fuer Reader.

impl SubscriptionBuiltinTopicData

pub fn to_pl_cdr_le(&self) -> Result<Vec<u8>, WireError>

Encoded zu PL_CDR_LE-Bytes (mit 4-byte Encapsulation-Header).

Direkt implementiert (nicht ueber [PublicationBuiltinTopicData] delegiert), damit Erweiterungs-PIDs, die writer-only sind (z.B. PID_LIFESPAN, PID_OWNERSHIP_STRENGTH), nicht versehentlich in den Subscription-Payload wandern.

Errors

ValueOutOfRange wenn ein String laenger als u32::MAX ist.

pub fn from_pl_cdr_le(bytes: &[u8]) -> Result<Self, WireError>

Decoded aus PL_CDR_LE-Bytes (mit Encapsulation-Header).

Errors

UnexpectedEof bei zu kurzen Bytes, UnsupportedEncapsulation bei unbekanntem Encoding, ValueOutOfRange wenn Pflicht-PIDs fehlen.

Trait Implementations

impl Clone for SubscriptionBuiltinTopicData

fn clone(&self) -> SubscriptionBuiltinTopicData

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SubscriptionBuiltinTopicData

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for SubscriptionBuiltinTopicData

fn eq(&self, other: &SubscriptionBuiltinTopicData) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for SubscriptionBuiltinTopicData

impl StructuralPartialEq for SubscriptionBuiltinTopicData