Struct engine_rocks::RocksWriteBatch

[+] Show declaration

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[+]

[+] Show hidden undocumented items

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[+]

[+] Show hidden undocumented items

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[+]

[+] Show hidden undocumented items

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