Struct backup::writer::BackupRawKVWriter [−][src]
A writer writes Raw kv into SST files.
Fields
name: String
cf: CfName
writer: Writer
limiter: Limiter
Implementations
impl BackupRawKVWriter
[src]
pub fn new(
db: Arc<DB>,
name: &str,
cf: CfName,
limiter: Limiter,
compression_type: Option<SstCompressionType>,
compression_level: i32
) -> Result<BackupRawKVWriter>
[src]
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>>,
[src]
I: Iterator<Item = Result<KvPair>>,
Write Kv_pair to buffered SST files.
pub fn save(self, storage: &dyn ExternalStorage) -> Result<Vec<File>>
[src]
Save buffered SST files to the given external storage.
Auto Trait Implementations
impl RefUnwindSafe for BackupRawKVWriter
impl Send for BackupRawKVWriter
impl !Sync for BackupRawKVWriter
impl Unpin for BackupRawKVWriter
impl UnwindSafe for BackupRawKVWriter
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<V, W> ConvertFrom<W> for V where
W: ConvertTo<V>,
[src]
W: ConvertTo<V>,
pub fn convert_from(ctx: &mut EvalContext, from: W) -> Result<V, Error>
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> Pointable for T
[src]
pub const ALIGN: usize
[src]
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize
[src]
pub unsafe fn deref<'a>(ptr: usize) -> &'a T
[src]
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T
[src]
pub unsafe fn drop(ptr: usize)
[src]
impl<T> Pointable for T
[src]
pub const ALIGN: usize
[src]
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize
[src]
pub unsafe fn deref<'a>(ptr: usize) -> &'a T
[src]
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T
[src]
pub unsafe fn drop(ptr: usize)
[src]
impl<T> Same<T> for T
[src]
type Output = T
Should always be Self
impl<T> Sealed<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
[src]
V: MultiLane<T>,