BinaryFormatReader

adaptive_pipeline::infrastructure::services::binary_format

Trait BinaryFormatReader 

Source 
pub trait BinaryFormatReader: Send + Sync {
    // Required methods
    fn read_header(&self) -> Result<FileHeader, PipelineError>;
    fn read_next_chunk<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<Option<ChunkFormat>, PipelineError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn seek_to_chunk<'life0, 'async_trait>(
        &'life0 mut self,
        chunk_index: u32,
    ) -> Pin<Box<dyn Future<Output = Result<(), PipelineError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn validate_integrity<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<bool, PipelineError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}
Expand description

Reader for streaming .adapipe processed files

Required Methods§

Source

fn read_header(&self) -> Result<FileHeader, PipelineError>

Reads the .adapipe file header/metadata

Source

fn read_next_chunk<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<ChunkFormat>, PipelineError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Reads the next processed chunk (compressed/encrypted data) from the .adapipe file

Source

fn seek_to_chunk<'life0, 'async_trait>( &'life0 mut self, chunk_index: u32, ) -> Pin<Box<dyn Future<Output = Result<(), PipelineError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Seeks to a specific chunk by index

Source

fn validate_integrity<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<bool, PipelineError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Validates the file integrity

Implementors§