Struct CaptureWorker 

pub struct CaptureWorker { /* private fields */ }

Fixed-capacity worker. Enqueue is always try_send; persistence never runs on the turn-completion or compaction-transition path.

Implementations

impl CaptureWorker

pub fn new(capacity: usize) -> Self

pub fn submit_terminal( &self, lease: &MemoryContextLease, history: TerminalTurnHistory, retention: RetentionClass, provider: Arc<dyn CaptureProvider>, ) -> Result<bool, CaptureBuildError>

Apply lease capability and capture gates, build the bounded payload, and attempt a nonblocking enqueue. Ok(false) means capture was gated off.

pub fn submit_summary( &self, lease: &MemoryContextLease, source: CompactionSource, source_message_count: usize, summary_text: &str, redaction_policy: RedactionPolicy, retention: RetentionClass, provider: Arc<dyn CaptureProvider>, ) -> Result<bool, SummaryCaptureBuildError>

Apply the same exact lease gate as turn capture, build a bounded first-class compaction memory, and attempt a nonblocking enqueue.

pub fn overflow_drops(&self) -> u64

pub fn provider_failures(&self) -> u64