Struct RealtimeSessionState 

pub struct RealtimeSessionState<M, S, R, C> { /* private fields */ }

Canonical state for one fair-scheduler realtime request.

Implementations

impl<M, S, R, C> RealtimeSessionState<M, S, R, C>

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

Exact selected model identity.

pub const fn model_owner(&self) -> &RealtimeModelOwnerIdentity

Typed model owner derived from the selected contract.

pub const fn incarnation(&self) -> RealtimeSessionIncarnation

Session incarnation allocated at first registration.

pub const fn history_generation(&self) -> RealtimeHistoryGeneration

Coordinate-history generation preserved by release/resume.

pub const fn committed_batch(&self) -> Option<NonZeroUsize>

Batch committed by the first successful frame, if any.

pub fn payload_contract( &self, ingress: &RealtimeIngressContract, ) -> Result<RealtimePayloadContract, RealtimeSessionExecutionError>

Derives the exact payload contract for the committed session batch.

pub const fn generation(&self) -> &RealtimeGenerationState<M, S, R, C>

Canonical atomic generation state.

pub fn generation_mut(&mut self) -> &mut RealtimeGenerationState<M, S, R, C>

Mutably borrows generation state while the scheduler proves the request idle.

Trait Implementations

impl<M, S, R, C> SemanticStateTransaction for RealtimeSessionState<M, S, R, C>

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

type Branch = RealtimeSessionBranch<<M as SemanticStateTransaction>::Branch, S, R, C>

Transition-local branch.

type Error = RealtimeSessionTransactionError<<M as SemanticStateTransaction>::Error, <C as Completion>::Error>

State error.

fn branch(&self) -> Result<Self::Branch, Self::Error>

Creates an unpublished branch.

fn commit_branch(&mut self, branch: Self::Branch) -> Result<(), Self::Error>

Publishes a completed branch.

fn discard_branch(branch: Self::Branch) -> Result<(), Self::Error>

Discards an unpublished branch.

fn permits_parallel_branches(&self) -> bool

Whether independent branches may share the current canonical base.