Struct UncompressedStorage 

pub struct UncompressedStorage;

Uncompressed storage handler for transaction files

Stores transactions as plain .sql files with no compression. Simple and efficient for smaller transactions or when compression overhead is not justified.

Implementations

impl UncompressedStorage

pub fn new() -> Self

Create a new uncompressed storage handler

Trait Implementations

impl Clone for UncompressedStorage

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for UncompressedStorage

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

Formats the value using the given formatter.

impl Default for UncompressedStorage

fn default() -> Self

Returns the “default value” for a type.

impl TransactionStorage for UncompressedStorage

fn write_transaction<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, file_path: &'life1 Path, data: &'life2 [String], ) -> Pin<Box<dyn Future<Output = Result<PathBuf>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Write a transaction file to storage

fn write_transaction_from_file<'life0, 'life1, 'async_trait>( &'life0 self, file_path: &'life1 Path, known_statement_count: usize, ) -> Pin<Box<dyn Future<Output = Result<PathBuf>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Write a transaction file from an existing uncompressed file

fn write_raw_lines_from_file<'life0, 'life1, 'async_trait>( &'life0 self, file_path: &'life1 Path, _known_line_count: usize, ) -> Pin<Box<dyn Future<Output = Result<PathBuf>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Write a raw-lines file (event mode) from an existing uncompressed file

fn read_transaction<'life0, 'life1, 'async_trait>( &'life0 self, file_path: &'life1 Path, start_index: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read SQL commands from a transaction file, starting from a specific index

fn delete_transaction<'life0, 'life1, 'async_trait>( &'life0 self, file_path: &'life1 Path, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a transaction file

fn file_exists<'life0, 'life1, 'async_trait>( &'life0 self, file_path: &'life1 Path, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if a file exists

fn file_extension(&self) -> &str

Get the actual file extension used by this storage implementation

fn transform_path(&self, base_path: &Path) -> PathBuf

Transform a base file path to the actual storage path