Struct CachingDirectory 

pub struct CachingDirectory { /* private fields */ }

The caching directory is a simple cache that wraps another directory.

Implementations

impl CachingDirectory

pub fn bounded( underlying: Arc<dyn Directory>, _capacity_in_bytes: usize, file_stats: FileStats, ) -> CachingDirectory

Creates a new CachingDirectory.

Warming: The resulting CacheDirectory will cache all information without ever removing any item from the cache.

pub fn unbounded( underlying: Arc<dyn Directory>, file_stats: FileStats, ) -> CachingDirectory

Trait Implementations

impl Clone for CachingDirectory

fn clone(&self) -> CachingDirectory

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CachingDirectory

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

Formats the value using the given formatter.

impl Directory for CachingDirectory

fn get_file_handle( &self, path: &Path, ) -> Result<Arc<dyn FileHandle>, OpenReadError>

Opens a file and returns a boxed FileHandle.

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

Removes a file

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

Returns true if and only if the file exists

fn open_write(&self, path: &Path) -> Result<WritePtr, OpenWriteError>

Opens a writer for the virtual file associated with a Path.

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

Reads the full content file that has been written using Directory::atomic_write().

fn atomic_read_async<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 Path, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, OpenReadError>> + Send + 'async_trait>>

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

Reads asynchronously the full content file that has been written using Directory::atomic_write().

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

Atomically replace the content of a file with data.

fn sync_directory(&self) -> Result<()>

Sync the directory.

fn acquire_lock(&self, lock: &Lock) -> Result<DirectoryLock, LockError>

Acquire a lock in the directory given in the Lock.

fn watch(&self, callback: WatchCallback) -> Result<WatchHandle>

Registers a callback that will be called whenever a change on the meta.json using the Directory::atomic_write() API is detected.

fn as_any(&self) -> &dyn Any

fn underlying_directory(&self) -> Option<&dyn Directory>

fn real_directory(&self) -> &dyn Directory

fn open_read(&self, path: &Path) -> Result<FileSlice, OpenReadError>

Once a virtual file is open, its data may not change.

fn open_read_async<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 Path, ) -> Pin<Box<dyn Future<Output = Result<FileSlice, OpenReadError>> + Send + 'async_trait>>

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

fn delete_async<'life0, 'life1, 'async_trait>( &'life0 self, _: &'life1 Path, ) -> Pin<Box<dyn Future<Output = Result<(), DeleteError>> + Send + 'async_trait>>

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