Struct reth_nippy_jar::compression::Zstd

pub struct Zstd {
    pub use_dict: bool,
    /* private fields */
}

Zstd compression structure. Supports a compression dictionary per column.

Fields

use_dict: bool

Uses custom dictionaries to compress data.

Implementations

impl Zstd

pub const fn new(use_dict: bool, max_dict_size: usize, columns: usize) -> Self

Creates new Zstd.

pub const fn with_level(self, level: i32) -> Self

pub fn decompressors(&self) -> Result<Vec<Decompressor<'_>>, NippyJarError>

Creates a list of Decompressor if using dictionaries.

pub fn compressors(&self) -> Result<Option<Vec<Compressor<'_>>>, NippyJarError>

If using dictionaries, creates a list of [Compressor].

pub fn compress_with_dictionary( column_value: &[u8], buffer: &mut Vec<u8>, handle: &mut File, compressor: Option<&mut Compressor<'_>>, ) -> Result<(), NippyJarError>

Compresses a value using a dictionary. Reserves additional capacity for buffer if necessary.

pub fn decompress_with_dictionary( column_value: &[u8], output: &mut Vec<u8>, decompressor: &mut Decompressor<'_>, ) -> Result<(), NippyJarError>

Appends a decompressed value using a dictionary to a user provided buffer.

Trait Implementations

impl Compression for Zstd

fn decompress_to( &self, value: &[u8], dest: &mut Vec<u8>, ) -> Result<(), NippyJarError>

Appends decompressed data to the dest buffer. Requires dest to have sufficient capacity.

fn decompress(&self, value: &[u8]) -> Result<Vec<u8>, NippyJarError>

Returns decompressed data.

fn compress_to( &self, src: &[u8], dest: &mut Vec<u8>, ) -> Result<usize, NippyJarError>

Appends compressed data from src to dest. dest. Requires dest to have sufficient capacity.

fn compress(&self, src: &[u8]) -> Result<Vec<u8>, NippyJarError>

Compresses data from src

fn is_ready(&self) -> bool

Returns true if it’s ready to compress.

impl Debug for Zstd

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Zstd

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Zstd

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 32 bytes