Struct StorageMetadata 

pub struct StorageMetadata { /* private fields */ }

Message storage metadata

Contains indexing and location information for messages in the Broker storage engine.

Implementations

impl StorageMetadata

pub fn new( broker_name: CheetahString, queue_id: i32, queue_offset: i64, commit_log_offset: i64, store_timestamp: i64, store_host: SocketAddr, store_size: i32, ) -> Self

Creates new storage metadata

pub fn broker_name(&self) -> &str

Gets the broker name

pub fn queue_id(&self) -> i32

Gets the queue ID

pub fn queue_offset(&self) -> i64

Gets the queue logical offset

pub fn commit_log_offset(&self) -> i64

Gets the CommitLog physical offset

pub fn store_timestamp(&self) -> i64

Gets the storage timestamp

pub fn store_host(&self) -> SocketAddr

Gets the storage host address

pub fn store_size(&self) -> i32

Gets the storage size in bytes

pub fn store_host_bytes(&self) -> Bytes

Serializes store_host to bytes

Trait Implementations

impl Clone for StorageMetadata

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StorageMetadata

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

Formats the value using the given formatter.

impl Default for StorageMetadata

fn default() -> Self

Returns the “default value” for a type.

impl Eq for StorageMetadata

impl PartialEq for StorageMetadata

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for StorageMetadata