Struct OffsetLog 

pub struct OffsetLog<ByteType> {
    pub file: File,
    /* private fields */
}

Fields

file: File

Implementations

impl<ByteType> OffsetLog<ByteType>

pub fn new<P: AsRef<Path>>(path: P) -> Result<OffsetLog<ByteType>, Error>

pub fn open_read_only<P: AsRef<Path>>( path: P, ) -> Result<OffsetLog<ByteType>, Error>

pub fn from_file(file: File) -> Result<OffsetLog<ByteType>, Error>

pub fn end(&self) -> u64

pub fn read(&self, offset: u64) -> Result<ReadResult, Error>

pub fn append_batch<T: AsRef<[u8]>>( &mut self, buffs: &[T], ) -> Result<Vec<u64>, Error>

pub fn iter(&self) -> Forward<OffsetLogIter<ByteType>>

pub fn bidir_iter(&self) -> OffsetLogIter<ByteType>

pub fn bidir_iter_at_offset(&self, offset: u64) -> OffsetLogIter<ByteType>

Trait Implementations

impl<ByteType> FlumeLog for OffsetLog<ByteType>

fn get(&self, seq_num: u64) -> Result<Vec<u8>, Error>

fn latest(&self) -> Option<u64>

fn append(&mut self, buff: &[u8]) -> Result<u64, Error>

fn clear(&mut self, _seq_num: u64)

impl<ByteType> IterAtOffset<Forward<OffsetLogIter<ByteType>>> for OffsetLog<ByteType>

fn iter_at_offset(&self, offset: u64) -> Forward<OffsetLogIter<ByteType>>