Struct TurnHost 

#[non_exhaustive]
pub struct TurnHost<'a> {
    pub session_id: SessionId,
    pub definition: &'a AgentDefinition,
    pub environment: &'a AgentEnvironment,
    pub model: &'a ModelSpec,
    pub log: &'a dyn EventLog,
    pub history: &'a mut History,
    pub cancellation: CancellationToken,
    pub input: InputQueue,
}

Agent composition plus the session-specific resources for one turn.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

session_id: SessionId

Session being advanced.

definition: &'a AgentDefinition

Valid behavioral definition being interpreted.

environment: &'a AgentEnvironment

Shared execution resources.

model: &'a ModelSpec

Effective model after per-turn controls.

log: &'a dyn EventLog

Durable event storage.

history: &'a mut History

Live projection of durable message history.

cancellation: CancellationToken

Cooperative cancellation signal.

input: InputQueue

Messages that arrived while this turn was running — see agentyk_core::input::InputQueue. Empty and inert unless the caller attached one.

Implementations

impl<'a> TurnHost<'a>

pub fn new( session_id: SessionId, definition: &'a AgentDefinition, environment: &'a AgentEnvironment, log: &'a dyn EventLog, history: &'a mut History, ) -> Self

Construct a host context using the agent’s default model.

pub fn model(self, model: &'a ModelSpec) -> Self

Override the effective model for this turn.

pub fn cancellation(self, token: CancellationToken) -> Self

Attach the cooperative cancellation signal.

pub fn input(self, input: InputQueue) -> Self

Attach the queue a caller steers this turn through.

pub async fn record( &mut self, turn_id: TurnId, effects: Vec<EventData>, ) -> Result<()>

Persist durable effects atomically, then advance projections and notify observers. Ephemeral effects bypass storage.