Struct AgentBuilder 

pub struct AgentBuilder { /* private fields */ }

Implementations

impl AgentBuilder

pub fn model(self, model: impl Into<String>) -> Self

pub fn temperature(self, t: f32) -> Self

pub fn max_tokens(self, mt: u32) -> Self

pub fn reasoning_effort(self, effort: ReasoningEffort) -> Self

pub fn instructions(self, text: impl Into<String>) -> Self

Set agent-level instructions (system prompt). These will be injected on each step.

pub fn instruction_provider( self, provider: Arc<dyn LLMInstructionProvider>, ) -> Self

pub fn tool(self, tool: ToolDef) -> Self

pub fn tools(self, tools: Vec<ToolDef>) -> Self

pub fn policy(self, policy: CompositePolicy) -> Self

pub fn handoff_policy(self, policy: AnyHandoffPolicy) -> Self

Enable handoff-aware tool interception and advertise handoff tools

pub fn with_provider<P>(self, provider: P) -> Self

where P: ModelService + Clone + Send + 'static, P::Future: Send + 'static,

Override the non-streaming provider (useful for testing with a fixed/mocked model)

pub fn parallel_tools(self, enabled: bool) -> Self

Enable or disable parallel tool execution within a step

pub fn tool_concurrency_limit(self, limit: usize) -> Self

Set an optional concurrency limit for parallel tool execution

pub fn tool_join_policy(self, policy: ToolJoinPolicy) -> Self

Configure how parallel tool errors are handled (fail fast or join all)

pub fn map_agent_service<F>(self, f: F) -> Self

where F: Fn(AgentSvc) -> AgentSvc + Send + Sync + 'static,

Optional: wrap the final built agent service with a custom function. This enables applying Tower layers at the agent boundary.

pub fn auto_compaction(self, policy: CompactionPolicy) -> Self

Enable auto-compaction with the specified policy

pub fn build(self) -> AgentSvc

pub fn build_with_session<Ls, Ss>( self, load: Arc<Ls>, save: Arc<Ss>, session_id: SessionId, ) -> AgentSvc

where Ls: Service<LoadSession, Response = History, Error = BoxError> + Send + Sync + Clone + 'static, Ls::Future: Send + 'static, Ss: Service<SaveSession, Response = (), Error = BoxError> + Send + Sync + Clone + 'static, Ss::Future: Send + 'static,

Build an agent service wrapped with session memory persistence