Struct MessageHeader 

#[repr(C, align(64))]
pub struct MessageHeader {

    pub magic: u64,
    pub version: u32,
    pub flags: u32,
    pub message_id: MessageId,
    pub correlation_id: CorrelationId,
    pub source_kernel: u64,
    pub dest_kernel: u64,
    pub message_type: u64,
    pub priority: u8,
    pub _reserved1: [u8; 7],
    pub payload_size: u64,
    pub checksum: u32,
    pub _reserved2: u32,
    pub timestamp: HlcTimestamp,
    pub deadline: HlcTimestamp,
    pub _reserved3a: [u8; 32],
    pub _reserved3b: [u8; 32],
    pub _reserved3c: [u8; 32],
    pub _reserved3d: [u8; 8],
}

Fixed-size message header (256 bytes, cache-line aligned).

This header precedes the variable-length payload and provides all metadata needed for routing and processing.

Fields

magic: u64

Magic number for validation (0xRINGKERN).

version: u32

Header version for compatibility.

flags: u32

Message flags.

message_id: MessageId

Unique message identifier.

correlation_id: CorrelationId

Correlation ID for request-response.

source_kernel: u64

Source kernel ID (0 for host).

dest_kernel: u64

Destination kernel ID (0 for host).

message_type: u64

Message type discriminator.

priority: u8

Priority level.

_reserved1: [u8; 7]

Reserved for alignment.

payload_size: u64

Payload size in bytes.

checksum: u32

Checksum of payload (CRC32).

_reserved2: u32

Reserved for alignment.

timestamp: HlcTimestamp

HLC timestamp when message was created.

deadline: HlcTimestamp

Deadline timestamp (0 = no deadline).

_reserved3a: [u8; 32]

Reserved for future use (split for derive compatibility).

_reserved3b: [u8; 32]

Reserved for future use.

_reserved3c: [u8; 32]

Reserved for future use.

_reserved3d: [u8; 8]

Reserved for future use.

Implementations

impl MessageHeader

pub const MAGIC: u64 = 5_929_356_452_522_447_438u64

Magic number for validation.

pub const VERSION: u32 = 1u32

Current header version.

pub const MAX_PAYLOAD_SIZE: usize = 65_536usize

Maximum payload size (64KB).

pub fn as_bytes(&self) -> &[u8]

Convert header to bytes.

pub fn read_from(bytes: &[u8]) -> Option<MessageHeader>

Read header from bytes.

pub fn new( message_type: u64, source_kernel: u64, dest_kernel: u64, payload_size: usize, timestamp: HlcTimestamp, ) -> MessageHeader

Create a new message header.

pub fn validate(&self) -> bool

Validate the header.

pub fn with_correlation(self, correlation_id: CorrelationId) -> MessageHeader

Set correlation ID.

pub fn with_priority(self, priority: Priority) -> MessageHeader

Set priority.

pub fn with_deadline(self, deadline: HlcTimestamp) -> MessageHeader

Set deadline.

Trait Implementations

impl Clone for MessageHeader

fn clone(&self) -> MessageHeader

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageHeader

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

Formats the value using the given formatter.

impl Default for MessageHeader

fn default() -> MessageHeader

Returns the “default value” for a type.

impl Copy for MessageHeader