firedbg_stream_indexer/processor.rs
1use anyhow::Result;
2use async_trait::async_trait;
3use sea_streamer::SharedMessage;
4
5#[async_trait]
6pub trait Processor {
7 async fn batch(&mut self, messages: impl Iterator<Item = SharedMessage> + Send) -> Result<()>;
8
9 async fn end(&mut self) -> Result<()>;
10
11 fn finish(self) -> Result<()>;
12}