Struct backup::BackupWriter

pub struct BackupWriter {
    name: String,
    default: Writer,
    write: Writer,
    limiter: Limiter,
    sst_max_size: u64,
}

A writer writes txn entries into SST files.

Fields

name: String

default: Writer

write: Writer

limiter: Limiter

sst_max_size: u64

Implementations

impl BackupWriter

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

Create a new BackupWriter.

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

Write entries to buffered SST files.

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

Save buffered SST files to the given external storage.

pub fn need_split_keys(&self) -> bool

pub fn need_flush_keys(&self) -> bool