diff --git a/crates/stages/src/pipeline/builder.rs b/crates/stages/src/pipeline/builder.rs index 0f3d94d64f..f4902c4de7 100644 --- a/crates/stages/src/pipeline/builder.rs +++ b/crates/stages/src/pipeline/builder.rs @@ -55,13 +55,6 @@ where self } - /// Tell the pipeline to continuously run the pipeline, to accomodate continuous syncing / - /// downloading. - pub fn with_continuous(mut self) -> Self { - self.pipeline.continuous = true; - self - } - /// Set the tip sender. pub fn with_tip_sender(mut self, tip_tx: watch::Sender) -> Self { self.pipeline.tip_tx = Some(tip_tx); diff --git a/crates/stages/src/pipeline/mod.rs b/crates/stages/src/pipeline/mod.rs index 00173574f7..71d0f37e17 100644 --- a/crates/stages/src/pipeline/mod.rs +++ b/crates/stages/src/pipeline/mod.rs @@ -79,12 +79,19 @@ use sync_metrics::*; /// pipeline will unwind the stages in reverse order of execution. It is also possible to /// request an unwind manually (see [Pipeline::unwind]). pub struct Pipeline { + /// All configured stages in the order they will be executed. stages: Vec>, + /// The maximum block number to sync to. max_block: Option, - continuous: bool, + /// All listeners for events the pipeline emits. listeners: EventListeners, + /// Used for emitting updates about whether the pipeline is running or not. sync_state_updater: Box, + /// Keeps track of the progress of the pipeline. progress: PipelineProgress, + /// A receiver for the current chain tip to sync to + /// + /// Note: this is only used for debugging purposes. tip_tx: Option>, metrics: Metrics, } @@ -101,7 +108,6 @@ impl Default for Pipeline { Self { stages: Vec::new(), max_block: None, - continuous: false, listeners: EventListeners::default(), sync_state_updater: Box::::default(), progress: PipelineProgress::default(),