Struct ProcessorRegistry 

pub struct ProcessorRegistry { /* private fields */ }

Registry of structured processors.

Thread-safe (processors are Arc<dyn Processor>) and can be shared across threads via Arc<ProcessorRegistry>.

Implementations

impl ProcessorRegistry

pub fn new() -> Self

Create an empty registry.

pub fn with_builtins() -> Self

Create a registry pre-populated with all built-in processors.

pub fn register(&mut self, processor: Arc<dyn Processor>)

Register a processor. Overwrites any existing processor with the same name.

pub fn register_with_alias( &mut self, processor: Arc<dyn Processor>, alias: &str, )

Register a processor under its canonical name and an additional alias.

pub fn get(&self, name: &str) -> Option<&Arc<dyn Processor>>

Look up a processor by its name.

pub fn names(&self) -> Vec<&str>

List all registered processor names.

pub fn len(&self) -> usize

Number of registered processors.

pub fn is_empty(&self) -> bool

Whether the registry is empty.

pub fn find_processor( &self, content: &[u8], profile: &FileTypeProfile, ) -> Option<&Arc<dyn Processor>>

Find a processor that can handle the given content + profile.

1. If the profile names a specific processor, look it up directly.
2. Otherwise, iterate all processors and return the first whose can_handle returns true.

Returns None if no processor matches (caller should fall back to the streaming scanner).

pub fn process( &self, content: &[u8], profile: &FileTypeProfile, store: &MappingStore, ) -> Result<Option<Vec<u8>>>

Process content using the matching processor.

Returns Ok(Some(output)) if a processor matched and succeeded, Ok(None) if no processor matches (caller should fall back), or Err(...) if processing failed.

Errors

Returns the underlying processor’s error if processing fails.

Trait Implementations

impl Default for ProcessorRegistry

fn default() -> Self

Returns the “default value” for a type.