blob_indexer/indexer/
types.rs

1use tokio::{
2    sync::{
3        mpsc::{Receiver as MPSCReceiver, Sender as MPSCSender},
4        oneshot::{Receiver as OneshotReceiver, Sender as OneshotSender},
5    },
6    task::JoinHandle,
7};
8
9use crate::indexer::error::IndexerTaskError;
10
11pub struct ErrorResport {
12    pub task_name: String,
13    pub error: IndexerTaskError,
14}
15
16pub type TaskResult = ();
17pub type TaskResultChannelSender = OneshotSender<TaskResult>;
18pub type TaskResultChannelReceiver = OneshotReceiver<TaskResult>;
19pub type TaskErrorChannelSender = MPSCSender<ErrorResport>;
20pub type TaskErrorChannelReceiver = MPSCReceiver<ErrorResport>;
21
22pub type IndexingTaskJoinHandle = JoinHandle<()>;