pub struct DlqReprocessor { /* private fields */ }Expand description
DLQ reprocessor for handling failed items
Implementations§
Source§impl DlqReprocessor
impl DlqReprocessor
Sourcepub fn new(
dlq: Arc<DeadLetterQueue>,
event_logger: Option<Arc<EventLogger>>,
project_root: PathBuf,
) -> Self
pub fn new( dlq: Arc<DeadLetterQueue>, event_logger: Option<Arc<EventLogger>>, project_root: PathBuf, ) -> Self
Create a new DLQ reprocessor
Sourcepub async fn reprocess_items(
&self,
options: ReprocessOptions,
) -> Result<ReprocessResult>
pub async fn reprocess_items( &self, options: ReprocessOptions, ) -> Result<ReprocessResult>
Reprocess items from the DLQ (main entry point as per spec)
Sourcepub async fn reprocess(
&self,
workflow_id: &str,
options: ReprocessOptions,
executor: Arc<MapReduceExecutor>,
) -> Result<ReprocessResult>
pub async fn reprocess( &self, workflow_id: &str, options: ReprocessOptions, executor: Arc<MapReduceExecutor>, ) -> Result<ReprocessResult>
Legacy reprocess method for backward compatibility
Sourcepub async fn get_global_stats(
&self,
project_root: &Path,
) -> Result<GlobalDLQStats>
pub async fn get_global_stats( &self, project_root: &Path, ) -> Result<GlobalDLQStats>
Get statistics across all DLQs
Sourcepub async fn clear_processed_items(&self, workflow_id: &str) -> Result<usize>
pub async fn clear_processed_items(&self, workflow_id: &str) -> Result<usize>
Clear processed items from DLQ
Sourcepub fn apply_advanced_filter(
&self,
items: Vec<DeadLetteredItem>,
filter: &DlqFilterAdvanced,
) -> Result<Vec<DeadLetteredItem>>
pub fn apply_advanced_filter( &self, items: Vec<DeadLetteredItem>, filter: &DlqFilterAdvanced, ) -> Result<Vec<DeadLetteredItem>>
Apply advanced filtering to DLQ items
Auto Trait Implementations§
impl !RefUnwindSafe for DlqReprocessor
impl !UnwindSafe for DlqReprocessor
impl Freeze for DlqReprocessor
impl Send for DlqReprocessor
impl Sync for DlqReprocessor
impl Unpin for DlqReprocessor
impl UnsafeUnpin for DlqReprocessor
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
impl<A, B, T> HttpServerConnExec<A, B> for Twhere
B: Body,
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