Struct tantivy::directory::ManagedDirectory

pub struct ManagedDirectory { /* private fields */ }

Wrapper of directories that keeps track of files created by Tantivy.

A managed directory is just a wrapper of a directory that keeps a (persisted) list of the files that have been created (and not deleted) by tantivy so far.

Thanks to this list, it implements a garbage_collect method that removes the files that were created by tantivy and are not useful anymore.

Implementations

impl ManagedDirectory

pub fn wrap(directory: Box<dyn Directory>) -> Result<ManagedDirectory>

Wraps a directory as managed directory.

pub fn garbage_collect<L: FnOnce() -> HashSet<PathBuf>>( &mut self, get_living_files: L ) -> Result<GarbageCollectionResult>

Garbage collect unused files.

Removes the files that were created by tantivy and are not used by any segment anymore.

• living_files - List of files that are still used by the index.

The use a callback ensures that the list of living_files is computed while we hold the lock on meta.

This method does not panick nor returns errors. If a file cannot be deleted (for permission reasons for instance) an error is simply logged, and the file remains in the list of managed files.

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

Verify checksum of a managed file

pub fn list_managed_files(&self) -> HashSet<PathBuf>

List all managed files

Trait Implementations

impl Clone for ManagedDirectory

fn clone(&self) -> ManagedDirectory

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ManagedDirectory

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

Formats the value using the given formatter.

impl Directory for ManagedDirectory

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

Opens a file and returns a boxed FileHandle.

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_write(&self, path: &Path, data: &[u8]) -> Result<()>

Atomically replace the content of a file with data.

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

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

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

Acquire a lock in the directory given in the Lock.

fn watch(&self, watch_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 sync_directory(&self) -> Result<()>

Sync the directory.