Struct AgentCore 

pub struct AgentCore { /* private fields */ }

Core agent execution engine

Implementations

impl AgentCore

pub fn new( profile: AgentProfile, provider: Arc<dyn ModelProvider>, embeddings_client: Option<EmbeddingsClient>, persistence: Persistence, session_id: String, agent_name: Option<String>, tool_registry: Arc<ToolRegistry>, policy_engine: Arc<PolicyEngine>, speak_responses: bool, ) -> Self

Create a new agent core

pub fn with_fast_provider(self, fast_provider: Arc<dyn ModelProvider>) -> Self

Set the fast model provider for hierarchical reasoning

pub fn with_session(self, session_id: String) -> Self

Set a new session ID and clear conversation history

pub async fn run_step(&mut self, input: &str) -> Result<AgentOutput>

Execute a single interaction step

pub async fn run_spec(&mut self, spec: &AgentSpec) -> Result<AgentOutput>

Execute a structured spec by converting it into a single prompt.

pub async fn run_step_streaming( &mut self, input: &str, ) -> Result<Pin<Box<dyn Stream<Item = Result<String>> + Send>>>

Execute a streaming interaction step.

Returns a stream of text chunks. After consuming the stream, call finalize_streaming_step with the accumulated content to store the assistant message and update conversation history.

pub async fn finalize_streaming_step(&mut self, content: &str) -> Result<i64>

Finalize a streaming step by storing the assistant message.

Call this after consuming the stream from run_step_streaming.

pub fn session_id(&self) -> &str

Get the current session ID

pub fn profile(&self) -> &AgentProfile

Get the agent profile

pub fn agent_name(&self) -> Option<&str>

Get the logical agent name (if provided)

pub fn conversation_history(&self) -> &[Message]

Get conversation history

pub fn load_history(&mut self, limit: i64) -> Result<()>

Load conversation history from persistence

pub fn tool_registry(&self) -> &ToolRegistry

Get the tool registry

pub fn policy_engine(&self) -> &PolicyEngine

Get the policy engine

pub fn set_policy_engine(&mut self, policy_engine: Arc<PolicyEngine>)

Set a new policy engine (useful for reloading policies)

pub fn set_speak_responses(&mut self, enabled: bool)

Enable or disable speech-oriented prompting

pub async fn generate_embedding(&self, text: &str) -> Option<i64>

Generate and store an embedding for arbitrary text (e.g., transcriptions) Returns the embedding_id if successful, None otherwise