Struct SchedulerState 

pub struct SchedulerState {

    pub run_spec: Option<LogicalAgentSpec>,
    pub advertised_tool_ids: Option<Vec<String>>,
    pub turn: u32,
    pub total_tokens: WireU64,
    pub rounds_completed: u32,
    pub subagents_spawned: u32,
    pub started_at_ms: Option<WireU64>,
    pub wall_budget_ms: Option<WireU64>,
    pub tasks: Vec<TaskControlState>,
    pub attempts: Vec<TaskAttemptState>,
    pub workflow: Option<WorkflowGraphState>,
    pub queued_signals: Vec<QueuedSignalState>,
    pub signal_dedupe_keys: Vec<String>,
    pub milestone: Option<MilestoneState>,
    pub entropy: EntropyState,
    pub channels: Vec<LocalChannelState>,
    pub objects: Vec<ObjectDescriptor>,
}

§12.1 · the P2 plane: task control blocks and their attempts, budgets and waits, the workflow graph, queued signals plus dedupe memory, and the milestone cascade.

Fields

run_spec: Option<LogicalAgentSpec>

The active agent’s logical run contract. Required even when absent so checkpoints from the retired shape cannot be mistaken for current state.

advertised_tool_ids: Option<Vec<String>>

Exact task-tool surface advertised by the most recent provider call. None means no provider call has been emitted yet and is fail-closed, not permissive.

turn: u32

total_tokens: WireU64

rounds_completed: u32

subagents_spawned: u32

started_at_ms: Option<WireU64>

First observed clock of the run, the anchor the wall-budget axis measures against.

wall_budget_ms: Option<WireU64>

§13.2 · the wall-clock budget an UpdateDeadline command last projected onto the axis. Not derivable from the configuration — the command sets a duration measured from Self::started_at_ms — so a restore that dropped it would un-bound the run.

tasks: Vec<TaskControlState>

The task table. The home of task lifecycle and, with Self::attempts, of task identity.

attempts: Vec<TaskAttemptState>

§10.4 · the attempt the kernel minted for each live task. A completion naming an attempt that is not here has no authority, which is why the mapping is checkpointed rather than re-derived from task ids.

workflow: Option<WorkflowGraphState>

queued_signals: Vec<QueuedSignalState>

signal_dedupe_keys: Vec<String>

Router dedupe keys in eviction order, including keys for already-dispatched signals.

milestone: Option<MilestoneState>

entropy: EntropyState

Session-disorder measurement and alert-gate state. These values intentionally survive a canonical crash restore even though they do not participate in a same-process turn rollback: otherwise the first post-restore sample forgets prior failures and rollbacks.

channels: Vec<LocalChannelState>

Durable local fan-out channels, including per-consumer cursors and dedupe memory.

objects: Vec<ObjectDescriptor>

Handle-only local object registry; bodies remain in context/payload storage.

Trait Implementations

impl Clone for SchedulerState

fn clone(&self) -> SchedulerState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchedulerState

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

Formats the value using the given formatter.

impl Default for SchedulerState

fn default() -> SchedulerState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SchedulerState

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SchedulerState

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for SchedulerState

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SchedulerState