Struct DefaultIoContext 

pub struct DefaultIoContext { /* private fields */ }

A default implementation of IoContext that uses the default compressor. It uses tokio’s async IO by default.

Implementations

impl DefaultIoContext

pub fn new(base_dir: PathBuf) -> Self

Create a new instance of DefaultIoContext.

Trait Implementations

impl Debug for DefaultIoContext

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

Formats the value using the given formatter.

impl IoContext for DefaultIoContext

fn add_squeeze_hint(&self, entry_id: &EntryID, expression: Arc<CacheExpression>)

Add a squeeze hint for an entry.

fn squeeze_hint(&self, entry_id: &EntryID) -> Option<Arc<CacheExpression>>

Get the squeeze hint for an entry. If None, the entry will be evicted to disk entirely. If Some, the entry will be squeezed according to the cache expressions previously recorded for this column. For example, if expression is ExtractDate32 { field: Date32Field::Year }, the entry will be squeezed to a crate::liquid_array::SqueezedDate32Array with the year component (Date32 or Timestamp input).

fn get_compressor(&self, _entry_id: &EntryID) -> Arc<LiquidCompressorStates>

Get the compressor for an entry.

fn disk_path(&self, entry_id: &EntryID) -> PathBuf

Get the disk path for a cache entry.

fn read<'life0, 'async_trait>( &'life0 self, path: PathBuf, range: Option<Range<u64>>, ) -> Pin<Box<dyn Future<Output = Result<Bytes, Error>> + Send + 'async_trait>>

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

Read bytes from the file at the given path, optionally restricted to the provided range.

fn write_file<'life0, 'async_trait>( &'life0 self, path: PathBuf, data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Write the entire buffer to a file at the given path.