pub struct AttemptTimeoutScanner { /* private fields */ }Implementations§
Source§impl AttemptTimeoutScanner
impl AttemptTimeoutScanner
pub fn new(interval: Duration, lanes: Vec<LaneId>) -> Self
Sourcepub fn with_filter(
interval: Duration,
_lanes: Vec<LaneId>,
filter: ScannerFilter,
) -> Self
pub fn with_filter( interval: Duration, _lanes: Vec<LaneId>, filter: ScannerFilter, ) -> Self
Construct with a ScannerFilter applied per candidate
(issue #122).
Trait Implementations§
Source§impl Scanner for AttemptTimeoutScanner
impl Scanner for AttemptTimeoutScanner
Source§fn filter(&self) -> &ScannerFilter
fn filter(&self) -> &ScannerFilter
Per-consumer filter applied by execution-shaped scanners to
restrict the set of candidates they act on (issue #122). Read more
Source§async fn scan_partition(&self, client: &Client, partition: u16) -> ScanResult
async fn scan_partition(&self, client: &Client, partition: u16) -> ScanResult
Scan a single partition. Called once per partition per cycle.
Source§fn sample_backlog_depth(
&self,
_client: &Client,
_partition: u16,
) -> impl Future<Output = Option<u64>> + Send
fn sample_backlog_depth( &self, _client: &Client, _partition: u16, ) -> impl Future<Output = Option<u64>> + Send
PR-94: per-cycle gauge sample. Returns
Some(depth) summed
across all partitions by the scanner runner to produce a
single gauge value (today only cancel_reconciler exports
one, feeding ff_cancel_backlog_depth). Default: None so
scanners that don’t export a gauge compile unchanged. Read moreAuto Trait Implementations§
impl !Freeze for AttemptTimeoutScanner
impl RefUnwindSafe for AttemptTimeoutScanner
impl Send for AttemptTimeoutScanner
impl Sync for AttemptTimeoutScanner
impl Unpin for AttemptTimeoutScanner
impl UnsafeUnpin for AttemptTimeoutScanner
impl UnwindSafe for AttemptTimeoutScanner
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