Struct ParallelImporter 

pub struct ParallelImporter { /* private fields */ }

Parallel import pipeline. Hashing and filesystem reads are parallelized by the scanner; blob/document writes retain their ordering and async safety.

Implementations

impl ParallelImporter

pub fn new( blob_store: BlobStore, docs_engine: DocsEngine, doc: Doc, author: AuthorId, ) -> Self

pub const fn with_threads(self, threads: usize) -> Self

pub fn with_root(self, root: impl Into<PathBuf>) -> Self

pub fn with_ignore_patterns(self, patterns: Vec<String>) -> Self

pub async fn import_path( &self, input: impl AsRef<Path>, ) -> Result<Vec<ImportEntry>>

Import all files under a directory.

Errors

Returns an error if the filesystem or database cannot be accessed.

pub async fn import_entries( &self, source_entries: Vec<FileEntry>, ) -> Result<Vec<ImportEntry>>

Import pre-scanned entries. This method can be used with a custom scanner while preserving the document update semantics.

Errors

Returns an error if the filesystem or database cannot be accessed.

Trait Implementations

impl Clone for ParallelImporter

fn clone(&self) -> ParallelImporter

Returns a duplicate of the value.

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

Performs copy-assignment from source.