pub enum QueueStatus {
Idle,
Active {
pending: u64,
},
Paused {
reason: String,
pending: u64,
next_retry_at: Option<i64>,
},
}Expand description
Background document-enrichment queue state, surfaced on /api/status so
operators can see whether folder-ingest enrichment is progressing, idle, or
paused on an LLM failure (waiting for a backoff retry). Mirrors the
RerankerStatus tagged-enum shape.
Variants§
Idle
No documents are queued for enrichment (nothing pending, in-progress, or paused).
Active
Documents are queued or being enriched. pending counts rows not yet done.
Paused
At least one document is paused after an LLM failure. reason is that
pause’s failure reason, next_retry_at the earliest Unix-secs retry time
(the scheduler auto-resumes once it elapses — no daemon restart needed),
and pending counts rows not yet done.
Trait Implementations§
Source§impl Clone for QueueStatus
impl Clone for QueueStatus
Source§fn clone(&self) -> QueueStatus
fn clone(&self) -> QueueStatus
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for QueueStatus
impl Debug for QueueStatus
Source§impl Default for QueueStatus
impl Default for QueueStatus
Source§fn default() -> QueueStatus
fn default() -> QueueStatus
Returns the “default value” for a type. Read more
Source§impl<'de> Deserialize<'de> for QueueStatus
impl<'de> Deserialize<'de> for QueueStatus
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl PartialEq for QueueStatus
impl PartialEq for QueueStatus
Source§impl Serialize for QueueStatus
impl Serialize for QueueStatus
impl StructuralPartialEq for QueueStatus
Auto Trait Implementations§
impl Freeze for QueueStatus
impl RefUnwindSafe for QueueStatus
impl Send for QueueStatus
impl Sync for QueueStatus
impl Unpin for QueueStatus
impl UnsafeUnpin for QueueStatus
impl UnwindSafe for QueueStatus
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