Struct CacheDirectPusher 

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

Pusher wrapper that buffers chunks and flushes large contiguous runs without merging.

Out-of-order chunks are stored in a BTreeMap. When a contiguous run reaches the high watermark, it is flushed to the inner pusher as-is (no byte merging). This reduces CPU overhead compared to super::CacheMergePusher at the cost of more individual write calls.

Implementations

impl<P> CacheDirectPusher<P>

where P: Pusher,

pub const fn new( inner: P, high_watermark: usize, low_watermark: usize, ) -> CacheDirectPusher<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 does nothing until the buffered size passes low_watermark, which then acts as the sole watermark.

With high_watermark == low_watermark, a push that lands the buffered size exactly on the watermark evicts nothing; the next push takes it above and eviction proceeds as usual.

Trait Implementations

impl<P> Debug for CacheDirectPusher<P>

where P: Debug,

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

Formats the value using the given formatter.

impl<P> Pusher for CacheDirectPusher<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<(), (<CacheDirectPusher<P> as Pusher>::Error, Bytes)>

Write content covering the given range to the destination.

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

Flush any buffered data to the destination.