Struct DetectionScheduler 

pub struct DetectionScheduler { /* private fields */ }

Scheduler for coordinating detection tasks Uses a simple priority queue instead of nanosecond-scheduler

Implementations

impl DetectionScheduler

pub fn new() -> Result<Self>

Create a new detection scheduler

pub async fn schedule_detection(&self, task_id: Uuid) -> Result<()>

Schedule a detection task with priority

pub async fn prioritize_threat( &self, severity: ThreatSeverity, ) -> Result<ThreatPriority>

Prioritize a threat based on severity (nanosecond-level operation)

pub async fn schedule_immediate(&self, task_id: &str) -> Result<()>

Schedule immediate processing for critical threats

pub async fn schedule_batch(&self, task_ids: Vec<Uuid>) -> Result<()>

Schedule a batch of detection tasks

pub async fn pending_count(&self) -> usize

Get the number of pending tasks

Trait Implementations

impl Default for DetectionScheduler

fn default() -> Self

Returns the “default value” for a type.