Enum WindowedSourceFile 

pub enum WindowedSourceFile {
    Plain(WindowedFile),
    Spilled(SpillWindowedFile),
}

A seekable bounded source, with compressed input spooled only when the execution context explicitly permits temporary storage.

Variants

Plain(WindowedFile)

Uncompressed source read directly from its file.

Spilled(SpillWindowedFile)

Decompressed bytes held in execution-owned spill storage.

Implementations

impl WindowedSourceFile

pub fn open( path: impl AsRef<Path>, max_window_bytes: usize, context: &ExecutionContext, ) -> Result<Self, Diagnostic>

Opens a plain, gzip or Zstandard file with bounded resident memory.

Compressed inputs require an enabled crate::TempStoragePolicy. The spool is charged, checksummed and deleted with this source.

Errors

Returns a registered I/O, codec, spill-budget or memory diagnostic.

pub const fn spill_bytes(&self) -> u64

Physical bytes currently retained in spill storage.

Trait Implementations

impl Debug for WindowedSourceFile

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

Formats the value using the given formatter.

impl SourceBytes for WindowedSourceFile

fn window( &mut self, start: u64, len: usize, ) -> Result<ByteWindow<'_>, Diagnostic>

Returns at most len bytes starting at the global byte offset start.

fn len_hint(&self) -> Option<u64>

Exact source length when known without consuming the source.