Module dds_interface 

DDS Interface Abstraction

Provides an abstract interface for DDS operations that the persistence service uses. This allows the persistence service to work without direct dependency on the core hdds Participant implementation.

Integration

To integrate with HDDS core, implement the DdsInterface trait:

impl DdsInterface for HddsParticipant {
    fn subscribe(&self, topic: &str) -> Result<Box<dyn DataReader>> {
        // Create real DataReader...
    }
    // ...
}

Structs

DiscoveredReader

Discovered reader information

DiscoveredWriter

Discovered writer information

MockDdsInterface

Mock DDS interface for testing without real HDDS

ReceivedSample

Received sample from DDS

Enums

DurabilityKind

Durability policy exposed by discovery.

Traits

DataReader

Abstract data reader interface

DataWriter

Abstract data writer interface

DdsInterface

Abstract DDS interface for persistence service

DiscoveryCallback

Callback-based discovery listener

SampleCallback

Callback-based sample receiver