diff --git a/timely/src/logging.rs b/timely/src/logging.rs index adb8ed620..00e648b85 100644 --- a/timely/src/logging.rs +++ b/timely/src/logging.rs @@ -198,29 +198,22 @@ pub struct InputEvent { pub start_stop: StartStop, } -#[derive(Serialize, Deserialize, Abomonation, Debug, Clone, Hash, Eq, PartialEq, Ord, PartialOrd)] -/// Input logic start/stop -pub struct ParkEvent { - /// True when activity begins, false when it stops - pub event: ParkUnpark -} - -impl ParkEvent { - /// Creates a new park event from the supplied duration. - pub fn park(duration: Option) -> Self { ParkEvent { event: ParkUnpark::Park(duration) } } - /// Creates a new unpark event. - pub fn unpark() -> Self { ParkEvent { event: ParkUnpark::Unpark } } -} - /// Records the starting and stopping of an operator. #[derive(Serialize, Deserialize, Abomonation, Debug, Clone, Hash, PartialEq, Eq, Ord, PartialOrd)] -pub enum ParkUnpark { +pub enum ParkEvent { /// Worker parks. Park(Option), /// Worker unparks. Unpark, } +impl ParkEvent { + /// Creates a new park event from the supplied duration. + pub fn park(duration: Option) -> Self { ParkEvent::Park(duration) } + /// Creates a new unpark event. + pub fn unpark() -> Self { ParkEvent::Unpark } +} + #[derive(Serialize, Deserialize, Debug, Clone, Abomonation, Hash, Eq, PartialEq, Ord, PartialOrd)] /// An event in a timely worker pub enum TimelyEvent {