Struct SkeletonScheduler 

pub struct SkeletonScheduler<R: RuntimeRepository> { /* private fields */ }

Compile-safe scheduler skeleton for queue -> lease dispatch.

Implementations

impl<R: RuntimeRepository> SkeletonScheduler<R>

pub fn new(repository: R) -> Self

pub fn with_circuit_breaker(self, breaker: Arc<CircuitBreaker>) -> Self

Attach a shared circuit breaker to this scheduler.

When the breaker is Open, all dispatch calls return SchedulerDecision::Backpressure until the probe window elapses.

pub fn dispatch_one( &self, worker_id: &str, ) -> Result<SchedulerDecision, KernelError>

Attempt to dispatch one eligible attempt to worker_id.

pub fn dispatch_one_with_context( &self, worker_id: &str, context: Option<&DispatchContext>, ) -> Result<SchedulerDecision, KernelError>

Dispatch one attempt to worker_id with optional context for tenant/priority/capability routing. Context is passed through for future filtering or sorting; current implementation uses the same candidate list as dispatch_one.

If context.max_queue_depth is set and the number of dispatchable candidates is greater than or equal to that limit, returns SchedulerDecision::Backpressure without acquiring any lease.