Struct OperatorSession 

pub struct OperatorSession {

    pub id: SessionId,
    pub operator_id: String,
    pub role: Role,
    pub attached_at: u64,
    pub last_seen: u64,
    pub attached: bool,
    pub owned_task_ids: Vec<TaskId>,
    pub token_nonce: String,
    pub operator_kind: Option<OperatorKind>,
    pub runtime_agent_kinds: HashMap<String, OperatorKind>,
    pub bp_agent_kinds: HashMap<String, OperatorKind>,
    pub bp_global_kind: Option<OperatorKind>,
    pub bridge_id: Option<String>,
    pub hook_id: Option<String>,
    pub operator_backend_id: Option<String>,
}

Persisted record of one attached Operator session: identity, role, heartbeat bookkeeping, owned tasks, and the OperatorKind cascade inputs plus registry IDs used to rebuild OperatorInfo on dispatch (see Engine::resolve_operator_info).

Fields

id: SessionId

Unique session identifier (distinct from the token nonce).

operator_id: String

Caller-supplied name identifying the Operator (not necessarily unique across sessions).

role: Role

Role the session’s token was minted with.

attached_at: u64

Unix timestamp (seconds) when the session was attached.

last_seen: u64

Unix timestamp (seconds) of the last heartbeat/attach touch.

attached: bool

Whether the session is currently considered live. Flipped to false by detach or by start_detach_loop on a heartbeat miss.

owned_task_ids: Vec<TaskId>

Task IDs started by this session (via start_task while this session’s token was current).

token_nonce: String

Nonce of the CapToken this session was attached with; used to look sessions up by token in with_state closures.

operator_kind: Option<OperatorKind>

The Operator’s kind, plus IDs of the SeniorBridge / SpawnHook registered on the engine’s BridgeRegistry. Persisted (all String; no Arc<dyn ...>). At dispatch_attempt time the engine looks these up in the registry and builds an OperatorInfo to inject into Ctx.

4-tier OperatorKind cascade — “Runtime Global” tier

This field is the literal value passed to Engine::attach_with_ids’s kind parameter, and is fed to crate::core::ctx::collapse_operator_kind as the runtime_global tier verbatim: Some(_) is always an explicit Runtime Global request that outranks both BP tiers — even Some(OperatorKind::Automate) — and None means “not requested”, letting the BP-level tiers (bp_agent_kinds / bp_global_kind) take over. #[serde(default)] keeps existing persisted sessions (from before this field existed / was Option) deserializing as None. See crate::core::ctx::collapse_operator_kind for the full cascade + rationale.

runtime_agent_kinds: HashMap<String, OperatorKind>

“Runtime Agent-level” tier (highest priority) of the OperatorKind cascade — per-agent override supplied at task-launch time via TaskLaunchInput.operator_kind_overrides / TaskApplicationInput .operator_kind_overrides. Keyed by AgentDef.name.

bp_agent_kinds: HashMap<String, OperatorKind>

“BP Agent-level” tier of the OperatorKind cascade — baked at TaskLaunchService::launch time from Blueprint.operators[].kind, resolved per-agent via AgentDef.spec.operator_ref. Keyed by AgentDef.name (not OperatorDef.name).

bp_global_kind: Option<OperatorKind>

“BP Global” tier of the OperatorKind cascade — baked at TaskLaunchService::launch time from Blueprint.default_operator_kind.

bridge_id: Option<String>

ID of the Arc<dyn SeniorBridge> registered on the engine’s BridgeRegistry, if any; resolved back into OperatorInfo.senior_bridge.

hook_id: Option<String>

ID of the Arc<dyn SpawnHook> registered on the engine’s BridgeRegistry, if any; resolved back into OperatorInfo.spawn_hook.

operator_backend_id: Option<String>

ID of the Arc<dyn Operator> registered on the OperatorRegistry. Used by OperatorDelegateMiddleware when kind = MainAi / Composite and operator_id is Some: it delegates the entire spawn to operator.execute.

Trait Implementations

impl Clone for OperatorSession

fn clone(&self) -> OperatorSession

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OperatorSession

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OperatorSession

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for OperatorSession

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

where __S: Serializer,

Serialize this value into the given Serde serializer.