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>, ) -> 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 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 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