Struct CacheSeqPusher 

pub struct CacheSeqPusher<P> { /* private fields */ }

Pusher wrapper that reorders out-of-order chunks into sequential order.

Buffers chunks in a BTreeMap keyed by offset. Eviction starts once the buffered size reaches high_watermark and hands chunks to the inner pusher in ascending offset order — across gaps if need be, so memory stays bounded while a gap is still unfilled — until the size falls back to low_watermark. It then keeps going for as long as the next chunk continues the one just written, so a contiguous run is never cut in half. flush drains the whole buffer.

Implementations

impl<P> CacheSeqPusher<P>

where P: Pusher,

pub const fn new( inner: P, high_watermark: usize, low_watermark: usize, ) -> CacheSeqPusher<P>

Wrap inner with the given high_watermark / low_watermark (in bytes).

Eviction to the inner pusher triggers once the buffered size reaches high_watermark, and stops once it falls back to low_watermark.

low_watermark must not exceed high_watermark. A larger low_watermark makes high_watermark irrelevant, because eviction stops as soon as the buffered size is at or below low_watermark, which then acts as the sole watermark.

Trait Implementations

impl<P> Debug for CacheSeqPusher<P>

where P: Debug,

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

Formats the value using the given formatter.

impl<P> Pusher for CacheSeqPusher<P>

where P: Pusher,

type Error = <P as Pusher>::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<(), (<CacheSeqPusher<P> as Pusher>::Error, Bytes)>

Write content covering the given range to the destination.

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

Flush any buffered data to the destination.