Struct FocusedSourceExtractor 

pub struct FocusedSourceExtractor { /* private fields */ }

Built-in focused source HTTP and test extractor.

Implementations

impl FocusedSourceExtractor

pub fn new(language: FocusedSourceLanguage) -> Self

Creates an extractor for one mandatory source-language matrix.

pub fn with_budgets( language: FocusedSourceLanguage, budgets: ExtractionBudgets, ) -> Self

Creates an extractor with explicit effective per-invocation budgets.

Trait Implementations

impl BoundaryExtractor for FocusedSourceExtractor

fn id(&self) -> &'static str

Stable extractor identity.

fn version(&self) -> Version

Extractor and payload-schema semantic version.

fn supports(&self, file: &FileDescriptor) -> bool

Returns whether this extractor can consume a candidate file.

fn discover<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, context: &'life1 DiscoverContext<'life2>, ) -> Pin<Box<dyn Future<Output = Result<Vec<DiscoveredInput>, ExtractorError>> + Send + 'async_trait>>

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

Selects supported files from a bounded deterministic inventory.

fn extract<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, input: &'life1 ExtractInput<'life2>, ) -> Pin<Box<dyn Future<Output = Result<ExtractionBatch, ExtractorError>> + Send + 'async_trait>>

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

Produces a complete replacement batch for one source file.

fn fingerprint<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, input: &'life1 ExtractInput<'life2>, ) -> Pin<Box<dyn Future<Output = Result<ContentFingerprint, ExtractorError>> + Send + 'async_trait>>

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

Computes the source fingerprint used for incremental reuse.