Struct SlowFileSystem 

pub struct SlowFileSystem { /* private fields */ }

Slow filesystem wrapper for testing

Wraps any FileSystem implementation and adds configurable delays to each operation. Also tracks metrics about operation counts.

Implementations

impl SlowFileSystem

pub fn new(inner: Arc<dyn FileSystem>, config: SlowFsConfig) -> Self

Create a new slow filesystem wrapper

pub fn with_uniform_delay(inner: Arc<dyn FileSystem>, delay: Duration) -> Self

Create with uniform delay for all operations

pub fn metrics(&self) -> &Arc<BackendMetrics>

Get a reference to the metrics

pub fn reset_metrics(&self)

Reset metrics to zero

Trait Implementations

impl FileSystem for SlowFileSystem

fn read_file(&self, path: &Path) -> Result<Vec<u8>>

Read entire file into memory

fn read_range(&self, path: &Path, offset: u64, len: usize) -> Result<Vec<u8>>

Read a range of bytes from a file (for lazy loading large files)

fn write_file(&self, path: &Path, data: &[u8]) -> Result<()>

Write data to file atomically (temp file + rename)

fn create_file(&self, path: &Path) -> Result<Box<dyn FileWriter>>

Create a file for writing, returns a writer handle

fn open_file(&self, path: &Path) -> Result<Box<dyn FileReader>>

Open a file for reading, returns a reader handle

fn open_file_for_write(&self, path: &Path) -> Result<Box<dyn FileWriter>>

Open a file for writing in-place (truncating, preserves ownership on Unix)

fn open_file_for_append(&self, path: &Path) -> Result<Box<dyn FileWriter>>

Open a file for appending (creates if doesn’t exist)

fn set_file_length(&self, path: &Path, len: u64) -> Result<()>

Set file length (truncate or extend with zeros)

fn rename(&self, from: &Path, to: &Path) -> Result<()>

Rename/move a file or directory atomically

fn copy(&self, from: &Path, to: &Path) -> Result<u64>

Copy a file (fallback when rename fails across filesystems)

fn remove_file(&self, path: &Path) -> Result<()>

Remove a file

fn remove_dir(&self, path: &Path) -> Result<()>

Remove an empty directory

fn metadata(&self, path: &Path) -> Result<FileMetadata>

Get file/directory metadata

fn symlink_metadata(&self, path: &Path) -> Result<FileMetadata>

Get symlink metadata (doesn’t follow symlinks)

fn is_dir(&self, path: &Path) -> Result<bool>

Check if path is a directory

fn is_file(&self, path: &Path) -> Result<bool>

Check if path is a file

fn set_permissions( &self, path: &Path, permissions: &FilePermissions, ) -> Result<()>

Set file permissions

fn read_dir(&self, path: &Path) -> Result<Vec<DirEntry>>

List entries in a directory (non-recursive)

fn create_dir(&self, path: &Path) -> Result<()>

Create a directory

fn create_dir_all(&self, path: &Path) -> Result<()>

Create a directory and all parent directories

fn canonicalize(&self, path: &Path) -> Result<PathBuf>

Get canonical (absolute, normalized) path

fn current_uid(&self) -> u32

Get the current user’s UID (Unix only, returns 0 on other platforms)

fn sudo_write( &self, path: &Path, data: &[u8], mode: u32, uid: u32, gid: u32, ) -> Result<()>

Write file using sudo (for root-owned files).

fn search_file( &self, path: &Path, pattern: &str, opts: &FileSearchOptions, cursor: &mut FileSearchCursor, ) -> Result<Vec<SearchMatch>>

Search a file on disk for a pattern, returning one batch of matches.

fn count_line_feeds_in_range( &self, path: &Path, offset: u64, len: usize, ) -> Result<usize>

Count \n bytes in a file range without returning the data.

fn write_patched( &self, src_path: &Path, dst_path: &Path, ops: &[WriteOp<'_>], ) -> Result<()>

Write a file using a patch recipe (optimized for remote filesystems).

fn exists(&self, path: &Path) -> bool

Check if path exists

fn metadata_if_exists(&self, path: &Path) -> Option<FileMetadata>

Check if path exists, returns metadata if it does

fn is_writable(&self, path: &Path) -> bool

Check if the current user has write permission to the given path.

fn is_owner(&self, path: &Path) -> bool

Check if the current user is the owner of the file

fn temp_path_for(&self, path: &Path) -> PathBuf

Get a temporary file path for atomic writes

fn unique_temp_path(&self, dest_path: &Path) -> PathBuf

Get a unique temporary file path (using timestamp and PID)

fn remote_connection_info(&self) -> Option<&str>

Get remote connection info if this is a remote filesystem

fn home_dir(&self) -> Result<PathBuf>

Get the home directory for this filesystem