pub struct MonitoringPipeline { /* private fields */ }Expand description
File monitoring pipeline that connects FileWatcher to ParserEngine
Implementations§
Source§impl MonitoringPipeline
impl MonitoringPipeline
Sourcepub fn new(
config: PipelineConfig,
parser_engine: Arc<ParserEngine>,
event_handler: Arc<dyn PipelineEventHandler>,
) -> Result<Self>
pub fn new( config: PipelineConfig, parser_engine: Arc<ParserEngine>, event_handler: Arc<dyn PipelineEventHandler>, ) -> Result<Self>
Create a new monitoring pipeline
Sourcepub async fn start_monitoring<P: AsRef<Path>>(
&mut self,
repo_path: P,
) -> Result<()>
pub async fn start_monitoring<P: AsRef<Path>>( &mut self, repo_path: P, ) -> Result<()>
Start monitoring a repository path
Sourcepub fn stop_monitoring(&mut self)
pub fn stop_monitoring(&mut self)
Stop monitoring and shutdown the pipeline
Sourcepub fn get_stats(&self) -> &PipelineStats
pub fn get_stats(&self) -> &PipelineStats
Get pipeline statistics
Sourcepub fn reset_stats(&mut self)
pub fn reset_stats(&mut self)
Reset pipeline statistics
Auto Trait Implementations§
impl Freeze for MonitoringPipeline
impl !RefUnwindSafe for MonitoringPipeline
impl Send for MonitoringPipeline
impl Sync for MonitoringPipeline
impl Unpin for MonitoringPipeline
impl !UnwindSafe for MonitoringPipeline
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more