Struct HeartbeatSubmessage 

pub struct HeartbeatSubmessage {
    pub reader_id: EntityId,
    pub writer_id: EntityId,
    pub first_sn: SequenceNumber,
    pub last_sn: SequenceNumber,
    pub count: i32,
    pub final_flag: bool,
    pub liveliness_flag: bool,
    pub group_info: Option<HeartbeatGroupInfo>,
}

HEARTBEAT-Submessage.

final_flag, liveliness_flag und group_info_flag (via Some von group_info) entsprechen den F-/L-/G-Bits im Submessage-Header (Spec §8.3.7.5.1, §8.3.8.6.2) — sie liegen nicht im Body, werden aber als semantischer Teil der Nachricht hier gefuehrt.

Fields

reader_id: EntityId

Reader-EntityId (Ziel).

writer_id: EntityId

Writer-EntityId (Quelle).

first_sn: SequenceNumber

Erste verfuegbare Sequence-Number im History-Cache.

last_sn: SequenceNumber

Letzte gesendete Sequence-Number.

count: i32

Count_t (i32) — Heartbeat-Sequenznummer (zur ACK-Korrelation).

final_flag: bool

F-Flag: true = Reader muss keine Response senden wenn vollstaendig.

liveliness_flag: bool

L-Flag: Liveliness-Announce (ohne History-Semantik).

group_info: Option<HeartbeatGroupInfo>

G-Flag (§8.3.8.6.2): optionaler GroupInfo-Trailer.

Implementations

impl HeartbeatSubmessage

pub const WIRE_SIZE: usize = 28

Minimal-Wire-Size (Body ohne GroupInfo): 28 Bytes (4+4+8+8+4). Flags sind im Submessage-Header.

pub fn write_body(&self, little_endian: bool) -> (Vec<u8>, u8)

Encoded den Body. Liefert (bytes, flags), wobei flags das Submessage-Header-Flag-Byte inkl. E/F/L/G enthaelt.

pub fn read_body( body: &[u8], little_endian: bool, final_flag: bool, liveliness_flag: bool, group_info_flag: bool, ) -> Result<Self, WireError>

Decoded den Body. final_flag, liveliness_flag, group_info_flag werden vom Caller aus dem Submessage-Header extrahiert.

Errors

UnexpectedEof, ValueOutOfRange (writerSet-Laenge bizarr gross).

Trait Implementations

impl Clone for HeartbeatSubmessage

fn clone(&self) -> HeartbeatSubmessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HeartbeatSubmessage

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

Formats the value using the given formatter.

impl PartialEq for HeartbeatSubmessage

fn eq(&self, other: &HeartbeatSubmessage) -> 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 HeartbeatSubmessage

impl StructuralPartialEq for HeartbeatSubmessage