Struct SessionSystemContextState 

pub struct SessionSystemContextState {
    pub pending: Vec<PendingSystemContextAppend>,
    pub applied: Vec<PendingSystemContextAppend>,
    pub seen: BTreeMap<String, SeenSystemContextKey>,
    pub active_turn_pending_keys: BTreeSet<String>,
}

Durable control state for runtime system-context append requests.

Fields

pending: Vec<PendingSystemContextAppend>

applied: Vec<PendingSystemContextAppend>

seen: BTreeMap<String, SeenSystemContextKey>

active_turn_pending_keys: BTreeSet<String>

Implementations

impl SessionSystemContextState

pub fn stage_append( &mut self, req: &AppendSystemContextRequest, accepted_at: SystemTime, ) -> Result<AppendSystemContextStatus, SystemContextStageError>

Stage an append request, enforcing per-session idempotency.

pub fn stage_active_turn_append( &mut self, req: &AppendSystemContextRequest, accepted_at: SystemTime, ) -> Result<AppendSystemContextStatus, SystemContextStageError>

Stage an append that is scoped to the currently-active turn only.

If the active turn reaches another model boundary, normal pending consumption moves it to applied. If the turn completes first, callers should discard the still-pending active-turn keys so the context cannot leak into an unrelated later run.

pub fn mark_pending_applied(&mut self)

Mark all currently-pending appends as applied and clear the pending queue.

pub fn discard_unapplied_active_turn_pending( &mut self, ) -> Vec<PendingSystemContextAppend>

Discard active-turn-only appends that were not consumed by the turn’s next LLM boundary.

pub fn discard_active_turn_pending_by_keys( &mut self, idempotency_keys: &[String], ) -> Vec<PendingSystemContextAppend>

Discard specific active-turn-only appends that are still pending.

This is the rollback companion for live-boundary staging. The runtime owns the accepted input, so if that commit fails after the session has staged context, the session-side projection must be removed by the same idempotency keys before the caller reports failure.

Trait Implementations

impl Clone for SessionSystemContextState

fn clone(&self) -> SessionSystemContextState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SessionSystemContextState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SessionSystemContextState

fn default() -> SessionSystemContextState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SessionSystemContextState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SessionSystemContextState

fn eq(&self, other: &SessionSystemContextState) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for SessionSystemContextState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for SessionSystemContextState

impl StructuralPartialEq for SessionSystemContextState