Skip to main content

fast_pull/base/
event.rs

1use crate::ProgressEntry;
2
3pub type WorkerId = usize;
4
5#[derive(Debug)]
6pub enum Event<PullError, PushError> {
7    Pulling(WorkerId),
8    PullError(WorkerId, PullError),
9    PullTimeout(WorkerId),
10    PullProgress(WorkerId, ProgressEntry),
11    PushError(WorkerId, PushError),
12    PushProgress(WorkerId, ProgressEntry),
13    FlushError(PushError),
14    Finished(WorkerId),
15}