Struct HddsDdsInterface 

pub struct HddsDdsInterface { /* private fields */ }

HDDS-backed implementation of the persistence DDS interface.

Implementations

impl HddsDdsInterface

pub fn new(participant: Arc<Participant>) -> Result<Self>

Create a new HDDS-backed DDS interface.

Trait Implementations

impl DdsInterface for HddsDdsInterface

fn create_reader( &self, topic: &str, type_name: &str, durability: DurabilityKind, ) -> Result<Box<dyn DataReader>>

Create a data reader for a topic

fn create_writer( &self, topic: &str, type_name: &str, durability: DurabilityKind, ) -> Result<Box<dyn DataWriter>>

Create a data writer for a topic

fn discovered_readers( &self, topic_pattern: &str, ) -> Result<Vec<DiscoveredReader>>

Get list of discovered readers matching a topic pattern

fn discovered_writers( &self, topic_pattern: &str, ) -> Result<Vec<DiscoveredWriter>>

Get list of discovered writers matching a topic pattern

fn wait_for_discovery(&self, timeout: Duration) -> Result<bool>

Wait for discovery events

fn register_discovery_callback( &self, callback: Arc<dyn DiscoveryCallback>, ) -> Result<()>

Register a discovery callback for endpoint events.

fn guid(&self) -> [u8; 16]

Get participant GUID