Struct Session 

pub struct Session {
    pub id: String,
    pub workflow: Workflow,
    pub identity: AgentIdentity,
    pub loop_state: SessionLoopState,
    pub chain: Mutex<EventChain>,
    pub atif: Mutex<TrajectoryBuilder>,
    pub totals: Totals,
    pub last_activity_ms: AtomicU64,
    pub closed: AtomicU64,
    pub receipt: Mutex<Option<Receipt>>,
    pub atif_path: Mutex<Option<PathBuf>>,
    /* private fields */
}

A live session.

Fields

id: String

Session id.

workflow: Workflow

Workflow kind.

identity: AgentIdentity

Agent identity bound at open (from NHI validation).

loop_state: SessionLoopState

Loop-breaker state.

chain: Mutex<EventChain>

Signed workflow: incremental event chain.

atif: Mutex<TrajectoryBuilder>

Unsigned workflow: ATIF steps.

totals: Totals

Aggregates for the receipt.

last_activity_ms: AtomicU64

Last-activity timestamp (idle sweeping), epoch ms.

closed: AtomicU64

Set once closed (idempotent close).

receipt: Mutex<Option<Receipt>>

Issued signed or retroactive receipt.

atif_path: Mutex<Option<PathBuf>>

Persisted unsigned ATIF artifact.

Implementations

impl Session

pub fn new( id: String, workflow: Workflow, identity: AgentIdentity, breaker: BreakerConfig, ) -> Self

Open a session.

pub fn next_seq(&self) -> u64

Next event sequence number.

pub fn touch(&self)

Touch the activity clock.

pub fn try_close(&self) -> bool

Attempt to claim the close transition. Only one caller can hold the claim at a time; a failed finalize resets it (reset_close) so the close can be retried.

pub fn is_closed(&self) -> bool

True when closed.

pub fn artifact_committed_flag(&self) -> bool

True once the receipt/ATIF artifact is durably persisted.

pub fn close_complete_flag(&self) -> bool

True once the close ran to full completion (journal removed).

pub fn try_promote(&self) -> bool

Atomically claim promotion. Only one caller can hold the claim at a time; failed receipt persistence resets it (reset_promotion) so promotion can be retried.

pub fn is_promoted(&self) -> bool

True after promotion has completed (receipt persisted), not merely been claimed.

pub fn recover_unsigned( id: String, identity: AgentIdentity, breaker: BreakerConfig, path: PathBuf, metrics: Option<&FinalMetrics>, ) -> Result<Self, String>

Recreate a closed unsigned session from a persisted ATIF trajectory.

pub fn take_trajectory(&self) -> Trajectory

Consume the current ATIF builder and replace it with an empty one.

pub fn active_streams_count(&self) -> u64

Number of forwarded chat responses currently streaming.

pub fn pending_jobs_count(&self) -> u64

Number of worker jobs accepted but not yet fully captured.

pub fn refresh_identity(&self, identity: &AgentIdentity)

Refresh token-derived fields after successful validation.

pub fn current_identity(&self) -> AgentIdentity

Current validated identity snapshot.

pub fn receipt_body( &self, subject: ReceiptSubject, stop: StopReason, ) -> ReceiptBody

Build the receipt body for this session (signed close or promotion).