pub struct DebugService { /* private fields */ }Expand description
Service that passes data through while emitting Prometheus metrics
This is a diagnostic stage that:
- Passes data through completely unchanged
- Calculates SHA256 checksum of each chunk
- Emits metrics to Prometheus for monitoring
Implementations§
Source§impl DebugService
impl DebugService
Sourcepub fn new(metrics: Arc<MetricsService>) -> Self
pub fn new(metrics: Arc<MetricsService>) -> Self
Creates a new DebugService with metrics integration
Trait Implementations§
Source§impl StageService for DebugService
impl StageService for DebugService
Source§fn process_chunk(
&self,
chunk: FileChunk,
config: &StageConfiguration,
_context: &mut ProcessingContext,
) -> Result<FileChunk, PipelineError>
fn process_chunk( &self, chunk: FileChunk, config: &StageConfiguration, _context: &mut ProcessingContext, ) -> Result<FileChunk, PipelineError>
Process a file chunk according to the operation (Forward or Reverse). Read more
Source§fn position(&self) -> StagePosition
fn position(&self) -> StagePosition
Returns the position where this stage can execute in the pipeline. Read more
Source§fn is_reversible(&self) -> bool
fn is_reversible(&self) -> bool
Indicates whether this stage supports reverse operations. Read more
Source§fn stage_type(&self) -> StageType
fn stage_type(&self) -> StageType
Returns the type classification of this stage. Read more
Auto Trait Implementations§
impl Freeze for DebugService
impl !RefUnwindSafe for DebugService
impl Send for DebugService
impl Sync for DebugService
impl Unpin for DebugService
impl !UnwindSafe for DebugService
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