Struct StreamRecordIndex 

pub struct StreamRecordIndex { /* private fields */ }

Implementations

impl StreamRecordIndex

pub fn new() -> Self

pub fn restore( first_record: u64, record_offsets: Vec<u64>, retained_offset: u64, tail_offset: u64, ) -> Result<Self, RecordIndexError>

pub fn range(&self) -> Result<StreamRecordRange, RecordIndexError>

pub fn record_offsets(&self) -> &[u64]

pub fn append_relative_ends( &mut self, base_offset: u64, payload_len: u64, relative_ends: &[u64], ) -> Result<StreamRecordRange, RecordIndexError>

pub fn offset_for( &self, record: u64, tail_offset: u64, ) -> Result<u64, RecordIndexError>

pub fn record_for_offset( &self, offset: u64, tail_offset: u64, ) -> Result<u64, RecordIndexError>

pub fn retain_from_offset( &mut self, retained_offset: u64, tail_offset: u64, ) -> Result<u64, RecordIndexError>

pub fn validate( &self, retained_offset: u64, tail_offset: u64, ) -> Result<(), RecordIndexError>

Trait Implementations

impl Clone for StreamRecordIndex

fn clone(&self) -> StreamRecordIndex

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamRecordIndex

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

Formats the value using the given formatter.

impl Default for StreamRecordIndex

fn default() -> StreamRecordIndex

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamRecordIndex

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for StreamRecordIndex

impl PartialEq for StreamRecordIndex

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for StreamRecordIndex

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for StreamRecordIndex