Struct CachingDirectory 

pub struct CachingDirectory<D> { /* private fields */ }

A Directory implementation wrapping another one and caching some data using deadpool_redis.

Implementations

impl<D> CachingDirectory<D>

pub fn new(dir: D, redis: Pool) -> Self

Creates a new CachingDirectory from the given directory and pool.

The provided Directory must return a FileHandle that implements read_bytes_async() without panicking.

This must be called from within a tokio context.

impl<D: Directory + Clone> CachingDirectory<D>

pub fn warmer(&self) -> Warmer<D>

Creates a Warmer that allows warming this directory’s cache.

The warmer defaults to the host’s available parallelism; configure it with Warmer::with_concurrency.

Trait Implementations

impl<D: Clone> Clone for CachingDirectory<D>

fn clone(&self) -> CachingDirectory<D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<D: Debug> Debug for CachingDirectory<D>

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

Formats the value using the given formatter.

impl<D: Clone + Directory> Directory for CachingDirectory<D>

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_read(&self, path: &Path) -> Result<FileSlice, OpenReadError>

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

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_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 watch(&self, cb: 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 acquire_lock(&self, lock: &Lock) -> Result<DirectoryLock, LockError>

Acquire a lock in the directory given in the Lock.