Struct CacheFilePusher 

pub struct CacheFilePusher { /* private fields */ }

File pusher combining CacheSeqPusher with StdFilePusher.

Provides out-of-order reordering on top of standard file I/O. The write buffer, watermark levels, and sync-all behavior are forwarded to StdFilePusher::new.

Implementations

impl CacheFilePusher

pub async fn new( file: File, size: u64, sync_all: bool, high_watermark: usize, low_watermark: usize, buffer_size: usize, ) -> Result<CacheFilePusher, Error>

Errors

1. Returns an error if fs::set_len fails.
2. Returns an error if StdFilePusher initialization fails.

Trait Implementations

impl Debug for CacheFilePusher

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

Formats the value using the given formatter.

impl Pusher for CacheFilePusher

type Error = Error

Error produced while pushing.

fn set_listener(&mut self, cb: Box<dyn FnMut(Range<u64>) + Send>)

Install a callback that fires whenever a chunk has been successfully pushed to its destination.

fn push( &mut self, range: &Range<u64>, bytes: Bytes, ) -> Result<(), (<CacheFilePusher as Pusher>::Error, Bytes)>

Write content covering the given range to the destination.

fn flush(&mut self) -> Result<(), <CacheFilePusher as Pusher>::Error>

Flush any buffered data to the destination.