Struct RealtimeSessionScheduler 

pub struct RealtimeSessionScheduler<M, S, R, C, O>
where
    M: SemanticStateTransaction,
    M::Error: 'static,
    S: Clone,
    R: Clone,
    C: Completion,
    O: TransitionOutput,
{ /* private fields */ }

Singular fair scheduler for one exact selected realtime model.

Implementations

impl<M, S, R, C, O> RealtimeSessionScheduler<M, S, R, C, O>

where M: SemanticStateTransaction, M::Error: 'static, S: Clone, R: Clone, C: Completion, O: TransitionOutput,

pub const fn model_identity(&self) -> &RealtimeModelSessionIdentity

Exact selected model identity shared by every admitted request.

pub fn new( model: RealtimeModelSessionIdentity, limits: SchedulerLimits, ) -> Result<Self, SchedulerError>

Creates one scheduler for both single-request and concurrent production use.

pub fn register( &mut self, request: RequestId, generation: RealtimeGenerationState<M, S, R, C>, ) -> Result<RealtimeSessionIncarnation, RealtimeSessionError>

Registers a new canonical session with a fresh monotonic incarnation.

pub fn resume( &mut self, request: RequestId, released: ReleasedRealtimeSession<M, S, R, C>, ) -> Result<(), RealtimeSessionResumeError<M, S, R, C>>

Resumes released state only under the exact selected model identity.

pub fn enqueue( &mut self, request: RequestId, frame: RealtimeInputFrame, ) -> Result<WorkId, SchedulerError>

Enqueues one portable frame on the singular fair path.

pub fn enqueue_with_deadline( &mut self, request: RequestId, frame: RealtimeInputFrame, deadline: Option<Instant>, ) -> Result<WorkId, SchedulerError>

Enqueues one portable frame with an absolute deadline.

pub fn enqueue_batch( &mut self, request: RequestId, frames: Vec<RealtimeInputFrame>, ) -> Result<Vec<WorkId>, SchedulerError>

Atomically enqueues ordered frames on one request.

pub fn run_local_turn<E>( &mut self, now: Instant, execute: impl FnMut(WorkId, &RealtimeInputFrame, &mut RealtimeSessionBranch<M::Branch, S, R, C>) -> Result<O, E>, ) -> Result<SchedulerProgress<RealtimeInputFrame, O>, SchedulerError>

where E: Error,

Runs one fair local turn using an injected family/backend-independent submission closure.

pub fn run_local_bounded<E>( &mut self, now: Instant, maximum_frames: usize, execute: impl FnMut(WorkId, &RealtimeInputFrame, &mut RealtimeSessionBranch<M::Branch, S, R, C>) -> Result<O, E>, ) -> Result<SchedulerProgress<RealtimeInputFrame, O>, SchedulerError>

where E: Error,

Runs one local turn while admitting at most maximum_frames new transitions.

pub fn run_distributed_turn<T, E>( &mut self, protocol: u64, transport: &T, now: Instant, execute: impl FnMut(WorkId, &RealtimeInputFrame, &mut RealtimeSessionBranch<M::Branch, S, R, C>) -> Result<O, E>, ) -> Result<SchedulerProgress<RealtimeInputFrame, O>, SchedulerError>

where T: BoundedConsensusTransport, <T::Completion as Completion>::Error: Display, E: Error, O: DistributedTransitionOutput,

Runs one fair turn with mandatory topology-wide schedule and completion consensus.

pub fn replace_sampling<E>( &mut self, request: RequestId, sampling: RealtimeSampling, realize: impl FnOnce(RealtimeSampling) -> Result<(Vec<S>, Option<R>), E>, ) -> Result<(), RealtimeSamplingUpdateError<E, M::Error, C::Error>>

Atomically replaces sampling only when the request owns no queued or branched work.

pub fn cancel(&mut self, request: RequestId) -> Result<(), SchedulerError>

Cancels queued/prepared/submitted work using core scheduler semantics.

pub fn finish(&mut self, request: RequestId) -> Result<(), SchedulerError>

Marks a request finished using core scheduler semantics.

pub fn release( &mut self, request: RequestId, ) -> Result<ReleasedRealtimeSession<M, S, R, C>, SchedulerError>

Releases an idle canonical session for exact later resumption.

pub fn request_status(&self, request: RequestId) -> Option<RequestStatus>

Active or terminal request status.

pub fn queued_for_request(&self, request: RequestId) -> usize

Number of portable frames still queued for one active request.

pub fn forget_terminal( &mut self, request: RequestId, ) -> Result<RequestStatus, SchedulerError>

Removes a terminal identity so the caller may explicitly reuse it.

pub fn request_state( &self, request: RequestId, ) -> Option<&RealtimeSessionState<M, S, R, C>>

Immutable canonical session state, when active.

pub fn report(&self) -> SchedulerReport

Current scheduler telemetry.

pub fn capabilities(&self) -> SchedulerCapabilities

Configured and observed scheduler capabilities.