Struct DdsSection

pub(crate) struct DdsSection {
    pub(crate) enabled: bool,
    pub(crate) id: String,
    pub(crate) provider: String,
    pub(crate) domain_id: u16,
    pub(crate) qos: PathBuf,
    pub(crate) topics: Vec<String>,
    pub(crate) unwrap_ma_payloads: bool,
    pub(crate) suppress_echo: bool,
    pub(crate) reconnect: bool,
    pub(crate) reconnect_delay_secs: u64,
    pub(crate) on_panic: String,
    pub(crate) max_sample_size: usize,
}

DDS adapter settings.

Fields

enabled: bool

Whether to spawn the adapter. true when the section is present.

id: String

Engine adapter id. Defaults to "dds".

provider: String

Provider name. Defaults to "rustdds".

domain_id: u16

DDS domain id. Defaults to 0.

qos: PathBuf

QoS XML path. Required when the section is present.

topics: Vec<String>

Engine topic names and DDS topic names, bridged both ways.

unwrap_ma_payloads: bool

Peel A-GRA Rx/Tx wrappers on inbound samples.

suppress_echo: bool

Skip outbound samples that originated on this adapter.

reconnect: bool

Rejoin the domain after the session ends or panics. Defaults to false: an existing deployment sees no behavior change until it opts in.

reconnect_delay_secs: u64

Seconds to wait between rejoin attempts. Defaults to 1.

on_panic: String

abort or reconnect when the session panics. Defaults to "abort".

max_sample_size: usize

Largest inbound sample accepted, in bytes. Defaults to the adapter crate’s limit.

Implementations

impl DdsSection

pub(crate) fn provider_kind(&self) -> Result<DdsProviderKind, String>

Parses Self::provider into oa_gateway_dds::DdsProviderKind.

Errors

Returns an error if the string is not a known provider.

pub(crate) fn on_panic_mode(&self) -> Result<OnPanic, String>

Parses Self::on_panic into [oa_gateway_adapter::OnPanic].

Errors

Returns an error if the string is not abort or reconnect.

pub(crate) fn require_qos(&self) -> Result<PathBuf, String>

Errors

Returns an error if qos is empty or the file is missing.

Trait Implementations

impl Debug for DdsSection

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

Formats the value using the given formatter.

impl Default for DdsSection

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for DdsSection

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.