Struct WorkerState 

pub struct WorkerState {
    pub id: AgentId,
    pub history: ActionHistory,
    pub cache: LocalCache,
    pub pending_tasks: HashSet<TaskId>,
    pub escalation: Option<Escalation>,
    pub consecutive_failures: u32,
    pub last_output: Option<String>,
    /* private fields */
}

Worker の永続状態（Tick間で保持される）

WorkerStateDelta 経由で更新される。

Fields

id: AgentId

Agent ID（内部識別用）

history: ActionHistory

行動履歴

cache: LocalCache

ローカルキャッシュ

pending_tasks: HashSet<TaskId>

保留中の非同期Task（HashSet で O(1) 検索）

escalation: Option<Escalation>

Escalation 情報（Worker が設定、Manager が読み取り）

consecutive_failures: u32

連続失敗カウント

last_output: Option<String>

最新アクションの出力（Environment からの結果）

Implementations

impl WorkerState

pub fn new(id: AgentId) -> Self

pub fn raise_escalation(&mut self, escalation: Escalation)

Escalation を発生させる

pub fn clear_escalation(&mut self)

Escalation をクリア

pub fn record_failure(&mut self, tick: u64, threshold: u32) -> bool

失敗を記録し、閾値を超えたら Escalation

pub fn record_success(&mut self)

成功を記録（連続失敗をリセット）

pub fn set_state<T: Any + Send + Sync + 'static>(&mut self, state: T)

内部状態を設定

pub fn get_state<T: Any + Send + Sync + 'static>(&self) -> Option<&T>

内部状態を取得

pub fn get_state_mut<T: Any + Send + Sync + 'static>( &mut self, ) -> Option<&mut T>

内部状態を可変で取得

pub fn add_pending_task(&mut self, task_id: TaskId)

非同期タスクを追加（O(1)）

pub fn complete_task(&mut self, task_id: TaskId)

完了したタスクを削除（O(1)）