Struct Agent 

pub struct Agent { /* private fields */ }

The Agent orchestrator running the Think → Act → Observe loop.

Implementations

impl Agent

pub fn new( provider: Arc<dyn LlmProvider>, config: AgentConfig, callback: Arc<dyn AgentCallback>, ) -> Self

pub fn register_tool(&mut self, tool: RegisteredTool)

Register a tool with the agent.

pub fn tool_definitions( &self, classification: Option<&TaskClassification>, ) -> Vec<ToolDefinition>

Get tool definitions for the LLM, optionally filtered by task classification.

When a classification is provided (and is not General/Workflow), only tools relevant to that task type are returned, reducing token overhead by 60-82% (~25K-35K tokens down to ~5K-12K).

pub async fn process_task( &mut self, task: &str, ) -> Result<TaskResult, RustantError>

Process a user task through the agent loop.

pub fn state(&self) -> &AgentState

Get the current agent state.

pub fn cancellation_token(&self) -> CancellationToken

Get a cancellation token for this agent.

pub fn cancel(&self)

Cancel the current task.

pub fn reset_cancellation(&mut self)

Reset the cancellation token so the agent can process another task. Must be called before process_task() if a previous task was cancelled.

pub fn brain(&self) -> &Brain

Get the brain reference (for usage stats).

pub fn safety(&self) -> &SafetyGuardian

Get the safety guardian reference (for audit log).

pub fn safety_mut(&mut self) -> &mut SafetyGuardian

Get a mutable reference to the safety guardian (for contract setup).

pub fn memory(&self) -> &MemorySystem

Get the memory system reference.

pub fn memory_mut(&mut self) -> &mut MemorySystem

Get a mutable reference to the memory system.

pub fn config(&self) -> &AgentConfig

Get a reference to the agent configuration.

pub fn config_mut(&mut self) -> &mut AgentConfig

Get a mutable reference to the agent configuration.

pub fn cron_scheduler(&self) -> Option<&CronScheduler>

Get a reference to the cron scheduler (if enabled).

pub fn cron_scheduler_mut(&mut self) -> Option<&mut CronScheduler>

Get a mutable reference to the cron scheduler (if enabled).

pub fn job_manager(&self) -> &JobManager

Get a reference to the job manager.

pub fn job_manager_mut(&mut self) -> &mut JobManager

Get a mutable reference to the job manager.

pub fn check_scheduler(&mut self) -> Vec<String>

Check scheduler for due tasks and return their task strings.

pub fn save_scheduler_state( &self, state_dir: &Path, ) -> Result<(), SchedulerError>

Save scheduler state (cron jobs + background jobs) to the given directory.

pub fn load_scheduler_state(&mut self, state_dir: &Path)

Load scheduler state from disk and replace current scheduler/job_manager.

pub fn recent_explanations(&self) -> &[DecisionExplanation]

Get recent decision explanations for transparency.

pub fn tool_token_breakdown(&self) -> &HashMap<String, usize>

Get per-tool token usage breakdown (tool_name -> estimated tokens).

pub fn top_tool_consumers(&self, n: usize) -> String

Format top token consumers as a summary string.

pub async fn think_with_council( &self, task: &str, council: &PlanningCouncil, ) -> Option<CouncilResult>

Run a council deliberation if configured and the task is appropriate.

Returns Some(CouncilResult) if council was used, None if skipped. Falls back gracefully if council fails.

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

Toggle plan mode on or off.

pub fn plan_mode(&self) -> bool

Query whether plan mode is active.

pub fn current_plan(&self) -> Option<&ExecutionPlan>

Access the current plan, if any.

pub fn compact(&mut self) -> (usize, usize)

Compact the conversation context by summarizing older messages. Returns (messages_before, messages_after).