pub struct EnrichmentQueue { /* private fields */ }Expand description
Bounded async enrichment queue (embedding + fact extraction).
Implementations§
Source§impl EnrichmentQueue
impl EnrichmentQueue
pub fn new(max_depth: usize) -> Self
pub fn depth(&self) -> usize
pub fn processed_count(&self) -> u64
pub fn try_enqueue(&self, job: EnrichmentJob) -> Result<(), EnrichmentError>
pub fn pop(&self) -> Option<EnrichmentJob>
pub fn mark_processed(&self)
Auto Trait Implementations§
impl !Freeze for EnrichmentQueue
impl !RefUnwindSafe for EnrichmentQueue
impl Send for EnrichmentQueue
impl Sync for EnrichmentQueue
impl Unpin for EnrichmentQueue
impl UnsafeUnpin for EnrichmentQueue
impl UnwindSafe for EnrichmentQueue
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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
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