Struct aeron_rs::concurrent::logbuffer::header::Header

pub struct Header { /* fields omitted */ }

Represents the header of the data frame for accessing meta data fields.

Methods

impl Header

pub fn new(initial_term_id: i32, capacity: Index) -> Self

pub fn initial_term_id(&self) -> i32

Get the initial term id this stream started at.

@return the initial term id this stream started at.

pub fn set_initial_term_id(&mut self, initial_term_id: i32)

pub fn offset(&self) -> Index

The offset at which the frame begins.

@return offset at which the frame begins.

pub fn set_offset(&mut self, offset: Index)

pub fn buffer(&self) -> AtomicBuffer

The AtomicBuffer containing the header.

@return AtomicBuffer containing the header.

pub fn set_buffer(&mut self, buffer: AtomicBuffer)

pub fn frame_length(&self) -> Index

The total length of the frame including the header.

@return the total length of the frame including the header.

pub fn session_id(&self) -> i32

The session ID to which the frame belongs.

@return the session ID to which the frame belongs.

pub fn stream_id(&self) -> i32

The stream ID to which the frame belongs.

@return the stream ID to which the frame belongs.

pub fn term_id(&self) -> i32

The term ID to which the frame belongs.

@return the term ID to which the frame belongs.

pub fn term_offset(&self) -> Index

The offset in the term at which the frame begins. This will be the same as {@link #offset()}

@return the offset in the term at which the frame begins.

pub fn frame_type(&self) -> u16

The type of the the frame which should always be {@link DataFrameHeader::HDR_TYPE_DATA}

@return type of the the frame which should always be {@link DataFrameHeader::HDR_TYPE_DATA}

pub fn flags(&self) -> u8

The flags for this frame. Valid flags are {@link DataFrameHeader::BEGIN_FLAG} and {@link DataFrameHeader::END_FLAG}. A convenience flag {@link DataFrameHeader::BEGIN_AND_END_FLAGS} can be used for both flags.

@return the flags for this frame.

pub fn position(&self) -> i64

Get the current position to which the Image has advanced on reading this message.

@return the current position to which the Image has advanced on reading this message.

pub fn reserved_value(&self) -> i64

Get the value stored in the reserve space at the end of a data frame header.

@return the value stored in the reserve space at the end of a data frame header.

Trait Implementations

impl Clone for Header

fn clone(&self) -> Header

Returns a copy of the value.

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

Performs copy-assignment from source.