Trait hydrate_pipeline::JobProcessor

source ·

pub trait JobProcessor: TypeUuid {
    type InputT: JobInput + 'static;
    type OutputT: JobOutput + 'static;

    // Required methods
    fn version(&self) -> u32;
    fn run<'a>(
        &'a self,
        context: &'a RunContext<'a, Self::InputT>
    ) -> PipelineResult<Self::OutputT>;

    // Provided method
    fn enumerate_dependencies(
        &self,
        _context: EnumerateDependenciesContext<'_, Self::InputT>
    ) -> PipelineResult<JobEnumeratedDependencies> { ... }
}