Struct AgentRequest 

pub struct AgentRequest {
    pub input: String,
    pub history: Vec<Message>,
    pub system_prompt: Option<String>,
    pub streaming: bool,
    pub max_iterations: Option<usize>,
    pub metadata: RequestMetadata,
    pub resume_from: Option<PausedExecutionState>,
}

A request to be processed by the agent pipeline

Fields

input: String

The user’s input text (transcribed if from voice)

history: Vec<Message>

Conversation history (role, content pairs)

system_prompt: Option<String>

Optional system prompt override

streaming: bool

Whether to use streaming response

max_iterations: Option<usize>

Optional override for the maximum tool execution iterations.

When None, the pipeline uses its configured default (or runs unbounded when iteration budgeting is disabled).

metadata: RequestMetadata

Request metadata

resume_from: Option<PausedExecutionState>

Optional paused execution state to resume from.

When set, the pipeline will reconstruct the conversational context from the paused state and continue the agentic loop from where it left off.

Implementations

impl AgentRequest

pub fn new(input: impl Into<String>) -> AgentRequest

Create a new request with minimal configuration

pub fn with_history(self, history: Vec<Message>) -> AgentRequest

Set conversation history

pub fn with_system_prompt(self, prompt: impl Into<String>) -> AgentRequest

Set system prompt

pub fn with_streaming(self, streaming: bool) -> AgentRequest

Set streaming mode

pub fn with_max_iterations(self, max_iterations: usize) -> AgentRequest

Override the maximum number of agentic-loop iterations for this request.

pub fn with_source(self, source: RequestSource) -> AgentRequest

Set request source

pub fn with_session(self, session_id: impl Into<String>) -> AgentRequest

Set session ID

pub fn with_directive(self, directive_id: impl Into<String>) -> AgentRequest

Set directive ID for targeted memory retrieval and coordination.

pub fn with_task(self, task_id: impl Into<String>) -> AgentRequest

Set active task ID for targeted memory retrieval and coordination.

pub fn with_agent(self, agent_id: impl Into<String>) -> AgentRequest

Set agent ID for targeted memory retrieval and coordination.

pub fn with_memory_tags(self, tags: Vec<String>) -> AgentRequest

Set retrieval tags for targeted memory loading.

pub fn with_allowed_tools(self, tools: Vec<String>) -> AgentRequest

Set allowed tools (for orchestrator/delegated tasks)

pub fn with_tools_enabled(self, enabled: bool) -> AgentRequest

Enable or disable tool execution for this request.

Setting this to false ensures the pipeline will not attempt to execute tools (even if the model asks) for this request.

pub fn with_reflection_enabled(self, enabled: bool) -> AgentRequest

Enable or disable experiential reflection for this request.

pub fn with_workspace(self, workspace: impl Into<PathBuf>) -> AgentRequest

Set workspace directory for sandboxed operations

pub fn with_session_llm_config( self, provider: impl Into<String>, model: impl Into<String>, ) -> AgentRequest

Set session LLM configuration (for agent awareness)

pub fn with_permission_level(self, level: PermissionLevel) -> AgentRequest

Set session permission level for tool execution

pub fn with_permission_level_str(self, level: &str) -> AgentRequest

Set session permission level from string (for backwards compatibility)

pub fn with_resume_state(self, state: PausedExecutionState) -> AgentRequest

Attach a paused execution state so the pipeline resumes from that point.

Trait Implementations

impl Clone for AgentRequest

fn clone(&self) -> AgentRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentRequest

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

Formats the value using the given formatter.