Struct Walrus 

pub struct Walrus { /* private fields */ }

Implementations

impl Walrus

pub fn new() -> Result<Self>

pub fn with_consistency(mode: ReadConsistency) -> Result<Self>

pub fn with_consistency_and_schedule( mode: ReadConsistency, fsync_schedule: FsyncSchedule, ) -> Result<Self>

pub fn new_for_key(key: &str) -> Result<Self>

pub fn with_consistency_for_key( key: &str, mode: ReadConsistency, ) -> Result<Self>

pub fn with_consistency_and_schedule_for_key( key: &str, mode: ReadConsistency, fsync_schedule: FsyncSchedule, ) -> Result<Self>

impl Walrus

pub fn read_next( &self, col_name: &str, checkpoint: bool, ) -> Result<Option<Entry>>

pub fn batch_read_for_topic( &self, col_name: &str, max_bytes: usize, checkpoint: bool, ) -> Result<Vec<Entry>>

impl Walrus

pub fn append_for_topic(&self, col_name: &str, raw_bytes: &[u8]) -> Result<()>

pub fn batch_append_for_topic( &self, col_name: &str, batch: &[&[u8]], ) -> Result<()>