Struct engine_rocks::RocksWriteBatch

pub struct RocksWriteBatch {
    db: Arc<DB>,
    wb: RawWriteBatch,
}

Fields

db: Arc<DB>

wb: RawWriteBatch

Implementations

impl RocksWriteBatch

pub fn new(db: Arc<DB>) -> RocksWriteBatch

pub fn as_inner(&self) -> &RawWriteBatch

pub fn with_capacity(db: Arc<DB>, cap: usize) -> RocksWriteBatch

pub fn from_raw(db: Arc<DB>, wb: RawWriteBatch) -> RocksWriteBatch

pub fn get_db(&self) -> &DB

impl RocksWriteBatch

fn append_impl(
    &mut self,
    raft_group_id: u64,
    entries: &[Entry],
    ser_buf: Vec<u8>
) -> Result<()>

Trait Implementations

impl Mutable for RocksWriteBatch

fn put(&mut self, key: &[u8], value: &[u8]) -> Result<()>

Write a key/value in the default column family

fn put_cf(&mut self, cf: &str, key: &[u8], value: &[u8]) -> Result<()>

Write a key/value in a given column family

fn delete(&mut self, key: &[u8]) -> Result<()>

Delete a key/value in the default column family

fn delete_cf(&mut self, cf: &str, key: &[u8]) -> Result<()>

Delete a key/value in a given column family

fn delete_range(&mut self, begin_key: &[u8], end_key: &[u8]) -> Result<()>

Delete a range of key/values in the default column family

fn delete_range_cf(
    &mut self,
    cf: &str,
    begin_key: &[u8],
    end_key: &[u8]
) -> Result<()>

Delete a range of key/values in a given column family

pub fn put_msg<M>(&mut self, key: &[u8], m: &M) -> Result<(), Error> where
    M: Message, 

pub fn put_msg_cf<M>(
    &mut self,
    cf: &str,
    key: &[u8],
    m: &M
) -> Result<(), Error> where
    M: Message, 

impl RaftLogBatch for RocksWriteBatch

fn append(&mut self, raft_group_id: u64, entries: Vec<Entry>) -> Result<()>

Note: RaftLocalState won’t be updated in this call.

fn cut_logs(&mut self, raft_group_id: u64, from: u64, to: u64)

Remove Raft logs in [from, to) which will be overwritten later.

fn put_raft_state(
    &mut self,
    raft_group_id: u64,
    state: &RaftLocalState
) -> Result<()>

fn is_empty(&self) -> bool

impl WriteBatch<RocksEngine> for RocksWriteBatch

fn with_capacity(e: &RocksEngine, cap: usize) -> RocksWriteBatch

Create a WriteBatch with a given command capacity

fn write_opt(&self, opts: &WriteOptions) -> Result<()>

Commit the WriteBatch to disk with the given options

fn data_size(&self) -> usize

The data size of a write batch

fn count(&self) -> usize

The number of commands in this batch

fn is_empty(&self) -> bool

Whether any commands have been issued to this batch

fn should_write_to_engine(&self) -> bool

Whether the number of commands exceeds WRITE_BATCH_MAX_KEYS

fn clear(&mut self)

Clears the WriteBatch of all commands

fn set_save_point(&mut self)

Push a save point onto the save point stack

fn pop_save_point(&mut self) -> Result<()>

Pop a save point from the save point stack

fn rollback_to_save_point(&mut self) -> Result<()>

Revert all commands issued since the last save point

pub fn write(&self) -> Result<(), Error>

Commit the WriteBatch to disk atomically