[−][src]Trait rocks::write_batch::WriteBatchHandler

pub trait WriteBatchHandler {
    fn put_cf(&mut self, column_family_id: u32, key: &[u8], value: &[u8]) { ... }

    fn delete_cf(&mut self, column_family_id: u32, key: &[u8]) { ... }

    fn single_delete_cf(&mut self, column_family_id: u32, key: &[u8]) { ... }

    fn delete_range_cf(
        &mut self, 
        column_family_id: u32, 
        begin_key: &[u8], 
        end_key: &[u8]
    ) { ... }

    fn merge_cf(&mut self, column_family_id: u32, key: &[u8], value: &[u8]) { ... }

    fn log_data(&mut self, blob: &[u8]) { ... }

    fn mark_begin_prepare(&mut self) { ... }

    fn mark_end_prepare(&mut self, xid: &[u8]) { ... }

    fn mark_rollback(&mut self, xid: &[u8]) { ... }

    fn mark_commit(&mut self, xid: &[u8]) { ... }

    fn will_continue(&mut self) -> bool { ... }
}

Support for iterating over the contents of a batch.

All handler functions in this class provide default implementations so we won't break existing clients of Handler on a source code level when adding a new member function.

Provided methods

fn put_cf(&mut self, column_family_id: u32, key: &[u8], value: &[u8])

fn delete_cf(&mut self, column_family_id: u32, key: &[u8])

fn single_delete_cf(&mut self, column_family_id: u32, key: &[u8])

fn delete_range_cf(
    &mut self,
    column_family_id: u32,
    begin_key: &[u8],
    end_key: &[u8]
)

fn merge_cf(&mut self, column_family_id: u32, key: &[u8], value: &[u8])

fn log_data(&mut self, blob: &[u8])

fn mark_begin_prepare(&mut self)

fn mark_end_prepare(&mut self, xid: &[u8])

fn mark_rollback(&mut self, xid: &[u8])

fn mark_commit(&mut self, xid: &[u8])

fn will_continue(&mut self) -> bool

Continue is called by WriteBatch::Iterate. If it returns false, iteration is halted. Otherwise, it continues iterating. The default implementation always returns true.

Loading content...

Implementors

impl WriteBatchHandler for WriteBatchIteratorHandler[src]

Loading content...