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    Pushing(WorkerId, ProgressEntry),
12    PushError(WorkerId, ProgressEntry, PushError),
13    PushProgress(WorkerId, ProgressEntry),
14    Flushing,
15    FlushError(PushError),
16    Finished(WorkerId),
17}