blob_indexer/indexer/
types.rs1use 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<()>;