Interface Processor

indexer/src/processor.rs:6–12

#[async_trait]
pub trait Processor {
    async fn batch(&mut self, messages: impl Iterator<Item = SharedMessage> + Send) -> Result<()>;

    async fn end(&mut self) -> Result<()>;

    fn finish(self) -> Result<()>;
}