Struct DocumentIngestor 

pub(crate) struct DocumentIngestor<'a, S> {
    config: &'a Config,
    store: &'a S,
    max_extract_bytes: u64,
}

Executes the existing canonical write path for one already-discovered item.

Fields

config: &'a Config

store: &'a S

max_extract_bytes: u64

Implementations

impl<'a, S: AppStore> DocumentIngestor<'a, S>

pub(crate) fn new(config: &'a Config, store: &'a S, source_label: &str) -> Self

pub(crate) async fn ingest( &self, item: &mut SourceItem, ) -> Result<DocumentIngestOutcome>