Enum rustdds::DataReaderStatus

pub enum DataReaderStatus {
    SampleRejected {
        count: CountWithChange,
        last_reason: SampleRejectedStatusKind,
    },
    LivelinessChanged {
        alive_total: CountWithChange,
        not_alive_total: CountWithChange,
    },
    RequestedDeadlineMissed {
        count: CountWithChange,
    },
    RequestedIncompatibleQos {
        count: CountWithChange,
        last_policy_id: QosPolicyId,
        writer: GUID,
        requested_qos: Box<QosPolicies>,
        offered_qos: Box<QosPolicies>,
    },
    SampleLost {
        count: CountWithChange,
    },
    SubscriptionMatched {
        total: CountWithChange,
        current: CountWithChange,
        writer: GUID,
    },
}

Variants

SampleRejected

Fields

count: CountWithChange

last_reason: SampleRejectedStatusKind

Sample was rejected, because resource limits would have been exceeded.

LivelinessChanged

Fields

alive_total: CountWithChange

not_alive_total: CountWithChange

Remote Writer has become active or inactive.

RequestedDeadlineMissed

Fields

count: CountWithChange

Deadline requested by this DataReader was missed.

RequestedIncompatibleQos

Fields

count: CountWithChange

last_policy_id: QosPolicyId

writer: GUID

requested_qos: Box<QosPolicies>

offered_qos: Box<QosPolicies>

This DataReader has requested a QoS policy that is incompatible with what is offered.

SampleLost

Fields

count: CountWithChange

A sample has been lost (never received). TODO: Implement this.

• Check that the following interpretation is correct:
• For a BEST_EFFORT reader: Whenever we skip ahead in SequenceNumber, possibly because a message is lost, or messages arrive out of order.
• For a RELIABLE reader: Whenever we skip ahead in SequenceNumbers that are delivered via DataReader. The reason may be that we receive a HEARTBEAT or GAP submessage indicating that some samples we are expecting are not available.

SubscriptionMatched

Fields

total: CountWithChange

current: CountWithChange

writer: GUID

The DataReader has found a DataWriter that matches the Topic and has compatible QoS, or has ceased to be matched with a DataWriter that was previously considered to be matched.

Trait Implementations

impl Clone for DataReaderStatus

fn clone(&self) -> DataReaderStatus

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DataReaderStatus

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

Formats the value using the given formatter.

impl<'a, D, DA> StatusEvented<'a, DataReaderStatus, SimpleDataReaderEventStream<'a, D, DA>> for DataReader<D, DA>

where D: Keyed + 'static, DA: DeserializerAdapter<D>,

fn as_status_evented(&mut self) -> &dyn Evented

fn as_status_source(&mut self) -> &mut dyn Source

fn as_async_status_stream(&'a self) -> SimpleDataReaderEventStream<'a, D, DA>

fn try_recv_status(&self) -> Option<DataReaderStatus>

impl<'a, D, DA> StatusEvented<'a, DataReaderStatus, SimpleDataReaderEventStream<'a, D, DA>> for SimpleDataReader<D, DA>

where D: Keyed, DA: DeserializerAdapter<D>,

fn as_status_evented(&mut self) -> &dyn Evented

fn as_status_source(&mut self) -> &mut dyn Source

fn as_async_status_stream(&'a self) -> SimpleDataReaderEventStream<'a, D, DA>

fn try_recv_status(&self) -> Option<DataReaderStatus>

impl<'a, D, DA> StatusEvented<'a, DataReaderStatus, SimpleDataReaderEventStream<'a, NoKeyWrapper<D>, DAWrapper<DA>>> for DataReader<D, DA>

where D: 'static, DA: DeserializerAdapter<D>,

fn as_status_evented(&mut self) -> &dyn Evented

fn as_status_source(&mut self) -> &mut dyn Source

fn as_async_status_stream( &'a self ) -> SimpleDataReaderEventStream<'a, NoKeyWrapper<D>, DAWrapper<DA>>

fn try_recv_status(&self) -> Option<DataReaderStatus>

impl<'a, D, DA> StatusEvented<'a, DataReaderStatus, SimpleDataReaderEventStream<'a, NoKeyWrapper<D>, DAWrapper<DA>>> for SimpleDataReader<D, DA>

where D: 'static, DA: DeserializerAdapter<D>,

fn as_status_evented(&mut self) -> &dyn Evented

fn as_status_source(&mut self) -> &mut dyn Source

fn as_async_status_stream( &'a self ) -> SimpleDataReaderEventStream<'a, NoKeyWrapper<D>, DAWrapper<DA>>

fn try_recv_status(&self) -> Option<DataReaderStatus>