Struct CachedDiskWriter 

pub struct CachedDiskWriter { /* private fields */ }

Implementations

impl CachedDiskWriter

pub fn new( path: &Path, total_size: Option<u64>, cache_size_mb: Option<usize>, ) -> Self

Create a new CachedDiskWriter using PositionedDiskWriter (pwrite/seek_write) as the underlying I/O strategy.

This is the default constructor; use new_with_mmap to select the memory-mapped strategy instead.

pub fn new_with_mmap( path: &Path, total_size: Option<u64>, cache_size_mb: Option<usize>, use_mmap: bool, ) -> Self

Create a new CachedDiskWriter with explicit control over the I/O strategy.

Arguments

• path - Output file path.
• total_size - Expected total file size, used for pre-allocation.
• cache_size_mb - Optional write-back cache size in megabytes.
• use_mmap - If true, use MmapDiskWriter (memory-mapped I/O); otherwise use PositionedDiskWriter (positioned pwrite/seek_write).

pub fn open_existing(path: &Path) -> Result<Self>

pub fn with_rate_limiter(self, limiter: Arc<RateLimiter>) -> Self

Attach a rate limiter for write throttling. Uses non-blocking try_acquire: if tokens unavailable, writes proceed without blocking.

pub fn is_opened(&self) -> bool

impl CachedDiskWriter

pub async fn read_all(&mut self) -> Result<Vec<u8>>

Trait Implementations

impl SeekableDiskWriter for CachedDiskWriter

fn write_bytes_at<'life0, 'async_trait>( &'life0 mut self, offset: u64, data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Zero-copy write: accepts Bytes directly. When caching, the Bytes is moved into the cache (O(1) refcount bump). When direct-writing, the Bytes is passed by reference to pwrite (no copy).

fn open<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn write_at<'life0, 'life1, 'async_trait>( &'life0 mut self, offset: u64, data: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn read_at<'life0, 'life1, 'async_trait>( &'life0 mut self, offset: u64, buf: &'life1 mut [u8], ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

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

fn truncate<'life0, 'async_trait>( &'life0 mut self, length: u64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn flush<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn len<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

fn path(&self) -> &Path

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Close the writer and release underlying file resources.