Struct TokioFileIO 

pub struct TokioFileIO { /* private fields */ }

Implementation of FileIOService with memory mapping support

This struct provides a high-performance implementation of the file I/O service interface, featuring memory-mapped file access, asynchronous operations, and comprehensive statistics tracking.

Features

• Memory Mapping: Uses memory-mapped files for optimal performance
• Async I/O: All operations are asynchronous and non-blocking
• Thread Safety: Safe for concurrent access from multiple threads
• Statistics: Tracks detailed I/O performance metrics
• Configuration: Runtime configuration updates supported

Examples

Implementations

impl TokioFileIO

pub fn new(config: FileIOConfig) -> Self

Creates a new FileIOService instance

pub fn new_default() -> Self

Creates a new FileIOService with default configuration

Trait Implementations

impl FileIOService for TokioFileIO

fn read_file_chunks<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 Path, options: ReadOptions, ) -> Pin<Box<dyn Future<Output = Result<ReadResult, PipelineError>> + Send + 'async_trait>>

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

Reads a file and returns it as chunks

fn read_file_mmap<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 Path, options: ReadOptions, ) -> Pin<Box<dyn Future<Output = Result<ReadResult, PipelineError>> + Send + 'async_trait>>

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

Reads a file using memory mapping if possible

fn write_file_chunks<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 Path, chunks: &'life2 [FileChunk], options: WriteOptions, ) -> Pin<Box<dyn Future<Output = Result<WriteResult, PipelineError>> + Send + 'async_trait>>

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

Writes chunks to a file

fn write_file_data<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 Path, data: &'life2 [u8], options: WriteOptions, ) -> Pin<Box<dyn Future<Output = Result<WriteResult, PipelineError>> + Send + 'async_trait>>

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

Writes data directly to a file

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

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

Gets information about a file

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

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

Checks if a file exists

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

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

Deletes a file

fn copy_file<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source: &'life1 Path, destination: &'life2 Path, options: WriteOptions, ) -> Pin<Box<dyn Future<Output = Result<WriteResult, PipelineError>> + Send + 'async_trait>>

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

Copies a file

fn move_file<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source: &'life1 Path, destination: &'life2 Path, options: WriteOptions, ) -> Pin<Box<dyn Future<Output = Result<WriteResult, PipelineError>> + Send + 'async_trait>>

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

Moves a file

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

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

Creates a directory

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

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

Checks if a directory exists

fn list_directory<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 Path, ) -> Pin<Box<dyn Future<Output = Result<Vec<FileInfo>, PipelineError>> + Send + 'async_trait>>

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

Lists files in a directory

fn get_config(&self) -> FileIOConfig

Gets the current configuration

fn update_config(&mut self, config: FileIOConfig)

Updates the configuration

fn get_stats(&self) -> FileIOStats

Gets I/O statistics

fn reset_stats(&mut self)

Resets I/O statistics

fn validate_file_integrity<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 Path, expected_checksum: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool, PipelineError>> + Send + 'async_trait>>

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

Validates file integrity using checksums

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

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

Calculates file checksum

fn stream_file_chunks<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 Path, options: ReadOptions, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<FileChunk, PipelineError>> + Send>>, PipelineError>> + Send + 'async_trait>>

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

Streams file chunks for processing

fn write_chunk_to_file<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 Path, chunk: &'life2 FileChunk, options: WriteOptions, is_first_chunk: bool, ) -> Pin<Box<dyn Future<Output = Result<WriteResult, PipelineError>> + Send + 'async_trait>>

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

Writes a single chunk to a file (for streaming writes)