Struct ZernelScheduler 

pub struct ZernelScheduler {
    config: SchedulerConfig,
    phase_detector: PhaseDetector,
    task_states: HashMap<u32, ZernelTaskState>,
    numa: NumaTopology,
    tenant_scheduler: TenantScheduler,
    cpu_loads: HashMap<u32, f32>,
    pub decisions_made: u64,
}

The Zernel ML-aware scheduler.

Integrates phase detection, NUMA-aware CPU selection, and multi-tenant GPU-proportional scheduling.

Fields

config: SchedulerConfig

phase_detector: PhaseDetector

task_states: HashMap<u32, ZernelTaskState>

numa: NumaTopology

tenant_scheduler: TenantScheduler

cpu_loads: HashMap<u32, f32>

Per-CPU load estimates (cpu_id -> load fraction 0.0-1.0).

decisions_made: u64

Total scheduling decisions made.

Implementations

impl ZernelScheduler

pub fn new(config: SchedulerConfig) -> Self

pub fn register_task(&mut self, pid: u32, is_ml: bool, gpu_id: Option<u32>)

Register a new task for tracking.

pub fn unregister_task(&mut self, pid: u32)

Remove a task from tracking.

pub fn update_task(&mut self, pid: u32, update: TaskUpdate)

Update task metrics (called from BPF ringbuf events or polling).

pub fn update_cpu_loads(&mut self, loads: HashMap<u32, f32>)

Update CPU load estimates (called periodically from /proc/stat or BPF).

pub fn schedule(&mut self, pid: u32, now_ns: u64) -> SchedulingDecision

Run phase detection and return a scheduling decision for a task.

pub fn tenant_scheduler_mut(&mut self) -> &mut TenantScheduler

Get a reference to the tenant scheduler.

pub fn task_states(&self) -> &HashMap<u32, ZernelTaskState>

Get current state snapshot for telemetry export.

pub fn numa_topology(&self) -> &NumaTopology

pub fn phase_transition_count(&self) -> u64

pub fn config(&self) -> &SchedulerConfig