Struct AgentWorkflow 

pub struct AgentWorkflow { /* private fields */ }

Durable AI agent workflow.

Each invocation runs a ReAct loop until the model emits a final answer or max_turns is reached. Every LLM call and every tool call is a separate Temporal activity; crashes resume from the last completed activity without re-paying for prior LLM turns.

Implementations

impl AgentWorkflow

pub async fn __run( ctx: &mut WorkflowContext<Self>, input: AgentInput, ) -> WorkflowResult<AgentOutput>

Entry point. Initializes state from input, then loops until the LLM emits a final answer or max_turns is reached.

pub fn __add_user_message( &mut self, _ctx: &mut SyncWorkflowContext<Self>, msg: String, )

Inject a new user message mid-conversation.

Buffered until the start of the next loop iteration so we never mutate history concurrently with an in-flight LLM activity.

pub fn __get_state(&self, _ctx: &WorkflowContextView) -> AgentState

Read the full live state.

pub fn __turn_count(&self, _ctx: &WorkflowContextView) -> u32

Cheap turn counter for monitoring.

impl AgentWorkflow

pub const run: Run = agent_workflow::Run

pub const add_user_message: AddUserMessage = agent_workflow::AddUserMessage

pub const get_state: GetState = agent_workflow::GetState

pub const turn_count: TurnCount = agent_workflow::TurnCount

pub const fn name() -> &'static str

Returns the workflow type name

Trait Implementations

impl Default for AgentWorkflow

fn default() -> AgentWorkflow

Returns the “default value” for a type.

impl HasWorkflowDefinition for AgentWorkflow

type Run = Run

The WorkflowDefinition type that SignalDefinition, QueryDefinition, and UpdateDefinition are associated with.

impl WorkflowDefinition for AgentWorkflow

type Input = AgentInput

Type of the input argument to the workflow

type Output = AgentOutput

Type of the output of the workflow

fn name(&self) -> &str

The workflow type name