Struct backup::BackupRawKVWriter

pub struct BackupRawKVWriter {
    name: String,
    cf: CfName,
    writer: Writer,
    limiter: Limiter,
}

A writer writes Raw kv into SST files.

Fields

name: String

cf: CfName

writer: Writer

limiter: Limiter

Implementations

impl BackupRawKVWriter

pub fn new(
    db: Arc<DB>,
    name: &str,
    cf: CfName,
    limiter: Limiter,
    compression_type: Option<SstCompressionType>,
    compression_level: i32
) -> Result<BackupRawKVWriter>

Create a new BackupRawKVWriter.

pub fn write<I>(&mut self, kv_pairs: I, need_checksum: bool) -> Result<()> where
    I: Iterator<Item = Result<KvPair>>, 

Write Kv_pair to buffered SST files.

pub fn save(self, storage: &dyn ExternalStorage) -> Result<Vec<File>>

Save buffered SST files to the given external storage.